[jira] [Created] (FLINK-34957) JDBC Autoscaler event handler throws Column 'message' cannot be null

Rui Fan created FLINK-34957: --- Summary: JDBC Autoscaler event handler throws Column 'message' cannot be null Key: FLINK-34957 URL: https://issues.apache.org/jira/browse/FLINK-34957 Project: Flink

[jira] [Updated] (FLINK-34957) JDBC Autoscaler event handler throws Column 'message' cannot be null

[ https://issues.apache.org/jira/browse/FLINK-34957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34957: Description: JDBC Autoscaler event handler doesn't allow the event message is null, but the message may b

[jira] [Resolved] (FLINK-34957) JDBC Autoscaler event handler throws Column 'message' cannot be null

[ https://issues.apache.org/jira/browse/FLINK-34957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34957. - Resolution: Fixed > JDBC Autoscaler event handler throws Column 'message' cannot be null >

[jira] [Commented] (FLINK-34957) JDBC Autoscaler event handler throws Column 'message' cannot be null

[ https://issues.apache.org/jira/browse/FLINK-34957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831712#comment-17831712 ] Rui Fan commented on FLINK-34957: - Merged master(1.9.0) via: 9119d73a904bc5a5eb675c2edff

[jira] [Commented] (FLINK-34956) The config type is wrong for Duration

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

[jira] [Updated] (FLINK-34956) The config type is wrong for Duration

[ https://issues.apache.org/jira/browse/FLINK-34956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34956: Fix Version/s: 1.19.1 > The config type is wrong for Duration > - > >

[jira] [Resolved] (FLINK-34956) The config type is wrong for Duration

[ https://issues.apache.org/jira/browse/FLINK-34956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34956. - Resolution: Fixed > The config type is wrong for Duration > - > >

[jira] [Assigned] (FLINK-34980) Translate overview document into Chinese

[ https://issues.apache.org/jira/browse/FLINK-34980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-34980: --- Assignee: Caican Cai > Translate overview document into Chinese > -

[jira] [Assigned] (FLINK-34970) Translate architecture documents into Chinese

[ https://issues.apache.org/jira/browse/FLINK-34970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-34970: --- Assignee: Caican Cai > Translate architecture documents into Chinese >

[jira] [Assigned] (FLINK-34932) Translate concepts of Flink-Kubernetes-Operator documentation

[ https://issues.apache.org/jira/browse/FLINK-34932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-34932: --- Assignee: Caican Cai > Translate concepts of Flink-Kubernetes-Operator documentation >

[jira] [Assigned] (FLINK-35006) Use try with-resource for StandaloneAutoscalerExecutor

[ https://issues.apache.org/jira/browse/FLINK-35006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35006: --- Assignee: Kirill Plugatarev > Use try with-resource for StandaloneAutoscalerExecutor >

[jira] [Created] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

Rui Fan created FLINK-35040: --- Summary: The performance of serializerHeavyString regresses since April 3 Key: FLINK-35040 URL: https://issues.apache.org/jira/browse/FLINK-35040 Project: Flink Issue

[jira] [Updated] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35040: Attachment: screenshot-1.png > The performance of serializerHeavyString regresses since April 3 >

[jira] [Updated] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35040: Description: The performance of serializerHeavyString regresses since April 3, and had not yet recovered

[jira] [Updated] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35040: Description: The performance of serializerHeavyString regresses since April 3, and had not yet recovered

[jira] [Commented] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835662#comment-17835662 ] Rui Fan commented on FLINK-35040: - After running a series of benchmarks, I found FLINK-3

[jira] [Comment Edited] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835662#comment-17835662 ] Rui Fan edited comment on FLINK-35040 at 4/10/24 10:17 AM: --- Af

[jira] [Commented] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835959#comment-17835959 ] Rui Fan commented on FLINK-35040: - Also, I revert [163b9cca6d2ccac0ff89dd985e3232667ddf

[jira] [Commented] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed

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

[jira] [Updated] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35040: Attachment: image-2024-04-11-12-53-53-353.png > The performance of serializerHeavyString regresses since A

[jira] [Commented] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836001#comment-17836001 ] Rui Fan commented on FLINK-35040: - Hi [~slfan1989] , would you mind helping take a look

[jira] [Commented] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836000#comment-17836000 ] Rui Fan commented on FLINK-35040: - {quote}Can this result be consistently reproduced? {q

[jira] [Commented] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836091#comment-17836091 ] Rui Fan commented on FLINK-35040: - Hi [~slfan1989] , thanks for your quick feedback! FL

[jira] [Comment Edited] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

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

[jira] [Comment Edited] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

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

[jira] [Commented] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837041#comment-17837041 ] Rui Fan commented on FLINK-35040: - Thanks [~slfan1989] and [~rmetzger] for the comment!

[jira] [Created] (FLINK-35105) Support setting default Autoscaler options at autoscaler standalone level

Rui Fan created FLINK-35105: --- Summary: Support setting default Autoscaler options at autoscaler standalone level Key: FLINK-35105 URL: https://issues.apache.org/jira/browse/FLINK-35105 Project: Flink

[jira] [Commented] (FLINK-34906) Don't start autoscaling when some tasks are not running

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

[jira] [Resolved] (FLINK-34906) Don't start autoscaling when some tasks are not running

[ https://issues.apache.org/jira/browse/FLINK-34906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34906. - Resolution: Fixed > Don't start autoscaling when some tasks are not running > --

[jira] [Updated] (FLINK-34907) jobRunningTs should be the timestamp that all tasks are running

[ https://issues.apache.org/jira/browse/FLINK-34907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34907: Description: Currently, we consider the timestamp that JobStatus is changed to RUNNING as jobRunningTs. B

[jira] [Commented] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

[ https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839906#comment-17839906 ] Rui Fan commented on FLINK-35088: - Thanks [~martijnvisser] for the ping, I will take a l

[jira] [Commented] (FLINK-35187) FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines

[ https://issues.apache.org/jira/browse/FLINK-35187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839921#comment-17839921 ] Rui Fan commented on FLINK-35187: - Hi [~lsy] , I wanna check with you, will this great f

[jira] [Resolved] (FLINK-34970) Translate architecture documents into Chinese

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

[jira] [Commented] (FLINK-34970) Translate architecture documents into Chinese

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

[jira] [Created] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed

Rui Fan created FLINK-35215: --- Summary: The performance of serializerKryo and serializerKryoWithoutRegistration are regressed Key: FLINK-35215 URL: https://issues.apache.org/jira/browse/FLINK-35215 Project:

[jira] [Commented] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed

[ https://issues.apache.org/jira/browse/FLINK-35215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839949#comment-17839949 ] Rui Fan commented on FLINK-35215: - Hi [~q.xu] , would you mind taking a look this issue

[jira] [Commented] (FLINK-35187) FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines

[ https://issues.apache.org/jira/browse/FLINK-35187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839977#comment-17839977 ] Rui Fan commented on FLINK-35187: - Thank you very much for the feedback and update! > F

[jira] [Commented] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

[ https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17840040#comment-17840040 ] Rui Fan commented on FLINK-35088: - Hi [~elon] , thanks for reporting this issue. It mak

[jira] [Commented] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

[ https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17840043#comment-17840043 ] Rui Fan commented on FLINK-35088: - [~elon] thank you for your volunteering, assigned. >

[jira] [Assigned] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

[ https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35088: --- Assignee: elon_X > watermark alignment maxAllowedWatermarkDrift and updateInterval param need > ch

[jira] [Comment Edited] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

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

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

[ https://issues.apache.org/jira/browse/FLINK-35909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35909: --- Assignee: João Boto > JdbcFilterPushdownPreparedStatementVisitorTest fails > --

[jira] [Commented] (FLINK-33386) Support tasks balancing at slot level for Default Scheduler

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

[jira] [Resolved] (FLINK-33386) Support tasks balancing at slot level for Default Scheduler

[ https://issues.apache.org/jira/browse/FLINK-33386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33386. - Fix Version/s: 2.0.0 Resolution: Fixed > Support tasks balancing at slot level for Default Schedu

[jira] [Updated] (FLINK-35926) During rescale, AdaptiveScheduler has incorrect judgment logic for the max parallelism.

[ https://issues.apache.org/jira/browse/FLINK-35926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35926: Priority: Major (was: Blocker) > During rescale, AdaptiveScheduler has incorrect judgment logic for the m

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

[ https://issues.apache.org/jira/browse/FLINK-35896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35896. - Fix Version/s: kubernetes-operator-1.10.0 Resolution: Fixed Merged to main(1.10.0) via: 7d90ce871

[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: Fix Version/s: jdbc-3.3.0 > JdbcFilterPushdownPreparedStatementVisitorTest fails > ---

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-35909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35909: --- Assignee: He Wang (was: João Boto) > JdbcFilterPushdownPreparedStatementVisitorTest fails > --

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

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

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

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

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

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

[jira] [Commented] (FLINK-34572) JDBC: Support OceanBase catalog

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

[jira] [Resolved] (FLINK-34572) JDBC: Support OceanBase catalog

[ https://issues.apache.org/jira/browse/FLINK-34572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34572. - Fix Version/s: jdbc-3.3.0 Assignee: He Wang Resolution: Fixed > JDBC: Support OceanBase

[jira] [Assigned] (FLINK-35966) Introduce the TASKS for TaskManagerLoadBalanceMode enum

[ https://issues.apache.org/jira/browse/FLINK-35966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35966: --- Assignee: RocMarshal > Introduce the TASKS for TaskManagerLoadBalanceMode enum > --

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-35678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17870069#comment-17870069 ] Rui Fan edited comment on FLINK-35678 at 8/2/24 8:33 AM: - Merged

[jira] [Commented] (FLINK-35978) adapt labelling of boring cyborg

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

[jira] [Resolved] (FLINK-35978) adapt labelling of boring cyborg

[ https://issues.apache.org/jira/browse/FLINK-35978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35978. - Fix Version/s: jdbc-3.3.0 Assignee: João Boto Resolution: Fixed > adapt labelling of bor

[jira] [Resolved] (FLINK-34215) Support fine-grained configuration to control filter push down for JDBC Connector

[ https://issues.apache.org/jira/browse/FLINK-34215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34215. - Fix Version/s: jdbc-3.3.0 (was: jdbc-3.1.3) Assignee: Jiabao Sun R

[jira] [Updated] (FLINK-34214) FLIP-377: Support fine-grained configuration to control filter push down for Table/SQL Sources

[ https://issues.apache.org/jira/browse/FLINK-34214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34214: Fix Version/s: jdbc-3.3.0 (was: jdbc-3.1.3) > FLIP-377: Support fine-grained config

[jira] [Resolved] (FLINK-33875) Support slots wait mechanism at DeclarativeSlotPoolBridge side for Default Scheduler

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

[jira] [Created] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

Rui Fan created FLINK-36018: --- Summary: Support lazy scale down to avoid frequent rescaling Key: FLINK-36018 URL: https://issues.apache.org/jira/browse/FLINK-36018 Project: Flink Issue Type: Improve

[jira] [Commented] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

[ https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872182#comment-17872182 ] Rui Fan commented on FLINK-36018: - Hey [~gyfora] [~mxm] , would you mind checking whethe

[jira] [Commented] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

[ https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1787#comment-1787 ] Rui Fan commented on FLINK-36018: - Thanks [~heigebupahei] and [~mxm]  for the quick feed

[jira] [Commented] (FLINK-36022) When scaling.enabled =false, adjust the values ​​​​of some parameters to provide bette recommendation values.

[ https://issues.apache.org/jira/browse/FLINK-36022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872234#comment-17872234 ] Rui Fan commented on FLINK-36022: - Thanks [~heigebupahei] for reporting this issue and f

[jira] [Comment Edited] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

[ https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1787#comment-1787 ] Rui Fan edited comment on FLINK-36018 at 8/9/24 8:26 AM: - Thanks

[jira] [Commented] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

[ https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872261#comment-17872261 ] Rui Fan commented on FLINK-36018: - Hey [~mxm] , I thought about it again. I found job.a

[jira] [Updated] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

[ https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-36018: Description: {*}{color:#de350b}Core idea{color}{*}: Make scaling up sensitive to prevent lags, and make s

[jira] [Commented] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

[ https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872769#comment-17872769 ] Rui Fan commented on FLINK-36018: - Hey [~gyfora]  {quote}It makes sense to introduce a n

[jira] [Commented] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

[ https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872831#comment-17872831 ] Rui Fan commented on FLINK-36018: - {quote}Based on your proposals how about simply `job

[jira] [Assigned] (FLINK-36039) Support clean historical event handler records in autoscaler jdbc plugin

[ https://issues.apache.org/jira/browse/FLINK-36039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-36039: --- Assignee: RocMarshal > Support clean historical event handler records in autoscaler jdbc plugin > -

[jira] [Created] (FLINK-36071) Using System.nanoTime to measure the elapsed time instead of System.currentTimeMillis

Rui Fan created FLINK-36071: --- Summary: Using System.nanoTime to measure the elapsed time instead of System.currentTimeMillis Key: FLINK-36071 URL: https://issues.apache.org/jira/browse/FLINK-36071 Project:

[jira] [Updated] (FLINK-36071) Using System.nanoTime to measure the elapsed time instead of System.currentTimeMillis

[ https://issues.apache.org/jira/browse/FLINK-36071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-36071: Description: A series of flink metrics are using the System.currentTimeMillis[1] to measure the elapsed t

[jira] [Updated] (FLINK-36071) Using System.nanoTime to measure the elapsed time instead of System.currentTimeMillis

[ https://issues.apache.org/jira/browse/FLINK-36071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-36071: Description: A series of flink metrics are using the System.currentTimeMillis[1] to measure the elapsed t

[jira] [Updated] (FLINK-36071) Using System.nanoTime to measure the elapsed time instead of System.currentTimeMillis

[ https://issues.apache.org/jira/browse/FLINK-36071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-36071: Description: A series of flink metrics are using the System.currentTimeMillis[1] to measure the elapsed t

[jira] [Created] (FLINK-36106) t_flink_autoscaler_event_handler is not cleaned after each testing

Rui Fan created FLINK-36106: --- Summary: t_flink_autoscaler_event_handler is not cleaned after each testing Key: FLINK-36106 URL: https://issues.apache.org/jira/browse/FLINK-36106 Project: Flink Iss

[jira] [Resolved] (FLINK-36106) t_flink_autoscaler_event_handler is not cleaned after each testing

[ https://issues.apache.org/jira/browse/FLINK-36106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-36106. - Fix Version/s: kubernetes-operator-1.10.0 Resolution: Fixed Merged to main(1.10.0) via: 84c1934d6

[jira] [Updated] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

[ https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-36018: Description: {*}{color:#de350b}Core idea{color}{*}: Make scaling up sensitive to prevent lags, and make s

[jira] [Updated] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

[ https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-36018: Description: {*}{color:#de350b}Core idea{color}{*}: Make scaling up sensitive to prevent lags, and make s

[jira] [Created] (FLINK-36129) Autoscaler is compatible with Flink 1.20

Rui Fan created FLINK-36129: --- Summary: Autoscaler is compatible with Flink 1.20 Key: FLINK-36129 URL: https://issues.apache.org/jira/browse/FLINK-36129 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-36129) Autoscaler is compatible with Flink 1.20

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

[jira] [Resolved] (FLINK-36039) Support clean historical event handler records in JDBC event handler

[ https://issues.apache.org/jira/browse/FLINK-36039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-36039. - Fix Version/s: kubernetes-operator-1.10.0 Resolution: Fixed Merged to main(1.10.0) via: 6a426b2ff

[jira] [Resolved] (FLINK-36170) Bump assertj-core version

[ https://issues.apache.org/jira/browse/FLINK-36170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-36170. - Fix Version/s: kubernetes-operator-1.10.0 Resolution: Fixed Merged to main(1.10.0) via: 2ee9f20c3

[jira] [Assigned] (FLINK-36170) Bump assertj-core version

[ https://issues.apache.org/jira/browse/FLINK-36170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-36170: --- Assignee: Siddharth R > Bump assertj-core version > - > > K

[jira] [Commented] (FLINK-36192) Optimize the logic to make it the common divisor of the partition number of the data source when determining the parallelism of the source task.

[ https://issues.apache.org/jira/browse/FLINK-36192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878688#comment-17878688 ] Rui Fan commented on FLINK-36192: - Thanks [~heigebupahei] for reporting this issue! {quo

[jira] [Created] (FLINK-36201) StateLocalitySlotAssigner will be used even if local recovery is disable for Adaptive Scheduler

Rui Fan created FLINK-36201: --- Summary: StateLocalitySlotAssigner will be used even if local recovery is disable for Adaptive Scheduler Key: FLINK-36201 URL: https://issues.apache.org/jira/browse/FLINK-36201

[jira] [Updated] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-36201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-36201: Summary: StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Schedul

[jira] [Commented] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-36201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878729#comment-17878729 ] Rui Fan commented on FLINK-36201: - Hey [~roman]  [~dmvk] , would you mind taking a look

[jira] [Updated] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-36201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-36201: Description: SlotSharingSlotAllocator created the StateLocalitySlotAssigner[1] instead of DefaultSlotAssi

[jira] [Commented] (FLINK-36192) Optimize the logic to make it the common divisor of the partition number of the data source when determining the parallelism of the source task.

[ https://issues.apache.org/jira/browse/FLINK-36192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878735#comment-17878735 ] Rui Fan commented on FLINK-36192: - {quote}{color:#172b4d}like  {color}{*}eventType='{*}{

[jira] [Assigned] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-36201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-36201: --- Assignee: Rui Fan > StateLocalitySlotAssigner should be only used when local recovery is enabled >

[jira] [Commented] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-36201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878756#comment-17878756 ] Rui Fan commented on FLINK-36201: - Thanks [~dmvk] for the quick feedback, I have filed a

[jira] [Commented] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-36201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879136#comment-17879136 ] Rui Fan commented on FLINK-36201: - {quote} This makes me wonder whether we should defaul

[jira] [Comment Edited] (FLINK-36201) StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-36201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879116#comment-17879116 ] Rui Fan edited comment on FLINK-36201 at 9/4/24 8:34 AM: - master

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

[ https://issues.apache.org/jira/browse/FLINK-33625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879750#comment-17879750 ] Rui Fan commented on FLINK-33625: - I'm curious is there any difference between logging d

[jira] [Resolved] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

[ https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-36018. - Fix Version/s: kubernetes-operator-1.10.0 Resolution: Fixed Merged to main(1.10.0) via: 968a57851

[jira] [Commented] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

[ https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17880472#comment-17880472 ] Rui Fan commented on FLINK-36018: - Thanks [~mxm] for the review! {quote}Looking forward

[jira] [Resolved] (FLINK-36281) resourceSpec replace SlotSharingGroupUtils.extractResourceSpec(slotSharingGroup)

[ https://issues.apache.org/jira/browse/FLINK-36281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-36281. - Fix Version/s: 2.0-preview (was: 2.0.0) Assignee: Caican Cai Resol

[jira] [Updated] (FLINK-29481) Show JobType on WebUI

[ https://issues.apache.org/jira/browse/FLINK-29481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-29481: Description: This is an umbrella Jira of [FLIP-441|https://cwiki.apache.org/confluence/x/agrPEQ] (was: Fl

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