aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java
diff options
context:
space:
mode:
authorPaul Rogers <progers@maprtech.com>2017-10-02 15:45:21 -0700
committerArina Ielchiieva <arina.yelchiyeva@gmail.com>2017-11-13 14:59:19 +0200
commit42fc11e53557477ac01c7dd31c3aa93e22fb4384 (patch)
tree6b7fcfedbefeceba55d03abdc5c45f1826b576ec /exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java
parent3036d3700aa620bbbffc260e52f633cdaae1172c (diff)
DRILL-5832: Change OperatorFixture to use system option manager
- Rename FixtureBuilder to ClusterFixtureBuilder - Provide alternative way to reset system/session options - Fix for DRILL-5833: random failure in TestParquetWriter - Provide strict, but clear, errors for missing options closes #970
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java')
-rw-r--r--exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java5
1 files changed, 2 insertions, 3 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java
index 59e744802..690a6624e 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java
@@ -1,4 +1,4 @@
-/**
+/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
@@ -31,6 +31,7 @@ import org.apache.drill.exec.work.batch.RawBatchBuffer;
public class MergingReceiverCreator implements BatchCreator<MergingReceiverPOP> {
static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(MergingReceiverCreator.class);
+ @SuppressWarnings("resource")
@Override
public MergingRecordBatch getBatch(FragmentContext context,
MergingReceiverPOP receiver,
@@ -45,6 +46,4 @@ public class MergingReceiverCreator implements BatchCreator<MergingReceiverPOP>
return new MergingRecordBatch(context, receiver, buffers);
}
-
-
}