[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17910918#comment-17910918 ] RocMarshal commented on FLINK-33977: [The more discussion detail could be viewed in

[jira] [Updated] (FLINK-36691) Support configuration to enable tasks balancing at slot level for Default Scheduler

[ https://issues.apache.org/jira/browse/FLINK-36691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-36691: --- Description: First support balanced task allocation in the Default Scheduler slot dimension in strea

[jira] [Created] (FLINK-36691) Support configuration to enable tasks balancing at slot level for Default Scheduler

RocMarshal created FLINK-36691: -- Summary: Support configuration to enable tasks balancing at slot level for Default Scheduler Key: FLINK-36691 URL: https://issues.apache.org/jira/browse/FLINK-36691 Proje

[jira] [Updated] (FLINK-36426) Introduce the strategy for adaptive scheduler to control state locality preferred or minimal task executors preferred when matching resource requests and slots

[ https://issues.apache.org/jira/browse/FLINK-36426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-36426: --- Description: as discussed in [https://github.com/apache/flink/pull/25218#discussion_r1771187666] j

[jira] [Updated] (FLINK-36426) Introduce the strategy for adaptive scheduler to control state locality preferred or minimal task executors preferred when matching resource requests and slots

[ https://issues.apache.org/jira/browse/FLINK-36426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-36426: --- Description: as discussed in [https://github.com/apache/flink/pull/25218#discussion_r1771187666] j

[jira] (FLINK-36426) Introduce the strategy for adaptive scheduler to control state locality preferred or minimal task executors preferred when matching resource requests and slots

[ https://issues.apache.org/jira/browse/FLINK-36426 ] RocMarshal deleted comment on FLINK-36426: was (Author: rocmarshal): as discussed in [https://github.com/apache/flink/pull/25218#discussion_r1771187666] jobmanager.adaptive-scheduler.state

[jira] [Commented] (FLINK-36426) Introduce the strategy for adaptive scheduler to control state locality preferred or minimal task executors preferred when matching resource requests and slots

[ https://issues.apache.org/jira/browse/FLINK-36426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886954#comment-17886954 ] RocMarshal commented on FLINK-36426: as discussed in [https://github.com/apache/fli

[jira] [Created] (FLINK-36426) Introduce the strategy for adaptive scheduler to control state locality preferred or minimal task executors preferred when matching resource requests and slots

RocMarshal created FLINK-36426: -- Summary: Introduce the strategy for adaptive scheduler to control state locality preferred or minimal task executors preferred when matching resource requests and slots Key: FLINK-36426

[jira] [Updated] (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 ] RocMarshal updated FLINK-36039: --- Description: Currently, the autoscaler generates a large amount of historical data for event handle

[jira] [Updated] (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 ] RocMarshal updated FLINK-36039: --- Description: Currently, the autoscaler generates a large amount of historical data for event handle

[jira] [Updated] (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 ] RocMarshal updated FLINK-36039: --- Description: Currently, the autoscaler generates a large amount of historical data for event handle

[jira] [Updated] (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 ] RocMarshal updated FLINK-36039: --- Summary: Support clean historical event handler records in JDBC event handler (was: Support clean h

[jira] [Updated] (FLINK-36039) Support clean historical event handler records in autoscaler standalone

[ https://issues.apache.org/jira/browse/FLINK-36039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-36039: --- Description: Currently, the autoscaler generates a large amount of historical data for event handle

[jira] [Updated] (FLINK-36039) Support clean historical event handler records in autoscaler standalone

[ https://issues.apache.org/jira/browse/FLINK-36039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-36039: --- Description: Currently, the autoscaler generates a large amount of historical data for event handle

[jira] [Updated] (FLINK-36039) Support clean historical event handler records in autoscaler standalone

[ https://issues.apache.org/jira/browse/FLINK-36039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-36039: --- Summary: Support clean historical event handler records in autoscaler standalone (was: Support clea

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

RocMarshal created FLINK-36039: -- Summary: Support clean historical event handler records in autoscaler jdbc plugin Key: FLINK-36039 URL: https://issues.apache.org/jira/browse/FLINK-36039 Project: Flink

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

RocMarshal created FLINK-35966: -- Summary: Introduce the TASKS for TaskManagerLoadBalanceMode enum Key: FLINK-35966 URL: https://issues.apache.org/jira/browse/FLINK-35966 Project: Flink Issue Typ

[jira] [Created] (FLINK-35918) Migrate the Time to Duration for the flink-runtime module.

RocMarshal created FLINK-35918: -- Summary: Migrate the Time to Duration for the flink-runtime module. Key: FLINK-35918 URL: https://issues.apache.org/jira/browse/FLINK-35918 Project: Flink Issue

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17868012#comment-17868012 ] RocMarshal commented on FLINK-33977: Thanks [~Zhanghao Chen] for reporting it. Thi

[jira] [Updated] (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 ] RocMarshal updated FLINK-33977: --- Attachment: screenshot-1.png > Adaptive scheduler may not minimize the number of TMs during downscal

[jira] [Commented] (FLINK-35811) Add the documentation sections to describe the usage of users-oriented interfaces

[ https://issues.apache.org/jira/browse/FLINK-35811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864945#comment-17864945 ] RocMarshal commented on FLINK-35811: Hi, [~eskabetxe] Would you like to contribute f

[jira] [Created] (FLINK-35811) Add the documentation sections to describe the usage of users-oriented interfaces

RocMarshal created FLINK-35811: -- Summary: Add the documentation sections to describe the usage of users-oriented interfaces Key: FLINK-35811 URL: https://issues.apache.org/jira/browse/FLINK-35811 Project

[jira] [Commented] (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=17863688#comment-17863688 ] RocMarshal commented on FLINK-35750: Thanks [~fanrui] for the review & reminding :)

[jira] [Updated] (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 ] RocMarshal updated FLINK-35765: --- Description: As described in https://docs.google.com/document/d/1WBGcyMSEVoi8LYI9z6RLVWiNtvGIv9qj_Zq

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

[ https://issues.apache.org/jira/browse/FLINK-35765 ] RocMarshal deleted comment on FLINK-35765: was (Author: rocmarshal): Hi, [~fanrui] I conducted a brief survey for the pre-change of the improvement, in order to better evolve this feature,

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=17863188#comment-17863188 ] RocMarshal edited comment on FLINK-35765 at 7/5/24 9:58 AM:

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17863188#comment-17863188 ] RocMarshal commented on FLINK-35765: Hi, [~fanrui] I conducted a brief survey for t

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17863184#comment-17863184 ] RocMarshal commented on FLINK-35765: I'd like to contribute for it. I'm still workin

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

RocMarshal created FLINK-35765: -- Summary: Support Fine Grained Resource Specifications for Adaptive Scheduler Key: FLINK-35765 URL: https://issues.apache.org/jira/browse/FLINK-35765 Project: Flink

[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=17862722#comment-17862722 ] RocMarshal edited comment on FLINK-35750 at 7/3/24 10:54 AM: -

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

RocMarshal created FLINK-35750: -- Summary: The latency marker metrics aren't updated after failover Key: FLINK-35750 URL: https://issues.apache.org/jira/browse/FLINK-35750 Project: Flink Issue Ty

[jira] [Commented] (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=17862722#comment-17862722 ] RocMarshal commented on FLINK-35750: I'd like to contribute for the jira. Could som

[jira] [Commented] (FLINK-35733) Change org.jetbrains.annotations.NotNull to javax.annotation.Nonnull

[ https://issues.apache.org/jira/browse/FLINK-35733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861059#comment-17861059 ] RocMarshal commented on FLINK-35733: I'd like to contribute for the ticket. May I ge

[jira] [Created] (FLINK-35733) Change org.jetbrains.annotations.NotNull to javax.annotation.Nonnull

RocMarshal created FLINK-35733: -- Summary: Change org.jetbrains.annotations.NotNull to javax.annotation.Nonnull Key: FLINK-35733 URL: https://issues.apache.org/jira/browse/FLINK-35733 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-33463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854916#comment-17854916 ] RocMarshal commented on FLINK-33463: Hi, [~fanrui] [~eskabetxe]  Should we split the

[jira] [Commented] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

[ https://issues.apache.org/jira/browse/FLINK-35496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851899#comment-17851899 ] RocMarshal commented on FLINK-35496: - I carefully read the discussion and found tha

[jira] [Commented] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

[ https://issues.apache.org/jira/browse/FLINK-35496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851897#comment-17851897 ] RocMarshal commented on FLINK-35496: >> BTW, should we update the Experimental to Pu

[jira] [Commented] (FLINK-35516) Update the Experimental annotation to PublicEvolving for files connector

[ https://issues.apache.org/jira/browse/FLINK-35516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851896#comment-17851896 ] RocMarshal commented on FLINK-35516: I'd like to contribute for the Jira. Could some

[jira] [Created] (FLINK-35516) Update the Experimental annotation to PublicEvolving for files connector

RocMarshal created FLINK-35516: -- Summary: Update the Experimental annotation to PublicEvolving for files connector Key: FLINK-35516 URL: https://issues.apache.org/jira/browse/FLINK-35516 Project: Flink

[jira] [Commented] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

[ https://issues.apache.org/jira/browse/FLINK-35496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851881#comment-17851881 ] RocMarshal commented on FLINK-35496: Thanks [~fanrui] for the checking and [~leonard

[jira] [Created] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

RocMarshal created FLINK-35496: -- Summary: The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving Key: FLINK-35496 URL: https://issues.apache.org/jira/browse/FLINK-35496

[jira] [Updated] (FLINK-35469) Unstable test case 'testProject' of JdbcDynamicTableSourceITCase

[ https://issues.apache.org/jira/browse/FLINK-35469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-35469: --- Labels: JDBC (was: ) > Unstable test case 'testProject' of JdbcDynamicTableSourceITCase > -

[jira] [Created] (FLINK-35469) Unstable test case 'testProject' of JdbcDynamicTableSourceITCase

RocMarshal created FLINK-35469: -- Summary: Unstable test case 'testProject' of JdbcDynamicTableSourceITCase Key: FLINK-35469 URL: https://issues.apache.org/jira/browse/FLINK-35469 Project: Flink

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

[ 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 streaming relate

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

[ https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847199#comment-17847199 ] RocMarshal commented on FLINK-20628: Thanks [~chalixar] for taking over it ! (y) >

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

[ https://issues.apache.org/jira/browse/FLINK-33462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844238#comment-17844238 ] RocMarshal commented on FLINK-33462: Hi, [~martijnvisser]  There's a minor item to c

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

[ https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17843202#comment-17843202 ] RocMarshal commented on FLINK-20628: Could someone help review this one ? thank a lo

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

[ https://issues.apache.org/jira/browse/FLINK-33463 ] RocMarshal deleted comment on FLINK-33463: was (Author: rocmarshal): The ticket is mainly to do the three items: 1. Support the implementation of dynamic source/factories tables based on the

[jira] [Updated] (FLINK-35176) Support property authentication connection for JDBC catalog & dynamic table

[ https://issues.apache.org/jira/browse/FLINK-35176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-35176: --- Parent: FLINK-25420 Issue Type: Sub-task (was: Improvement) > Support property authenticati

[jira] [Created] (FLINK-35176) Support property authentication connection for JDBC catalog & dynamic table

RocMarshal created FLINK-35176: -- Summary: Support property authentication connection for JDBC catalog & dynamic table Key: FLINK-35176 URL: https://issues.apache.org/jira/browse/FLINK-35176 Project: Flin

[jira] [Updated] (FLINK-33460) Support property authentication connection.

[ https://issues.apache.org/jira/browse/FLINK-33460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33460: --- Summary: Support property authentication connection. (was: Support more authentication connection t

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

[ https://issues.apache.org/jira/browse/FLINK-29050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798856#comment-17798856 ] RocMarshal edited comment on FLINK-29050 at 4/11/24 10:56 AM:

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-34564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822758#comment-17822758 ] RocMarshal commented on FLINK-34564: Thx a lot for [~lincoln.86xy] your comments, I'

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

[ https://issues.apache.org/jira/browse/FLINK-34564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822744#comment-17822744 ] RocMarshal commented on FLINK-34564: I discovered this issue while assisting [~fanru

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

RocMarshal created FLINK-34564: -- Summary: Unstable test case TableSourceITCase#testTableHintWithLogicalTableScanReuse Key: FLINK-34564 URL: https://issues.apache.org/jira/browse/FLINK-34564 Project: Flin

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-34249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811463#comment-17811463 ] RocMarshal commented on FLINK-34249: pre step: https://issues.apache.org/jira/browse

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

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 De

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

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

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

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 D

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

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

[ 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. level=

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

[ 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. level=DEBU

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

[ 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. level=DE

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

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

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

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 P

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

[ 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 (was

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

[ https://issues.apache.org/jira/browse/FLINK-33959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17801149#comment-17801149 ] RocMarshal commented on FLINK-33959: Hi, could someone help to check it ? Thank you

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-33959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33959: --- Description: [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=55940&view=logs

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

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

[ https://issues.apache.org/jira/browse/FLINK-33959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33959: --- Description: [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=55940&view=logs

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800805#comment-17800805 ] RocMarshal commented on FLINK-33947: > And how about allow prefix is empty? SGTM +1

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

[ https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800794#comment-17800794 ] RocMarshal commented on FLINK-33947: hi, [~fanrui] thanks for your attention. I wan

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800774#comment-17800774 ] RocMarshal commented on FLINK-33947: Before officially starting the repair, there ar

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

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 I

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-29050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798856#comment-17798856 ] RocMarshal commented on FLINK-29050: Based on [https://github.com/apache/flink/pull/

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

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 Proj

[jira] [Updated] (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 ] RocMarshal updated FLINK-33874: --- Summary: Support resource request wait mechanism at DefaultDeclarativeSlotPool side for Default Sche

[jira] [Updated] (FLINK-33874) Introduce 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 ] RocMarshal updated FLINK-33874: --- Parent: FLINK-31757 Issue Type: Sub-task (was: New Feature) > Introduce resource request wa

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

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

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

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

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

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

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

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: S

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

[ https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17782972#comment-17782972 ] RocMarshal edited comment on FLINK-25420 at 11/5/23 10:09 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17782972#comment-17782972 ] RocMarshal commented on FLINK-25420: Hi, [~martijnvisser] [~eskabetxe]  I have divi

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

[ https://issues.apache.org/jira/browse/FLINK-33463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17782969#comment-17782969 ] RocMarshal edited comment on FLINK-33463 at 11/5/23 9:36 AM: -

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

[ https://issues.apache.org/jira/browse/FLINK-33463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17782969#comment-17782969 ] RocMarshal commented on FLINK-33463: The ticket is mainly to do the two items: 1. Su

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

[ https://issues.apache.org/jira/browse/FLINK-33459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17782968#comment-17782968 ] RocMarshal commented on FLINK-33459: The ticket is mainly to do the two items: 1. Su

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

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 Type:

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

[ 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

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: Flin

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

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 Ty

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

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

  1   2   3   >