modify getIncrStateCollectAddress get by hard code

Author: baisui1981

tis-console/src/main/java/com/qlangtech/tis/runtime/module/action/SysInitializeAction.java

@@ -319,10 +319,10 @@ public boolean initializeZkPath(String zkHost) {
       createPaths.add(createPath);
       ZkUtils.guaranteeExist(coordinator, createPath);
       buildLog.append(",path2:").append(createPath);
-      createPath = zkSubDir + "/configs/" + CoreAction.DEFAULT_SOLR_CONFIG;
-      createPaths.add(createPath);
-      ZkUtils.guaranteeExist(coordinator, createPath);
-      buildLog.append(",path3:").append(createPath);
+//      createPath = zkSubDir + "/configs/" + CoreAction.DEFAULT_SOLR_CONFIG;
+//      createPaths.add(createPath);
+//      ZkUtils.guaranteeExist(coordinator, createPath);
+//      buildLog.append(",path3:").append(createPath);
       logger.info(buildLog.toString());
 
 

tis-datax-executor/src/main/java/com/qlangtech/tis/datax/DataXJobConsumer.java

@@ -206,7 +206,8 @@ protected DataXJobSubmit.InstanceType getExecMode() {
     }
 
     protected String getIncrStateCollectAddress() {
-        return ZkUtils.getFirstChildValue(this.coordinator, ZkUtils.ZK_ASSEMBLE_LOG_COLLECT_PATH);
+        // return ZkUtils.getFirstChildValue(this.coordinator, ZkUtils.ZK_ASSEMBLE_LOG_COLLECT_PATH);
+        return Config.getAssembleHost() + ":" + ZkUtils.ZK_ASSEMBLE_LOG_COLLECT_PORT;
     }
 
     protected String getMainClassName() {