[FLINK-27877] Enable object reuse in flink-ml-bench

zhipeng93 · lindong28 · commit 966cedd7bbab · 2022-06-20T11:43:11.000+08:00
diff --git a/flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/Benchmark.java b/flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/Benchmark.java
@@ -77,6 +77,7 @@ private static void executeBenchmarks(CommandLine commandLine) throws Exception
         String saveFile = commandLine.getOptionValue(OUTPUT_FILE_OPTION.getLongOpt());
 
         StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
+        env.getConfig().enableObjectReuse();
         StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);
 
         int index = 0;
