You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sj...@apache.org on 2021/11/16 21:40:20 UTC
[flink] 09/11: [hotfix][examples] Replace StreamingFileSink with FileSink
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 <sj...@gmail.com>
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());