You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/06/15 03:23:34 UTC
[iotdb] 01/01: The sinkHandleListener should be onFinished once the local sink handle reaches noMoreTsBlock
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch xingtanzjr/fix_local_sink
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit f422990ea0b8534f9eb946750c1883d785ed1693
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Wed Jun 15 11:23:19 2022 +0800
The sinkHandleListener should be onFinished once the local sink handle reaches noMoreTsBlock
---
.../apache/iotdb/db/mpp/execution/datatransfer/LocalSinkHandle.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/LocalSinkHandle.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/LocalSinkHandle.java
index d1a8ac33f1..34159477dc 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/LocalSinkHandle.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/LocalSinkHandle.java
@@ -117,9 +117,7 @@ public class LocalSinkHandle implements ISinkHandle {
}
queue.setNoMoreTsBlocks(true);
sinkHandleListener.onEndOfBlocks(this);
- if (isFinished()) {
- sinkHandleListener.onFinish(this);
- }
+ sinkHandleListener.onFinish(this);
logger.info("No-more-tsblocks has been set.");
}