You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2019/02/12 11:45:00 UTC
[jira] [Updated] (FLINK-11053) Bucketing sink example does not
compile
[ https://issues.apache.org/jira/browse/FLINK-11053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chesnay Schepler updated FLINK-11053:
-------------------------------------
Summary: Bucketing sink example does not compile (was: Examples in documentation not compiling)
> Bucketing sink example does not compile
> ---------------------------------------
>
> Key: FLINK-11053
> URL: https://issues.apache.org/jira/browse/FLINK-11053
> Project: Flink
> Issue Type: Bug
> Components: Documentation
> Affects Versions: 1.7.0
> Reporter: Avi Levi
> Priority: Major
> Labels: pull-request-available
> Time Spent: 20m
> Remaining Estimate: 0h
>
> The example for `scala` for [ stramingFileSink - Using row encoded output formatshttps://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/streamfile_sink.html#using-row-encoded-output-formats] - is not written in scala (e.g in scala you do not define the type before the variable name) and it doesn't compile
> another example is the [BulkingSink|https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/filesystem_sink.html#bucketing-file-sink] - the scala example doesn't compile due to type mismatch
> {code:java}
> val sink = new BucketingSink[String]("/base/path")
> sink.setBucketer(new DateTimeBucketer[String]("yyyy-MM-dd--HHmm", ZoneId.of("America/Los_Angeles"))) sink.setWriter(new SequenceFileWriter[IntWritable, Text]()) sink.setBatchSize(1024 * 1024 * 400) // this is 400 MB, sink.setBatchRolloverInterval(20 * 60 * 1000); // this is 20 mins{code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)