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

caogaofei pushed a commit to branch ty/packageRefactor
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/ty/packageRefactor by this 
push:
     new 4b60c89049e fix idea refactor error in test
     new 91992d0330f Merge branch 'ty/packageRefactor' of 
github.com:apache/iotdb into ty/packageRefactor
4b60c89049e is described below

commit 4b60c89049eb388d3bf6223c919aa6352e4c44d2
Author: Beyyes <[email protected]>
AuthorDate: Tue Jun 27 12:26:38 2023 +0800

    fix idea refactor error in test
---
 .../iotdb/db/queryengine/execution/exchange/LocalSinkChannelTest.java | 2 +-
 .../db/queryengine/execution/exchange/MPPDataExchangeManagerTest.java | 4 ++--
 .../iotdb/db/queryengine/execution/exchange/SourceHandleTest.java     | 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/exchange/LocalSinkChannelTest.java
 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/exchange/LocalSinkChannelTest.java
index b55d9def59c..8d9c4b9cd65 100644
--- 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/exchange/LocalSinkChannelTest.java
+++ 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/exchange/LocalSinkChannelTest.java
@@ -43,7 +43,7 @@ public class LocalSinkChannelTest {
     final String remotePlanNodeId = "exchange_0";
     final TFragmentInstanceId localFragmentInstanceId = new 
TFragmentInstanceId(queryId, 1, "0");
 
-    // Construct a mock LocalMemoryManager with capacity 5 * mockTsBlockSize 
per read.
+    // Construct a mock LocalMemoryManager with capacity 5 * mockTsBlockSize 
per query.
     LocalMemoryManager mockLocalMemoryManager = 
Mockito.mock(LocalMemoryManager.class);
     MemoryPool spyMemoryPool =
         Mockito.spy(new MemoryPool("test", 10 * mockTsBlockSize, 5 * 
mockTsBlockSize));
diff --git 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/exchange/MPPDataExchangeManagerTest.java
 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/exchange/MPPDataExchangeManagerTest.java
index 72122471b09..8824f48f138 100644
--- 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/exchange/MPPDataExchangeManagerTest.java
+++ 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/exchange/MPPDataExchangeManagerTest.java
@@ -53,7 +53,7 @@ public class MPPDataExchangeManagerTest {
     final FragmentInstanceContext mockFragmentInstanceContext =
         Mockito.mock(FragmentInstanceContext.class);
 
-    // Construct a mock LocalMemoryManager with capacity 5 * mockTsBlockSize 
per read.
+    // Construct a mock LocalMemoryManager with capacity 5 * mockTsBlockSize 
per query.
     LocalMemoryManager mockLocalMemoryManager = 
Mockito.mock(LocalMemoryManager.class);
     MemoryPool spyMemoryPool = Mockito.spy(new MemoryPool("test", 10240L, 
5120L));
     
Mockito.when(mockLocalMemoryManager.getQueryPool()).thenReturn(spyMemoryPool);
@@ -109,7 +109,7 @@ public class MPPDataExchangeManagerTest {
     final FragmentInstanceContext mockFragmentInstanceContext =
         Mockito.mock(FragmentInstanceContext.class);
 
-    // Construct a mock LocalMemoryManager with capacity 5 * mockTsBlockSize 
per read.
+    // Construct a mock LocalMemoryManager with capacity 5 * mockTsBlockSize 
per query.
     LocalMemoryManager mockLocalMemoryManager = 
Mockito.mock(LocalMemoryManager.class);
     MemoryPool spyMemoryPool = Mockito.spy(new MemoryPool("test", 10240L, 
5120L));
     
Mockito.when(mockLocalMemoryManager.getQueryPool()).thenReturn(spyMemoryPool);
diff --git 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/exchange/SourceHandleTest.java
 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/exchange/SourceHandleTest.java
index 195c9099fe5..b49f4f3a471 100644
--- 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/exchange/SourceHandleTest.java
+++ 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/exchange/SourceHandleTest.java
@@ -191,7 +191,7 @@ public class SourceHandleTest {
     final String localPlanNodeId = "exchange_0";
     final TFragmentInstanceId localFragmentInstanceId = new 
TFragmentInstanceId(queryId, 0, "0");
 
-    // Construct a mock LocalMemoryManager with capacity 5 * MOCK_TSBLOCK_SIZE 
per read.
+    // Construct a mock LocalMemoryManager with capacity 5 * MOCK_TSBLOCK_SIZE 
per query.
     LocalMemoryManager mockLocalMemoryManager = 
Mockito.mock(LocalMemoryManager.class);
     MemoryPool spyMemoryPool =
         Mockito.spy(new MemoryPool("test", 10 * MOCK_TSBLOCK_SIZE, 5 * 
MOCK_TSBLOCK_SIZE));

Reply via email to