Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.7.0
Description
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 - the scala example doesn't compile due to type mismatch
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
Attachments
Issue Links
- links to