[jira] [Resolved] (FLINK-35365) Reorganize catalog and dialect code

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

[jira] [Resolved] (FLINK-35367) Reorganize sinks

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

[jira] [Resolved] (FLINK-35366) Create all database modules

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

[jira] [Resolved] (FLINK-35494) Reorganize sources

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

[jira] [Resolved] (FLINK-35788) Deprecate old InputFormat and SinkFunction

[ https://issues.apache.org/jira/browse/FLINK-35788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35788. - Fix Version/s: jdbc-3.3.0 Assignee: João Boto Resolution: Fixed Merged to main(3.3.0) vi

[jira] [Resolved] (FLINK-35368) Reorganize table code

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

[jira] [Commented] (FLINK-35363) FLIP-449: Reorganization of flink-connector-jdbc

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

[jira] [Updated] (FLINK-35363) FLIP-449: Reorganization of flink-connector-jdbc

[ https://issues.apache.org/jira/browse/FLINK-35363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35363: Fix Version/s: jdbc-3.3.0 > FLIP-449: Reorganization of flink-connector-jdbc > ---

[jira] [Updated] (FLINK-35909) JdbcFilterPushdownPreparedStatementVisitorTest fails

[ https://issues.apache.org/jira/browse/FLINK-35909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35909: Description: JdbcFilterPushdownPreparedStatementVisitorTest fails[1] after FLINK-35363 is merged.   Hey

[jira] [Created] (FLINK-35909) JdbcFilterPushdownPreparedStatementVisitorTest fails

Rui Fan created FLINK-35909: --- Summary: JdbcFilterPushdownPreparedStatementVisitorTest fails Key: FLINK-35909 URL: https://issues.apache.org/jira/browse/FLINK-35909 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-34405) RightOuterJoinTaskTest#testCancelOuterJoinTaskWhileSort2 fails due to an interruption of the RightOuterJoinDriver#prepare method

[ https://issues.apache.org/jira/browse/FLINK-34405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815531#comment-17815531 ] Rui Fan commented on FLINK-34405: - org.apache.flink.runtime.operators.RightOuterJoinTask

[jira] [Commented] (FLINK-34390) Release Testing: Verify FLINK-33325 Built-in cross-platform powerful java profiler

[ https://issues.apache.org/jira/browse/FLINK-34390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815570#comment-17815570 ] Rui Fan commented on FLINK-34390: - Thanks a lot [~easonqin] for the testing! :) > Relea

[jira] [Updated] (FLINK-33960) Adaptive Scheduler doesn't respect the lowerBound for tasks

[ https://issues.apache.org/jira/browse/FLINK-33960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33960: Fix Version/s: 1.19.0 1.18.2 1.20.0 > Adaptive Scheduler doesn't res

[jira] [Comment Edited] (FLINK-33960) Adaptive Scheduler doesn't respect the lowerBound for tasks

[ https://issues.apache.org/jira/browse/FLINK-33960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815475#comment-17815475 ] Rui Fan edited comment on FLINK-33960 at 2/8/24 10:57 AM: -- Merg

[jira] [Comment Edited] (FLINK-33960) Adaptive Scheduler doesn't respect the lowerBound for tasks

[ https://issues.apache.org/jira/browse/FLINK-33960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815475#comment-17815475 ] Rui Fan edited comment on FLINK-33960 at 2/18/24 9:38 AM: -- Merg

[jira] [Resolved] (FLINK-33960) Adaptive Scheduler doesn't respect the lowerBound for tasks

[ https://issues.apache.org/jira/browse/FLINK-33960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33960. - Resolution: Fixed > Adaptive Scheduler doesn't respect the lowerBound for tasks > --

[jira] [Commented] (FLINK-34252) WatermarkAssignerOperator should not emit WatermarkStatus.IDLE under continuous data flow

[ https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818266#comment-17818266 ] Rui Fan commented on FLINK-34252: - Thanks [~dchristle] for the report and fix, and thank

[jira] [Comment Edited] (FLINK-34252) WatermarkAssignerOperator should not emit WatermarkStatus.IDLE under continuous data flow

[ https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818266#comment-17818266 ] Rui Fan edited comment on FLINK-34252 at 2/18/24 10:13 AM: --- So

[jira] [Updated] (FLINK-34252) WatermarkAssignerOperator should not emit WatermarkStatus.IDLE under continuous data flow

[ https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34252: Fix Version/s: 1.19.0 1.18.2 1.20.0 > WatermarkAssignerOperator shou

[jira] [Assigned] (FLINK-34252) WatermarkAssignerOperator should not emit WatermarkStatus.IDLE under continuous data flow

[ https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-34252: --- Assignee: David Christle > WatermarkAssignerOperator should not emit WatermarkStatus.IDLE under >

[jira] [Commented] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818280#comment-17818280 ] Rui Fan commented on FLINK-34400: - Hi [~asardaes] , did you try enable idleness? I try

[jira] [Commented] (FLINK-34336) AutoRescalingITCase#testCheckpointRescalingWithKeyedAndNonPartitionedState may hang sometimes

[ https://issues.apache.org/jira/browse/FLINK-34336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818414#comment-17818414 ] Rui Fan commented on FLINK-34336: - Hi [~mapohl] , thanks for your report these failed CI

[jira] [Updated] (FLINK-34336) AutoRescalingITCase#testCheckpointRescalingWithKeyedAndNonPartitionedState may hang sometimes

[ https://issues.apache.org/jira/browse/FLINK-34336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34336: Fix Version/s: 1.20.0 > AutoRescalingITCase#testCheckpointRescalingWithKeyedAndNonPartitionedState > may

[jira] [Commented] (FLINK-34336) AutoRescalingITCase#testCheckpointRescalingWithKeyedAndNonPartitionedState may hang sometimes

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

[jira] [Commented] (FLINK-34336) AutoRescalingITCase#testCheckpointRescalingWithKeyedAndNonPartitionedState may hang sometimes

[ https://issues.apache.org/jira/browse/FLINK-34336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818688#comment-17818688 ] Rui Fan commented on FLINK-34336: - Hi [~mapohl] , thanks for your reminder. I have submi

[jira] [Created] (FLINK-34471) Tune the network memroy in Autoscaler

Rui Fan created FLINK-34471: --- Summary: Tune the network memroy in Autoscaler Key: FLINK-34471 URL: https://issues.apache.org/jira/browse/FLINK-34471 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-34471) Tune the network memroy in Autoscaler

[ https://issues.apache.org/jira/browse/FLINK-34471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818735#comment-17818735 ] Rui Fan commented on FLINK-34471: - cc  [~mxm] [~gyfora]  It is mentioned in this commen

[jira] [Resolved] (FLINK-34336) AutoRescalingITCase#testCheckpointRescalingWithKeyedAndNonPartitionedState may hang sometimes

[ https://issues.apache.org/jira/browse/FLINK-34336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34336. - Resolution: Fixed > AutoRescalingITCase#testCheckpointRescalingWithKeyedAndNonPartitionedState > may ha

[jira] [Comment Edited] (FLINK-34336) AutoRescalingITCase#testCheckpointRescalingWithKeyedAndNonPartitionedState may hang sometimes

[ https://issues.apache.org/jira/browse/FLINK-34336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818614#comment-17818614 ] Rui Fan edited comment on FLINK-34336 at 2/20/24 2:22 PM: -- Merg

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

[ https://issues.apache.org/jira/browse/FLINK-33636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33636: Fix Version/s: kubernetes-operator-1.8.0 > Implement JdbcAutoScalerEventHandler >

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

[ https://issues.apache.org/jira/browse/FLINK-33636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33636. - Resolution: Fixed > Implement JdbcAutoScalerEventHandler > > >

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

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

[jira] [Assigned] (FLINK-34064) Expose JobManagerOperatorMetrics via REST API

[ https://issues.apache.org/jira/browse/FLINK-34064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-34064: --- Assignee: Mason Chen > Expose JobManagerOperatorMetrics via REST API >

[jira] [Assigned] (FLINK-34445) Integrate new endpoint with Flink UI metrics section

[ https://issues.apache.org/jira/browse/FLINK-34445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-34445: --- Assignee: Mason Chen > Integrate new endpoint with Flink UI metrics section > -

[jira] [Assigned] (FLINK-34444) Add new endpoint handler to flink

[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-3: --- Assignee: Mason Chen > Add new endpoint handler to flink > - > >

[jira] [Commented] (FLINK-34471) Tune network memory as part of Autoscaler Memory Tuning

[ https://issues.apache.org/jira/browse/FLINK-34471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819443#comment-17819443 ] Rui Fan commented on FLINK-34471: - Assuming ALL_TO_ALL in the first version is fine for

[jira] [Commented] (FLINK-34471) Tune network memory as part of Autoscaler Memory Tuning

[ https://issues.apache.org/jira/browse/FLINK-34471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819590#comment-17819590 ] Rui Fan commented on FLINK-34471: - {quote}I realized point to point connections might be

[jira] [Created] (FLINK-34502) Support calculating network memory for forward and rescale edge

Rui Fan created FLINK-34502: --- Summary: Support calculating network memory for forward and rescale edge Key: FLINK-34502 URL: https://issues.apache.org/jira/browse/FLINK-34502 Project: Flink Issue

[jira] [Updated] (FLINK-34502) Support calculating network memory for forward and rescale edge

[ https://issues.apache.org/jira/browse/FLINK-34502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34502: Description: This is follow up Jira of FLINK-34471. FLINK-34471 assuming all connections type are ALL_TO_

[jira] [Updated] (FLINK-34502) Support calculating network memory for forward and rescale edge

[ https://issues.apache.org/jira/browse/FLINK-34502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34502: Fix Version/s: kubernetes-operator-1.8.0 > Support calculating network memory for forward and rescale edge

[jira] [Created] (FLINK-34504) Avoid the parallelism adjutment when the upstream shuffle type doesn't has keyBy

Rui Fan created FLINK-34504: --- Summary: Avoid the parallelism adjutment when the upstream shuffle type doesn't has keyBy Key: FLINK-34504 URL: https://issues.apache.org/jira/browse/FLINK-34504 Project: Flink

[jira] [Updated] (FLINK-34504) Avoid the parallelism adjustment when the upstream shuffle type doesn't has keyBy

[ https://issues.apache.org/jira/browse/FLINK-34504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34504: Description: JobVertexScaler#scale has a optimization: Try to adjust the parallelism such that it divides

[jira] [Updated] (FLINK-34504) Avoid the parallelism adjustment when the upstream shuffle type doesn't has keyBy

[ https://issues.apache.org/jira/browse/FLINK-34504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34504: Summary: Avoid the parallelism adjustment when the upstream shuffle type doesn't has keyBy (was: Avoid th

[jira] [Updated] (FLINK-34504) Avoid the parallelism adjustment when the upstream shuffle type doesn't have keyBy

[ https://issues.apache.org/jira/browse/FLINK-34504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34504: Summary: Avoid the parallelism adjustment when the upstream shuffle type doesn't have keyBy (was: Avoid t

[jira] [Resolved] (FLINK-34471) Tune network memory as part of Autoscaler Memory Tuning

[ https://issues.apache.org/jira/browse/FLINK-34471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34471. - Fix Version/s: kubernetes-operator-1.8.0 Resolution: Fixed > Tune network memory as part of Autos

[jira] [Commented] (FLINK-34471) Tune network memory as part of Autoscaler Memory Tuning

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

[jira] [Commented] (FLINK-34502) Support calculating network memory for forward and rescale edge

[ https://issues.apache.org/jira/browse/FLINK-34502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17820108#comment-17820108 ] Rui Fan commented on FLINK-34502: - Merged via main(1.8.0) via : 304fca82ccc153c0745c4688

[jira] [Resolved] (FLINK-34502) Support calculating network memory for forward and rescale edge

[ https://issues.apache.org/jira/browse/FLINK-34502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34502. - Resolution: Fixed > Support calculating network memory for forward and rescale edge > --

[jira] [Commented] (FLINK-34504) Avoid the parallelism adjustment when the upstream shuffle type doesn't have keyBy

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

[jira] [Resolved] (FLINK-34504) Avoid the parallelism adjustment when the upstream shuffle type doesn't have keyBy

[ https://issues.apache.org/jira/browse/FLINK-34504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34504. - Resolution: Fixed > Avoid the parallelism adjustment when the upstream shuffle type doesn't have > keyB

[jira] [Created] (FLINK-34521) Using the Duration instead of the deprecated Time classes

Rui Fan created FLINK-34521: --- Summary: Using the Duration instead of the deprecated Time classes Key: FLINK-34521 URL: https://issues.apache.org/jira/browse/FLINK-34521 Project: Flink Issue Type: T

[jira] [Created] (FLINK-34522) StateTtlConfig#cleanupInRocksdbCompactFilter still use the deprecated Time

Rui Fan created FLINK-34522: --- Summary: StateTtlConfig#cleanupInRocksdbCompactFilter still use the deprecated Time Key: FLINK-34522 URL: https://issues.apache.org/jira/browse/FLINK-34522 Project: Flink

[jira] [Updated] (FLINK-34522) StateTtlConfig#cleanupInRocksdbCompactFilter still uses the deprecated Time

[ https://issues.apache.org/jira/browse/FLINK-34522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34522: Summary: StateTtlConfig#cleanupInRocksdbCompactFilter still uses the deprecated Time (was: StateTtlConfig

[jira] [Updated] (FLINK-34522) StateTtlConfig#cleanupInRocksdbCompactFilter still uses the deprecated Time class

[ https://issues.apache.org/jira/browse/FLINK-34522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34522: Summary: StateTtlConfig#cleanupInRocksdbCompactFilter still uses the deprecated Time class (was: StateTtl

[jira] [Updated] (FLINK-34522) StateTtlConfig#cleanupInRocksdbCompactFilter still uses the deprecated Time class

[ https://issues.apache.org/jira/browse/FLINK-34522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34522: Description: FLINK-32570 deprecated the Time class and refactor all Public or PublicEvolving apis to use

[jira] [Updated] (FLINK-34522) StateTtlConfig#cleanupInRocksdbCompactFilter still uses the deprecated Time class

[ https://issues.apache.org/jira/browse/FLINK-34522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34522: Description: FLINK-32570 deprecated the Time class and refactor all Public or PublicEvolving apis to use

[jira] [Updated] (FLINK-34522) StateTtlConfig#cleanupInRocksdbCompactFilter still uses the deprecated Time class

[ https://issues.apache.org/jira/browse/FLINK-34522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34522: Description: FLINK-32570 deprecated the Time class and refactor all Public or PublicEvolving apis to use

[jira] [Assigned] (FLINK-34526) Without shuffling data, when a Task Manager is killed, restarting the Flink job takes a considerable amount of time

[ https://issues.apache.org/jira/browse/FLINK-34526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-34526: --- Assignee: junzhong qin > Without shuffling data, when a Task Manager is killed, restarting the Flin

[jira] [Assigned] (FLINK-34528) With shuffling data, when a Task Manager is killed, restarting the Flink job takes a considerable amount of time

[ https://issues.apache.org/jira/browse/FLINK-34528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-34528: --- Assignee: junzhong qin > With shuffling data, when a Task Manager is killed, restarting the Flink j

[jira] [Commented] (FLINK-34521) Using the Duration instead of the deprecated Time classes

[ https://issues.apache.org/jira/browse/FLINK-34521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822350#comment-17822350 ] Rui Fan commented on FLINK-34521: - Thanks for the reminder, i close this jira. > Using

[jira] [Closed] (FLINK-34521) Using the Duration instead of the deprecated Time classes

[ https://issues.apache.org/jira/browse/FLINK-34521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-34521. --- Resolution: Duplicate > Using the Duration instead of the deprecated Time classes >

[jira] [Commented] (FLINK-34522) StateTtlConfig#cleanupInRocksdbCompactFilter still uses the deprecated Time class

[ https://issues.apache.org/jira/browse/FLINK-34522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825162#comment-17825162 ] Rui Fan commented on FLINK-34522: - merged in master(1.20): * eb9bcfa5893374093d3add272c

[jira] [Resolved] (FLINK-34522) StateTtlConfig#cleanupInRocksdbCompactFilter still uses the deprecated Time class

[ https://issues.apache.org/jira/browse/FLINK-34522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34522. - Resolution: Fixed > StateTtlConfig#cleanupInRocksdbCompactFilter still uses the deprecated Time > class

[jira] [Commented] (FLINK-34152) Tune TaskManager memory

[ https://issues.apache.org/jira/browse/FLINK-34152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825218#comment-17825218 ] Rui Fan commented on FLINK-34152: - Merged to main(1.8.0) via: * 48692b7243086a2ccf2cb4c6

[jira] [Created] (FLINK-34655) Autoscaler doesn't work for flink 1.15

Rui Fan created FLINK-34655: --- Summary: Autoscaler doesn't work for flink 1.15 Key: FLINK-34655 URL: https://issues.apache.org/jira/browse/FLINK-34655 Project: Flink Issue Type: Bug Compon

[jira] [Commented] (FLINK-34655) Autoscaler doesn't work for flink 1.15

[ https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825669#comment-17825669 ] Rui Fan commented on FLINK-34655: - {quote}But the vertex parallelism overrides feature w

[jira] [Updated] (FLINK-34655) Autoscaler doesn't work for flink 1.15

[ https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34655: Fix Version/s: kubernetes-operator-1.8.0 (was: 1.8.0) > Autoscaler doesn't work for

[jira] [Comment Edited] (FLINK-34655) Autoscaler doesn't work for flink 1.15

[ https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825669#comment-17825669 ] Rui Fan edited comment on FLINK-34655 at 3/13/24 2:46 AM: -- {quo

[jira] [Updated] (FLINK-33798) Automatically clean up rocksdb logs when the task failover.

[ https://issues.apache.org/jira/browse/FLINK-33798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33798: Issue Type: Bug (was: Improvement) > Automatically clean up rocksdb logs when the task failover. > --

[jira] [Commented] (FLINK-33798) Automatically clean up rocksdb logs when the task failover.

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

[jira] [Commented] (FLINK-33798) Automatically clean up rocksdb logs when the task failover.

[ https://issues.apache.org/jira/browse/FLINK-33798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825899#comment-17825899 ] Rui Fan commented on FLINK-33798: - Hi [~liming], IIUC, this JIRA is a file leak related

[jira] [Updated] (FLINK-33798) Automatically clean up rocksdb logs when the task failover.

[ https://issues.apache.org/jira/browse/FLINK-33798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33798: Fix Version/s: 1.20.0 > Automatically clean up rocksdb logs when the task failover. >

[jira] [Updated] (FLINK-34655) Autoscaler doesn't work for flink 1.15

[ https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34655: Description: flink-ubernetes-operator is committed to supporting the latest 4 flink minor versions, and a

[jira] [Commented] (FLINK-34655) Autoscaler doesn't work for flink 1.15

[ https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17826923#comment-17826923 ] Rui Fan commented on FLINK-34655: - {quote}I understand the idea behind providing suggest

[jira] [Resolved] (FLINK-34655) Autoscaler doesn't work for flink 1.15

[ https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34655. - Resolution: Fixed > Autoscaler doesn't work for flink 1.15 > -- > >

[jira] [Commented] (FLINK-34655) Autoscaler doesn't work for flink 1.15

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

[jira] [Updated] (FLINK-34655) Autoscaler standalone doesn't work for flink 1.15

[ https://issues.apache.org/jira/browse/FLINK-34655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34655: Summary: Autoscaler standalone doesn't work for flink 1.15 (was: Autoscaler doesn't work for flink 1.15)

[jira] [Comment Edited] (FLINK-33798) Automatically clean up rocksdb logs when the task failover.

[ https://issues.apache.org/jira/browse/FLINK-33798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825898#comment-17825898 ] Rui Fan edited comment on FLINK-33798 at 3/14/24 10:13 AM: --- Me

[jira] [Resolved] (FLINK-33798) Automatically clean up rocksdb logs when the task failover.

[ https://issues.apache.org/jira/browse/FLINK-33798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33798. - Fix Version/s: 1.17.3 1.18.2 1.19.1 Resolution: Fixed > Aut

[jira] [Commented] (FLINK-34389) JdbcAutoscalerStateStore explicitly writes update_time

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

[jira] [Resolved] (FLINK-34389) JdbcAutoscalerStateStore explicitly writes update_time

[ https://issues.apache.org/jira/browse/FLINK-34389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34389. - Fix Version/s: kubernetes-operator-1.8.0 (was: kubernetes-operator-1.9.0) R

[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&focusedCommentId=17776993#comment-17776993 ] Rui Fan commented on FLINK-33287: - Thanks [~martijnvisser] for this comment! {quote}We'

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

Rui Fan created FLINK-33315: --- Summary: Optimize memory usage of large StreamOperator Key: FLINK-33315 URL: https://issues.apache.org/jira/browse/FLINK-33315 Project: Flink Issue Type: Improvement

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

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

[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&focusedCommentId=1129#comment-1129 ] Rui Fan commented on FLINK-33287: - {quote} If at a point in time you want to add support

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

Rui Fan created FLINK-33316: --- Summary: Avoid unnecessary heavy getStreamOperatorFactory Key: FLINK-33316 URL: https://issues.apache.org/jira/browse/FLINK-33316 Project: Flink Issue Type: Sub-task

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

[ https://issues.apache.org/jira/browse/FLINK-33316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33316: Description: This Jira focus on avoid unnecessary heavy getStreamOperatorFactory, it can optimize the mem

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

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

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

Rui Fan created FLINK-33317: --- Summary: Add cleaning mechanism for StreamConfig#SERIALIZEDUDF Key: FLINK-33317 URL: https://issues.apache.org/jira/browse/FLINK-33317 Project: Flink Issue Type: Sub-t

[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&focusedCommentId=1137#comment-1137 ] Rui Fan commented on FLINK-33315: - Thanks [~weizhong] for the analysis together. :) > O

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

[ https://issues.apache.org/jira/browse/FLINK-33315 ] Rui Fan deleted comment on FLINK-33315: - was (Author: fanrui): Thanks [~weizhong] for the analysis together. :) > 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&focusedCommentId=1141#comment-1141 ] Rui Fan commented on FLINK-33315: - Thanks [~zhongwei] for the analysis together.:) > Op

[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&focusedCommentId=1174#comment-1174 ] Rui Fan commented on FLINK-33315: - Hi [~pnowojski] , you may be interested in this optim

[jira] [Assigned] (FLINK-33320) Support Dynamic Logger Level Adjustment

[ https://issues.apache.org/jira/browse/FLINK-33320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33320: --- Assignee: RocMarshal > Support Dynamic Logger Level Adjustment > --

[jira] [Commented] (FLINK-33320) Support Dynamic Logger Level Adjustment

[ https://issues.apache.org/jira/browse/FLINK-33320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1527#comment-1527 ] Rui Fan commented on FLINK-33320: - The FLIP is necessary due to some of new rest apis ar

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

[ https://issues.apache.org/jira/browse/FLINK-33316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33316: Fix Version/s: 1.19.0 > Avoid unnecessary heavy getStreamOperatorFactory > ---

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

[ https://issues.apache.org/jira/browse/FLINK-33316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1547#comment-1547 ] Rui Fan commented on FLINK-33316: - Hi [~lindong] , this extra memory cost is introduced

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

[ https://issues.apache.org/jira/browse/FLINK-33316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1554#comment-1554 ] Rui Fan commented on FLINK-33316: - Thanks for your explanation! I will cherry-pick them

[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&focusedCommentId=1554#comment-1554 ] Rui Fan edited comment on FLINK-33316 at 10/20/23 3:51 AM: --- Th

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