[jira] [Updated] (FLINK-33461) Support streaming related semantics for the new jdbc source

2024-03-22 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33461: --- Summary: Support streaming related semantics for the new jdbc source (was: Support stream related

[jira] [Commented] (FLINK-34564) Unstable test case TableSourceITCase#testTableHintWithLogicalTableScanReuse

2024-03-01 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822758#comment-17822758 ] RocMarshal commented on FLINK-34564: Thx a lot for [~lincoln.86xy] your comments, I'll check the

[jira] [Commented] (FLINK-34564) Unstable test case TableSourceITCase#testTableHintWithLogicalTableScanReuse

2024-03-01 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822744#comment-17822744 ] RocMarshal commented on FLINK-34564: I discovered this issue while assisting [~fanrui]  in fixing a

[jira] [Created] (FLINK-34564) Unstable test case TableSourceITCase#testTableHintWithLogicalTableScanReuse

2024-03-01 Thread RocMarshal (Jira)
RocMarshal created FLINK-34564: -- Summary: Unstable test case TableSourceITCase#testTableHintWithLogicalTableScanReuse Key: FLINK-34564 URL: https://issues.apache.org/jira/browse/FLINK-34564 Project:

[jira] [Updated] (FLINK-34249) Remove DefaultSlotTracker related logic.

2024-01-29 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-34249: --- Description: pre step: https://issues.apache.org/jira/browse/FLINK-34174 The main reason for

[jira] [Commented] (FLINK-34249) Remove DefaultSlotTracker related logic.

2024-01-26 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811463#comment-17811463 ] RocMarshal commented on FLINK-34249: pre step: https://issues.apache.org/jira/browse/FLINK-34174

[jira] [Created] (FLINK-34249) Remove DefaultSlotTracker related logic.

2024-01-26 Thread RocMarshal (Jira)
RocMarshal created FLINK-34249: -- Summary: Remove DefaultSlotTracker related logic. Key: FLINK-34249 URL: https://issues.apache.org/jira/browse/FLINK-34249 Project: Flink Issue Type: Technical

[jira] [Commented] (FLINK-34174) Remove SlotMatchingStrategy related logic

2024-01-21 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809232#comment-17809232 ] RocMarshal commented on FLINK-34174: The main reason for initiating this ticket is 

[jira] [Created] (FLINK-34174) Remove SlotMatchingStrategy related logic

2024-01-20 Thread RocMarshal (Jira)
RocMarshal created FLINK-34174: -- Summary: Remove SlotMatchingStrategy related logic Key: FLINK-34174 URL: https://issues.apache.org/jira/browse/FLINK-34174 Project: Flink Issue Type: Technical

[jira] [Created] (FLINK-34102) Invalid configuration when using 'env.log.max' on yarn application mode

2024-01-15 Thread RocMarshal (Jira)
RocMarshal created FLINK-34102: -- Summary: Invalid configuration when using 'env.log.max' on yarn application mode Key: FLINK-34102 URL: https://issues.apache.org/jira/browse/FLINK-34102 Project: Flink

[jira] [Updated] (FLINK-33988) Invalid configuration when using initialized root logger level on yarn application mode

2024-01-04 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33988: --- Description: relevant https://issues.apache.org/jira/browse/FLINK-33166 When I set env. log.

[jira] [Updated] (FLINK-33988) Invalid configuration when using initialized root logger level on yarn application mode

2024-01-04 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33988: --- Description: from https://issues.apache.org/jira/browse/FLINK-33166 When I set env. log.

[jira] [Updated] (FLINK-33988) Invalid configuration when using initialized root logger level on yarn application mode

2024-01-04 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33988: --- Description: from https://issues.apache.org/jira/browse/FLINK-33166 When I set env. log.

[jira] [Updated] (FLINK-33988) Invalid configuration when using initialized root logger level on yarn application mode

2024-01-04 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33988: --- Description: from https://issues.apache.org/jira/browse/FLINK-33166 > Invalid configuration when

[jira] [Created] (FLINK-33988) Invalid configuration when using initialized root logger level on yarn application mode

2024-01-04 Thread RocMarshal (Jira)
RocMarshal created FLINK-33988: -- Summary: Invalid configuration when using initialized root logger level on yarn application mode Key: FLINK-33988 URL: https://issues.apache.org/jira/browse/FLINK-33988

[jira] [Updated] (FLINK-33959) Unstable test case ChangelogRecoveryITCase.testMaterialization on 1.17 release branch

2023-12-29 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33959: --- Summary: Unstable test case ChangelogRecoveryITCase.testMaterialization on 1.17 release branch

[jira] [Commented] (FLINK-33959) Unstable test case

2023-12-29 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801149#comment-17801149 ] RocMarshal commented on FLINK-33959: Hi, could someone help to check it ? Thank you very much :) >

[jira] [Updated] (FLINK-33959) Unstable test case

2023-12-29 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33959: --- Attachment: image-2023-12-29-19-51-35-996.png > Unstable test case > --- > >

[jira] [Updated] (FLINK-33959) Unstable test case

2023-12-29 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33959: --- Description:

[jira] [Created] (FLINK-33959) Unstable test case

2023-12-29 Thread RocMarshal (Jira)
RocMarshal created FLINK-33959: -- Summary: Unstable test case Key: FLINK-33959 URL: https://issues.apache.org/jira/browse/FLINK-33959 Project: Flink Issue Type: Bug Components: Tests

[jira] [Updated] (FLINK-33959) Unstable test case

2023-12-29 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33959: --- Description:

[jira] [Updated] (FLINK-33947) Fix bugs about prefix in DelegatingConfiguration

2023-12-27 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33947: --- Summary: Fix bugs about prefix in DelegatingConfiguration (was: Fix bugs in

[jira] [Commented] (FLINK-33947) Fix bugs in DelegatingConfiguration missed the prefix mapping

2023-12-27 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800805#comment-17800805 ] RocMarshal commented on FLINK-33947: > And how about allow prefix is empty? SGTM +1. > Fix bugs in

[jira] [Commented] (FLINK-33947) Fix bugs in DelegatingConfiguration missed the prefix mapping

2023-12-27 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800794#comment-17800794 ] RocMarshal commented on FLINK-33947: hi, [~fanrui] thanks for your attention. I want to set the

[jira] [Comment Edited] (FLINK-33947) Fix bugs in DelegatingConfiguration missed the prefix mapping

2023-12-27 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800774#comment-17800774 ] RocMarshal edited comment on FLINK-33947 at 12/27/23 2:09 PM: -- Before

[jira] [Commented] (FLINK-33947) Fix bugs in DelegatingConfiguration missed the prefix mapping

2023-12-27 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800774#comment-17800774 ] RocMarshal commented on FLINK-33947: Before officially starting the repair, there are two issues

[jira] [Created] (FLINK-33947) Fix bugs in DelegatingConfiguration missed the prefix mapping

2023-12-26 Thread RocMarshal (Jira)
RocMarshal created FLINK-33947: -- Summary: Fix bugs in DelegatingConfiguration missed the prefix mapping Key: FLINK-33947 URL: https://issues.apache.org/jira/browse/FLINK-33947 Project: Flink

[jira] [Comment Edited] (FLINK-29050) [JUnit5 Migration] Module: flink-hadoop-compatibility

2023-12-20 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798856#comment-17798856 ] RocMarshal edited comment on FLINK-29050 at 12/20/23 8:08 AM: -- Based on

[jira] [Comment Edited] (FLINK-29050) [JUnit5 Migration] Module: flink-hadoop-compatibility

2023-12-20 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798856#comment-17798856 ] RocMarshal edited comment on FLINK-29050 at 12/20/23 8:07 AM: -- Based on

[jira] [Commented] (FLINK-29050) [JUnit5 Migration] Module: flink-hadoop-compatibility

2023-12-20 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798856#comment-17798856 ] RocMarshal commented on FLINK-29050: Based on

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

2023-12-18 Thread RocMarshal (Jira)
RocMarshal created FLINK-33875: -- Summary: Support slots wait mechanism at DeclarativeSlotPoolBridge side for Default Scheduler Key: FLINK-33875 URL: https://issues.apache.org/jira/browse/FLINK-33875

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

2023-12-18 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33874: --- Summary: Support resource request wait mechanism at DefaultDeclarativeSlotPool side for Default

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

2023-12-18 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33874: --- Parent: FLINK-31757 Issue Type: Sub-task (was: New Feature) > Introduce resource request

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

2023-12-18 Thread RocMarshal (Jira)
RocMarshal created FLINK-33874: -- Summary: Introduce resource request wait mechanism at DefaultDeclarativeSlotPool side for Default Scheduler Key: FLINK-33874 URL: https://issues.apache.org/jira/browse/FLINK-33874

[jira] [Updated] (FLINK-33853) [JUnit5 Migration] Migrate Junit5 for DeclarativeSlotPoolBridge test classes of runtime module

2023-12-14 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33853: --- Summary: [JUnit5 Migration] Migrate Junit5 for DeclarativeSlotPoolBridge test classes of runtime

[jira] [Created] (FLINK-33853) Migrate Junit5 for DefaultDeclarativeSlotPool test classes

2023-12-14 Thread RocMarshal (Jira)
RocMarshal created FLINK-33853: -- Summary: Migrate Junit5 for DefaultDeclarativeSlotPool test classes Key: FLINK-33853 URL: https://issues.apache.org/jira/browse/FLINK-33853 Project: Flink Issue

[jira] [Updated] (FLINK-33853) [JUnit5 Migration] Migrate Junit5 for DefaultDeclarativeSlotPool test classes of runtime module

2023-12-14 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33853: --- Summary: [JUnit5 Migration] Migrate Junit5 for DefaultDeclarativeSlotPool test classes of runtime

[jira] [Created] (FLINK-33653) Introduce a benchmark for balanced tasks scheduling

2023-11-26 Thread RocMarshal (Jira)
RocMarshal created FLINK-33653: -- Summary: Introduce a benchmark for balanced tasks scheduling Key: FLINK-33653 URL: https://issues.apache.org/jira/browse/FLINK-33653 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-25420) Port JDBC Source to new Source API (FLIP-27)

2023-11-05 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782972#comment-17782972 ] RocMarshal edited comment on FLINK-25420 at 11/5/23 10:09 AM: -- Hi,

[jira] [Commented] (FLINK-25420) Port JDBC Source to new Source API (FLIP-27)

2023-11-05 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782972#comment-17782972 ] RocMarshal commented on FLINK-25420: Hi, [~martijnvisser] [~eskabetxe]  I have divided the work

[jira] [Comment Edited] (FLINK-33463) Support the implementation of dynamic source tables based on the new source

2023-11-05 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782969#comment-17782969 ] RocMarshal edited comment on FLINK-33463 at 11/5/23 9:36 AM: - The ticket is

[jira] [Commented] (FLINK-33463) Support the implementation of dynamic source tables based on the new source

2023-11-05 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782969#comment-17782969 ] RocMarshal commented on FLINK-33463: The ticket is mainly to do the two items: 1. Support the

[jira] [Commented] (FLINK-33459) Support the new source that keeps the same functionality as the original JDBC input format

2023-11-05 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782968#comment-17782968 ] RocMarshal commented on FLINK-33459: The ticket is mainly to do the two items: 1. Support the new

[jira] [Created] (FLINK-33462) Sort out the document page about the new Jdbc source.

2023-11-05 Thread RocMarshal (Jira)
RocMarshal created FLINK-33462: -- Summary: Sort out the document page about the new Jdbc source. Key: FLINK-33462 URL: https://issues.apache.org/jira/browse/FLINK-33462 Project: Flink Issue

[jira] [Updated] (FLINK-33459) Support the new source that keeps the same functionality as the original JDBC input format

2023-11-05 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33459: --- Summary: Support the new source that keeps the same functionality as the original JDBC input format

[jira] [Created] (FLINK-33463) Support the implementation of dynamic source tables based on the new source

2023-11-05 Thread RocMarshal (Jira)
RocMarshal created FLINK-33463: -- Summary: Support the implementation of dynamic source tables based on the new source Key: FLINK-33463 URL: https://issues.apache.org/jira/browse/FLINK-33463 Project:

[jira] [Created] (FLINK-33461) Support stream related semantics for the new jdbc source

2023-11-05 Thread RocMarshal (Jira)
RocMarshal created FLINK-33461: -- Summary: Support stream related semantics for the new jdbc source Key: FLINK-33461 URL: https://issues.apache.org/jira/browse/FLINK-33461 Project: Flink Issue

[jira] [Updated] (FLINK-33459) Support the new source that supports the same functionality as the original JDBC input format

2023-11-05 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33459: --- Summary: Support the new source that supports the same functionality as the original JDBC input

[jira] [Updated] (FLINK-33459) Port the new source that supports the same functionality as the original JDBC input format

2023-11-05 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33459: --- Summary: Port the new source that supports the same functionality as the original JDBC input format

[jira] [Created] (FLINK-33460) Support more authentication connection types such as the secret.

2023-11-05 Thread RocMarshal (Jira)
RocMarshal created FLINK-33460: -- Summary: Support more authentication connection types such as the secret. Key: FLINK-33460 URL: https://issues.apache.org/jira/browse/FLINK-33460 Project: Flink

[jira] [Created] (FLINK-33459) Introduce the new source that supports the same functionality as the original JDBC input format

2023-11-05 Thread RocMarshal (Jira)
RocMarshal created FLINK-33459: -- Summary: Introduce the new source that supports the same functionality as the original JDBC input format Key: FLINK-33459 URL: https://issues.apache.org/jira/browse/FLINK-33459

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

2023-11-03 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782503#comment-17782503 ] RocMarshal commented on FLINK-33448: Thanks for the reply~ :) > Introduce a new configuration item

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

2023-11-03 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33448: --- Description: Introduce a new configuration item 'taskmanager.load-balance.mode' and make it 

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

2023-11-03 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782487#comment-17782487 ] RocMarshal commented on FLINK-33448: The Jira ticket resulted from

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

2023-11-03 Thread RocMarshal (Jira)
RocMarshal created FLINK-33448: -- Summary: Introduce a new configuration item 'taskmanager.load-balance.mode' Key: FLINK-33448 URL: https://issues.apache.org/jira/browse/FLINK-33448 Project: Flink

[jira] [Updated] (FLINK-33389) Support tasks balancing at slot level for Adaptive Scheduler

2023-10-30 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33389: --- Summary: Support tasks balancing at slot level for Adaptive Scheduler (was: Introduce the assigner

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

2023-10-30 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33386: --- Summary: Support tasks balancing at slot level for Default Scheduler (was: Introduce the strategy

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

2023-10-30 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33388: --- Summary: Support tasks balancing at TM level for Default Scheduler (was: Implement tasks to

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

2023-10-30 Thread RocMarshal (Jira)
RocMarshal created FLINK-33392: -- Summary: Add the documentation page for balanced tasks scheduling Key: FLINK-33392 URL: https://issues.apache.org/jira/browse/FLINK-33392 Project: Flink Issue

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

2023-10-30 Thread RocMarshal (Jira)
RocMarshal created FLINK-33391: -- Summary: Support tasks balancing at TM level for Adaptive Scheduler Key: FLINK-33391 URL: https://issues.apache.org/jira/browse/FLINK-33391 Project: Flink Issue

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

2023-10-30 Thread RocMarshal (Jira)
RocMarshal created FLINK-33390: -- Summary: Support slot balancing at TM level for Adaptive Scheduler Key: FLINK-33390 URL: https://issues.apache.org/jira/browse/FLINK-33390 Project: Flink Issue

[jira] [Updated] (FLINK-33388) Implement tasks to taskmanagers balancing for the Default Scheduler

2023-10-30 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33388: --- Summary: Implement tasks to taskmanagers balancing for the Default Scheduler (was: Implement slots

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

2023-10-30 Thread RocMarshal (Jira)
RocMarshal created FLINK-33389: -- Summary: Introduce the assigner for Adaptive Scheduler to pursuit task balancing based slots level Key: FLINK-33389 URL: https://issues.apache.org/jira/browse/FLINK-33389

[jira] [Created] (FLINK-33388) Implement slots to taskmanagers balancing for the Default Scheduler

2023-10-30 Thread RocMarshal (Jira)
RocMarshal created FLINK-33388: -- Summary: Implement slots to taskmanagers balancing for the Default Scheduler Key: FLINK-33388 URL: https://issues.apache.org/jira/browse/FLINK-33388 Project: Flink

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

2023-10-30 Thread RocMarshal (Jira)
RocMarshal created FLINK-33387: -- Summary: Introduce the abstraction and the interface about loading Key: FLINK-33387 URL: https://issues.apache.org/jira/browse/FLINK-33387 Project: Flink Issue

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

2023-10-30 Thread RocMarshal (Jira)
RocMarshal created FLINK-33386: -- Summary: Introduce the strategy for Default Scheduler to pursue tasks balancing based on slots level. Key: FLINK-33386 URL: https://issues.apache.org/jira/browse/FLINK-33386

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

2023-10-19 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1522#comment-1522 ] RocMarshal commented on FLINK-33320: Hi, [~fanrui] Thank you for the assign~ I'm willing to

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

2023-10-19 Thread RocMarshal (Jira)
RocMarshal created FLINK-33320: -- Summary: Support Dynamic Logger Level Adjustment Key: FLINK-33320 URL: https://issues.apache.org/jira/browse/FLINK-33320 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-25420) Port JDBC Source to new Source API (FLIP-27)

2023-10-13 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17774850#comment-17774850 ] RocMarshal commented on FLINK-25420: Hi, [~eskabetxe] [~martijnvisser] Thank you very much for

[jira] [Updated] (FLINK-31757) Support Balanced Tasks Scheduling

2023-09-25 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-31757: --- Summary: Support Balanced Tasks Scheduling (was: Optimize Flink un-balanced tasks scheduling) >

[jira] [Updated] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-09-03 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-31757: --- Labels: pull-request-available (was: pull-request-available stale-assigned) > Optimize Flink

[jira] [Comment Edited] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-08-01 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750078#comment-17750078 ] RocMarshal edited comment on FLINK-31757 at 8/2/23 3:54 AM: Hi,

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-08-01 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750078#comment-17750078 ] RocMarshal commented on FLINK-31757: Hi, [~heigebupahei] Thanks for your attention. we've updated

[jira] [Commented] (FLINK-29050) [JUnit5 Migration] Module: flink-hadoop-compatibility

2023-06-30 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17739030#comment-17739030 ] RocMarshal commented on FLINK-29050: Hello, sorry for the late update. Could someone help to review

[jira] [Commented] (FLINK-20628) Port RabbitMQ Sources to FLIP-27 API

2023-06-20 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17735249#comment-17735249 ] RocMarshal commented on FLINK-20628: [~martijnvisser] Yes,I'd like to do it. There's nothing better.

[jira] [Commented] (FLINK-20628) Port RabbitMQ Sources to FLIP-27 API

2023-06-19 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17734964#comment-17734964 ] RocMarshal commented on FLINK-20628: [~martijnvisser] Thank you for your reply. Yes, I'd like to

[jira] [Commented] (FLINK-20628) Port RabbitMQ Sources to FLIP-27 API

2023-06-18 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733990#comment-17733990 ] RocMarshal commented on FLINK-20628: Hi, [pscls|https://github.com/pscls] Thank you very much for

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-05-29 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727041#comment-17727041 ] RocMarshal commented on FLINK-31757: I have compiled a draft  

[jira] [Comment Edited] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-05-29 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727041#comment-17727041 ] RocMarshal edited comment on FLINK-31757 at 5/29/23 8:25 AM: - I have

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-04-23 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715580#comment-17715580 ] RocMarshal commented on FLINK-31757: I am still working on this jira, and due to the Labor Day

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-04-13 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711897#comment-17711897 ] RocMarshal commented on FLINK-31757: Thanks for your [~Weijie Guo] sorted concise and precise

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-04-13 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711895#comment-17711895 ] RocMarshal commented on FLINK-31757: Thank you  [~fanrui] & [~huwh] very much. I'll prepare a design

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-04-13 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711875#comment-17711875 ] RocMarshal commented on FLINK-31757: Based on this problem, we has achieved balanced task

[jira] [Reopened] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-04-13 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal reopened FLINK-31757: > Optimize Flink un-balanced tasks scheduling > --- > >

[jira] [Comment Edited] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-04-13 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711776#comment-17711776 ] RocMarshal edited comment on FLINK-31757 at 4/13/23 9:24 AM: - h1. Problem

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-04-13 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711776#comment-17711776 ] RocMarshal commented on FLINK-31757: h1. Problem description and impact Supposed a Job has 21

[jira] [Commented] (FLINK-29672) Support oracle catalog

2023-04-10 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710104#comment-17710104 ] RocMarshal commented on FLINK-29672: It looks like a duplicated Jira as

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-04-09 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710022#comment-17710022 ] RocMarshal commented on FLINK-31757: [~Weijie Guo] Glad to get your attention and reminding~:) I'll

[jira] [Updated] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-04-09 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-31757: --- Summary: Optimize Flink un-balanced tasks scheduling (was: Optimize Flink tasks un-balanced

[jira] [Created] (FLINK-31757) Optimize Flink tasks un-balanced scheduling

2023-04-09 Thread RocMarshal (Jira)
RocMarshal created FLINK-31757: -- Summary: Optimize Flink tasks un-balanced scheduling Key: FLINK-31757 URL: https://issues.apache.org/jira/browse/FLINK-31757 Project: Flink Issue Type:

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2023-02-22 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692057#comment-17692057 ] RocMarshal commented on FLINK-29816: As described in the historical comments and description text,

[jira] [Updated] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2023-02-22 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-29816: --- Attachment: image-2023-02-22-17-26-06-200.png > Userfunction exception in ProcessWindowFunction was

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2023-02-20 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691339#comment-17691339 ] RocMarshal commented on FLINK-29816: [~Weijie Guo] thanks for the reply. I'm interested in it. May I

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

2023-02-20 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691132#comment-17691132 ] RocMarshal commented on FLINK-29816: hi, [~Weijie Guo] Any process on this issue ?  > Userfunction

[jira] [Commented] (FLINK-30511) Ignore the Exception in user-timer Triggerble when recover form state.

2023-01-05 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654895#comment-17654895 ] RocMarshal commented on FLINK-30511: Thank you [~Weijie Guo] [~kevin.cyj] . Looking forward to the

[jira] [Commented] (FLINK-25421) Port JDBC Sink to new Unified Sink API (FLIP-143)

2022-12-27 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652232#comment-17652232 ] RocMarshal commented on FLINK-25421: Get it. Thanks a lot~ [~eskabetxe]  > Port JDBC Sink to new

[jira] [Updated] (FLINK-30511) Ignore the Exception in user-timer Triggerble when recover form state.

2022-12-27 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-30511: --- Description: * Code segment: {code:java} public class OnTimerDemo { public static void

[jira] [Created] (FLINK-30511) Ignore the Exception in user-timer Triggerble when recover form state.

2022-12-27 Thread RocMarshal (Jira)
RocMarshal created FLINK-30511: -- Summary: Ignore the Exception in user-timer Triggerble when recover form state. Key: FLINK-30511 URL: https://issues.apache.org/jira/browse/FLINK-30511 Project: Flink

[jira] [Commented] (FLINK-25421) Port JDBC Sink to new Unified Sink API (FLIP-143)

2022-12-21 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17651050#comment-17651050 ] RocMarshal commented on FLINK-25421: Hi [~eskabetxe] Is here any new progress about sink ? > Port

[jira] [Commented] (FLINK-26999) Introduce ClickHouse Connector

2022-10-10 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615467#comment-17615467 ] RocMarshal commented on FLINK-26999: [~rmetzger] , The FLIP current content should be deprecated

  1   2   3   >