Hello Leonard, Sivaprasanna,
But my code was working fine with Flink v1.8.
I also tried with a simple String DataStream, and got the same error.
/ StreamingFileSink
.forRowFormat(new Path(path), new SimpleStringEncoder[String]())
.withRollingPolicy(DefaultRollingPolicy.builder().build())
.withBucketAssigner(new DateTimeBucketAssigner)
.build()/
(screenshot below)
<http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/t1586/FlinkError.png>
It's weird. At first I thought it's something wrong with IntelliJ, but I got
the same error when running mvn from commandline.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
