[jira] [Created] (FLINK-33042) Allow trigger flamegraph when task is initializing

Rui Fan created FLINK-33042: --- Summary: Allow trigger flamegraph when task is initializing Key: FLINK-33042 URL: https://issues.apache.org/jira/browse/FLINK-33042 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-32854) [JUnit5 Migration] The state package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-32854. - Fix Version/s: 1.19.0 Resolution: Fixed > [JUnit5 Migration] The state package of flink-runtime

[jira] [Commented] (FLINK-32854) [JUnit5 Migration] The state package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17763765#comment-17763765 ] Rui Fan commented on FLINK-32854: - Merged via 554810abbbd44a656a446d051b3dd199b0df9055 > [JUnit5

[jira] [Commented] (FLINK-32866) Unify the TestLoggerExtension config of junit5

[ https://issues.apache.org/jira/browse/FLINK-32866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758610#comment-17758610 ] Rui Fan commented on FLINK-32866: - Hi [~mapohl] , would you mind helping take a look this idea in your

[jira] [Commented] (FLINK-32858) [JUnit5 Migration] The util package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758612#comment-17758612 ] Rui Fan commented on FLINK-32858: - Merged <1.19, master> via 8e5bdd9405b15b21e209518e3c5881984bd16ce9 >

[jira] [Resolved] (FLINK-32858) [JUnit5 Migration] The util package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-32858. - Fix Version/s: 1.19.0 Resolution: Fixed > [JUnit5 Migration] The util package of flink-runtime

[jira] [Commented] (FLINK-20681) Support specifying the hdfs path when ship archives or files

[ https://issues.apache.org/jira/browse/FLINK-20681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760480#comment-17760480 ] Rui Fan commented on FLINK-20681: - Merged 2c50b4e956305426f478b726d4de4a640a16b810 > Support

[jira] [Resolved] (FLINK-20681) Support specifying the hdfs path when ship archives or files

[ https://issues.apache.org/jira/browse/FLINK-20681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-20681. - Fix Version/s: 1.19.0 Resolution: Fixed > Support specifying the hdfs path when ship archives

[jira] [Commented] (FLINK-33065) Optimize the exception message when the program plan could not be fetched

[ https://issues.apache.org/jira/browse/FLINK-33065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17764472#comment-17764472 ] Rui Fan commented on FLINK-33065: - Merged via d5b2cdb618cd7a50818d7eaa575c0fac6aaeac9a > Optimize the

[jira] [Resolved] (FLINK-33065) Optimize the exception message when the program plan could not be fetched

[ https://issues.apache.org/jira/browse/FLINK-33065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33065. - Fix Version/s: 1.19.0 Resolution: Fixed > Optimize the exception message when the program plan

[jira] [Commented] (FLINK-32895) Introduce the max attempts for Exponential Delay Restart Strategy

[ https://issues.apache.org/jira/browse/FLINK-32895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17763394#comment-17763394 ] Rui Fan commented on FLINK-32895: - Hi [~zhuzh] , I created the FLIP-364 in advance due to I found

[jira] [Resolved] (FLINK-33042) Allow trigger flamegraph when task is initializing

[ https://issues.apache.org/jira/browse/FLINK-33042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33042. - Fix Version/s: 1.19.0 Resolution: Fixed > Allow trigger flamegraph when task is initializing >

[jira] [Commented] (FLINK-33042) Allow trigger flamegraph when task is initializing

[ https://issues.apache.org/jira/browse/FLINK-33042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17763344#comment-17763344 ] Rui Fan commented on FLINK-33042: - Merged via 53702736382b80fa905494e69654061a84741e84 > Allow trigger

[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=17763391#comment-17763391 ] Rui Fan commented on FLINK-32818: - Hi, [~talat] , thanks for your interest in Adaptive Scheduler.  

[jira] [Updated] (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 updated FLINK-32818: Component/s: Runtime / Coordination > Support region failover for adaptive scheduler >

[jira] [Commented] (FLINK-32987) BlobClientSslTest>BlobClientTest.testSocketTimeout expected SocketTimeoutException but identified SSLException

[ https://issues.apache.org/jira/browse/FLINK-32987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760758#comment-17760758 ] Rui Fan commented on FLINK-32987: - Thanks [~mapohl]  for the report and [~ferenc-csaky]  for this fix.  

[jira] [Resolved] (FLINK-32987) BlobClientSslTest>BlobClientTest.testSocketTimeout expected SocketTimeoutException but identified SSLException

[ https://issues.apache.org/jira/browse/FLINK-32987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-32987. - Fix Version/s: 1.19.0 Resolution: Fixed > BlobClientSslTest>BlobClientTest.testSocketTimeout

[jira] [Created] (FLINK-33092) Improve the resource-stabilization-timeout mechanism when rescale a job for Adaptive Scheduler

Rui Fan created FLINK-33092: --- Summary: Improve the resource-stabilization-timeout mechanism when rescale a job for Adaptive Scheduler Key: FLINK-33092 URL: https://issues.apache.org/jira/browse/FLINK-33092

[jira] [Updated] (FLINK-33092) Improve the resource-stabilization-timeout mechanism when rescale a job for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-33092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33092: Description: !image-2023-09-15-14-43-35-104.png|width=1103,height=779! h1. 1. Propose The above is the

[jira] [Updated] (FLINK-33092) Improve the resource-stabilization-timeout mechanism when rescale a job for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-33092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33092: Description: !image-2023-09-15-14-43-35-104.png|width=916,height=647! h1. 1. Propose The above is the

[jira] [Commented] (FLINK-33092) Improve the resource-stabilization-timeout mechanism when rescale a job for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-33092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17765483#comment-17765483 ] Rui Fan commented on FLINK-33092: - Hi [~chesnay]  [~dmvk] , would you mind helping take a look this

[jira] [Created] (FLINK-33065) Optimize the exception message when the program plan could not be fetched

Rui Fan created FLINK-33065: --- Summary: Optimize the exception message when the program plan could not be fetched Key: FLINK-33065 URL: https://issues.apache.org/jira/browse/FLINK-33065 Project: Flink

[jira] [Created] (FLINK-33287) Using the flink shaded jackson for flink-autoscaler

Rui Fan created FLINK-33287: --- Summary: Using the flink shaded jackson for flink-autoscaler Key: FLINK-33287 URL: https://issues.apache.org/jira/browse/FLINK-33287 Project: Flink Issue Type:

[jira] [Commented] (FLINK-33097) Initialize the generic autoscaler module and interfaces

[ https://issues.apache.org/jira/browse/FLINK-33097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776248#comment-17776248 ] Rui Fan commented on FLINK-33097: - Merged main via 5c76d01c79a91a255b40e0f08d384d7b0326bea3 >

[jira] [Commented] (FLINK-33098) Support kubernetes autoscaler using generic interface

[ https://issues.apache.org/jira/browse/FLINK-33098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776252#comment-17776252 ] Rui Fan commented on FLINK-33098: - Thanks for the review and merging! > Support kubernetes autoscaler

[jira] [Resolved] (FLINK-33097) Initialize the generic autoscaler module and interfaces

[ https://issues.apache.org/jira/browse/FLINK-33097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33097. - Fix Version/s: kubernetes-operator-1.7.0 Resolution: Fixed > Initialize the generic autoscaler

[jira] [Commented] (FLINK-21883) Introduce cooldown period into adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-21883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17779741#comment-17779741 ] Rui Fan commented on FLINK-21883: - Thanks [~echauchot]  for your effort!:) Merged to master (1.19) via

[jira] [Resolved] (FLINK-21883) Introduce cooldown period into adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-21883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-21883. - Fix Version/s: 1.19.0 Resolution: Fixed > Introduce cooldown period into adaptive scheduler >

[jira] [Created] (FLINK-33403) Bump flink version to 1.18.0 for flink-kubernetes-operator

Rui Fan created FLINK-33403: --- Summary: Bump flink version to 1.18.0 for flink-kubernetes-operator Key: FLINK-33403 URL: https://issues.apache.org/jira/browse/FLINK-33403 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-33448) Introduce a new configuration item 'taskmanager.load-balance.mode'

[ https://issues.apache.org/jira/browse/FLINK-33448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33448: --- Assignee: RocMarshal > Introduce a new configuration item 'taskmanager.load-balance.mode' >

[jira] [Commented] (FLINK-33448) Introduce a new configuration item 'taskmanager.load-balance.mode'

[ https://issues.apache.org/jira/browse/FLINK-33448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782493#comment-17782493 ] Rui Fan commented on FLINK-33448: - {quote}1. Introduce a new configuration item

[jira] [Created] (FLINK-33450) Implement JdbcAutoScalerStateStore

Rui Fan created FLINK-33450: --- Summary: Implement JdbcAutoScalerStateStore Key: FLINK-33450 URL: https://issues.apache.org/jira/browse/FLINK-33450 Project: Flink Issue Type: Sub-task

[jira] [Updated] (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 updated FLINK-33100: Parent: FLINK-33452 Issue Type: Sub-task (was: New Feature) > Implement YarnJobFetcher for

[jira] [Commented] (FLINK-33451) Implement FileSytemAutoScalerStateStore

[ https://issues.apache.org/jira/browse/FLINK-33451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782585#comment-17782585 ] Rui Fan commented on FLINK-33451: - Hi [~samrat007] , thanks for creating this JIRA. I have assigned it

[jira] [Created] (FLINK-33452) A series of improvements of Autoscaler Standalone

Rui Fan created FLINK-33452: --- Summary: A series of improvements of Autoscaler Standalone Key: FLINK-33452 URL: https://issues.apache.org/jira/browse/FLINK-33452 Project: Flink Issue Type:

[jira] [Updated] (FLINK-32947) Standalone autoscaler supports the metric reporter

[ https://issues.apache.org/jira/browse/FLINK-32947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32947: Parent: (was: FLINK-32723) Issue Type: Improvement (was: Sub-task) > Standalone autoscaler

[jira] [Updated] (FLINK-32947) Standalone autoscaler supports the metric reporter

[ https://issues.apache.org/jira/browse/FLINK-32947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32947: Parent: FLINK-33452 Issue Type: Sub-task (was: Improvement) > Standalone autoscaler supports the

[jira] [Updated] (FLINK-33287) Using the flink shaded jackson for flink-autoscaler

[ https://issues.apache.org/jira/browse/FLINK-33287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33287: Parent: (was: FLINK-32723) Issue Type: Improvement (was: Sub-task) > Using the flink shaded

[jira] [Updated] (FLINK-33287) Using the flink shaded jackson for flink-autoscaler

[ https://issues.apache.org/jira/browse/FLINK-33287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33287: Parent: FLINK-33452 Issue Type: Sub-task (was: Improvement) > Using the flink shaded jackson for

[jira] [Assigned] (FLINK-33451) Implement FileSytemAutoScalerStateStore

[ https://issues.apache.org/jira/browse/FLINK-33451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33451: --- Assignee: Samrat Deb > Implement FileSytemAutoScalerStateStore >

[jira] [Commented] (FLINK-32723) FLIP-334 : Decoupling autoscaler and kubernetes and support the Standalone Autoscaler

[ https://issues.apache.org/jira/browse/FLINK-32723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782593#comment-17782593 ] Rui Fan commented on FLINK-32723: - FLIP-334 (FLINK-32723) wants to decouple autoscalers and kubernetes

[jira] [Updated] (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 updated FLINK-33100: Parent: (was: FLINK-32723) Issue Type: New Feature (was: Sub-task) > Implement

[jira] [Updated] (FLINK-33450) Implement JdbcAutoScalerStateStore

[ https://issues.apache.org/jira/browse/FLINK-33450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33450: Parent: FLINK-33452 Issue Type: Sub-task (was: Improvement) > Implement JdbcAutoScalerStateStore

[jira] [Updated] (FLINK-33101) Add the integration test for standalone autoscaler

[ https://issues.apache.org/jira/browse/FLINK-33101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33101: Parent: (was: FLINK-32723) Issue Type: Improvement (was: Sub-task) > Add the integration

[jira] [Updated] (FLINK-33101) Add the integration test for standalone autoscaler

[ https://issues.apache.org/jira/browse/FLINK-33101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33101: Parent: FLINK-33452 Issue Type: Sub-task (was: Improvement) > Add the integration test for

[jira] [Updated] (FLINK-33099) Introduce the Standalone Autoscaler and support flink cluster

[ https://issues.apache.org/jira/browse/FLINK-33099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33099: Summary: Introduce the Standalone Autoscaler and support flink cluster (was: Support the Standalone

[jira] [Updated] (FLINK-33451) Implement FileSytemAutoScalerStateStore

[ https://issues.apache.org/jira/browse/FLINK-33451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33451: Parent: (was: FLINK-32723) Issue Type: Improvement (was: Sub-task) > Implement

[jira] [Updated] (FLINK-33450) Implement JdbcAutoScalerStateStore

[ https://issues.apache.org/jira/browse/FLINK-33450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33450: Parent: (was: FLINK-32723) Issue Type: Improvement (was: Sub-task) > Implement

[jira] [Resolved] (FLINK-33429) Metric collection during stabilization phase may error due to missing metrics

[ https://issues.apache.org/jira/browse/FLINK-33429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33429. - Resolution: Fixed > Metric collection during stabilization phase may error due to missing metrics >

[jira] [Updated] (FLINK-32723) FLIP-334 : Decoupling autoscaler and kubernetes and support the Standalone Autoscaler

[ https://issues.apache.org/jira/browse/FLINK-32723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32723: Fix Version/s: kubernetes-operator-1.7.0 > FLIP-334 : Decoupling autoscaler and kubernetes and support

[jira] [Commented] (FLINK-33429) Metric collection during stabilization phase may error due to missing metrics

[ https://issues.apache.org/jira/browse/FLINK-33429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782599#comment-17782599 ] Rui Fan commented on FLINK-33429: - Merged master<1.7.0> via :  03c9eb6f57d5d61f68cd93ff765b663d13b01ffe

[jira] [Updated] (FLINK-33102) Document the standalone autoscaler

[ https://issues.apache.org/jira/browse/FLINK-33102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33102: Fix Version/s: kubernetes-operator-1.7.0 > Document the standalone autoscaler >

[jira] [Updated] (FLINK-33099) Introduce the Standalone Autoscaler and support flink cluster

[ https://issues.apache.org/jira/browse/FLINK-33099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33099: Fix Version/s: kubernetes-operator-1.7.0 > Introduce the Standalone Autoscaler and support flink cluster

[jira] [Commented] (FLINK-33099) Introduce the Standalone Autoscaler and support flink cluster

[ https://issues.apache.org/jira/browse/FLINK-33099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783460#comment-17783460 ] Rui Fan commented on FLINK-33099: - Merged master<1.7.0> via : a309af647c1eab5bd3ae0b4f056e53a43d01b607

[jira] [Resolved] (FLINK-33099) Introduce the Standalone Autoscaler and support flink cluster

[ https://issues.apache.org/jira/browse/FLINK-33099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33099. - Resolution: Fixed > Introduce the Standalone Autoscaler and support flink cluster >

[jira] [Resolved] (FLINK-33317) Add cleaning mechanism for StreamConfig#SERIALIZEDUDF

[ https://issues.apache.org/jira/browse/FLINK-33317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33317. - Fix Version/s: 1.19.0 Resolution: Fixed > Add cleaning mechanism for StreamConfig#SERIALIZEDUDF

[jira] [Commented] (FLINK-33354) Cache TaskInformation and JobInformation to avoid deserializing duplicate big objects

[ https://issues.apache.org/jira/browse/FLINK-33354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783499#comment-17783499 ] Rui Fan commented on FLINK-33354: - Merged to master<1.19> via 64992471c5dd52fb4269f6de51c15e27c2a45b55

[jira] [Resolved] (FLINK-33354) Cache TaskInformation and JobInformation to avoid deserializing duplicate big objects

[ https://issues.apache.org/jira/browse/FLINK-33354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33354. - Resolution: Fixed > Cache TaskInformation and JobInformation to avoid deserializing duplicate big >

[jira] [Updated] (FLINK-33354) Cache TaskInformation and JobInformation to avoid deserializing duplicate big objects

[ https://issues.apache.org/jira/browse/FLINK-33354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33354: Fix Version/s: 1.19.0 > Cache TaskInformation and JobInformation to avoid deserializing duplicate big >

[jira] [Assigned] (FLINK-33132) Flink Connector Redshift Sink Implementation

[ https://issues.apache.org/jira/browse/FLINK-33132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33132: --- Assignee: Samrat Deb > Flink Connector Redshift Sink Implementation >

[jira] [Assigned] (FLINK-31854) FLIP-307: Flink Connector Redshift

[ https://issues.apache.org/jira/browse/FLINK-31854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-31854: --- Assignee: Samrat Deb > FLIP-307: Flink Connector Redshift > --- >

[jira] [Assigned] (FLINK-33385) Flink connector redshift Sink Table API implementation

[ https://issues.apache.org/jira/browse/FLINK-33385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33385: --- Assignee: Samrat Deb > Flink connector redshift Sink Table API implementation >

[jira] [Commented] (FLINK-33317) Add cleaning mechanism for StreamConfig#SERIALIZEDUDF

[ https://issues.apache.org/jira/browse/FLINK-33317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783550#comment-17783550 ] Rui Fan commented on FLINK-33317: - Merged master<1.19> via: c83792b0f3fb6ae18dfabd52a89dc42c074ee73c >

[jira] [Commented] (FLINK-33448) Introduce a new configuration item 'taskmanager.load-balance.mode'

[ https://issues.apache.org/jira/browse/FLINK-33448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783554#comment-17783554 ] Rui Fan commented on FLINK-33448: - Merged to master<1.19> via : ed07a70e45a753a259287c9fdbdae73e3415cc21

[jira] [Resolved] (FLINK-33448) Introduce a new configuration item 'taskmanager.load-balance.mode'

[ https://issues.apache.org/jira/browse/FLINK-33448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33448. - Resolution: Fixed > Introduce a new configuration item 'taskmanager.load-balance.mode' >

[jira] [Updated] (FLINK-33448) Introduce a new configuration item 'taskmanager.load-balance.mode'

[ https://issues.apache.org/jira/browse/FLINK-33448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33448: Fix Version/s: 1.19.0 > Introduce a new configuration item 'taskmanager.load-balance.mode' >

[jira] [Assigned] (FLINK-33133) Flink Document Update

[ https://issues.apache.org/jira/browse/FLINK-33133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33133: --- Assignee: Samrat Deb > Flink Document Update > -- > > Key:

[jira] [Assigned] (FLINK-33134) Flink Connector redshift E2E test

[ https://issues.apache.org/jira/browse/FLINK-33134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33134: --- Assignee: Samrat Deb > Flink Connector redshift E2E test > -- > >

[jira] [Commented] (FLINK-33473) Update Flink client to 1.18.0

[ https://issues.apache.org/jira/browse/FLINK-33473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783484#comment-17783484 ] Rui Fan commented on FLINK-33473: - Hi [~prabhujoseph] , this Jira duplicates with FLINK-33403.   And

[jira] [Assigned] (FLINK-33386) Introduce the strategy for Default Scheduler to pursue tasks balancing based on slots level.

[ https://issues.apache.org/jira/browse/FLINK-33386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33386: --- Assignee: RocMarshal > Introduce the strategy for Default Scheduler to pursue tasks balancing

[jira] [Assigned] (FLINK-33387) Introduce the abstraction and the interface about loading

[ https://issues.apache.org/jira/browse/FLINK-33387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33387: --- Assignee: RocMarshal > Introduce the abstraction and the interface about loading >

[jira] [Assigned] (FLINK-33390) Support slot balancing at TM level for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-33390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33390: --- Assignee: Rui Fan > Support slot balancing at TM level for Adaptive Scheduler >

[jira] [Assigned] (FLINK-33391) Support tasks balancing at TM level for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-33391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33391: --- Assignee: Rui Fan > Support tasks balancing at TM level for Adaptive Scheduler >

[jira] [Assigned] (FLINK-33392) Add the documentation page for balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-33392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33392: --- Assignee: RocMarshal > Add the documentation page for balanced tasks scheduling >

[jira] [Assigned] (FLINK-33388) Support tasks balancing at TM level for Default Scheduler

[ https://issues.apache.org/jira/browse/FLINK-33388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33388: --- Assignee: RocMarshal > Support tasks balancing at TM level for Default Scheduler >

[jira] [Assigned] (FLINK-33389) Introduce the assigner for Adaptive Scheduler to pursuit task balancing based slots level

[ https://issues.apache.org/jira/browse/FLINK-33389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33389: --- Assignee: Rui Fan > Introduce the assigner for Adaptive Scheduler to pursuit task balancing based

[jira] [Commented] (FLINK-33393) flink document description error

[ https://issues.apache.org/jira/browse/FLINK-33393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780964#comment-17780964 ] Rui Fan commented on FLINK-33393: - Merged to master<1.19> via : 806147c3233a47eacaa630dca5fdfef83397ab31

[jira] [Resolved] (FLINK-33393) flink document description error

[ https://issues.apache.org/jira/browse/FLINK-33393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33393. - Resolution: Fixed > flink document description error > > >

[jira] [Updated] (FLINK-33393) flink document description error

[ https://issues.apache.org/jira/browse/FLINK-33393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33393: Fix Version/s: 1.19.0 (was: 1.17.1) > flink document description error >

[jira] [Assigned] (FLINK-33393) flink document description error

[ https://issues.apache.org/jira/browse/FLINK-33393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33393: --- Assignee: 蔡灿材 > flink document description error > > >

[jira] [Updated] (FLINK-32868) Document the need to backport FLINK-30213 for using autoscaler with older version Flinks

[ https://issues.apache.org/jira/browse/FLINK-32868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32868: Fix Version/s: kubernetes-operator-1.7.0 kubernetes-operator-1.6.1 > Document the need

[jira] [Updated] (FLINK-33011) Operator deletes HA data unexpectedly

[ https://issues.apache.org/jira/browse/FLINK-33011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33011: Fix Version/s: kubernetes-operator-1.6.1 > Operator deletes HA data unexpectedly >

[jira] [Updated] (FLINK-32890) Flink app rolled back with old savepoints (3 hours back in time) while some checkpoints have been taken in between

[ https://issues.apache.org/jira/browse/FLINK-32890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32890: Fix Version/s: kubernetes-operator-1.6.1 > Flink app rolled back with old savepoints (3 hours back in

[jira] [Updated] (FLINK-33354) Cache TaskInformation and JobInformation to avoid deserializing duplicate big objects

[ https://issues.apache.org/jira/browse/FLINK-33354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33354: Summary: Cache TaskInformation and JobInformation to avoid deserializing duplicate big objects (was:

[jira] [Commented] (FLINK-32850) [JUnit5 Migration] The io package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17779841#comment-17779841 ] Rui Fan commented on FLINK-32850: - Merged via: 0ccd95ef48bcd7246f8c88c9aa7b69ffa268c865 > [JUnit5

[jira] [Comment Edited] (FLINK-32850) [JUnit5 Migration] The io package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17779841#comment-17779841 ] Rui Fan edited comment on FLINK-32850 at 10/26/23 11:05 AM: Merged master

[jira] [Comment Edited] (FLINK-33316) Avoid unnecessary heavy getStreamOperatorFactory

[ https://issues.apache.org/jira/browse/FLINK-33316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778510#comment-17778510 ] Rui Fan edited comment on FLINK-33316 at 10/26/23 1:31 PM: --- The change is

[jira] [Updated] (FLINK-33315) Optimize memory usage of large StreamOperator

[ https://issues.apache.org/jira/browse/FLINK-33315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33315: Component/s: Runtime / Task > Optimize memory usage of large StreamOperator >

[jira] [Updated] (FLINK-33315) Optimize memory usage of large StreamOperator

[ https://issues.apache.org/jira/browse/FLINK-33315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33315: Description: Some of our batch jobs are upgraded from flink-1.15 to flink-1.17, and TM always fail with

[jira] [Updated] (FLINK-33315) Optimize memory usage of large StreamOperator

[ https://issues.apache.org/jira/browse/FLINK-33315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33315: Attachment: 130f436613b52b321bd9bd0211dd109f0b010220e860f292a13c0702016976850466192b.png > Optimize

[jira] [Created] (FLINK-33354) Reuse the TaskInformation for multiple slots

Rui Fan created FLINK-33354: --- Summary: Reuse the TaskInformation for multiple slots Key: FLINK-33354 URL: https://issues.apache.org/jira/browse/FLINK-33354 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-33317) Add cleaning mechanism for StreamConfig#SERIALIZEDUDF

[ https://issues.apache.org/jira/browse/FLINK-33317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33317: Description: See FLINK-33315 for details. This Jira focus on avoid unnecessary memory usage, it can

[jira] [Updated] (FLINK-33317) Add cleaning mechanism for StreamConfig#SERIALIZEDUDF

[ https://issues.apache.org/jira/browse/FLINK-33317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33317: Description: See FLINK-33315 for details. This Jira focus on avoid unnecessary memory usage, it can

[jira] [Updated] (FLINK-33359) Kubernetes operator supports compile with Java 17

[ https://issues.apache.org/jira/browse/FLINK-33359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33359: Summary: Kubernetes operator supports compile with Java 17 (was: Kubernetes operator supports Java 17)

[jira] [Updated] (FLINK-33359) Kubernetes operator supports compile with Java 17

[ https://issues.apache.org/jira/browse/FLINK-33359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33359: Description: In the voting mailing list for flink-kubernetes-operator version 1.6.1, Thomas mentioned

[jira] [Created] (FLINK-33359) Kubernetes operator supports Java 17

Rui Fan created FLINK-33359: --- Summary: Kubernetes operator supports Java 17 Key: FLINK-33359 URL: https://issues.apache.org/jira/browse/FLINK-33359 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-33359) Kubernetes operator supports compiling with Java 17

[ https://issues.apache.org/jira/browse/FLINK-33359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33359: Summary: Kubernetes operator supports compiling with Java 17 (was: Kubernetes operator supports compile

[jira] [Updated] (FLINK-33359) Kubernetes operator supports compile with Java 17

[ https://issues.apache.org/jira/browse/FLINK-33359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33359: Description: In the voting mailing list for flink-kubernetes-operator version 1.6.1, Thomas mentioned

[jira] [Commented] (FLINK-33287) Using the flink shaded jackson for flink-autoscaler

[ https://issues.apache.org/jira/browse/FLINK-33287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776993#comment-17776993 ] Rui Fan commented on FLINK-33287: - Thanks [~martijnvisser] for this comment! {quote}We're decoupling

[jira] [Updated] (FLINK-32723) FLIP-334 : Decoupling autoscaler and kubernetes and support the Standalone Autoscaler

[ https://issues.apache.org/jira/browse/FLINK-32723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32723: Summary: FLIP-334 : Decoupling autoscaler and kubernetes and support the Standalone Autoscaler (was:

  1   2   3   4   5   6   7   8   9   10   >