Extend the startup waiting time of AINode in CI (#13759)

apache · Oct 14, 2024 · 8815529 · 8815529
1 parent 3b121f7
commit 8815529
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/env/AIEnv.java b/integration-test/src/main/java/org/apache/iotdb/it/env/cluster/env/AIEnv.java
@@ -27,7 +27,7 @@ public void initClusterEnvironment() {
 
   @Override
   public void initClusterEnvironment(int configNodesNum, int dataNodesNum) {
-    super.initEnvironment(configNodesNum, dataNodesNum, 500, true);
+    super.initEnvironment(configNodesNum, dataNodesNum, 1000, true);
   }
 
   @Override

diff --git a/...perator/process/AI/InferenceOperator.java → ...perator/process/ai/InferenceOperator.java b/...perator/process/AI/InferenceOperator.java → ...perator/process/ai/InferenceOperator.java
@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.apache.iotdb.db.queryengine.execution.operator.process.AI;
+package org.apache.iotdb.db.queryengine.execution.operator.process.ai;
 
 import org.apache.iotdb.ainode.rpc.thrift.TInferenceResp;
 import org.apache.iotdb.ainode.rpc.thrift.TWindowParams;

diff --git a/...ode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java b/...ode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java
@@ -2286,7 +2286,7 @@ public Operator visitInference(InferenceNode node, LocalExecutionPlanContext con
             .addOperatorContext(
                 context.getNextOperatorId(),
                 node.getPlanNodeId(),
-                org.apache.iotdb.db.queryengine.execution.operator.process.AI.InferenceOperator
+                org.apache.iotdb.db.queryengine.execution.operator.process.ai.InferenceOperator
                     .class
                     .getSimpleName());
 
@@ -2301,7 +2301,7 @@ public Operator visitInference(InferenceNode node, LocalExecutionPlanContext con
         calculateSize(inputShape[0], inputTypes) + TimeColumn.SIZE_IN_BYTES_PER_POSITION;
     long maxReturnSize = calculateSize(outputShape[0], outputTypes);
 
-    return new org.apache.iotdb.db.queryengine.execution.operator.process.AI.InferenceOperator(
+    return new org.apache.iotdb.db.queryengine.execution.operator.process.ai.InferenceOperator(
         operatorContext,
         child,
         modelInferenceDescriptor,