flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sivaprasanna <sivaprasanna...@gmail.com>
Subject Re: Change to StreamingFileSink in Flink 1.10
Date Tue, 21 Apr 2020 08:59:48 GMT
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 <xbjtdcq@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 <lvhuyen@gmail.com> 写道:
>
> myEncoder
>
>
>

Mime
View raw message