apache#13 Fix race condition in batch ReduceStateByKeyTranslator

dmvk · May 15, 2018 · c9ab3c2 · c9ab3c2
1 parent dd615a2
commit c9ab3c2
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...ia/euphoria-flink/src/main/java/cz/seznam/euphoria/flink/batch/ReduceByKeyTranslator.java b/...ia/euphoria-flink/src/main/java/cz/seznam/euphoria/flink/batch/ReduceByKeyTranslator.java
@@ -149,12 +149,11 @@ public DataSet translate(FlinkOperator<ReduceByKey> operator,
   static class RBKKeySelector
           implements KeySelector<BatchElement<Window, Pair>, Integer> {
 
-    private final Tuple2 tuple = new Tuple2();
-
     @Override
     public Integer getKey(
             BatchElement<Window, Pair> value) {
 
+      Tuple2 tuple = new Tuple2();
       tuple.f0 = value.getWindow();
       tuple.f1 =  value.getElement().getFirst();
       return tuple.hashCode();