Repository: incubator-impala
Updated Branches:
  refs/heads/master 14cdb0497 -> 46c3e43ed


IMPALA-3527: use codegen'd ProcessProbeBatch() when spilling.

Change-Id: I92ebfb01e370d0a842270771c9e5f1a4610dc16a
Reviewed-on: http://gerrit.cloudera.org:8080/3035
Reviewed-by: Tim Armstrong <[email protected]>
Tested-by: Internal Jenkins


Project: http://git-wip-us.apache.org/repos/asf/incubator-impala/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-impala/commit/6910f497
Tree: http://git-wip-us.apache.org/repos/asf/incubator-impala/tree/6910f497
Diff: http://git-wip-us.apache.org/repos/asf/incubator-impala/diff/6910f497

Branch: refs/heads/master
Commit: 6910f4975ad7969f5b6ba67e341f68dddf6608fa
Parents: a2e88f0
Author: Tim Armstrong <[email protected]>
Authored: Wed May 11 17:56:40 2016 -0700
Committer: Tim Armstrong <[email protected]>
Committed: Thu May 12 23:06:35 2016 -0700

----------------------------------------------------------------------
 be/src/exec/partitioned-hash-join-node.cc | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/6910f497/be/src/exec/partitioned-hash-join-node.cc
----------------------------------------------------------------------
diff --git a/be/src/exec/partitioned-hash-join-node.cc 
b/be/src/exec/partitioned-hash-join-node.cc
index 0ecec1e..47c118a 100644
--- a/be/src/exec/partitioned-hash-join-node.cc
+++ b/be/src/exec/partitioned-hash-join-node.cc
@@ -952,7 +952,7 @@ Status PartitionedHashJoinNode::GetNext(RuntimeState* 
state, RowBatch* out_batch
       // in the xcompiled function, so call it here instead.
       int rows_added = 0;
       SCOPED_TIMER(probe_timer_);
-      if (process_probe_batch_fn_ == NULL || ht_ctx_->level() != 0) {
+      if (process_probe_batch_fn_ == NULL) {
         rows_added = ProcessProbeBatch(join_op_, out_batch, ht_ctx_.get(), 
&status);
       } else {
         DCHECK(process_probe_batch_fn_level0_ != NULL);

Reply via email to