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/04/19 09:32:54 UTC
[iotdb] branch xingtanzjr/mpp_issues updated: fix the test for SourceHandle
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch xingtanzjr/mpp_issues
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/xingtanzjr/mpp_issues by this push:
new c860c0fcff fix the test for SourceHandle
c860c0fcff is described below
commit c860c0fcff34f2f6b9158be3103d80b311cf5f7c
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Tue Apr 19 17:32:43 2022 +0800
fix the test for SourceHandle
---
.../test/java/org/apache/iotdb/db/mpp/buffer/SourceHandleTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/buffer/SourceHandleTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/buffer/SourceHandleTest.java
index 3b9783023f..461fac1e13 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/buffer/SourceHandleTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/buffer/SourceHandleTest.java
@@ -152,7 +152,7 @@ public class SourceHandleTest {
// Receive EndOfDataBlock event from upstream fragment instance.
sourceHandle.setNoMoreTsBlocks(numOfMockTsBlock - 1);
- Assert.assertFalse(sourceHandle.isBlocked().isDone());
+ Assert.assertTrue(sourceHandle.isBlocked().isDone());
Assert.assertFalse(sourceHandle.isClosed());
Assert.assertTrue(sourceHandle.isFinished());
Assert.assertEquals(0L, sourceHandle.getBufferRetainedSizeInBytes());
@@ -298,7 +298,7 @@ public class SourceHandleTest {
// Receive EndOfDataBlock event from upstream fragment instance.
sourceHandle.setNoMoreTsBlocks(numOfMockTsBlock - 1);
- Assert.assertFalse(sourceHandle.isBlocked().isDone());
+ Assert.assertTrue(sourceHandle.isBlocked().isDone());
Assert.assertFalse(sourceHandle.isClosed());
Assert.assertTrue(sourceHandle.isFinished());
Assert.assertEquals(0L, sourceHandle.getBufferRetainedSizeInBytes());
@@ -488,7 +488,7 @@ public class SourceHandleTest {
// Receive EndOfDataBlock event from upstream fragment instance.
sourceHandle.setNoMoreTsBlocks(3 * numOfMockTsBlock - 1);
- Assert.assertFalse(sourceHandle.isBlocked().isDone());
+ Assert.assertTrue(sourceHandle.isBlocked().isDone());
Assert.assertFalse(sourceHandle.isClosed());
Assert.assertTrue(sourceHandle.isFinished());
Assert.assertEquals(0L, sourceHandle.getBufferRetainedSizeInBytes());