|
@@ -26,6 +26,8 @@ import (
|
|
"syscall"
|
|
"syscall"
|
|
"time"
|
|
"time"
|
|
|
|
|
|
|
|
+ "go.uber.org/automaxprocs/maxprocs"
|
|
|
|
+
|
|
"github.com/lf-edge/ekuiper/internal/binder/function"
|
|
"github.com/lf-edge/ekuiper/internal/binder/function"
|
|
"github.com/lf-edge/ekuiper/internal/binder/io"
|
|
"github.com/lf-edge/ekuiper/internal/binder/io"
|
|
"github.com/lf-edge/ekuiper/internal/binder/meta"
|
|
"github.com/lf-edge/ekuiper/internal/binder/meta"
|
|
@@ -87,6 +89,9 @@ func StartUp(Version, LoadFileType string) {
|
|
conf.InitConf()
|
|
conf.InitConf()
|
|
factory.InitClientsFactory()
|
|
factory.InitClientsFactory()
|
|
|
|
|
|
|
|
+ undo, _ := maxprocs.Set(maxprocs.Logger(conf.Log.Infof))
|
|
|
|
+ defer undo()
|
|
|
|
+
|
|
err := store.SetupWithKuiperConfig(conf.Config)
|
|
err := store.SetupWithKuiperConfig(conf.Config)
|
|
if err != nil {
|
|
if err != nil {
|
|
panic(err)
|
|
panic(err)
|