[jira] [Created] (FLINK-9556) Scala TypeAnalyzer does not consider ResultTypeQueryable
Timo Walther created FLINK-9556:
Summary: Scala TypeAnalyzer does not consider ResultTypeQueryable
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.
val myConsumer: FlinkKafkaConsumer010[Row] = new FlinkKafkaConsumer010(topics, new MyDeserializationSchema(jsonSchema), properties)
val inputStream: DataStream[Row] = env.addSource(myConsumer)
The row type is always generic even though a type information has been specified in the DeserializationSchema.
This message was sent by Atlassian JIRA