[jira] [Commented] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

2020-11-12 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230689#comment-17230689 ] Stephan Ewen commented on FLINK-19717: -- Fixed in 1.12.0 via

[jira] [Commented] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

2020-11-09 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228550#comment-17228550 ] Stephan Ewen commented on FLINK-19717: -- Yes, we need to pick back all changes from master to

[jira] [Commented] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

2020-11-08 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228328#comment-17228328 ] Jiangjie Qin commented on FLINK-19717: -- [~sewen] I have merged the patch to master. But

[jira] [Commented] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

2020-11-08 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228016#comment-17228016 ] Stephan Ewen commented on FLINK-19717: -- We are about to merge this. There is consensus on problem

[jira] [Commented] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

2020-11-05 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17226786#comment-17226786 ] Robert Metzger commented on FLINK-19717: Is this blocker expected to be merged before the

[jira] [Commented] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

2020-10-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221318#comment-17221318 ] Dian Fu commented on FLINK-19717: - [~rmetzger] You are right. I missed the PR. >

[jira] [Commented] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

2020-10-27 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221272#comment-17221272 ] Robert Metzger commented on FLINK-19717: [~dian.fu] I believe the issue here is that [~kezhuw]

[jira] [Commented] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

2020-10-27 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221252#comment-17221252 ] Dian Fu commented on FLINK-19717: - [~kezhuw] Any update on this ticket? It would be great if we can fix

[jira] [Commented] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

2020-10-26 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17220783#comment-17220783 ] Robert Metzger commented on FLINK-19717: Thank you. I assigned you to the ticket. >

[jira] [Commented] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

2020-10-23 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219695#comment-17219695 ] Kezhu Wang commented on FLINK-19717: [~sewen] I am willing to take over this. >

[jira] [Commented] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

2020-10-23 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219692#comment-17219692 ] Stephan Ewen commented on FLINK-19717: -- [~kezhuw] I agree with your analysis and with the suggested

[jira] [Commented] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

2020-10-21 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218676#comment-17218676 ] Kezhu Wang commented on FLINK-19717: [~rmetzger] Thanks for response. Let's wait their decision.

[jira] [Commented] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

2020-10-21 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218181#comment-17218181 ] Robert Metzger commented on FLINK-19717: Thanks a lot for your investigation and for opening

[jira] [Commented] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

2020-10-19 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17216840#comment-17216840 ] Kezhu Wang commented on FLINK-19717: {quote}Maybe the fix would be to always check for errors before