Github user kkhatua commented on a diff in the pull request:
https://github.com/apache/drill/pull/1141#discussion_r171767495
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/ops/FragmentStats.java ---
@@ -79,4 +71,21 @@ public void addOperatorStats(OperatorStats stats) {
operators.add(stats);
}
+ //DRILL-6197
+ public OperatorStats addOrReplaceOperatorStats(OperatorStats stats) {
+ //Remove existing stat
+ OperatorStats replacedStat = null;
+ int index = 0;
+ for (OperatorStats opStat : operators) {
--- End diff --
Everything worked fine. Tried doing a join for TPCH tables - `lineitem` and
`orders`, and confirmed no more duplicates for SCREEN, SINGLE_SENDER and
HASH_PARTITION_SENDER. For a smaller substitute of `orders` with `supplier` ;
confirmed that the BROADCAST_SENDER was also not having duplicates..
---
