diff options
| author | Jinfeng Ni <jni@apache.org> | 2016-09-21 16:03:49 -0700 |
|---|---|---|
| committer | Jinfeng Ni <jni@apache.org> | 2016-10-05 20:40:46 -0700 |
| commit | 4edabe7a392f38b0f7a9c8af51a74bf6932a821d (patch) | |
| tree | befeaca14754d136fcd64316738e3d6ab9deed0a /exec/java-exec/src/main/java/org/apache/drill/exec/planner/fragment/SimpleParallelizer.java | |
| parent | 1375a0065f1acae4ff5edf3c6370b7ad25f188c4 (diff) | |
DRILL-4911: Avoid plan serialization in SimpleParallelizer when debug logging is not enabled.
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/planner/fragment/SimpleParallelizer.java')
| -rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/planner/fragment/SimpleParallelizer.java | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/fragment/SimpleParallelizer.java b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/fragment/SimpleParallelizer.java index 47de88e7c..c389e89cd 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/fragment/SimpleParallelizer.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/fragment/SimpleParallelizer.java @@ -316,11 +316,15 @@ public class SimpleParallelizer implements ParallelizationParameters { .build(); if (isRootNode) { - logger.debug("Root fragment:\n {}", DrillStringUtils.unescapeJava(fragment.toString())); + if (logger.isDebugEnabled()) { + logger.debug("Root fragment:\n {}", DrillStringUtils.unescapeJava(fragment.toString())); + } rootFragment = fragment; rootOperator = root; } else { - logger.debug("Remote fragment:\n {}", DrillStringUtils.unescapeJava(fragment.toString())); + if (logger.isDebugEnabled()) { + logger.debug("Remote fragment:\n {}", DrillStringUtils.unescapeJava(fragment.toString())); + } fragments.add(fragment); } } |