diff --git a/be/src/exec/broker_scan_node.cpp b/be/src/exec/broker_scan_node.cpp index a378c41203..c47134be19 100644 --- a/be/src/exec/broker_scan_node.cpp +++ b/be/src/exec/broker_scan_node.cpp @@ -304,7 +304,7 @@ Status BrokerScanNode::scanner_scan(const TBrokerScanRange& scan_range, } // This row batch has been filled up, and break this - if (row_batch->is_full() || row_batch->is_full_uncommited()) { + if (row_batch->is_full() || row_batch->is_full_uncommitted()) { break; } diff --git a/be/src/runtime/row_batch.h b/be/src/runtime/row_batch.h index 26a9f8b534..9deb9e9b82 100644 --- a/be/src/runtime/row_batch.h +++ b/be/src/runtime/row_batch.h @@ -158,8 +158,8 @@ public: // Returns true if row_batch has reached capacity. bool is_full() const { return _num_rows == _capacity; } - // Returns true if uncommited rows has reached capacity. - bool is_full_uncommited() { return _num_uncommitted_rows == _capacity; } + // Returns true if uncommitted rows has reached capacity. + bool is_full_uncommitted() { return _num_uncommitted_rows == _capacity; } // Returns true if the row batch has accumulated enough external memory (in MemPools // and io buffers). This would be a trigger to compact the row batch or reclaim