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 bug
@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
The issue of Scala case classes that can not be restored is a known
issue in Flink 1.4. We need to investigate if it can be fixed easily.
@Shashank: Could you give us a little reproducible example? Just a case
class with a java.util.List in it?
@Gordon: Is there a Jira issue for this? I might
Can you show us the exception you get when restoring?
Looping in Time who knows more about how types are analyzed/serializers
are constructed.
On 17.01.2018 10:25, shashank agarwal wrote:
Hello,
A quick question which scala collection should I use in my scala case
class which won't go throu
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 replac
