You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2020/03/19 11:59:47 UTC
[flink] branch release-1.10 updated: [FLINK-16592][docs] The doc of
Streaming File Sink has a mistake of grammar
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.10 by this push:
new fdb864c [FLINK-16592][docs] The doc of Streaming File Sink has a mistake of grammar
fdb864c is described below
commit fdb864c33be0bf287cac8130c6ba13a4efac417c
Author: chen <58...@qq.com>
AuthorDate: Sun Mar 15 21:00:26 2020 +0800
[FLINK-16592][docs] The doc of Streaming File Sink has a mistake of grammar
This closes #11409.
---
docs/dev/connectors/streamfile_sink.md | 2 +-
docs/dev/connectors/streamfile_sink.zh.md | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/dev/connectors/streamfile_sink.md b/docs/dev/connectors/streamfile_sink.md
index bf25182..2e302a6 100644
--- a/docs/dev/connectors/streamfile_sink.md
+++ b/docs/dev/connectors/streamfile_sink.md
@@ -84,7 +84,7 @@ import org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.
DataStream<String> input = ...;
final StreamingFileSink<String> sink = StreamingFileSink
- .forRowFormat(new Path(outputPath), new SimpleStringEncoder<>("UTF-8"))
+ .forRowFormat(new Path(outputPath), new SimpleStringEncoder<String>("UTF-8"))
.withRollingPolicy(
DefaultRollingPolicy.builder()
.withRolloverInterval(TimeUnit.MINUTES.toMillis(15))
diff --git a/docs/dev/connectors/streamfile_sink.zh.md b/docs/dev/connectors/streamfile_sink.zh.md
index fdf678e..bd74bef 100644
--- a/docs/dev/connectors/streamfile_sink.zh.md
+++ b/docs/dev/connectors/streamfile_sink.zh.md
@@ -73,7 +73,7 @@ import org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.
DataStream<String> input = ...;
final StreamingFileSink<String> sink = StreamingFileSink
- .forRowFormat(new Path(outputPath), new SimpleStringEncoder<>("UTF-8"))
+ .forRowFormat(new Path(outputPath), new SimpleStringEncoder<String>("UTF-8"))
.withRollingPolicy(
DefaultRollingPolicy.builder()
.withRolloverInterval(TimeUnit.MINUTES.toMillis(15))