You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2024/10/15 06:53:49 UTC
(iotdb) branch rc/1.3.3 updated: Extend the startup waiting time of AINode in CI
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch rc/1.3.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/rc/1.3.3 by this push:
new d562e24762f Extend the startup waiting time of AINode in CI
d562e24762f is described below
commit d562e24762f059478f0631a82dc1fc82b770c869
Author: YangCaiyin <yc...@gmail.com>
AuthorDate: Tue Oct 15 14:53:42 2024 +0800
Extend the startup waiting time of AINode in CI
(cherry picked from commit 8815529f7a33ec556587831e05b417127b3418fd)
---
.../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 d7fcd7c5dd7..208985b2e6b 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
@@ -2231,7 +2231,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());
@@ -2246,7 +2246,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,