flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-9384) KafkaAvroTableSource failed to work due to type mismatch
Date Wed, 16 May 2018 22:07:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16478190#comment-16478190
] 

ASF GitHub Bot commented on FLINK-9384:
---------------------------------------

Github user suez1224 commented on a diff in the pull request:

    https://github.com/apache/flink/pull/6026#discussion_r188786307
  
    --- Diff: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java
---
    @@ -110,6 +116,8 @@ private void writeObject(ObjectOutputStream oos) throws IOException
{
     		oos.writeObject(recordClazz);
     	}
     
    +
    --- End diff --
    
    extra blank line here.


> 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
>    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)

Mime
View raw message