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));