[jira] [Created] (FLINK-33701) restart.time-tracking doc is wrong

Rui Fan created FLINK-33701: --- Summary: restart.time-tracking doc is wrong Key: FLINK-33701 URL: https://issues.apache.org/jira/browse/FLINK-33701 Project: Flink Issue Type: Technical Debt

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17791485#comment-17791485 ] Rui Fan commented on FLINK-27681: - Hey [~mayuehappy]  [~masteryhx] , thanks for your feedback.:)

[jira] [Created] (FLINK-33693) The disable unaligned checkpoint isn't respected when the aligned checkpoint timeout is enabled

Rui Fan created FLINK-33693: --- Summary: The disable unaligned checkpoint isn't respected when the aligned checkpoint timeout is enabled Key: FLINK-33693 URL: https://issues.apache.org/jira/browse/FLINK-33693

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17790010#comment-17790010 ] Rui Fan commented on FLINK-27681: - {quote} * That's why we'd like to focus on not uploading the corruped

[jira] [Resolved] (FLINK-33650) Checkpoint Storage doc is missed

[ https://issues.apache.org/jira/browse/FLINK-33650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33650. - Fix Version/s: 1.19.0 Resolution: Fixed > Checkpoint Storage doc is missed >

[jira] [Commented] (FLINK-33650) Checkpoint Storage doc is missed

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

[jira] [Created] (FLINK-33650) Checkpoint Storage doc is missed

Rui Fan created FLINK-33650: --- Summary: Checkpoint Storage doc is missed Key: FLINK-33650 URL: https://issues.apache.org/jira/browse/FLINK-33650 Project: Flink Issue Type: Technical Debt

[jira] [Resolved] (FLINK-33649) Exponential Delay doc is missed

[ https://issues.apache.org/jira/browse/FLINK-33649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33649. - Resolution: Fixed > Exponential Delay doc is missed > --- > >

[jira] [Commented] (FLINK-33649) Exponential Delay doc is missed

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

[jira] [Updated] (FLINK-33649) Exponential Delay doc is missed

[ https://issues.apache.org/jira/browse/FLINK-33649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33649: Fix Version/s: 1.19.0 > Exponential Delay doc is missed > --- > >

[jira] [Created] (FLINK-33649) Exponential Delay doc is missed

Rui Fan created FLINK-33649: --- Summary: Exponential Delay doc is missed Key: FLINK-33649 URL: https://issues.apache.org/jira/browse/FLINK-33649 Project: Flink Issue Type: Technical Debt

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789427#comment-17789427 ] Rui Fan commented on FLINK-27681: - {quote}In what scenario file that we are verifying before the upload,

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789409#comment-17789409 ] Rui Fan commented on FLINK-27681: - Thanks for the quick response. {quote}Strictly speaking, I think it

[jira] [Commented] (FLINK-27681) Improve the availability of Flink when the RocksDB file is corrupted.

[ https://issues.apache.org/jira/browse/FLINK-27681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789355#comment-17789355 ] Rui Fan commented on FLINK-27681: - {quote}In our production, the underlying environment may produce some

[jira] [Commented] (FLINK-33565) The concurrentExceptions doesn't work

[ https://issues.apache.org/jira/browse/FLINK-33565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789329#comment-17789329 ] Rui Fan commented on FLINK-33565: - Give some background here:

[jira] [Created] (FLINK-33636) Implement JdbcAutoScalerEventHandler

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

[jira] [Commented] (FLINK-33565) The concurrentExceptions doesn't work

[ https://issues.apache.org/jira/browse/FLINK-33565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789137#comment-17789137 ] Rui Fan commented on FLINK-33565: - Before creating this JIRA, I found that the concurrentExceptions

[jira] [Commented] (FLINK-33565) The concurrentExceptions doesn't work

[ https://issues.apache.org/jira/browse/FLINK-33565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789060#comment-17789060 ] Rui Fan commented on FLINK-33565: - Thanks for the clarification! So you mean that when a job has

[jira] [Created] (FLINK-33625) FLIP-390: Support System out and err to be redirected to LOG or discarded

Rui Fan created FLINK-33625: --- Summary: FLIP-390: Support System out and err to be redirected to LOG or discarded Key: FLINK-33625 URL: https://issues.apache.org/jira/browse/FLINK-33625 Project: Flink

[jira] [Commented] (FLINK-33121) Failed precondition in JobExceptionsHandler due to concurrent global failures

[ https://issues.apache.org/jira/browse/FLINK-33121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17788272#comment-17788272 ] Rui Fan commented on FLINK-33121: - Hey [~pgaref] , thanks for reporing this Jira and fixing it. :) I

[jira] [Commented] (FLINK-33565) The concurrentExceptions doesn't work

[ https://issues.apache.org/jira/browse/FLINK-33565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17788255#comment-17788255 ] Rui Fan commented on FLINK-33565: - Hi [~mapohl] , thanks for providing these background.:)

[jira] [Resolved] (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 resolved FLINK-33315. - Fix Version/s: 1.19.0 Resolution: Fixed > Optimize memory usage of large StreamOperator >

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

[ https://issues.apache.org/jira/browse/FLINK-33315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17787823#comment-17787823 ] Rui Fan commented on FLINK-33315: - 3 subtasks have been merged for some time, and after these

[jira] [Assigned] (FLINK-33575) FLIP-394: Add Metrics for Connector Agnostic Autoscaling

[ https://issues.apache.org/jira/browse/FLINK-33575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33575: --- Assignee: Mason Chen > FLIP-394: Add Metrics for Connector Agnostic Autoscaling >

[jira] [Created] (FLINK-33565) The concurrentExceptions doesn't work

Rui Fan created FLINK-33565: --- Summary: The concurrentExceptions doesn't work Key: FLINK-33565 URL: https://issues.apache.org/jira/browse/FLINK-33565 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-18473) Optimize RocksDB disk load balancing strategy

[ https://issues.apache.org/jira/browse/FLINK-18473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786304#comment-17786304 ] Rui Fan commented on FLINK-18473: - Hi [~yigress] , thanks for your feedback. The current strategy is

[jira] [Updated] (FLINK-33526) Improve default autoscaler configs

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

[jira] [Resolved] (FLINK-33526) Improve default autoscaler configs

[ https://issues.apache.org/jira/browse/FLINK-33526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33526. - Resolution: Fixed > Improve default autoscaler configs > -- > >

[jira] [Commented] (FLINK-33526) Improve default autoscaler configs

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

[jira] [Updated] (FLINK-33527) Clear all physical states after autoscaler is disabled

[ https://issues.apache.org/jira/browse/FLINK-33527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33527: Description: Currently, we just clear ParallelismOverrides  after autoscaler is disabled. We should

[jira] [Created] (FLINK-33527) Clear all pysical states after autoscaler is disabled

Rui Fan created FLINK-33527: --- Summary: Clear all pysical states after autoscaler is disabled Key: FLINK-33527 URL: https://issues.apache.org/jira/browse/FLINK-33527 Project: Flink Issue Type:

[jira] [Updated] (FLINK-33527) Clear all physical states after autoscaler is disabled

[ https://issues.apache.org/jira/browse/FLINK-33527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33527: Summary: Clear all physical states after autoscaler is disabled (was: Clear all pysical states after

[jira] [Resolved] (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 resolved FLINK-32723. - Resolution: Fixed > FLIP-334 : Decoupling autoscaler and kubernetes and support the Standalone >

[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=17784714#comment-17784714 ] Rui Fan commented on FLINK-32723: - Hi [~gyfora]  [~mxm] , I resolve this Jira first, it means the

[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] [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-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] [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] [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] [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] [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-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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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-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] [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] [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] [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-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-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] [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-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-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-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-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] [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-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-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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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-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-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] [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] [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] [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-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-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-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-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-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] [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] [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] [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] [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] [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] [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] [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] [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] [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] [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

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