Skip to content

Commit

Permalink
fix scanRangeNum
Browse files Browse the repository at this point in the history
  • Loading branch information
924060929 committed Nov 13, 2024
1 parent d43b16b commit 4996e71
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -45,17 +45,17 @@ public void init() throws Exception {
@Test
public void testNereidsCoordinatorScanRangeNum() throws IOException {
NereidsPlanner planner = plan("select * from test.tbl");
NereidsCoordinator coordinator
= (NereidsCoordinator) EnvFactory.getInstance().createCoordinator(connectContext, null, planner, null);
NereidsCoordinator coordinator = (NereidsCoordinator) EnvFactory.getInstance()
.createCoordinator(connectContext, null, planner, null);
int scanRangeNum = coordinator.getScanRangeNum();
Assertions.assertEquals(10, scanRangeNum);
}

@Test
public void testNereidsCoordinatorScanRangeNum2() throws IOException {
NereidsPlanner planner = plan("select * from information_schema.columns");
NereidsCoordinator coordinator
= (NereidsCoordinator) EnvFactory.getInstance().createCoordinator(connectContext, null, planner, null);
NereidsCoordinator coordinator = (NereidsCoordinator) EnvFactory.getInstance()
.createCoordinator(connectContext, null, planner, null);
int scanRangeNum = coordinator.getScanRangeNum();
Assertions.assertEquals(0, scanRangeNum);
}
Expand Down

0 comments on commit 4996e71

Please sign in to comment.