Github user Ben-Zvi commented on a diff in the pull request:
https://github.com/apache/drill/pull/1059#discussion_r163045737
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/HashJoinProbeTemplate.java
---
@@ -136,7 +136,9 @@ public void executeProbePhase() throws
SchemaChangeException {
case OK_NEW_SCHEMA:
if (probeBatch.getSchema().equals(probeSchema)) {
doSetup(outgoingJoinBatch.getContext(), buildBatch,
probeBatch, outgoingJoinBatch);
- hashTable.updateBatches();
+ if (hashTable != null) {
+ hashTable.updateBatches();
+ }
--- End diff --
Fine.
---