diff --git a/be/src/exec/partitioned-hash-join-node.cc b/be/src/exec/partitioned-hash-join-node.cc
index 5277650..a05b23a 100644
--- a/be/src/exec/partitioned-hash-join-node.cc
+++ b/be/src/exec/partitioned-hash-join-node.cc
@@ -725,6 +725,7 @@ Status PartitionedHashJoinNode::NextProbeRowBatch(
     }
     RETURN_IF_ERROR(child(0)->GetNext(state, probe_batch_.get(), &probe_side_eos_));
     COUNTER_ADD(probe_row_counter_, probe_batch_->num_rows());
+    LOG(INFO) << "Batch with " << probe_batch_->num_rows();
   } while (probe_batch_->num_rows() == 0);
 
   ResetForProbe();
@@ -914,8 +915,10 @@ Status PartitionedHashJoinNode::GetNext(RuntimeState* state, RowBatch* out_batch
       }
     }
 
+    int probe_batch_start_pos = probe_batch_pos_;
     // Finish up the current batch.
     {
+      LOG(INFO) << "Process batch with " << probe_batch_->num_rows() << " pos " << probe_batch_pos_;
       // Putting SCOPED_TIMER in ProcessProbeBatch() causes weird exception handling IR
       // in the xcompiled function, so call it here instead.
       int rows_added = 0;
@@ -940,6 +943,13 @@ Status PartitionedHashJoinNode::GetNext(RuntimeState* state, RowBatch* out_batch
       num_rows_returned_ += rows_added;
       COUNTER_SET(rows_returned_counter_, num_rows_returned_);
     }
+
+    if (probe_batch_pos_ >= 0) {
+      LOG(INFO) << "PROBE BATCH PROCESSED IN " << id_ << ":";
+      for (int i = probe_batch_start_pos; i < probe_batch_pos_; ++i) {
+        LOG(INFO) << PrintRow(probe_batch_->GetRow(i), child(0)->row_desc());
+      }
+    }
     if (out_batch->AtCapacity() || ReachedLimit()) break;
     DCHECK(current_probe_row_ == NULL);