[iotdb] branch ty-mpp updated: initially the driverBlockedFuture is not blocked

[ja...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch ty-mpp
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/ty-mpp by this push:
     new f33e61f  initially the driverBlockedFuture is not blocked
f33e61f is described below

commit f33e61fb9eccf1ab9d438248d7b7d8949c3d35ae
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Fri Apr 1 17:47:52 2022 +0800

    initially the driverBlockedFuture is not blocked
---
 .../src/main/java/org/apache/iotdb/db/mpp/execution/DataDriver.java   | 4 ++++
 .../src/main/java/org/apache/iotdb/db/mpp/execution/SchemaDriver.java | 4 ++++
 2 files changed, 8 insertions(+)

diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/DataDriver.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/DataDriver.java
index b1e06ab..4d96322 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/DataDriver.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/DataDriver.java
@@ -73,6 +73,10 @@ public class DataDriver implements ExecFragmentInstance {
     this.root = root;
     this.sinkHandle = sinkHandle;
     this.dataDriverContext = dataDriverContext;
+    // initially the driverBlockedFuture is not blocked (it is completed)
+    SettableFuture<Void> future = SettableFuture.create();
+    future.set(null);
+    driverBlockedFuture.set(future);
   }
 
   @Override
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/SchemaDriver.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/SchemaDriver.java
index e9df0f7..efb5484 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/SchemaDriver.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/SchemaDriver.java
@@ -53,6 +53,10 @@ public class SchemaDriver implements ExecFragmentInstance {
     this.root = root;
     this.sinkHandle = sinkHandle;
     this.driverContext = driverContext;
+    // initially the driverBlockedFuture is not blocked (it is completed)
+    SettableFuture<Void> future = SettableFuture.create();
+    future.set(null);
+    driverBlockedFuture.set(future);
   }
 
   @Override