Re: Change to StreamingFileSink in Flink 1.10

[Averell]

Hi,

I tried to add the following cast, and it works. Doesn't look nice though

/            StreamingFileSink
              .forRowFormat(new Path(path), myEncoder)
              .withRollingPolicy(DefaultRollingPolicy.create().build())
             
.withBucketAssigner(myBucketAssigner)*.asInstanceOf[RowFormatBuilder[IN,
String, _]]*
              .build()/

Thanks and regards,
Averell



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