This is an automated email from the ASF dual-hosted git repository. sjwiesman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 84e1a529626427a184acc88a356e04f4f9f17007 Author: sjwiesman <[email protected]> AuthorDate: Mon Nov 15 15:26:01 2021 -0600 [hotfix][examples] Replace StreamingFileSink with FileSink --- .../org/apache/flink/streaming/examples/gpu/MatrixVectorMul.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/gpu/MatrixVectorMul.java b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/gpu/MatrixVectorMul.java index 5b793a8..f267e67 100644 --- a/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/gpu/MatrixVectorMul.java +++ b/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/gpu/MatrixVectorMul.java @@ -23,10 +23,10 @@ import org.apache.flink.api.common.functions.RichMapFunction; import org.apache.flink.api.common.serialization.SimpleStringEncoder; import org.apache.flink.api.java.utils.ParameterTool; import org.apache.flink.configuration.Configuration; +import org.apache.flink.connector.file.sink.FileSink; import org.apache.flink.core.fs.Path; import org.apache.flink.streaming.api.datastream.DataStream; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; -import org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink; import org.apache.flink.streaming.api.functions.source.RichSourceFunction; import org.apache.flink.util.Preconditions; @@ -101,8 +101,8 @@ public class MatrixVectorMul { // Emit result if (params.has("output")) { - result.addSink( - StreamingFileSink.forRowFormat( + result.sinkTo( + FileSink.forRowFormat( new Path(params.get("output")), new SimpleStringEncoder<List<Float>>()) .build());
