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 org.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartition is treated as a generic type. Is this expected? I figure I may just have to register a custom serializer for this, but (wrongly?) expected the class to have its own serializer, although there's not much overhead for this class. I do understand the documentation behind using disableGenericTypes() only in application development, but would this possibly hide other classes since it could possibly eagerly fail on this class? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
