diff options
| author | Aman Sinha <asinha@maprtech.com> | 2015-04-29 20:34:04 -0700 |
|---|---|---|
| committer | Aman Sinha <asinha@maprtech.com> | 2015-05-07 15:32:13 -0700 |
| commit | 79a712aaee320594dc9fc88e49d953df3d9fad9d (patch) | |
| tree | 95a72bc74b58db03c41aa552a454ba257624d8e1 /exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/PartitionSenderRootExec.java | |
| parent | 8c706e6fa44e100cef6c117ddeceb238d150e89d (diff) | |
DRILL-2809: Increase the default value of partitioner_sender_threads_factor.
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/PartitionSenderRootExec.java')
| -rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/PartitionSenderRootExec.java | 2 |
1 files changed, 0 insertions, 2 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/PartitionSenderRootExec.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/PartitionSenderRootExec.java index cf7ba1610..16d140051 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/PartitionSenderRootExec.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/partitionsender/PartitionSenderRootExec.java @@ -111,8 +111,6 @@ public class PartitionSenderRootExec extends BaseRootExec { stats.setLongStat(Metric.N_RECEIVERS, outGoingBatchCount); // Algorithm to figure out number of threads to parallelize output // numberOfRows/sliceTarget/numReceivers/threadfactor - // threadFactor = 4 by default - // one more param to put a limit on number max number of threads: default 32 this.cost = operator.getChild().getCost(); final OptionManager optMgr = context.getOptions(); long sliceTarget = optMgr.getOption(ExecConstants.SLICE_TARGET).num_val; |