[jira] [Commented] (FLINK-28051) Promote ExternallyInducedSourceReader to non-experimental @Public

[ https://issues.apache.org/jira/browse/FLINK-28051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17791402#comment-17791402 ] Brian Zhou commented on FLINK-28051: Hi [~afedulov] , we can confirm the usage of

[jira] [Commented] (FLINK-28051) Promote ExternallyInducedSourceReader to non-experimental @Public

[ https://issues.apache.org/jira/browse/FLINK-28051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17788970#comment-17788970 ] Brian Zhou commented on FLINK-28051: Hi [~afedulov] and [~knaufk] , thanks for bringing the topic to

[jira] [Commented] (FLINK-31560) Savepoint failing to complete with ExternallyInducedSources

[ https://issues.apache.org/jira/browse/FLINK-31560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719314#comment-17719314 ] Brian Zhou commented on FLINK-31560: [~Yanfei Lei]  I think it's fair for the community to not fix a

[jira] [Commented] (FLINK-31560) Savepoint failing to complete with incremental RocksDB statebackend

[ https://issues.apache.org/jira/browse/FLINK-31560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704058#comment-17704058 ] Brian Zhou commented on FLINK-31560: Thanks [~Yanfei Lei]  to look into this. I am in the same team

[jira] [Updated] (FLINK-31560) Savepoint failing to complete with incremental RocksDB statebackend

[ https://issues.apache.org/jira/browse/FLINK-31560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Zhou updated FLINK-31560: --- Attachment: jobmanager_log.txt > Savepoint failing to complete with incremental RocksDB

[jira] [Updated] (FLINK-31560) Savepoint failing to complete with incremental RocksDB statebackend

[ https://issues.apache.org/jira/browse/FLINK-31560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Zhou updated FLINK-31560: --- Attachment: image-2023-03-23-18-19-24-482.png > Savepoint failing to complete with incremental

[jira] [Updated] (FLINK-31560) Savepoint failing to complete with incremental RocksDB statebackend

[ https://issues.apache.org/jira/browse/FLINK-31560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Zhou updated FLINK-31560: --- Attachment: image-2023-03-23-18-03-05-943.png > Savepoint failing to complete with incremental

[jira] [Updated] (FLINK-31560) Savepoint failing to complete with incremental RocksDB statebackend

[ https://issues.apache.org/jira/browse/FLINK-31560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Zhou updated FLINK-31560: --- Summary: Savepoint failing to complete with incremental RocksDB statebackend (was: Savepoint

[jira] [Updated] (FLINK-31560) Savepoint failing to complete with incremental checkpointing

[ https://issues.apache.org/jira/browse/FLINK-31560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Zhou updated FLINK-31560: --- Summary: Savepoint failing to complete with incremental checkpointing (was: Issue deleting Flink

[jira] [Updated] (FLINK-31560) Issue deleting Flink cluster due to savepoint failing to complete

[ https://issues.apache.org/jira/browse/FLINK-31560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Zhou updated FLINK-31560: --- Description: Flink version: 1.16.0   We are using Flink to run some streaming applications with

[jira] [Commented] (FLINK-28695) Fail to send partition request to restarted taskmanager

[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629618#comment-17629618 ] Brian Zhou commented on FLINK-28695: Thanks [~Weijie Guo] for your suggestion, we can try that. For

[jira] [Commented] (FLINK-28695) Fail to send partition request to restarted taskmanager

[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629596#comment-17629596 ] Brian Zhou commented on FLINK-28695: Not sure if the original reporter has the same, but from our

[jira] [Commented] (FLINK-28695) Fail to send partition request to restarted taskmanager

[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629570#comment-17629570 ] Brian Zhou commented on FLINK-28695: >From investigating the code, looks like it is related to

[jira] [Commented] (FLINK-28695) Fail to send partition request to restarted taskmanager

[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628826#comment-17628826 ] Brian Zhou commented on FLINK-28695: We have experienced this issue on Flink 1.15, is there anyone

[jira] [Commented] (FLINK-25256) Savepoints do not work with ExternallyInducedSources

[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505212#comment-17505212 ] Brian Zhou commented on FLINK-25256: Hi [~dwysakowicz] , I want to ask what the influence is of this

[jira] [Commented] (FLINK-25256) Savepoints do not work with ExternallyInducedSources

[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503251#comment-17503251 ] Brian Zhou commented on FLINK-25256: Hi [~dwysakowicz] , there are still something we want to know

[jira] [Commented] (FLINK-25256) Savepoints do not work with ExternallyInducedSources

[ https://issues.apache.org/jira/browse/FLINK-25256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499879#comment-17499879 ] Brian Zhou commented on FLINK-25256: Yes, this interface is now used in the both the legacy reader

[jira] [Created] (FLINK-24059) SourceReaderTestBase should allow NUM_SPLITS to be overridden in implementation

Brian Zhou created FLINK-24059: -- Summary: SourceReaderTestBase should allow NUM_SPLITS to be overridden in implementation Key: FLINK-24059 URL: https://issues.apache.org/jira/browse/FLINK-24059 Project:

[jira] [Resolved] (FLINK-14095) Add Pravega in Flink ecosystem page

[ https://issues.apache.org/jira/browse/FLINK-14095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Zhou resolved FLINK-14095. Resolution: Fixed > Add Pravega in Flink ecosystem page > --- > >

[jira] [Commented] (FLINK-14095) Add Pravega in Flink ecosystem page

[ https://issues.apache.org/jira/browse/FLINK-14095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326279#comment-17326279 ] Brian Zhou commented on FLINK-14095: Close this ticket via adding in the ecosystem page, will reopen

[jira] [Updated] (FLINK-22133) SplitEmumerator does not provide checkpoint id in snapshot

[ https://issues.apache.org/jira/browse/FLINK-22133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Zhou updated FLINK-22133: --- Description: In ExternallyInducedSource API, the checkpoint trigger exposes the checkpoint Id for

[jira] [Created] (FLINK-22133) SplitEmumerator does not provide checkpoint id in snapshot

Brian Zhou created FLINK-22133: -- Summary: SplitEmumerator does not provide checkpoint id in snapshot Key: FLINK-22133 URL: https://issues.apache.org/jira/browse/FLINK-22133 Project: Flink Issue

[jira] [Created] (FLINK-21178) Task failure will not trigger master hook's reset()

Brian Zhou created FLINK-21178: -- Summary: Task failure will not trigger master hook's reset() Key: FLINK-21178 URL: https://issues.apache.org/jira/browse/FLINK-21178 Project: Flink Issue Type:

[jira] [Commented] (FLINK-18044) Add the subtask index information to the SourceReaderContext.

[ https://issues.apache.org/jira/browse/FLINK-18044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204649#comment-17204649 ] Brian Zhou commented on FLINK-18044: As another example, in the ongoing integration of FLIP-27 in

[jira] [Commented] (FLINK-19098) Make Rowdata converters public

[ https://issues.apache.org/jira/browse/FLINK-19098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17197312#comment-17197312 ] Brian Zhou commented on FLINK-19098: I have raised a PR and left open for a week. It has passed the

[jira] [Comment Edited] (FLINK-19098) Make Rowdata converters public

[ https://issues.apache.org/jira/browse/FLINK-19098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17187607#comment-17187607 ] Brian Zhou edited comment on FLINK-19098 at 8/31/20, 9:48 AM: -- Thanks Jark

[jira] [Commented] (FLINK-19098) Make Rowdata converters public

[ https://issues.apache.org/jira/browse/FLINK-19098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17187607#comment-17187607 ] Brian Zhou commented on FLINK-19098: Thanks Jark and Danny, I can pick up this change and will take

[jira] [Commented] (FLINK-19098) Make Rowdata converters public

[ https://issues.apache.org/jira/browse/FLINK-19098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17187518#comment-17187518 ] Brian Zhou commented on FLINK-19098: Notify the author of FLINK-16048 [~danny0405] to see if this is

[jira] [Created] (FLINK-19098) Make Rowdata converters public

Brian Zhou created FLINK-19098: -- Summary: Make Rowdata converters public Key: FLINK-19098 URL: https://issues.apache.org/jira/browse/FLINK-19098 Project: Flink Issue Type: Improvement

[jira] [Comment Edited] (FLINK-18641) "Failure to finalize checkpoint" error in MasterTriggerRestoreHook

[ https://issues.apache.org/jira/browse/FLINK-18641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17162428#comment-17162428 ] Brian Zhou edited comment on FLINK-18641 at 7/22/20, 7:16 AM: -- Thanks

[jira] [Commented] (FLINK-18641) "Failure to finalize checkpoint" error in MasterTriggerRestoreHook

[ https://issues.apache.org/jira/browse/FLINK-18641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17162428#comment-17162428 ] Brian Zhou commented on FLINK-18641: Thanks Jiangjie for looking into this. I noticed the vote for

[jira] [Updated] (FLINK-18641) "Failure to finalize checkpoint" error in MasterTriggerRestoreHook

[ https://issues.apache.org/jira/browse/FLINK-18641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Zhou updated FLINK-18641: --- Description: https://github.com/pravega/flink-connectors is a Pravega connector for Flink. The

[jira] [Created] (FLINK-18641) "Failure to finalize checkpoint" error in MasterTriggerRestoreHook

Brian Zhou created FLINK-18641: -- Summary: "Failure to finalize checkpoint" error in MasterTriggerRestoreHook Key: FLINK-18641 URL: https://issues.apache.org/jira/browse/FLINK-18641 Project: Flink