diff --git a/euphoria-flink/src/main/java/cz/seznam/euphoria/flink/batch/BatchFlowTranslator.java b/euphoria-flink/src/main/java/cz/seznam/euphoria/flink/batch/BatchFlowTranslator.java
index bde945d9..8b63f6c4 100644
--- a/euphoria-flink/src/main/java/cz/seznam/euphoria/flink/batch/BatchFlowTranslator.java
+++ b/euphoria-flink/src/main/java/cz/seznam/euphoria/flink/batch/BatchFlowTranslator.java
@@ -101,8 +101,8 @@ public BatchFlowTranslator(Settings settings,
     this.accumulatorFactory = Objects.requireNonNull(accumulatorFactory);
 
     // basic operators
-    Translation.add(translations, FlowUnfolder.InputOperator.class, new InputTranslator
-        (splitAssignerFactory));
+    Translation.add(translations, FlowUnfolder.InputOperator.class, new InputTranslator(
+        splitAssignerFactory));
     Translation.add(translations, FlatMap.class, new FlatMapTranslator());
     Translation.add(translations, ReduceStateByKey.class, new ReduceStateByKeyTranslator());
     Translation.add(translations, Union.class, new UnionTranslator());
@@ -158,8 +158,8 @@ public List<DataSink<?>> translateInto(Flow flow) {
       }
       // ~ verify the flowToDag translation
       Translation<Operator<?, ?>> firstMatch = null;
-      for (Translation tx : txs) {
-        if (tx.accept == null || (boolean)tx.accept.apply(originalOp)) {
+      for (Translation<Operator<?, ?>> tx : txs) {
+        if (tx.accept == null || tx.accept.apply(originalOp)) {
           firstMatch = tx;
           break;
         }