You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/04/22 05:49:42 UTC
[iotdb] branch stable-mpp created (now 9d3207e648)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch stable-mpp
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 9d3207e648 Fix CI
This branch includes the following new commits:
new 9d3207e648 Fix CI
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: Fix CI
Posted by ja...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch stable-mpp
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 9d3207e6488a6a57fec56056a14fe53ac2aee97d
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Fri Apr 22 13:49:24 2022 +0800
Fix CI
---
.../apache/iotdb/db/mpp/operator/TimeJoinOperatorTest.java | 13 +++++++++----
1 file changed, 9 insertions(+), 4 deletions(-)
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/operator/TimeJoinOperatorTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/operator/TimeJoinOperatorTest.java
index a16281452d..a4b8c3bcc3 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/operator/TimeJoinOperatorTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/operator/TimeJoinOperatorTest.java
@@ -174,6 +174,8 @@ public class TimeJoinOperatorTest {
/** test time join with non-exist sensor */
@Test
public void batchTest2() {
+ ExecutorService instanceNotificationExecutor =
+ IoTDBThreadPoolFactory.newFixedThreadPool(1, "test-instance-notification");
try {
MeasurementPath measurementPath1 =
new MeasurementPath(TIME_JOIN_OPERATOR_TEST_SG + ".device0.sensor0", TSDataType.INT32);
@@ -182,11 +184,12 @@ public class TimeJoinOperatorTest {
allSensors.add("sensor1");
allSensors.add("error_sensor");
QueryId queryId = new QueryId("stub_query");
- AtomicReference<FragmentInstanceState> state =
- new AtomicReference<>(FragmentInstanceState.RUNNING);
+ FragmentInstanceId instanceId =
+ new FragmentInstanceId(new PlanFragmentId(queryId, 0), "stub-instance");
+ FragmentInstanceStateMachine stateMachine =
+ new FragmentInstanceStateMachine(instanceId, instanceNotificationExecutor);
FragmentInstanceContext fragmentInstanceContext =
- new FragmentInstanceContext(
- new FragmentInstanceId(new PlanFragmentId(queryId, 0), "stub-instance"), state);
+ createFragmentInstanceContext(instanceId, stateMachine);
PlanNodeId planNodeId1 = new PlanNodeId("1");
fragmentInstanceContext.addOperatorContext(
1, planNodeId1, SeriesScanOperator.class.getSimpleName());
@@ -280,6 +283,8 @@ public class TimeJoinOperatorTest {
} catch (IllegalPathException e) {
e.printStackTrace();
fail();
+ } finally {
+ instanceNotificationExecutor.shutdown();
}
}
}