Skip to content

Commit

Permalink
Fix the retention bug
Browse files Browse the repository at this point in the history
Signed-off-by: Song Jiacheng <[email protected]>
  • Loading branch information
Jcnessss committed Nov 25, 2024
1 parent 20bdd4a commit 915d897
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions be/test/exec/connector_scan_node_test.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -226,7 +226,7 @@ TEST_F(ConnectorScanNodeTest, test_convert_scan_range_to_morsel_queue_factory_hi

// dop is 1 and not so much morsels
int pipeline_dop = 1;
auto scan_ranges = create_scan_ranges_hive(1, "hive"));
auto scan_ranges = create_scan_ranges_hive(1, "hive");
ASSIGN_OR_ABORT(auto morsel_queue_factory,
scan_node->convert_scan_range_to_morsel_queue_factory(
scan_ranges, no_scan_ranges_per_driver_seq, scan_node->id(), pipeline_dop, false,
Expand All @@ -235,7 +235,7 @@ TEST_F(ConnectorScanNodeTest, test_convert_scan_range_to_morsel_queue_factory_hi

// dop is 2 and not so much morsels
pipeline_dop = 2;
scan_ranges = create_scan_ranges_hive(pipeline_dop * scan_node->io_tasks_per_scan_operator(), "hive"));
scan_ranges = create_scan_ranges_hive(pipeline_dop * scan_node->io_tasks_per_scan_operator(), "hive");
ASSIGN_OR_ABORT(morsel_queue_factory,
scan_node->convert_scan_range_to_morsel_queue_factory(
scan_ranges, no_scan_ranges_per_driver_seq, scan_node->id(), pipeline_dop, false,
Expand Down

0 comments on commit 915d897

Please sign in to comment.