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

[ https://issues.apache.org/jira/browse/FLINK-35765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-35765. --- Resolution: Duplicate Thanks [~mapohl] for picking it up. Following it in FLINK-29344 sounds make sense to

[jira] [Resolved] (FLINK-34082) Remove deprecated methods of Configuration in 2.0

[ https://issues.apache.org/jira/browse/FLINK-34082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34082. - Fix Version/s: 2.0-preview (was: 2.0.0) Resolution: Fixed > Remove depreca

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

[ https://issues.apache.org/jira/browse/FLINK-34079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34079. - Fix Version/s: 2.0-preview (was: 2.0.0) Resolution: Fixed > FLIP-405: Migr

[jira] [Commented] (FLINK-34082) Remove deprecated methods of Configuration in 2.0

[ https://issues.apache.org/jira/browse/FLINK-34082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884218#comment-17884218 ] Rui Fan commented on FLINK-34082: - Merged to 2.0 via: * 16b8ed3fabc64fef387b641695472a9

[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] [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-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-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] [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-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] [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] [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-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] [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-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: Summary: StateLocalitySlotAssigner should be only used when local recovery is enabled for Adaptive Schedul

[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] [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] [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] [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] [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-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] [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] [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] [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] [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] [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-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] [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] [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] [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] [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=17872261#comment-17872261 ] Rui Fan commented on FLINK-36018: - Hey [~mxm] , I thought about it again. I found job.a

[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-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] [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-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] [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] [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] [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-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] [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] [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] [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] [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] [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-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] [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-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] [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] [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] [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-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] [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] [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-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-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] [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] [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] [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] [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] [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] [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] [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] [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-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-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-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-35370) Create a temp module to test backward compatibility

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

  1   2   3   4   5   6   7   8   9   10   >