[jira] [Commented] (FLINK-30158) [Flink SQL][Protobuf] NullPointerException when querying Kafka topic using repeated or map attributes

2022-12-01 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641895#comment-17641895 ] Benchao Li commented on FLINK-30158: bq. Even if I commented out the second column in the table

[jira] [Commented] (FLINK-30158) [Flink SQL][Protobuf] NullPointerException when querying Kafka topic using repeated or map attributes

2022-11-30 Thread James Mcguire (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641592#comment-17641592 ] James Mcguire commented on FLINK-30158: --- You are correct, I was trying to recreate the schema from

[jira] [Commented] (FLINK-30158) [Flink SQL][Protobuf] NullPointerException when querying Kafka topic using repeated or map attributes

2022-11-28 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640323#comment-17640323 ] Benchao Li commented on FLINK-30158: [~jamesmcguirepro] The schema for 'second' seems not correct.

[jira] [Commented] (FLINK-30158) [Flink SQL][Protobuf] NullPointerException when querying Kafka topic using repeated or map attributes

2022-11-28 Thread James Mcguire (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640182#comment-17640182 ] James Mcguire commented on FLINK-30158: --- Sorry about that, I meant to provide the Flink schema!

[jira] [Commented] (FLINK-30158) [Flink SQL][Protobuf] NullPointerException when querying Kafka topic using repeated or map attributes

2022-11-27 Thread Tony Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17639822#comment-17639822 ] Tony Zhu commented on FLINK-30158: -- [~jamesmcguirepro]  could you provide more info? I'd like to take a

[jira] [Commented] (FLINK-30158) [Flink SQL][Protobuf] NullPointerException when querying Kafka topic using repeated or map attributes

2022-11-26 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17639340#comment-17639340 ] Benchao Li commented on FLINK-30158: [~jamesmcguirepro] Currently Protobuf format requires users to

[jira] [Commented] (FLINK-30158) [Flink SQL][Protobuf] NullPointerException when querying Kafka topic using repeated or map attributes

2022-11-23 Thread James Mcguire (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637881#comment-17637881 ] James Mcguire commented on FLINK-30158: --- [~luoyuxia] , {{message-class-name }}is set to

[jira] [Commented] (FLINK-30158) [Flink SQL][Protobuf] NullPointerException when querying Kafka topic using repeated or map attributes

2022-11-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637688#comment-17637688 ] Martijn Visser commented on FLINK-30158: [~maosuhan] Could you also take a look at this issue?

[jira] [Commented] (FLINK-30158) [Flink SQL][Protobuf] NullPointerException when querying Kafka topic using repeated or map attributes

2022-11-22 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17637524#comment-17637524 ] luoyuxia commented on FLINK-30158: -- I have no much knowledge about protobuf format. But I had a quick