[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[jira] [Created] (FLINK-11053) Examples in documentation not compiling

Avi Levi created FLINK-11053:

             Summary: Examples in documentation not compiling
                 Key: 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 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{code}

This message was sent by Atlassian JIRA