[ https://issues.apache.org/jira/browse/FLINK-8824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stephan Ewen resolved FLINK-8824. --------------------------------- Resolution: Fixed Fix Version/s: 1.6.0 Fixed in - 1.5.0 via 70347bcc788dea1d4f64539701e60bafcc772946 - 1.6.0 via 75a4aaea8b051aa6dae52d421f7b4d7eeab99486 > 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 > Assignee: mingleizhang > Priority: Major > Fix For: 1.5.0, 1.6.0 > > > The connector uses {{getCanonicalName()}} inĀ all places, gather than > {{getClassName()}}. > {{getCanonicalName()}}'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)