Github user kkhatua commented on a diff in the pull request:
https://github.com/apache/drill/pull/1141#discussion_r171485412
--- 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 --
The add-on commit refactors by having the BaseRootExec constructor handle
the substition without risking going out of sync with other senders extending
BaseRootExec.
---
