Timo Walther created FLINK-9556:
-----------------------------------
Summary: Scala TypeAnalyzer does not consider ResultTypeQueryable
Key: FLINK-9556
URL: https://issues.apache.org/jira/browse/FLINK-9556
Project: Flink
Issue Type: Bug
Components: Scala API
Reporter: Timo Walther
Assignee: Timo Walther
Scala's TypeAnalyzer does not consider the ResultTypeQueryable interface. This
means that type information that has been specified manually is ignored in many
cases.
For example:
{code}
val myConsumer: FlinkKafkaConsumer010[Row] = new FlinkKafkaConsumer010(topics,
new MyDeserializationSchema(jsonSchema), properties)
val inputStream: DataStream[Row] = env.addSource(myConsumer)
{code}
The row type is always generic even though a type information has been
specified in the DeserializationSchema.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
