[iotdb] 01/01: The sinkHandleListener should be onFinished once the local sink handle reaches noMoreTsBlock

[xingtanzjr]

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 <xingtan...@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.");
   }