[jira] [Commented] (FLINK-24854) StateHandleSerializationTest unit test error

[ https://issues.apache.org/jira/browse/FLINK-24854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448255#comment-17448255 ] Stephan Ewen commented on FLINK-24854: -- Thanks for reporting this. It looks like [~

[jira] [Closed] (FLINK-24366) Unnecessary/misleading error message about failing restores when tasks are already canceled.

[ https://issues.apache.org/jira/browse/FLINK-24366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-24366. > Unnecessary/misleading error message about failing restores when tasks are > already canceled. > --

[jira] [Resolved] (FLINK-24366) Unnecessary/misleading error message about failing restores when tasks are already canceled.

[ https://issues.apache.org/jira/browse/FLINK-24366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-24366. -- Resolution: Fixed Fixed - 1.13.4 (release-1.13) via a72bd1c5cde8e5a0bc25c4d2c78d890aa660bb1c

[jira] [Closed] (FLINK-23842) Add log messages for reader registrations and split requests.

[ https://issues.apache.org/jira/browse/FLINK-23842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-23842. > Add log messages for reader registrations and split requests. >

[jira] [Closed] (FLINK-24255) Test Environment / Mini Cluster do not forward configuration.

[ https://issues.apache.org/jira/browse/FLINK-24255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-24255. > Test Environment / Mini Cluster do not forward configuration. >

[jira] [Resolved] (FLINK-23842) Add log messages for reader registrations and split requests.

[ https://issues.apache.org/jira/browse/FLINK-23842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-23842. -- Resolution: Fixed Fixed - 1.13.4 (release-1.13) via a3a776d1264735d38b9f5d979a617d65e5c5069a

[jira] [Resolved] (FLINK-24255) Test Environment / Mini Cluster do not forward configuration.

[ https://issues.apache.org/jira/browse/FLINK-24255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-24255. -- Fix Version/s: 1.13.4 Resolution: Fixed Fixed - 1.13.4 (release-1.13) via 20323e32ac0

[jira] [Updated] (FLINK-23842) Add log messages for reader registrations and split requests.

[ https://issues.apache.org/jira/browse/FLINK-23842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-23842: - Labels: pull-request-available (was: pull-request-available stale-assigned) > Add log messages

[jira] [Updated] (FLINK-24255) Test Environment / Mini Cluster do not forward configuration.

[ https://issues.apache.org/jira/browse/FLINK-24255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-24255: - Labels: pull-request-available (was: pull-request-available stale-assigned) > Test Environment

[jira] (FLINK-24255) Test Environment / Mini Cluster do not forward configuration.

[ https://issues.apache.org/jira/browse/FLINK-24255 ] Stephan Ewen deleted comment on FLINK-24255: -- was (Author: flink-jira-bot): I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its developme

[jira] (FLINK-23842) Add log messages for reader registrations and split requests.

[ https://issues.apache.org/jira/browse/FLINK-23842 ] Stephan Ewen deleted comment on FLINK-23842: -- was (Author: flink-jira-bot): I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its developme

[jira] [Updated] (FLINK-23842) Add log messages for reader registrations and split requests.

[ https://issues.apache.org/jira/browse/FLINK-23842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-23842: - Fix Version/s: 1.14.1 1.13.4 > Add log messages for reader registrations and

[jira] (FLINK-17464) Stanalone HA Cluster crash with non-recoverable cluster state - need to wipe cluster to recover service

[ https://issues.apache.org/jira/browse/FLINK-17464 ] Stephan Ewen deleted comment on FLINK-17464: -- was (Author: flink-jira-bot): I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its developme

[jira] (FLINK-17464) Stanalone HA Cluster crash with non-recoverable cluster state - need to wipe cluster to recover service

[ https://issues.apache.org/jira/browse/FLINK-17464 ] Stephan Ewen deleted comment on FLINK-17464: -- was (Author: flink-jira-bot): This issue was labeled "stale-critical" 7 ago and has not received any updates so it is being deprioritized. If t

[jira] (FLINK-17464) Stanalone HA Cluster crash with non-recoverable cluster state - need to wipe cluster to recover service

[ https://issues.apache.org/jira/browse/FLINK-17464 ] Stephan Ewen deleted comment on FLINK-17464: -- was (Author: flink-jira-bot): This critical issue is unassigned and itself and all of its Sub-Tasks have not been updated for 7 days. So, it ha

[jira] (FLINK-17464) Stanalone HA Cluster crash with non-recoverable cluster state - need to wipe cluster to recover service

[ https://issues.apache.org/jira/browse/FLINK-17464 ] Stephan Ewen deleted comment on FLINK-17464: -- was (Author: flink-jira-bot): This issue was labeled "stale-major" 7 days ago and has not received any updates so it is being deprioritized. If

[jira] (FLINK-17464) Stanalone HA Cluster crash with non-recoverable cluster state - need to wipe cluster to recover service

[ https://issues.apache.org/jira/browse/FLINK-17464 ] Stephan Ewen deleted comment on FLINK-17464: -- was (Author: flink-jira-bot): I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its developme

[jira] [Commented] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444601#comment-17444601 ] Stephan Ewen commented on FLINK-20188: -- Hi! I started writing/outlining some docum

[jira] (FLINK-17723) Written design for flink threading model and guarantees made to the various structual components

[ https://issues.apache.org/jira/browse/FLINK-17723 ] Stephan Ewen deleted comment on FLINK-17723: -- was (Author: flink-jira-bot): I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its developme

[jira] (FLINK-18357) ContinuousFileReaderOperator checkpoint timeout when files and directories get larger

[ https://issues.apache.org/jira/browse/FLINK-18357 ] Stephan Ewen deleted comment on FLINK-18357: -- was (Author: flink-jira-bot): This major issue is unassigned and itself and all of its Sub-Tasks have not been updated for 30 days. So, it has

[jira] [Updated] (FLINK-18357) ContinuousFileReaderOperator checkpoint timeout when files and directories get larger

[ https://issues.apache.org/jira/browse/FLINK-18357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-18357: - Labels: (was: auto-deprioritized-major auto-deprioritized-minor) > ContinuousFileReaderOperato

[jira] (FLINK-18357) ContinuousFileReaderOperator checkpoint timeout when files and directories get larger

[ https://issues.apache.org/jira/browse/FLINK-18357 ] Stephan Ewen deleted comment on FLINK-18357: -- was (Author: flink-jira-bot): This issue was labeled "stale-minor" 7 days ago and has not received any updates so it is being deprioritized. If

[jira] (FLINK-18357) ContinuousFileReaderOperator checkpoint timeout when files and directories get larger

[ https://issues.apache.org/jira/browse/FLINK-18357 ] Stephan Ewen deleted comment on FLINK-18357: -- was (Author: flink-jira-bot): I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its developme

[jira] (FLINK-18357) ContinuousFileReaderOperator checkpoint timeout when files and directories get larger

[ https://issues.apache.org/jira/browse/FLINK-18357 ] Stephan Ewen deleted comment on FLINK-18357: -- was (Author: flink-jira-bot): This issue was labeled "stale-major" 7 ago and has not received any updates so it is being deprioritized. If this

[jira] (FLINK-17723) Written design for flink threading model and guarantees made to the various structual components

[ https://issues.apache.org/jira/browse/FLINK-17723 ] Stephan Ewen deleted comment on FLINK-17723: -- was (Author: flink-jira-bot): This major issue is unassigned and itself and all of its Sub-Tasks have not been updated for 30 days. So, it has

[jira] (FLINK-17723) Written design for flink threading model and guarantees made to the various structual components

[ https://issues.apache.org/jira/browse/FLINK-17723 ] Stephan Ewen deleted comment on FLINK-17723: -- was (Author: flink-jira-bot): This issue was labeled "stale-major" 7 ago and has not received any updates so it is being deprioritized. If this

[jira] [Resolved] (FLINK-17089) Checkpoint fail because RocksDBException: Error While opening a file for sequentially reading

[ https://issues.apache.org/jira/browse/FLINK-17089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-17089. -- Resolution: Cannot Reproduce > Checkpoint fail because RocksDBException: Error While opening a

[jira] (FLINK-17089) Checkpoint fail because RocksDBException: Error While opening a file for sequentially reading

[ https://issues.apache.org/jira/browse/FLINK-17089 ] Stephan Ewen deleted comment on FLINK-17089: -- was (Author: flink-jira-bot): I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its developme

[jira] (FLINK-17089) Checkpoint fail because RocksDBException: Error While opening a file for sequentially reading

[ https://issues.apache.org/jira/browse/FLINK-17089 ] Stephan Ewen deleted comment on FLINK-17089: -- was (Author: flink-jira-bot): This issue was labeled "stale-minor" 7 days ago and has not received any updates so it is being deprioritized. If

[jira] (FLINK-17089) Checkpoint fail because RocksDBException: Error While opening a file for sequentially reading

[ https://issues.apache.org/jira/browse/FLINK-17089 ] Stephan Ewen deleted comment on FLINK-17089: -- was (Author: flink-jira-bot): This issue was labeled "stale-major" 7 ago and has not received any updates so it is being deprioritized. If this

[jira] [Updated] (FLINK-17089) Checkpoint fail because RocksDBException: Error While opening a file for sequentially reading

[ https://issues.apache.org/jira/browse/FLINK-17089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-17089: - Labels: (was: auto-deprioritized-major auto-deprioritized-minor) > Checkpoint fail because Roc

[jira] (FLINK-17089) Checkpoint fail because RocksDBException: Error While opening a file for sequentially reading

[ https://issues.apache.org/jira/browse/FLINK-17089 ] Stephan Ewen deleted comment on FLINK-17089: -- was (Author: flink-jira-bot): This major issue is unassigned and itself and all of its Sub-Tasks have not been updated for 30 days. So, it has

[jira] [Commented] (FLINK-13598) frocksdb doesn't have arm release

[ https://issues.apache.org/jira/browse/FLINK-13598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444538#comment-17444538 ] Stephan Ewen commented on FLINK-13598: -- Is it mainly an issue that Mac M1 should no

[jira] [Commented] (FLINK-24852) Cleanup of Orphaned Incremental State Artifacts

[ https://issues.apache.org/jira/browse/FLINK-24852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1789#comment-1789 ] Stephan Ewen commented on FLINK-24852: -- Very good comments in general, thanks! (1)

[jira] [Commented] (FLINK-24852) Cleanup of Orphaned Incremental State Artifacts

[ https://issues.apache.org/jira/browse/FLINK-24852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441423#comment-17441423 ] Stephan Ewen commented on FLINK-24852: -- /cc [~yunta] and [~roman] > Cleanup of Orp

[jira] [Commented] (FLINK-24611) Prevent JM from discarding state on checkpoint abortion

[ https://issues.apache.org/jira/browse/FLINK-24611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441422#comment-17441422 ] Stephan Ewen commented on FLINK-24611: -- I created FLINK-24852 as a follow-up for th

[jira] [Created] (FLINK-24852) Cleanup of Orphaned Incremental State Artifacts

Stephan Ewen created FLINK-24852: Summary: Cleanup of Orphaned Incremental State Artifacts Key: FLINK-24852 URL: https://issues.apache.org/jira/browse/FLINK-24852 Project: Flink Issue Type: I

[jira] [Commented] (FLINK-24611) Prevent JM from discarding state on checkpoint abortion

[ https://issues.apache.org/jira/browse/FLINK-24611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441281#comment-17441281 ] Stephan Ewen commented on FLINK-24611: -- Good points that you brought up. *Regardin

[jira] [Commented] (FLINK-24611) Prevent JM from discarding state on checkpoint abortion

[ https://issues.apache.org/jira/browse/FLINK-24611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1743#comment-1743 ] Stephan Ewen commented on FLINK-24611: -- I would be curious to learn your ideas on h

[jira] [Comment Edited] (FLINK-24611) Prevent JM from discarding state on checkpoint abortion

[ https://issues.apache.org/jira/browse/FLINK-24611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435505#comment-17435505 ] Stephan Ewen edited comment on FLINK-24611 at 10/28/21, 3:59 PM: -

[jira] [Comment Edited] (FLINK-24611) Prevent JM from discarding state on checkpoint abortion

[ https://issues.apache.org/jira/browse/FLINK-24611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435505#comment-17435505 ] Stephan Ewen edited comment on FLINK-24611 at 10/28/21, 3:59 PM: -

[jira] [Comment Edited] (FLINK-24611) Prevent JM from discarding state on checkpoint abortion

[ https://issues.apache.org/jira/browse/FLINK-24611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435505#comment-17435505 ] Stephan Ewen edited comment on FLINK-24611 at 10/28/21, 3:58 PM: -

[jira] [Commented] (FLINK-24611) Prevent JM from discarding state on checkpoint abortion

[ https://issues.apache.org/jira/browse/FLINK-24611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435505#comment-17435505 ] Stephan Ewen commented on FLINK-24611: -- +1 to the general idea of changing the stat

[jira] [Created] (FLINK-24366) Unnecessary/misleading error message about failing restores when tasks are already canceled.

Stephan Ewen created FLINK-24366: Summary: Unnecessary/misleading error message about failing restores when tasks are already canceled. Key: FLINK-24366 URL: https://issues.apache.org/jira/browse/FLINK-24366

[jira] [Commented] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17419284#comment-17419284 ] Stephan Ewen commented on FLINK-20188: -- Hey ZhuoYu Chen! Sure, you can help with t

[jira] [Updated] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-20188: - Labels: (was: auto-deprioritized-critical auto-unassigned) > Add Documentation for new File So

[jira] [Issue Comment Deleted] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-20188: - Comment: was deleted (was: This issue is assigned but has not received an update in 7 days so it

[jira] [Issue Comment Deleted] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-20188: - Comment: was deleted (was: I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] a

[jira] [Issue Comment Deleted] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-20188: - Comment: was deleted (was: This issue was marked "stale-assigned" 7 ago and has not received an

[jira] [Issue Comment Deleted] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-20188: - Comment: was deleted (was: This issue was labeled "stale-critical" 7 ago and has not received an

[jira] [Closed] (FLINK-24347) KafkaSource cannot checkpoint if the parallelism is higher than the partition number

[ https://issues.apache.org/jira/browse/FLINK-24347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-24347. > KafkaSource cannot checkpoint if the parallelism is higher than the partition > number > --

[jira] [Resolved] (FLINK-24347) KafkaSource cannot checkpoint if the parallelism is higher than the partition number

[ https://issues.apache.org/jira/browse/FLINK-24347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-24347. -- Fix Version/s: 1.13.3 1.14.0 Resolution: Fixed Fixed in - master v

[jira] [Commented] (FLINK-24303) SourceCoordinator exception may fail Session Cluster

[ https://issues.apache.org/jira/browse/FLINK-24303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418021#comment-17418021 ] Stephan Ewen commented on FLINK-24303: -- This issue here tracks a potentially differ

[jira] [Closed] (FLINK-24303) SourceCoordinator exception may fail Session Cluster

[ https://issues.apache.org/jira/browse/FLINK-24303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-24303. > SourceCoordinator exception may fail Session Cluster > -

[jira] [Resolved] (FLINK-24303) SourceCoordinator exception may fail Session Cluster

[ https://issues.apache.org/jira/browse/FLINK-24303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-24303. -- Fix Version/s: (was: 1.14.0) 1.14.1 1.15.0

[jira] [Created] (FLINK-24343) Revisit Scheduler and Coordinator Startup Procedure

Stephan Ewen created FLINK-24343: Summary: Revisit Scheduler and Coordinator Startup Procedure Key: FLINK-24343 URL: https://issues.apache.org/jira/browse/FLINK-24343 Project: Flink Issue Typ

[jira] [Commented] (FLINK-24303) SourceCoordinator exception may fail Session Cluster

[ https://issues.apache.org/jira/browse/FLINK-24303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417603#comment-17417603 ] Stephan Ewen commented on FLINK-24303: -- In the longer term, I would like to change

[jira] [Commented] (FLINK-24303) SourceCoordinator exception may fail Session Cluster

[ https://issues.apache.org/jira/browse/FLINK-24303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417578#comment-17417578 ] Stephan Ewen commented on FLINK-24303: -- The issue is relatively easy to fix on the

[jira] [Comment Edited] (FLINK-24303) SourceCoordinator exception may fail Session Cluster

[ https://issues.apache.org/jira/browse/FLINK-24303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417578#comment-17417578 ] Stephan Ewen edited comment on FLINK-24303 at 9/20/21, 11:01 AM: -

[jira] [Assigned] (FLINK-24303) SourceCoordinator exception may fail Session Cluster

[ https://issues.apache.org/jira/browse/FLINK-24303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-24303: Assignee: Stephan Ewen > SourceCoordinator exception may fail Session Cluster > -

[jira] [Updated] (FLINK-24303) SourceCoordinator exception may fail Session Cluster

[ https://issues.apache.org/jira/browse/FLINK-24303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-24303: - Fix Version/s: 1.14.0 > SourceCoordinator exception may fail Session Cluster > -

[jira] [Updated] (FLINK-24303) SourceCoordinator exception may fail Session Cluster

[ https://issues.apache.org/jira/browse/FLINK-24303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-24303: - Priority: Blocker (was: Major) > SourceCoordinator exception may fail Session Cluster > ---

[jira] [Created] (FLINK-24255) Test Environment / Mini Cluster do not forward configuration.

Stephan Ewen created FLINK-24255: Summary: Test Environment / Mini Cluster do not forward configuration. Key: FLINK-24255 URL: https://issues.apache.org/jira/browse/FLINK-24255 Project: Flink

[jira] [Resolved] (FLINK-22358) Add missing stability annotation to Split Reader API classes

[ https://issues.apache.org/jira/browse/FLINK-22358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-22358. -- Fix Version/s: (was: 1.13.3) Resolution: Fixed Fixed in - master (1.15.0) via c28

[jira] [Closed] (FLINK-22358) Add missing stability annotation to Split Reader API classes

[ https://issues.apache.org/jira/browse/FLINK-22358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-22358. > Add missing stability annotation to Split Reader API classes > -

[jira] [Commented] (FLINK-22358) Add missing stability annotation to Split Reader API classes

[ https://issues.apache.org/jira/browse/FLINK-22358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412653#comment-17412653 ] Stephan Ewen commented on FLINK-22358: -- [~vinaypatil18] Sorry I saw this too late.

[jira] [Issue Comment Deleted] (FLINK-22358) Add missing stability annotation to Split Reader API classes

[ https://issues.apache.org/jira/browse/FLINK-22358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-22358: - Comment: was deleted (was: I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] a

[jira] [Issue Comment Deleted] (FLINK-22358) Add missing stability annotation to Split Reader API classes

[ https://issues.apache.org/jira/browse/FLINK-22358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-22358: - Comment: was deleted (was: This issue was marked "stale-assigned" 7 ago and has not received an

[jira] [Issue Comment Deleted] (FLINK-22358) Add missing stability annotation to Split Reader API classes

[ https://issues.apache.org/jira/browse/FLINK-22358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-22358: - Comment: was deleted (was: I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] a

[jira] [Updated] (FLINK-22358) Add missing stability annotation to Split Reader API classes

[ https://issues.apache.org/jira/browse/FLINK-22358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-22358: - Labels: pull-request-available (was: auto-deprioritized-critical auto-unassigned pull-request-a

[jira] [Assigned] (FLINK-22358) Add missing stability annotation to Split Reader API classes

[ https://issues.apache.org/jira/browse/FLINK-22358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-22358: Assignee: Stephan Ewen > Add missing stability annotation to Split Reader API classes > -

[jira] [Closed] (FLINK-22357) Mark FLIP-27 Source API as stable

[ https://issues.apache.org/jira/browse/FLINK-22357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-22357. > Mark FLIP-27 Source API as stable > - > > Key: FLINK

[jira] [Issue Comment Deleted] (FLINK-22358) Add missing stability annotation to Split Reader API classes

[ https://issues.apache.org/jira/browse/FLINK-22358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-22358: - Comment: was deleted (was: This issue was labeled "stale-critical" 7 ago and has not received an

[jira] [Resolved] (FLINK-22357) Mark FLIP-27 Source API as stable

[ https://issues.apache.org/jira/browse/FLINK-22357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-22357. -- Resolution: Fixed Fixed in - master (1.15.0) via e4b000818c15b5b781c4e5262ba83bfc9d65121a

[jira] [Issue Comment Deleted] (FLINK-22357) Mark FLIP-27 Source API as stable

[ https://issues.apache.org/jira/browse/FLINK-22357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-22357: - Comment: was deleted (was: I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] a

[jira] [Issue Comment Deleted] (FLINK-22357) Mark FLIP-27 Source API as stable

[ https://issues.apache.org/jira/browse/FLINK-22357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-22357: - Comment: was deleted (was: I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] a

[jira] [Issue Comment Deleted] (FLINK-22357) Mark FLIP-27 Source API as stable

[ https://issues.apache.org/jira/browse/FLINK-22357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-22357: - Comment: was deleted (was: This issue was labeled "stale-major" 7 days ago and has not received

[jira] [Assigned] (FLINK-22357) Mark FLIP-27 Source API as stable

[ https://issues.apache.org/jira/browse/FLINK-22357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-22357: Assignee: Stephan Ewen > Mark FLIP-27 Source API as stable >

[jira] [Issue Comment Deleted] (FLINK-22357) Mark FLIP-27 Source API as stable

[ https://issues.apache.org/jira/browse/FLINK-22357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-22357: - Comment: was deleted (was: This issue was marked "stale-assigned" 7 ago and has not received an

[jira] [Updated] (FLINK-22357) Mark FLIP-27 Source API as stable

[ https://issues.apache.org/jira/browse/FLINK-22357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-22357: - Labels: (was: auto-deprioritized-major auto-unassigned) > Mark FLIP-27 Source API as stable >

[jira] [Comment Edited] (FLINK-23527) Clarify `SourceFunction#cancel()` contract about interrupting

[ https://issues.apache.org/jira/browse/FLINK-23527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411305#comment-17411305 ] Stephan Ewen edited comment on FLINK-23527 at 9/9/21, 3:44 PM: ---

[jira] [Closed] (FLINK-23527) Clarify `SourceFunction#cancel()` contract about interrupting

[ https://issues.apache.org/jira/browse/FLINK-23527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-23527. > Clarify `SourceFunction#cancel()` contract about interrupting >

[jira] [Resolved] (FLINK-23527) Clarify `SourceFunction#cancel()` contract about interrupting

[ https://issues.apache.org/jira/browse/FLINK-23527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-23527. -- Resolution: Fixed Fixed in - 1.14.0 via 9136c4030baba575cfcccef5558a9f2b079bdc23 - 1.13.3

[jira] [Updated] (FLINK-23527) Clarify `SourceFunction#cancel()` contract about interrupting

[ https://issues.apache.org/jira/browse/FLINK-23527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-23527: - Fix Version/s: 1.13.3 > Clarify `SourceFunction#cancel()` contract about interrupting >

[jira] [Comment Edited] (FLINK-23906) Increase akka.ask.timeout for tests using the MiniCluster

[ https://issues.apache.org/jira/browse/FLINK-23906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404610#comment-17404610 ] Stephan Ewen edited comment on FLINK-23906 at 8/25/21, 5:07 PM: --

[jira] [Commented] (FLINK-23906) Increase akka.ask.timeout for tests using the MiniCluster

[ https://issues.apache.org/jira/browse/FLINK-23906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404610#comment-17404610 ] Stephan Ewen commented on FLINK-23906: -- Small comment: I am wondering if this can b

[jira] [Comment Edited] (FLINK-13414) Add support for Scala 2.13

[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404608#comment-17404608 ] Stephan Ewen edited comment on FLINK-13414 at 8/25/21, 5:06 PM: --

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404608#comment-17404608 ] Stephan Ewen commented on FLINK-13414: -- [~chesnay] "Isn't there still a somewhat hi

[jira] [Closed] (FLINK-22545) JVM crashes when runing OperatorEventSendingCheckpointITCase.testOperatorEventAckLost

[ https://issues.apache.org/jira/browse/FLINK-22545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-22545. > JVM crashes when runing > OperatorEventSendingCheckpointITCase.testOperatorEventAckLost > -

[jira] [Resolved] (FLINK-22545) JVM crashes when runing OperatorEventSendingCheckpointITCase.testOperatorEventAckLost

[ https://issues.apache.org/jira/browse/FLINK-22545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-22545. -- Fix Version/s: 1.12.6 Release Note: Fixed in 1.12.6 ({{release-1.12}}) via c22c3daa1ff661

[jira] [Commented] (FLINK-22545) JVM crashes when runing OperatorEventSendingCheckpointITCase.testOperatorEventAckLost

[ https://issues.apache.org/jira/browse/FLINK-22545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17404356#comment-17404356 ] Stephan Ewen commented on FLINK-22545: -- The cause seems to be the same. I am backpo

[jira] [Commented] (FLINK-20427) Remove CheckpointConfig.setPreferCheckpointForRecovery because it can lead to data loss

[ https://issues.apache.org/jira/browse/FLINK-20427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17403724#comment-17403724 ] Stephan Ewen commented on FLINK-20427: -- Here is the Mailing List Poll: https://lis

[jira] [Commented] (FLINK-20427) Remove CheckpointConfig.setPreferCheckpointForRecovery because it can lead to data loss

[ https://issues.apache.org/jira/browse/FLINK-20427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17403714#comment-17403714 ] Stephan Ewen commented on FLINK-20427: -- About the above-mentioned design doc for th

[jira] [Commented] (FLINK-13652) Setup instructions for creating an ARM environment

[ https://issues.apache.org/jira/browse/FLINK-13652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17403663#comment-17403663 ] Stephan Ewen commented on FLINK-13652: -- I am curious what would be in this document

[jira] [Commented] (FLINK-13448) Support ARM architecture

[ https://issues.apache.org/jira/browse/FLINK-13448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17403664#comment-17403664 ] Stephan Ewen commented on FLINK-13448: -- I think it would be nice to resolve this. M

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17403657#comment-17403657 ] Stephan Ewen commented on FLINK-13414: -- Just for context: The long-term plan for th

[jira] [Commented] (FLINK-23725) HadoopFsCommitter, file rename failure

[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17403647#comment-17403647 ] Stephan Ewen commented on FLINK-23725: -- Which of the above situations produced your

[jira] [Commented] (FLINK-20427) Remove CheckpointConfig.setPreferCheckpointForRecovery because it can lead to data loss

[ https://issues.apache.org/jira/browse/FLINK-20427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17403641#comment-17403641 ] Stephan Ewen commented on FLINK-20427: -- I'll start a poll on the mailing list to se

[jira] [Commented] (FLINK-22790) HybridSource end-to-end test

[ https://issues.apache.org/jira/browse/FLINK-22790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17403587#comment-17403587 ] Stephan Ewen commented on FLINK-22790: -- I tried the Hybrid Source for a combination

[jira] [Commented] (FLINK-23906) Increase akka.ask.timeout for tests using the MiniCluster

[ https://issues.apache.org/jira/browse/FLINK-23906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17403580#comment-17403580 ] Stephan Ewen commented on FLINK-23906: -- Is this only for CI, or for all Mini Cluste

  1   2   3   4   5   6   7   8   9   10   >