You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by li...@apache.org on 2022/06/20 03:43:21 UTC
[flink-ml] 04/04: [FLINK-27877] Enable object reuse in flink-ml-bench
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 <zh...@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;