[jira] [Reopened] (FLINK-35471) Kubernetes operator bumps the flink version to 1.19

[ https://issues.apache.org/jira/browse/FLINK-35471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reopened FLINK-35471: - > Kubernetes operator bumps the flink version to 1.19 > ---

[jira] [Closed] (FLINK-35471) Kubernetes operator bumps the flink version to 1.19

[ https://issues.apache.org/jira/browse/FLINK-35471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-35471. --- Resolution: Won't Fix > Kubernetes operator bumps the flink version to 1.19 > --

[jira] [Commented] (FLINK-35662) Use maven batch mode in k8s-operator CI

[ https://issues.apache.org/jira/browse/FLINK-35662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17859622#comment-17859622 ] Rui Fan commented on FLINK-35662: - Merged to main(1.10.0) via 2b78ea315cd6ea261cb92ffab8

[jira] [Resolved] (FLINK-35662) Use maven batch mode in k8s-operator CI

[ https://issues.apache.org/jira/browse/FLINK-35662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35662. - Assignee: Ferenc Csaky Resolution: Fixed > Use maven batch mode in k8s-operator CI > -

[jira] [Assigned] (FLINK-35542) ClassNotFoundException when deserializing CheckpointedOffset

[ https://issues.apache.org/jira/browse/FLINK-35542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35542: --- Assignee: Jan Gurda > ClassNotFoundException when deserializing CheckpointedOffset > --

[jira] [Updated] (FLINK-34079) FLIP-405: Migrate string configuration key to ConfigOption

[ https://issues.apache.org/jira/browse/FLINK-34079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34079: Fix Version/s: 2.0.0 (was: 1.20.0) > FLIP-405: Migrate string configuration key to

[jira] [Commented] (FLINK-35542) ClassNotFoundException when deserializing CheckpointedOffset

[ https://issues.apache.org/jira/browse/FLINK-35542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861049#comment-17861049 ] Rui Fan commented on FLINK-35542: - Merged to 3.3.0 via 90d69c7f2b8e4ccde7f1b39376e3bd0c5

[jira] [Resolved] (FLINK-35542) ClassNotFoundException when deserializing CheckpointedOffset

[ https://issues.apache.org/jira/browse/FLINK-35542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35542. - Resolution: Fixed > ClassNotFoundException when deserializing CheckpointedOffset > -

[jira] [Assigned] (FLINK-35663) Release Testing: FLIP-436: Introduce Catalog-related Syntax

[ https://issues.apache.org/jira/browse/FLINK-35663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35663: --- Assignee: Ferenc Csaky > Release Testing: FLIP-436: Introduce Catalog-related Syntax >

[jira] [Commented] (FLINK-35663) Release Testing: FLIP-436: Introduce Catalog-related Syntax

[ https://issues.apache.org/jira/browse/FLINK-35663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861052#comment-17861052 ] Rui Fan commented on FLINK-35663: - Thanks [~ferenc-csaky] for the volunteering, I have a

[jira] [Commented] (FLINK-35611) Release Testing Instructions: Verify [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunction

[ https://issues.apache.org/jira/browse/FLINK-35611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861054#comment-17861054 ] Rui Fan commented on FLINK-35611: - Hi [~martijnvisser] , could you please confirm whethe

[jira] [Assigned] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35624: --- Assignee: Rui Fan > Release Testing: Verify FLIP-306 Unified File Merging Mechanism for > Checkpoi

[jira] [Commented] (FLINK-35690) Release Testing: Verify FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

[ https://issues.apache.org/jira/browse/FLINK-35690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861058#comment-17861058 ] Rui Fan commented on FLINK-35690: - Hi [~tanyuxin] [~chalixar] , I see that both of you h

[jira] [Assigned] (FLINK-35678) [Release-1.20] Review and update documentation

[ https://issues.apache.org/jira/browse/FLINK-35678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35678: --- Assignee: Rui Fan > [Release-1.20] Review and update documentation > --

[jira] [Assigned] (FLINK-35679) [Release-1.20] Cross team testing

[ https://issues.apache.org/jira/browse/FLINK-35679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35679: --- Assignee: Rui Fan > [Release-1.20] Cross team testing > - > >

[jira] [Commented] (FLINK-35608) Release Testing Instructions: Verify FLIP-376: Add DISTRIBUTED BY clause

[ https://issues.apache.org/jira/browse/FLINK-35608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861291#comment-17861291 ] Rui Fan commented on FLINK-35608: - Hi [~jhughes] , thanks for your feedback! If this Ji

[jira] [Closed] (FLINK-35608) Release Testing Instructions: Verify FLIP-376: Add DISTRIBUTED BY clause

[ https://issues.apache.org/jira/browse/FLINK-35608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-35608. --- Resolution: Won't Fix > Release Testing Instructions: Verify FLIP-376: Add DISTRIBUTED BY clause > -

[jira] [Closed] (FLINK-35606) Release Testing Instructions: Verify FLINK-26050 Too many small sst files in rocksdb state backend when using time window created in ascending order

[ https://issues.apache.org/jira/browse/FLINK-35606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-35606. --- Resolution: Fixed > Release Testing Instructions: Verify FLINK-26050 Too many small sst files in > rocksdb

[jira] [Created] (FLINK-35738) Release Testing: Verify FLINK-26050 Too many small sst files in rocksdb state backend when using time window created in ascending order

Rui Fan created FLINK-35738: --- Summary: Release Testing: Verify FLINK-26050 Too many small sst files in rocksdb state backend when using time window created in ascending order Key: FLINK-35738 URL: https://issues.apache.

[jira] [Commented] (FLINK-35606) Release Testing Instructions: Verify FLINK-26050 Too many small sst files in rocksdb state backend when using time window created in ascending order

[ https://issues.apache.org/jira/browse/FLINK-35606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861328#comment-17861328 ] Rui Fan commented on FLINK-35606: - Created https://issues.apache.org/jira/browse/FLINK-3

[jira] [Commented] (FLINK-35733) Change org.jetbrains.annotations.NotNull to javax.annotation.Nonnull

[ https://issues.apache.org/jira/browse/FLINK-35733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862642#comment-17862642 ] Rui Fan commented on FLINK-35733: - Merged to 2.0.0 via: * 1db333158b8d0d338e4d116d39c65

[jira] [Resolved] (FLINK-35733) Change org.jetbrains.annotations.NotNull to javax.annotation.Nonnull

[ https://issues.apache.org/jira/browse/FLINK-35733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35733. - Fix Version/s: 2.0.0 Assignee: RocMarshal Resolution: Fixed > Change org.jetbrains.annot

[jira] [Assigned] (FLINK-35750) The latency marker metrics aren't updated after failover

[ https://issues.apache.org/jira/browse/FLINK-35750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35750: --- Assignee: RocMarshal > The latency marker metrics aren't updated after failover > -

[jira] [Resolved] (FLINK-35357) Add "kubernetes.operator.plugins.listeners" parameter description to the Operator configuration document

[ https://issues.apache.org/jira/browse/FLINK-35357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35357. - Fix Version/s: kubernetes-operator-1.10.0 Resolution: Fixed > Add "kubernetes.operator.plugins.li

[jira] [Commented] (FLINK-35357) Add "kubernetes.operator.plugins.listeners" parameter description to the Operator configuration document

[ https://issues.apache.org/jira/browse/FLINK-35357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862931#comment-17862931 ] Rui Fan commented on FLINK-35357: - Merged to main(1.10.0) via ffaa3dd8d4f03d98c01d938c73

[jira] [Created] (FLINK-35761) Speed up the restore process of unaligned checkpoint

Rui Fan created FLINK-35761: --- Summary: Speed up the restore process of unaligned checkpoint Key: FLINK-35761 URL: https://issues.apache.org/jira/browse/FLINK-35761 Project: Flink Issue Type: Improv

[jira] [Updated] (FLINK-35761) Speed up the restore process of unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-35761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35761: Description: Currently, the task will transition state from ExecutionState.INITIALIZING to ExecutionState

[jira] [Updated] (FLINK-35761) Speed up the restore process of unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-35761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35761: Description: Currently, the task will transition state from ExecutionState.INITIALIZING to ExecutionState

[jira] [Updated] (FLINK-35761) Speed up the restore process of unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-35761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35761: Description: Currently, the task will transition state from ExecutionState.INITIALIZING to ExecutionState

[jira] [Updated] (FLINK-35761) Speed up the restore process of unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-35761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35761: Description: Currently, the task will transition state from ExecutionState.INITIALIZING to ExecutionState

[jira] [Updated] (FLINK-35761) Speed up the restore process of unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-35761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35761: Description: Currently, the task will transition state from ExecutionState.INITIALIZING to ExecutionState

[jira] [Updated] (FLINK-35761) Speed up the restore process of unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-35761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35761: Description: Currently, the task will transition state from ExecutionState.INITIALIZING to ExecutionState

[jira] [Updated] (FLINK-35761) Speed up the restore process of unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-35761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35761: Description: Currently, the task will transition state from ExecutionState.INITIALIZING to ExecutionState

[jira] [Assigned] (FLINK-35765) Support Fine Grained Resource Specifications for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-35765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35765: --- Assignee: RocMarshal > Support Fine Grained Resource Specifications for Adaptive Scheduler > --

[jira] [Resolved] (FLINK-34130) Mark setBytes and getBytes of Configuration as @Internal in Flink 2.0

[ https://issues.apache.org/jira/browse/FLINK-34130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34130. - Resolution: Fixed > Mark setBytes and getBytes of Configuration as @Internal in Flink 2.0 > ---

[jira] [Commented] (FLINK-34130) Mark setBytes and getBytes of Configuration as @Internal in Flink 2.0

[ https://issues.apache.org/jira/browse/FLINK-34130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863427#comment-17863427 ] Rui Fan commented on FLINK-34130: - Merged to master(2.0.0) via: 7bc7ebdb6322d641680d5ebf

[jira] [Commented] (FLINK-35750) The latency marker metrics aren't updated after failover

[ https://issues.apache.org/jira/browse/FLINK-35750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863428#comment-17863428 ] Rui Fan commented on FLINK-35750: - Merged to master(2.0.0) via: 615d19735b0691b57262a110

[jira] [Commented] (FLINK-35750) The latency marker metrics aren't updated after failover

[ https://issues.apache.org/jira/browse/FLINK-35750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863429#comment-17863429 ] Rui Fan commented on FLINK-35750: - Hi [~RocMarshal] , would you mind backporting this fi

[jira] [Updated] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35624: Attachment: image-2024-07-07-14-04-47-065.png > Release Testing: Verify FLIP-306 Unified File Merging Mech

[jira] [Commented] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863540#comment-17863540 ] Rui Fan commented on FLINK-35624: - It seems file merging doesn't work. I'm not sure whet

[jira] [Commented] (FLINK-35345) FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table

[ https://issues.apache.org/jira/browse/FLINK-35345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863643#comment-17863643 ] Rui Fan commented on FLINK-35345: - Hi [~lsy] [~hackergin] , I saw FLINK-35187 has the re

[jira] [Commented] (FLINK-35345) FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table

[ https://issues.apache.org/jira/browse/FLINK-35345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863645#comment-17863645 ] Rui Fan commented on FLINK-35345: - thanks [~hackergin] for the quick feedback! :) > FLI

[jira] [Commented] (FLINK-35533) FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

[ https://issues.apache.org/jira/browse/FLINK-35533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863648#comment-17863648 ] Rui Fan commented on FLINK-35533: - Hi [~tanyuxin] [~Weijie Guo] , may I know do we need

[jira] [Updated] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35624: Attachment: image-2024-07-08-17-05-40-546.png > Release Testing: Verify FLIP-306 Unified File Merging Mech

[jira] [Commented] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863717#comment-17863717 ] Rui Fan commented on FLINK-35624: - In brief, I found one unexpected behavior: all merged

[jira] [Comment Edited] (FLINK-35750) The latency marker metrics aren't updated after failover

[ https://issues.apache.org/jira/browse/FLINK-35750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863428#comment-17863428 ] Rui Fan edited comment on FLINK-35750 at 7/8/24 9:48 AM: - Merged

[jira] [Commented] (FLINK-35784) The cp file-merging directory not properly registered in SharedStateRegistry

[ https://issues.apache.org/jira/browse/FLINK-35784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864457#comment-17864457 ] Rui Fan commented on FLINK-35784: - [https://github.com/apache/flink/actions/runs/9857042

[jira] [Comment Edited] (FLINK-35784) The cp file-merging directory not properly registered in SharedStateRegistry

[ https://issues.apache.org/jira/browse/FLINK-35784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864457#comment-17864457 ] Rui Fan edited comment on FLINK-35784 at 7/10/24 3:40 AM: -- http

[jira] [Commented] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864459#comment-17864459 ] Rui Fan commented on FLINK-35624: - Hi [~zakelly] , I saw FLINK-35778 and FLINK-35784 are

[jira] [Comment Edited] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864459#comment-17864459 ] Rui Fan edited comment on FLINK-35624 at 7/10/24 4:00 AM: -- Hi [

[jira] [Commented] (FLINK-33730) Update the compatibility table to only include last three released versions

[ https://issues.apache.org/jira/browse/FLINK-33730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864466#comment-17864466 ] Rui Fan commented on FLINK-33730: - [https://github.com/apache/flink/pull/23859] only upd

[jira] [Commented] (FLINK-33730) Update the compatibility table to only include last three released versions

[ https://issues.apache.org/jira/browse/FLINK-33730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864467#comment-17864467 ] Rui Fan commented on FLINK-33730: - Merged to master(1.19) via: a2cf8fca7b229dcfd49d0b2c2

[jira] [Commented] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864472#comment-17864472 ] Rui Fan commented on FLINK-35624: - Thanks for the quikc feedback! Looking forward to you

[jira] [Created] (FLINK-35803) ResumeCheckpointManuallyITCase fails with checkpoint file merging

Rui Fan created FLINK-35803: --- Summary: ResumeCheckpointManuallyITCase fails with checkpoint file merging Key: FLINK-35803 URL: https://issues.apache.org/jira/browse/FLINK-35803 Project: Flink Issu

[jira] [Commented] (FLINK-35803) ResumeCheckpointManuallyITCase fails with checkpoint file merging

[ https://issues.apache.org/jira/browse/FLINK-35803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864555#comment-17864555 ] Rui Fan commented on FLINK-35803: - Hi [~Zakelly] , I'm not sure whether the file is dele

[jira] [Updated] (FLINK-35803) ResumeCheckpointManuallyITCase fails with checkpoint file merging

[ https://issues.apache.org/jira/browse/FLINK-35803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35803: Attachment: image-2024-07-10-17-19-00-916.png > ResumeCheckpointManuallyITCase fails with checkpoint file

[jira] [Commented] (FLINK-35803) ResumeCheckpointManuallyITCase fails with checkpoint file merging

[ https://issues.apache.org/jira/browse/FLINK-35803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864565#comment-17864565 ] Rui Fan commented on FLINK-35803: - I'm very sure this CI failure isn't caused by CI unst

[jira] [Updated] (FLINK-35803) ResumeCheckpointManuallyITCase fails with checkpoint file merging

[ https://issues.apache.org/jira/browse/FLINK-35803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35803: Priority: Blocker (was: Major) > ResumeCheckpointManuallyITCase fails with checkpoint file merging >

[jira] [Updated] (FLINK-35803) ResumeCheckpointManuallyITCase fails with checkpoint file merging

[ https://issues.apache.org/jira/browse/FLINK-35803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35803: Affects Version/s: 1.20.0 > ResumeCheckpointManuallyITCase fails with checkpoint file merging > --

[jira] [Commented] (FLINK-35803) ResumeCheckpointManuallyITCase fails with checkpoint file merging

[ https://issues.apache.org/jira/browse/FLINK-35803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864571#comment-17864571 ] Rui Fan commented on FLINK-35803: - Hi [~zakelly] , I wanna provide more information to h

[jira] [Comment Edited] (FLINK-33730) Update the compatibility table to only include last three released versions

[ https://issues.apache.org/jira/browse/FLINK-33730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864467#comment-17864467 ] Rui Fan edited comment on FLINK-33730 at 7/10/24 12:15 PM: --- Me

[jira] [Comment Edited] (FLINK-33730) Update the compatibility table to only include last three released versions

[ https://issues.apache.org/jira/browse/FLINK-33730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864467#comment-17864467 ] Rui Fan edited comment on FLINK-33730 at 7/10/24 12:16 PM: --- Me

[jira] [Updated] (FLINK-33730) Update the compatibility table to only include last three released versions

[ https://issues.apache.org/jira/browse/FLINK-33730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33730: Fix Version/s: 2.0.0 1.20.0 1.19.2 > Update the compatibility table

[jira] [Assigned] (FLINK-20628) Port RabbitMQ Sources to FLIP-27 API

[ https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-20628: --- Assignee: (was: RocMarshal) > Port RabbitMQ Sources to FLIP-27 API > --

[jira] [Created] (FLINK-35810) AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry fails

Rui Fan created FLINK-35810: --- Summary: AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry fails Key: FLINK-35810 URL: https://issues.apache.org/jira/browse/FLINK-35810 Project: Flink

[jira] [Commented] (FLINK-35004) SqlGatewayE2ECase could not start container

[ https://issues.apache.org/jira/browse/FLINK-35004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864922#comment-17864922 ] Rui Fan commented on FLINK-35004: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Created] (FLINK-35814) Don't scale up continuously when the throughout cannot be increased after scaling up

Rui Fan created FLINK-35814: --- Summary: Don't scale up continuously when the throughout cannot be increased after scaling up Key: FLINK-35814 URL: https://issues.apache.org/jira/browse/FLINK-35814 Project: F

[jira] [Commented] (FLINK-35814) Don't scale up continuously when the throughout cannot be increased after scaling up

[ https://issues.apache.org/jira/browse/FLINK-35814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865034#comment-17865034 ] Rui Fan commented on FLINK-35814: - Thanks [~gyfora]  for the reminder! Sorry, I didn't

[jira] [Commented] (FLINK-21436) Speed ​​up the restore of UnionListState

[ https://issues.apache.org/jira/browse/FLINK-21436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865277#comment-17865277 ] Rui Fan commented on FLINK-21436: - > When does Union State plan to deprecated? I didn't

[jira] [Closed] (FLINK-35823) Introduce parameters to control the upper limit of rescale to avoid unlimited expansion due to server-side bottlenecks or data skew.

[ https://issues.apache.org/jira/browse/FLINK-35823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-35823. --- Resolution: Fixed It's duplicated with https://issues.apache.org/jira/browse/FLINK-35814, so close this. >

[jira] [Updated] (FLINK-35823) Introduce parameters to control the upper limit of rescale to avoid unlimited expansion due to server-side bottlenecks or data skew.

[ https://issues.apache.org/jira/browse/FLINK-35823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35823: Fix Version/s: (was: 2.0.0) > Introduce parameters to control the upper limit of rescale to avoid unli

[jira] [Resolved] (FLINK-35602) [Umbrella] Test Flink Release 1.20

[ https://issues.apache.org/jira/browse/FLINK-35602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35602. - Resolution: Fixed All subtask are done, thanks everyone for the test! Let me close this jira. > [Umbre

[jira] [Commented] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865343#comment-17865343 ] Rui Fan commented on FLINK-35624: - I re-tested it with the latest release-1.20 branch ba

[jira] [Resolved] (FLINK-35624) Release Testing: Verify FLIP-306 Unified File Merging Mechanism for Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-35624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35624. - Resolution: Fixed > Release Testing: Verify FLIP-306 Unified File Merging Mechanism for > Checkpoints >

[jira] [Comment Edited] (FLINK-33730) Update the compatibility table to only include last three released versions

[ https://issues.apache.org/jira/browse/FLINK-33730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864467#comment-17864467 ] Rui Fan edited comment on FLINK-33730 at 7/12/24 7:51 AM: -- Merg

[jira] [Resolved] (FLINK-33730) Update the compatibility table to only include last three released versions

[ https://issues.apache.org/jira/browse/FLINK-33730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33730. - Resolution: Fixed > Update the compatibility table to only include last three released versions > --

[jira] [Resolved] (FLINK-35750) The latency marker metrics aren't updated after failover

[ https://issues.apache.org/jira/browse/FLINK-35750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35750. - Resolution: Fixed > The latency marker metrics aren't updated after failover > -

[jira] [Comment Edited] (FLINK-35750) The latency marker metrics aren't updated after failover

[ https://issues.apache.org/jira/browse/FLINK-35750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863428#comment-17863428 ] Rui Fan edited comment on FLINK-35750 at 7/15/24 1:47 AM: -- Merg

[jira] [Assigned] (FLINK-35851) autoscaler standlone mode use `GlobalConfiguration.loadConfiguration` load config

[ https://issues.apache.org/jira/browse/FLINK-35851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35851: --- Assignee: yuanfenghu > autoscaler standlone mode use `GlobalConfiguration.loadConfiguration` load

[jira] [Commented] (FLINK-35851) autoscaler standlone mode use `GlobalConfiguration.loadConfiguration` load config

[ https://issues.apache.org/jira/browse/FLINK-35851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866603#comment-17866603 ] Rui Fan commented on FLINK-35851: - I load the config from main parameters for 2 reasons:

[jira] [Updated] (FLINK-35851) autoscaler standlone mode use `GlobalConfiguration.loadConfiguration` load config

[ https://issues.apache.org/jira/browse/FLINK-35851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35851: Fix Version/s: kubernetes-operator-1.10.0 > autoscaler standlone mode use `GlobalConfiguration.loadConfigu

[jira] [Resolved] (FLINK-35227) Remove execution-mode in ExecutionConfigInfo

[ https://issues.apache.org/jira/browse/FLINK-35227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35227. - Resolution: Fixed Merged to master(2.0.0) via: cef48545b54986dc9690bbf6b0b9193d53e798ed > Remove execut

[jira] [Assigned] (FLINK-22258) Adaptive Scheduler: Show history of rescales in the Web UI

[ https://issues.apache.org/jira/browse/FLINK-22258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-22258: --- Assignee: RocMarshal (was: Rui Fan) > Adaptive Scheduler: Show history of rescales in the Web UI >

[jira] [Commented] (FLINK-35814) Don't scale up continuously when the throughout cannot be increased after scaling up

[ https://issues.apache.org/jira/browse/FLINK-35814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867156#comment-17867156 ] Rui Fan commented on FLINK-35814: - Thanks for the feedback! I know that in some scenari

[jira] [Commented] (FLINK-32818) Support region failover for adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-32818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867158#comment-17867158 ] Rui Fan commented on FLINK-32818: - Sorry, I and my colleagues don't have capacity to wor

[jira] [Assigned] (FLINK-32818) Support region failover for adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-32818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-32818: --- Assignee: (was: Rui Fan) > Support region failover for adaptive scheduler > ---

[jira] [Comment Edited] (FLINK-32818) Support region failover for adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-32818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867158#comment-17867158 ] Rui Fan edited comment on FLINK-32818 at 7/19/24 2:43 AM: -- Sorr

[jira] [Resolved] (FLINK-35851) autoscaler standlone mode use `GlobalConfiguration.loadConfiguration` load config

[ https://issues.apache.org/jira/browse/FLINK-35851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35851. - Resolution: Fixed Merged to main(1.10.0) via: 29076c80eaac5547e3d12f703c43780cd4a52dad > autoscaler sta

[jira] [Assigned] (FLINK-33100) Implement YarnJobFetcher for Standalone Autoscaler

[ https://issues.apache.org/jira/browse/FLINK-33100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33100: --- Assignee: Samrat Deb (was: Rui Fan) > Implement YarnJobFetcher for Standalone Autoscaler > ---

[jira] [Assigned] (FLINK-33977) Adaptive scheduler may not minimize the number of TMs during downscaling

[ https://issues.apache.org/jira/browse/FLINK-33977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33977: --- Assignee: RocMarshal > Adaptive scheduler may not minimize the number of TMs during downscaling > -

[jira] [Commented] (FLINK-35835) SnapshotFileMergingCompatibilityITCase.testSwitchFromDisablingToEnablingFileMerging failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-35835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868218#comment-17868218 ] Rui Fan commented on FLINK-35835: - Hi [~zakelly] , this CI failure happens on master bra

[jira] [Commented] (FLINK-35896) eventHandler in RescaleApiScalingRealizer handle the event of scaling failure

[ https://issues.apache.org/jira/browse/FLINK-35896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868635#comment-17868635 ] Rui Fan commented on FLINK-35896: - RescaleApiScalingRealizer#realizeParallelismOverrides

[jira] [Assigned] (FLINK-35896) eventHandler in RescaleApiScalingRealizer handle the event of scaling failure

[ https://issues.apache.org/jira/browse/FLINK-35896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35896: --- Assignee: yuanfenghu > eventHandler in RescaleApiScalingRealizer handle the event of scaling failu

[jira] [Resolved] (FLINK-33874) Support resource request wait mechanism at DefaultDeclarativeSlotPool side for Default Scheduler

[ https://issues.apache.org/jira/browse/FLINK-33874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33874. - Fix Version/s: 2.0.0 Resolution: Fixed > Support resource request wait mechanism at DefaultDeclar

[jira] [Commented] (FLINK-33874) Support resource request wait mechanism at DefaultDeclarativeSlotPool side for Default Scheduler

[ https://issues.apache.org/jira/browse/FLINK-33874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868839#comment-17868839 ] Rui Fan commented on FLINK-33874: - Merged to master(2.0.0) via: * b1d78ed749bdd5f2e7325

[jira] [Commented] (FLINK-35903) Add CentralizedSlotAssigner support to adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-35903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868875#comment-17868875 ] Rui Fan commented on FLINK-35903: - I don't think extra SlotAssigner is needed. Instead,

[jira] [Commented] (FLINK-35370) Create a temp module to test backward compatibility

[ https://issues.apache.org/jira/browse/FLINK-35370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17869218#comment-17869218 ] Rui Fan commented on FLINK-35370: - Merged to main(3.3.0) via: 26655e5e8864511d20208ebf6d

[jira] [Updated] (FLINK-35370) Create a temp module to test backward compatibility

[ https://issues.apache.org/jira/browse/FLINK-35370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35370: Fix Version/s: jdbc-3.3.0 > Create a temp module to test backward compatibility >

[jira] [Resolved] (FLINK-35364) Create core module and move code

[ https://issues.apache.org/jira/browse/FLINK-35364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35364. - Fix Version/s: jdbc-3.3.0 Resolution: Fixed Merged to main(3.3.0) via: b5c030bb3910a356a219fa3c0f

[jira] [Resolved] (FLINK-35370) Create a temp module to test backward compatibility

[ https://issues.apache.org/jira/browse/FLINK-35370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35370. - Resolution: Fixed > Create a temp module to test backward compatibility > --

<    1   2   3   4   5   6   7   8   9   10   >