Github user vrozov commented on a diff in the pull request:

    https://github.com/apache/drill/pull/1208#discussion_r181926928
  
    --- Diff: 
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/PartitionerTemplate.java
 ---
    @@ -161,8 +161,11 @@ public OperatorStats getStats() {
        * @param schemaChanged  true if the schema has changed
        */
       @Override
    -  public void flushOutgoingBatches(boolean isLastBatch, boolean 
schemaChanged) throws IOException {
    +  public void flushOutgoingBatches(boolean isLastBatch, boolean 
schemaChanged) throws IOException, InterruptedException {
         for (OutgoingRecordBatch batch : outgoingBatches) {
    +      if (Thread.interrupted()) {
    +        throw new InterruptedException();
    --- End diff --
    
    I'll revert back throwing 'InterruptedException' to avoid mishandling of 
the last batch. 


---

Reply via email to