Github user arina-ielchiieva commented on a diff in the pull request:
https://github.com/apache/drill/pull/1105#discussion_r172024966
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/PartitionSenderRootExec.java
---
@@ -358,7 +357,7 @@ public void close() throws Exception {
}
}
- public void sendEmptyBatch(boolean isLast) {
+ public synchronized void sendEmptyBatch(boolean isLast) {
--- End diff --
Method can be made private. Plus maybe not be synchronized as well since is
being called from `innerNext`.
---
