Change to StreamingFileSink in Flink 1.10

[Averell]

Hi,

I have the following code:
 /           StreamingFileSink
              .forRowFormat(new Path(path), myEncoder)
              .withRollingPolicy(DefaultRollingPolicy.create().build())
              .withBucketAssigner(myBucketAssigner)
              .build()/
This is working fine in Flink 1.8.3. However, when I try to compile with
Flink 1.10.0, I got the following error:
    / value build is not a member of ?0
    possible cause: maybe a semicolon is missing before `value build'?/

As per the hint from IntelliJ,
/.forRowFormat returns a RowFormatBuilder[_ <: RowFormatBuilder[_]]
.withRollingPolicy(...) returns a RowFormatBuilder[_]
.withBucketAssigner(...) returns Any/

I'm using Maven 3.6.0, Java 1.8.0_242, and Scala 2.11.12. Tried with/without
IntelliJ, no difference.

Not sure/understand what's wrong

Thanks!
Averell




--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/