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

[lindong]

This is an automated email from the ASF dual-hosted git repository.

lindong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-ml.git

commit 966cedd7bbab4e12d8d8b37dbd582146714e68a6
Author: zhangzp <zhangzhipe...@gmail.com>
AuthorDate: Mon Jun 20 10:04:40 2022 +0800

    [FLINK-27877] Enable object reuse in flink-ml-bench
---
 .../src/main/java/org/apache/flink/ml/benchmark/Benchmark.java           | 1 +
 1 file changed, 1 insertion(+)

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
index caeb602..123205b 100644
--- 
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 @@ public class Benchmark {
         String saveFile = 
commandLine.getOptionValue(OUTPUT_FILE_OPTION.getLongOpt());
 
         StreamExecutionEnvironment env = 
StreamExecutionEnvironment.getExecutionEnvironment();
+        env.getConfig().enableObjectReuse();
         StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);
 
         int index = 0;