flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Leonard Xu <xbjt...@gmail.com>
Subject Re: Change to StreamingFileSink in Flink 1.10
Date Tue, 21 Apr 2020 12:32:50 GMT
Hi, Averell

I found you’re using scala so I reproduced your case local in Scala 2.11.12 with Flink 1.10.0
and it works too. 
From your picture it’s wired  that line`.withBucketAssigner(new DateTimeBucketAssigner)`
hint is `Any`, 
it should be `RowFormatBuilder` otherwise you can not call `#build` function from an `Any`
object. 
You can debug this line and to see what happened.


Best,
Leonard



> 在 2020年4月21日,17:47,Averell <lvhuyen@gmail.com> 写道:
> 
> 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/


Mime
View raw message