[
https://issues.apache.org/jira/browse/FLINK-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-9384.
---------------------------------
Resolution: Fixed
Fixed in 1.6.0: bc8d1b1f61deff51f131ab243f25f676f465e240
> KafkaAvroTableSource failed to work due to type mismatch
> --------------------------------------------------------
>
> Key: FLINK-9384
> URL: https://issues.apache.org/jira/browse/FLINK-9384
> Project: Flink
> Issue Type: Bug
> Components: Kafka Connector, Table API & SQL
> Affects Versions: 1.6.0
> Reporter: Jun Zhang
> Priority: Blocker
> Labels: easyfix, patch
> Fix For: 1.6.0
>
> Attachments: flink-9384.patch
>
>
> An exception was thrown when using KafkaAvroTableSource as follows:
> Exception in thread "main" org.apache.flink.table.api.TableException:
> TableSource of type
> org.apache.flink.streaming.connectors.kafka.Kafka011AvroTableSource returned
> a DataStream of type GenericType<org.apache.flink.types.Row> that does not
> match with the type Row(id: Integer, name: String, age: Integer, event:
> GenericType<java.util.Map>) declared by the TableSource.getReturnType()
> method. Please validate the implementation of the TableSource.
> at
> org.apache.flink.table.plan.nodes.datastream.StreamTableSourceScan.translateToPlan(StreamTableSourceScan.scala:100)
> at
> org.apache.flink.table.api.StreamTableEnvironment.translateToCRow(StreamTableEnvironment.scala:885)
> at
> org.apache.flink.table.api.StreamTableEnvironment.translate(StreamTableEnvironment.scala:812)
> at
> org.apache.flink.table.api.StreamTableEnvironment.writeToSink(StreamTableEnvironment.scala:279)
> at org.apache.flink.table.api.Table.writeToSink(table.scala:862)
> at org.apache.flink.table.api.Table.writeToSink(table.scala:830)
> at
> org.apache.flink.quickstart.StreamingJobAvro.main(StreamingJobAvro.java:85)
>
> It is caused by a discrepancy between the type returned by the TableSource
> and the type returned by the DataStream. I've already fixed it, would someone
> please review the patch and see if it could be merged.
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
