I agree with Leonard. I have just tried the same in Scala 2.11 with Flink 1.10.0 and it works just fine.
Cheers, Sivaprasanna On Tue, Apr 21, 2020 at 12:53 PM Leonard Xu <xbjt...@gmail.com> wrote: > Hi, Averell > > I guess it’s none of `#withRollingPolicy` and `#withBucketAssigner` and > may cause by generics type > that your Encoder<IN>’s element type(IN) does not match BucketAssigner<IN, > BuketId> element type(IN) or > you lost the generics type information when instantiate them. > > Could you post more code phase? > > Best, > Leonard Xu. > > 在 2020年4月21日，07:47，Averell <lvhu...@gmail.com> 写道： > > myEncoder > > >
