Merge pull request apache#13 from seznam/vasek/fipping-sumbykey

[BEAM-4609] Flipping tests
cosmoskitten · Jun 22, 2018 · 1dc0b42 · 1dc0b42
2 parents 529d05d + eac573d
commit 1dc0b42
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/...in/java/org/apache/beam/sdk/extensions/euphoria/core/translate/ReduceByKeyTranslator.java b/...in/java/org/apache/beam/sdk/extensions/euphoria/core/translate/ReduceByKeyTranslator.java
@@ -120,8 +120,9 @@ private static <InputT, OutputT> SerializableFunction<Iterable<InputT>, InputT>
 
     @SuppressWarnings("unchecked") final ReduceFunctor<InputT, InputT> combiner =
         (ReduceFunctor<InputT, InputT>) reducer;
-    final SingleValueCollector<InputT> collector = new SingleValueCollector<>();
+
     return (Iterable<InputT> input) -> {
+      SingleValueCollector<InputT> collector = new SingleValueCollector<>();
       combiner.apply(StreamSupport.stream(input.spliterator(), false), collector);
       return collector.get();
     };
@@ -153,8 +154,8 @@ public void processElement(ProcessContext ctx) {
   }
 
   /**
-   * Translation of {@link Collector} collect to Beam's context output. OperatorName serve
-   * as namespace for Beam's metrics.
+   * Translation of {@link Collector} collect to Beam's context output. OperatorName serve as
+   * namespace for Beam's metrics.
    */
   private static class Collector<K, V, OutT>
       implements DoFnCollector.BeamCollector<KV<K, Iterable<V>>, Pair<K, OutT>, OutT> {