[jira] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336961#comment-17336961 ] Flink Jira Bot commented on FLINK-18049: This issue was labeled "stale-critical" 7 ago and has

[jira] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17329035#comment-17329035 ] Flink Jira Bot commented on FLINK-18049: This critical issue is unassigned and itself and all of

[jira] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125108#comment-17125108 ] Seth Wiesman commented on FLINK-18049: -- I tend to agree with Dawid, this is not how Avro is

[jira] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124960#comment-17124960 ] Dawid Wysakowicz commented on FLINK-18049: -- Short update. I've talked to [~aljoscha] and had

[jira] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124584#comment-17124584 ] Jark Wu commented on FLINK-18049: - Thanks for the discussion and looking into this problem [~openinx].

[jira] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17123960#comment-17123960 ] Dawid Wysakowicz commented on FLINK-18049: -- Have you verified that it can work with other

[jira] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17123939#comment-17123939 ] Zheng Hu commented on FLINK-18049: -- > The Flink's documentation refers to "Avro type state" .. Got

[jira] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17123909#comment-17123909 ] Dawid Wysakowicz commented on FLINK-18049: -- The Flink's documentation refers to "Avro type

[jira] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17123902#comment-17123902 ] Zheng Hu commented on FLINK-18049: -- Thanks for your reply, [~dwysakowicz]. I read the flink document

[jira] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17123860#comment-17123860 ] Dawid Wysakowicz commented on FLINK-18049: -- I had a look into the PR. It does workaround that

[jira] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17123846#comment-17123846 ] Dawid Wysakowicz commented on FLINK-18049: -- If I understood your case correctly that's exactly

[jira] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17123796#comment-17123796 ] Zheng Hu commented on FLINK-18049: -- Ping [~tiwalter], [~dwysakowicz], [~sewen] Thanks. > The Flink

[jira] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121030#comment-17121030 ] Zheng Hu commented on FLINK-18049: -- After digging into the code, we found that the