Avi Levi created FLINK-11053:
--------------------------------
Summary: Examples in documentation not compiling
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
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)
