[ https://issues.apache.org/jira/browse/FLINK-8824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
mingleizhang updated FLINK-8824: -------------------------------- Summary: In Kafka Consumers, replace 'getCanonicalName()' with 'getClassName()' (was: In Kafka Consumers, replace 'getCanonicalClassName()' with 'getClassName()') > In Kafka Consumers, replace 'getCanonicalName()' with 'getClassName()' > ---------------------------------------------------------------------- > > Key: FLINK-8824 > URL: https://issues.apache.org/jira/browse/FLINK-8824 > Project: Flink > Issue Type: Bug > Components: Kafka Connector > Reporter: Stephan Ewen > Priority: Major > Fix For: 1.5.0 > > > The connector uses {{getCanonicalClassName()}} inĀ all places, gather than > {{getClassName()}}. > {{getCanonicalClassName()}}'s intention is to normalize class names for > arrays, etc, but is problematic when instantiating classes from class names. -- This message was sent by Atlassian JIRA (v7.6.3#76005)