Github user amansinha100 commented on a diff in the pull request:
https://github.com/apache/drill/pull/1141#discussion_r171431227
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/ops/FragmentStats.java ---
@@ -31,6 +32,13 @@
public class FragmentStats {
// private static final org.slf4j.Logger logger =
org.slf4j.LoggerFactory.getLogger(FragmentStats.class);
+ //Skip operators that already have stats reported by
org.apache.drill.exec.physical.impl.BaseRootExec
+ private static final List<Integer> operatorStatsInitToSkip =
Lists.newArrayList(
--- End diff --
This could get out of sync with the types of senders that extend
BaseRootExec.
---