flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timo Walther <twal...@apache.org>
Subject Re: Which collection to use in Scala case class
Date Thu, 18 Jan 2018 13:00:14 GMT
I filed a more specific issue for this: 
https://issues.apache.org/jira/browse/FLINK-8451

Am 1/18/18 um 10:47 AM schrieb shashank agarwal:
>
> @Chesnay , @Timo, yes it's simple case class which i am using with 
> java.util.List and one case class with Option and Seq. With CEP.
>
> I have filed Jira bugs also for that. I have put logs also there.
>
> https://issues.apache.org/jira/browse/FLINK-7760
>
> I have the issue with Rocksdb checkpointing also I have filed this bug 
> also:
>
> https://issues.apache.org/jira/browse/FLINK-7756
>
>
>
>
>
> ‌
>
> On Wed, Jan 17, 2018 at 2:55 PM, shashank agarwal 
> <shashank734@gmail.com <mailto:shashank734@gmail.com>> wrote:
>
>     Hello,
>
>     A quick question which scala collection should I use in my scala
>     case class which won't go through generic serializer.
>
>     I was using java.utill.List in my scala case class before, Will
>     this create the problem in savepoint and restore. cause, my
>     restore is not working so i am trying to replace that collection
>     with other scala collection.
>
>     Even PatternStream in CEP using Range which goes through generic
>     serializer.
>
>     when I put  "env.getConfig.disableGenericTypes" in my program CEP
>     gives error. After analyzing I found Range was used in
>     PatternStream so it's throwing an error.
>
>     -- 
>     Thanks Regards
>
>     SHASHANK AGARWAL
>      ---  Trying to mobilize the things....
>
>
>
>
>     ‌
>
>
>
>
> -- 
> Thanks Regards
>
> SHASHANK AGARWAL
>  ---  Trying to mobilize the things....
>


Mime
View raw message