You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@impala.apache.org by cs...@apache.org on 2024/11/13 07:43:23 UTC
(impala) 02/02: IMPALA-13509: (Addendum) Fix build issue
This is an automated email from the ASF dual-hosted git repository.
csringhofer pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/impala.git
commit a541670856c08d6809646863c305643f60a7e70d
Author: Michael Smith <mi...@cloudera.com>
AuthorDate: Tue Nov 12 16:49:01 2024 -0800
IMPALA-13509: (Addendum) Fix build issue
Fixes build issue introduced by merging IMPALA-13509 and IMPALA-13502
changes without testing them together.
Change-Id: Ie465af1c15052d29596ea86aa7d1661e81df5c81
Reviewed-on: http://gerrit.cloudera.org:8080/22059
Reviewed-by: Quanlong Huang <hu...@gmail.com>
Tested-by: Impala Public Jenkins <im...@cloudera.com>
Reviewed-by: Csaba Ringhofer <cs...@cloudera.com>
---
be/src/runtime/krpc-data-stream-sender.cc | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/be/src/runtime/krpc-data-stream-sender.cc b/be/src/runtime/krpc-data-stream-sender.cc
index c422de9c0..6a41018c2 100644
--- a/be/src/runtime/krpc-data-stream-sender.cc
+++ b/be/src/runtime/krpc-data-stream-sender.cc
@@ -894,7 +894,7 @@ Status KrpcDataStreamSender::Prepare(
RETURN_IF_ERROR(channels_[i]->Init(state, char_mem_tracker_allocator_));
}
for (PartitionRowCollector& collector: partition_row_collectors_) {
- collector.collector_batch_.reset(new OutboundRowBatch(char_mem_tracker_allocator_));
+ collector.collector_batch_.reset(new OutboundRowBatch(*char_mem_tracker_allocator_));
collector.row_batch_capacity_ = collector.channel_->RowBatchCapacity();
}
for (auto& [ch, ice_ch] : channel_to_ice_channel_) {