[BEAM-1095] Add support set config for reuse-object on flink

fix codestyle
apache · Dec 6, 2016 · a000ed3 · a000ed3
1 parent 8ae2441
commit a000ed3
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/...runner/src/main/java/org/apache/beam/runners/flink/FlinkPipelineExecutionEnvironment.java b/...runner/src/main/java/org/apache/beam/runners/flink/FlinkPipelineExecutionEnvironment.java
@@ -159,10 +159,11 @@ private ExecutionEnvironment createBatchExecutionEnvironment() {
     // set parallelism in the options (required by some execution code)
     options.setParallelism(flinkBatchEnv.getParallelism());
 
-    if (options.getReuseObject())
+    if (options.getReuseObject()) {
       flinkBatchEnv.getConfig().enableObjectReuse();
-    else
+    } else {
       flinkBatchEnv.getConfig().disableObjectReuse();
+    }
 
     return flinkBatchEnv;
   }
@@ -202,10 +203,11 @@ private StreamExecutionEnvironment createStreamExecutionEnvironment() {
     // set parallelism in the options (required by some execution code)
     options.setParallelism(flinkStreamEnv.getParallelism());
 
-    if (options.getReuseObject())
+    if (options.getReuseObject()) {
       flinkStreamEnv.getConfig().enableObjectReuse();
-    else
+    } else {
       flinkStreamEnv.getConfig().disableObjectReuse();
+    }
 
     // default to event time
     flinkStreamEnv.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);