浏览代码

fix kuiper base location

RockyJin 5 年之前
父节点
当前提交
54f6c09eac
共有 1 个文件被更改,包括 3 次插入2 次删除
  1. 3 2
      xstream/server/server/server.go

+ 3 - 2
xstream/server/server/server.go

@@ -262,11 +262,12 @@ func init(){
 func StartUp(Version string) {
 	common.InitConf()
 
-	dataDir, err := common.GetDataLoc()
+	dr, err := common.GetDataLoc()
 	if err != nil {
 		log.Panic(err)
 	}else{
-		log.Infof("db location is %s", dataDir)
+		log.Infof("db location is %s", dr)
+		dataDir = dr
 	}
 	processor = processors.NewRuleProcessor(path.Dir(dataDir))
 	registry = make(RuleRegistry)