You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2024/10/14 18:14:57 UTC
(iotdb) branch master updated: Extend the startup waiting time of AINode in CI (#13759)
This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 8815529f7a3 Extend the startup waiting time of AINode in CI (#13759)
8815529f7a3 is described below
commit 8815529f7a33ec556587831e05b417127b3418fd
Author: YangCaiyin <yc...@gmail.com>
AuthorDate: Tue Oct 15 02:14:51 2024 +0800
Extend the startup waiting time of AINode in CI (#13759)
---
.../src/main/java/org/apache/iotdb/it/env/cluster/env/AIEnv.java | 2 +-
.../execution/operator/process/{AI => ai}/InferenceOperator.java | 2 +-
.../iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java | 4 ++--
3 files changed, 4 insertions(+), 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
index 4a5b53ea0a9..916a2ee8cf6 100644
--- 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 class AIEnv extends AbstractEnv {
@Override
public void initClusterEnvironment(int configNodesNum, int dataNodesNum) {
- super.initEnvironment(configNodesNum, dataNodesNum, 500, true);
+ super.initEnvironment(configNodesNum, dataNodesNum, 1000, true);
}
@Override
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/AI/InferenceOperator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/ai/InferenceOperator.java
similarity index 99%
rename from iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/AI/InferenceOperator.java
rename to iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/ai/InferenceOperator.java
index ab8cf811af7..08cae2dc5b1 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/AI/InferenceOperator.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/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/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java
index b6893731bc4..8694f6f2a53 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/OperatorTreeGenerator.java
@@ -2286,7 +2286,7 @@ public class OperatorTreeGenerator extends PlanVisitor<Operator, LocalExecutionP
.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 class OperatorTreeGenerator extends PlanVisitor<Operator, LocalExecutionP
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,