(flink-benchmarks) branch master updated: [FLINK-34164] Fix compilation issue (#85)

[hangxiang]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new fc87459  [FLINK-34164] Fix compilation issue (#85)
fc87459 is described below

commit fc87459a27e702b15e590fdab2ba63e6a86a951e
Author: JunRuiLee <jrlee....@gmail.com>
AuthorDate: Fri Jan 19 15:32:03 2024 +0800

    [FLINK-34164] Fix compilation issue (#85)
---
 src/main/java/org/apache/flink/benchmark/StreamGraphUtils.java | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/src/main/java/org/apache/flink/benchmark/StreamGraphUtils.java 
b/src/main/java/org/apache/flink/benchmark/StreamGraphUtils.java
index d083843..2cb8e3e 100644
--- a/src/main/java/org/apache/flink/benchmark/StreamGraphUtils.java
+++ b/src/main/java/org/apache/flink/benchmark/StreamGraphUtils.java
@@ -19,6 +19,8 @@
 package org.apache.flink.benchmark;
 
 import org.apache.flink.benchmark.functions.LongSource;
+import org.apache.flink.configuration.Configuration;
+import org.apache.flink.configuration.PipelineOptions;
 import org.apache.flink.runtime.jobgraph.JobType;
 import org.apache.flink.streaming.api.datastream.DataStreamSource;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
@@ -34,8 +36,11 @@ public class StreamGraphUtils {
         DataStreamSource<Long> source = env.addSource(new 
LongSource(numRecords));
         source.addSink(new DiscardingSink<>());
 
+        Configuration config = new Configuration();
+        config.set(PipelineOptions.OPERATOR_CHAINING, false);
+        env.configure(config);
+
         StreamGraph streamGraph = env.getStreamGraph();
-        streamGraph.setChaining(false);
         
streamGraph.setGlobalStreamExchangeMode(GlobalStreamExchangeMode.ALL_EDGES_BLOCKING);
         streamGraph.setJobType(JobType.BATCH);