diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/CoGbkResult.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/CoGbkResult.java index 482018e198d5..2e26d13da547 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/CoGbkResult.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/CoGbkResult.java @@ -625,12 +625,6 @@ private static class TagIterable implements Iterable { Reiterator tail; boolean finished; - private Counter smallIterablesCount = - Metrics.counter(CoGbkResult.class, "cogbk-small-iterables"); - - private Counter largeIterablesCount = - Metrics.counter(CoGbkResult.class, "cogbk-large-iterables"); - public TagIterable( List head, int tag, int cacheSize, ObservingReiterator tip) { this.tag = tag;