You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Till Rohrmann (Jira)" <ji...@apache.org> on 2020/03/19 12:00:00 UTC
[jira] [Assigned] (FLINK-16592) The doc of Streaming File Sink has
a mistake of grammar
[ https://issues.apache.org/jira/browse/FLINK-16592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Till Rohrmann reassigned FLINK-16592:
-------------------------------------
Assignee: Chen
> The doc of Streaming File Sink has a mistake of grammar
> -------------------------------------------------------
>
> Key: FLINK-16592
> URL: https://issues.apache.org/jira/browse/FLINK-16592
> Project: Flink
> Issue Type: Task
> Components: Connectors / FileSystem, Documentation
> Reporter: Chen
> Assignee: Chen
> Priority: Minor
> Labels: pull-request-available
> Attachments: image-2020-03-14-12-04-27-065.png
>
> Time Spent: 10m
> Remaining Estimate: 0h
>
> In the following link, there is a mistake in grammar.
> [https://ci.apache.org/projects/flink/flink-docs-release-1.10/zh/dev/connectors/streamfile_sink.html]
> !image-2020-03-14-12-04-27-065.png|width=567,height=369!
> it should be
> {{}}
> {code:java}
> final StreamingFileSink<String> sink = StreamingFileSink
> .forRowFormat(new Path(outputPath), new SimpleStringEncoder<String>("UTF-8"))
> .withRollingPolicy(
> DefaultRollingPolicy.builder()
> .withRolloverInterval(TimeUnit.MINUTES.toMillis(15))
> .withInactivityInterval(TimeUnit.MINUTES.toMillis(5))
> .withMaxPartSize(1024 * 1024 * 1024)
> .build())
> .build();
> {code}
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)