[jira] [Commented] (FLINK-14941) The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception

[ https://issues.apache.org/jira/browse/FLINK-14941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995382#comment-16995382 ] Jark Wu commented on FLINK-14941: - 1.11.0: 127ef48ec510663debb31e96a0bca9322625e2fd 1.10.0:

[jira] [Commented] (FLINK-14941) The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception

[ https://issues.apache.org/jira/browse/FLINK-14941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983073#comment-16983073 ] Zheng Hu commented on FLINK-14941: -- > but I agree with you we should only re-scan if it is an HBase

[jira] [Commented] (FLINK-14941) The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception

[ https://issues.apache.org/jira/browse/FLINK-14941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16982179#comment-16982179 ] Jark Wu commented on FLINK-14941: - Hi [~modavis], I checked the API and the {{withStartRow}} is in

[jira] [Commented] (FLINK-14941) The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception

[ https://issues.apache.org/jira/browse/FLINK-14941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981618#comment-16981618 ] Mark Davis commented on FLINK-14941: I am not sure that the proposed solution is correct. It uses

[jira] [Commented] (FLINK-14941) The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception

[ https://issues.apache.org/jira/browse/FLINK-14941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981553#comment-16981553 ] Zheng Hu commented on FLINK-14941: -- FYI [~jark]. > The AbstractTableInputFormat#nextRecord in hbase