Re: KafkaTopicPartition internal class treated as generic type serialization

2019-02-18 Thread Fabian Hueske
Hi Eric, I did a quick search in our Jira to check if this is a known issue but didn't find anything. Maybe Gordon (in CC) knows a bit more about this problem. Best, Fabian Am Fr., 15. Feb. 2019 um 11:08 Uhr schrieb Eric Troies : > Hi, I'm having the exact same issue with flink 1.4.0 using

Re: KafkaTopicPartition internal class treated as generic type serialization

2019-02-15 Thread Eric Troies
Hi, I'm having the exact same issue with flink 1.4.0 using scala 2.11 . Do you have any suggestion on how to fix this ? I don't see how to register a custom serializer for a class I did not write. Thanks ! > I disabled generic type serialization via > env.getConfig.disableGenericTypes() >

KafkaTopicPartition internal class treated as generic type serialization

2018-09-02 Thread Yee-Ning Cheng
I disabled generic type serialization via env.getConfig.disableGenericTypes() and got the following exception when running my job on a standalone cluster. Caused by: java.lang.UnsupportedOperationException: Generic types have been disabled in the ExecutionConfig and type