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_) {