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/
Locked
