Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1105#discussion_r170782805
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/PartitionSenderRootExec.java
---
@@ -62,7 +62,7 @@
private static final org.slf4j.Logger logger =
org.slf4j.LoggerFactory.getLogger(PartitionSenderRootExec.class);
private RecordBatch incoming;
private HashPartitionSender operator;
- private PartitionerDecorator partitioner;
+ private volatile PartitionerDecorator partitioner;
--- End diff --
Consider using `AtomicReference` instead of `volatile`
---
