[jira] [Updated] (FLINK-14658) Drop ".returns()" for TypeInformation in the DataStream API

2024-09-03 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-14658: --- Fix Version/s: 3.0.0 (was: 2.0-preview) > Drop ".return

[jira] [Commented] (FLINK-9798) Drop canEqual() from TypeInformation, TypeSerializer, etc.

2024-09-03 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878731#comment-17878731 ] Weijie Guo commented on FLINK-9798: --- This method is not deprecated before, move to

[jira] [Updated] (FLINK-9798) Drop canEqual() from TypeInformation, TypeSerializer, etc.

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-9798: -- Parent Issue: FLINK-36200 (was: FLINK-3957) > Drop canEqual() from TypeInformation, TypeSeriali

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

2024-09-02 Thread Rui Fan (Jira)
[ 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

[jira] [Updated] (FLINK-32597) Drop Yarn specific get rest endpoints

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-32597: - Parent: FLINK-36200 Issue Type: Sub-task (was: Improvement) > Drop Yarn specific

[jira] [Updated] (FLINK-32597) Drop Yarn specific get rest endpoints

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-32597: - Fix Version/s: 3.0.0 > Drop Yarn specific get rest endpoi

[jira] [Updated] (FLINK-32597) Drop Yarn specific get rest endpoints

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-32597: - Labels: (was: 2.0-related) > Drop Yarn specific get rest endpoi

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

2024-09-02 Thread Rui Fan (Jira)
[ 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

[jira] [Updated] (FLINK-32688) Remove deprecated exception history fields

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-32688: - Priority: Blocker (was: Major) > Remove deprecated exception history fie

[jira] [Updated] (FLINK-9798) Drop canEqual() from TypeInformation, TypeSerializer, etc.

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-9798: -- Fix Version/s: 3.0.0 (was: 2.0-preview) > Drop canEqual() from TypeInformat

[jira] [Updated] (FLINK-32377) 2.0 Breaking REST API changes

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-32377: - Priority: Blocker (was: Major) > 2.0 Breaking REST API chan

[jira] [Updated] (FLINK-32377) 2.0 Breaking REST API changes

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-32377: - Fix Version/s: 2.0-preview (was: 2.0.0) > 2.0 Breaking REST API chan

[jira] [Updated] (FLINK-7691) Remove ClassTag in Scala DataSet API

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-7691: -- Fix Version/s: (was: 2.0-preview) > Remove ClassTag in Scala DataSet

[jira] [Updated] (FLINK-32198) Enforce single maxExceptions query parameter

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-32198: - Parent Issue: FLINK-36200 (was: FLINK-32377) > Enforce single maxExceptions query parame

[jira] [Closed] (FLINK-7691) Remove ClassTag in Scala DataSet API

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-7691. - Resolution: Invalid This is invalid as we will remove all Scale API in 2.0. > Remove ClassTag in Sc

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

2024-09-02 Thread Rui Fan (Jira)
[ 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

[jira] [Updated] (FLINK-15787) Upgrade REST API response to remove '-' from key names.

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15787: - Parent Issue: FLINK-36200 (was: FLINK-32377) > Upgrade REST API response to remove '

[jira] [Updated] (FLINK-29863) Properly handle NaN/Infinity in OpenAPI spec

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29863: - Parent Issue: FLINK-36200 (was: FLINK-32377) > Properly handle NaN/Infinity in OpenAPI s

[jira] [Closed] (FLINK-3991) Remove deprecated configuration keys from ConfigConstants

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-3991. - Fix Version/s: (was: 2.0-preview) Resolution: Duplicate Superseded by https

[jira] [Updated] (FLINK-32198) Enforce single maxExceptions query parameter

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-32198: - Labels: pull-request-available (was: 2.0-related pull-request-available) > Enforce sin

[jira] [Updated] (FLINK-32198) Enforce single maxExceptions query parameter

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-32198: - Fix Version/s: 3.0.0 (was: 2.0.0) > Enforce single maxExceptions qu

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

2024-09-02 Thread Rui Fan (Jira)
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] [Assigned] (FLINK-32383) 2.0 Breaking configuration changes

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-32383: -- Assignee: Junrui Li > 2.0 Breaking configuration chan

[jira] [Assigned] (FLINK-33750) Remove deprecated config options.

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-33750: -- Assignee: Xuannan Su (was: Junrui Li) > Remove deprecated config opti

[jira] [Updated] (FLINK-29863) Properly handle NaN/Infinity in OpenAPI spec

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29863: - Labels: (was: 2.0-related) > Properly handle NaN/Infinity in OpenAPI s

[jira] [Updated] (FLINK-29863) Properly handle NaN/Infinity in OpenAPI spec

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29863: - Fix Version/s: 3.0.0 (was: 2.0.0) > Properly handle NaN/Infinity

[jira] [Assigned] (FLINK-32384) Remove deprecated configuration keys which violate YAML spec

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-32384: -- Assignee: Junrui Li > Remove deprecated configuration keys which violate YAML s

[jira] [Updated] (FLINK-15787) Upgrade REST API response to remove '-' from key names.

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15787: - Fix Version/s: 3.0.0 > Upgrade REST API response to remove '-' f

[jira] [Assigned] (FLINK-33678) Remove configuration getters/setters that return/set complex Java objects

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-33678: -- Assignee: Junrui Li > Remove configuration getters/setters that return/set complex J

[jira] [Assigned] (FLINK-36185) Remove RuntimeContext#getExecutionConfig

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-36185: -- Assignee: Junrui Li > Remove RuntimeContext#getExecutionCon

[jira] [Updated] (FLINK-15787) Upgrade REST API response to remove '-' from key names.

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-15787: - Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was: 2.0-related

[jira] [Updated] (FLINK-36185) Remove RuntimeContext#getExecutionConfig

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36185: --- Priority: Blocker (was: Major) > Remove RuntimeContext#getExecutionCon

[jira] [Updated] (FLINK-33749) Remove deprecated getter method in Configuration.

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33749: --- Priority: Blocker (was: Major) > Remove deprecated getter method in Configurat

[jira] [Updated] (FLINK-32384) Remove deprecated configuration keys which violate YAML spec

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32384: --- Priority: Blocker (was: Major) > Remove deprecated configuration keys which violate YAML s

[jira] [Updated] (FLINK-32383) 2.0 Breaking configuration changes

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32383: --- Affects Version/s: 2.0-preview > 2.0 Breaking configuration chan

[jira] [Updated] (FLINK-33678) Remove configuration getters/setters that return/set complex Java objects

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33678: --- Priority: Blocker (was: Major) > Remove configuration getters/setters that return/set complex J

[jira] [Updated] (FLINK-33750) Remove deprecated config options.

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33750: --- Priority: Blocker (was: Major) > Remove deprecated config opti

[jira] [Updated] (FLINK-36199) Remove RuntimeContext#getExecutionConfig

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36199: --- Affects Version/s: (was: 2.0-preview) > Remove RuntimeContext#getExecutionCon

[jira] [Closed] (FLINK-36199) Remove RuntimeContext#getExecutionConfig

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-36199. -- Fix Version/s: (was: 2.0-preview) Resolution: Invalid > Remove RuntimeCont

[jira] [Created] (FLINK-36200) Breaking changes for Flink 3.0

2024-09-02 Thread Xintong Song (Jira)
Xintong Song created FLINK-36200: Summary: Breaking changes for Flink 3.0 Key: FLINK-36200 URL: https://issues.apache.org/jira/browse/FLINK-36200 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-36199) Remove RuntimeContext#getExecutionConfig

2024-09-02 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-36199: -- Summary: Remove RuntimeContext#getExecutionConfig Key: FLINK-36199 URL: https://issues.apache.org/jira/browse/FLINK-36199 Project: Flink Issue Type: Sub-task

[jira] [Resolved] (FLINK-36011) Generalize RescaleManager to become StateTransitionManager

2024-09-02 Thread Zdenek Tison (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zdenek Tison resolved FLINK-36011. -- Resolution: Implemented > Generalize RescaleManager to become StateTransitionMana

[jira] [Updated] (FLINK-3957) Breaking changes for Flink 2.0

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-3957: -- Priority: Blocker (was: Minor) > Breaking changes for Flink

[jira] [Updated] (FLINK-3957) Breaking changes for Flink 2.0

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-3957: -- Labels: 2.0-related (was: 2.0-related auto-deprioritized-major) > Breaking changes for Flink

[jira] [Updated] (FLINK-6912) Consider changing the RichFunction#open method signature to take no arguments.

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-6912: -- Priority: Blocker (was: Not a Priority) > Consider changing the RichFunction#open method signature

[jira] [Updated] (FLINK-36198) Remove legacy hybrid shuffle mode

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36198: --- Priority: Blocker (was: Major) > Remove legacy hybrid shuffle m

[jira] [Updated] (FLINK-36198) Remove legacy hybrid shuffle mode

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36198: --- Fix Version/s: 2.0-preview > Remove legacy hybrid shuffle m

[jira] [Updated] (FLINK-36198) Remove legacy hybrid shuffle mode

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36198: --- Issue Type: Technical Debt (was: Bug) > Remove legacy hybrid shuffle m

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

2024-09-02 Thread yuanfenghu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878715#comment-17878715 ] yuanfenghu commented on FLINK-36192: {quote}{color:#172b4d}In addition to the a

[jira] [Updated] (FLINK-36198) Remove legacy hybrid shuffle mode

2024-09-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36198: --- Labels: pull-request-available (was: ) > Remove legacy hybrid shuffle m

[jira] [Updated] (FLINK-6912) Consider changing the RichFunction#open method signature to take no arguments.

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-6912: -- Affects Version/s: 2.0.0 > Consider changing the RichFunction#open method signature to take

[jira] [Assigned] (FLINK-6912) Consider changing the RichFunction#open method signature to take no arguments.

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-6912: - Assignee: Weijie Guo > Consider changing the RichFunction#open method signature to take

[jira] [Closed] (FLINK-3610) Scala DataStream#addSink returns Java DataStreamSink

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-3610. - Resolution: Invalid > Scala DataStream#addSink returns Java DataStreamS

[jira] [Commented] (FLINK-3610) Scala DataStream#addSink returns Java DataStreamSink

2024-09-02 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878703#comment-17878703 ] Weijie Guo commented on FLINK-3610: --- I'm going to close this as we will r

[jira] [Created] (FLINK-36198) Remove legacy hybrid shuffle mode

2024-09-02 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-36198: -- Summary: Remove legacy hybrid shuffle mode Key: FLINK-36198 URL: https://issues.apache.org/jira/browse/FLINK-36198 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-35387) PG CDC source support heart beat

2024-09-02 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878696#comment-17878696 ] Hongshun Wang commented on FLINK-35387: --- I'd like to do it. > P

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

2024-09-02 Thread Rui Fan (Jira)
[ 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 i

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

2024-09-02 Thread yuanfenghu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878679#comment-17878679 ] yuanfenghu commented on FLINK-36192: > To fix the issue, we may have to

[jira] [Comment Edited] (FLINK-36051) JDBC sink doesn't re-prepare invalidated prepared statements

2024-09-02 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878674#comment-17878674 ] Jiabao Sun edited comment on FLINK-36051 at 9/3/24 1:2

[jira] [Resolved] (FLINK-36051) JDBC sink doesn't re-prepare invalidated prepared statements

2024-09-02 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-36051. Fix Version/s: jdbc-3.3.0 Assignee: Sergei Morozov Resolution: Fixed fixed via

[jira] [Updated] (FLINK-36197) Bump curator-test version

2024-09-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36197: --- Labels: pull-request-available (was: ) > Bump curator-test vers

[jira] [Updated] (FLINK-36197) Bump curator-test version

2024-09-02 Thread Siddharth R (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Siddharth R updated FLINK-36197: Description: Bump curator-test version to latest (5.7.0) to remediate the vulnerabilities in the

[jira] [Created] (FLINK-36197) Bump curator-test version

2024-09-02 Thread Siddharth R (Jira)
Siddharth R created FLINK-36197: --- Summary: Bump curator-test version Key: FLINK-36197 URL: https://issues.apache.org/jira/browse/FLINK-36197 Project: Flink Issue Type: Improvement

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

2024-09-02 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878606#comment-17878606 ] Maximilian Michels commented on FLINK-36192: Thanks for reporting

[jira] [Updated] (FLINK-35580) Improvements and fix ingestDB recovery mode related bugs

2024-09-02 Thread Stefan Richter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-35580: --- Summary: Improvements and fix ingestDB recovery mode related bugs (was: Fix ingestDB

[jira] [Closed] (FLINK-36179) Bump log4j version

2024-09-02 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-36179. -- Fix Version/s: kubernetes-operator-1.10.0 Assignee: Siddharth R Resolution: Fixed

[jira] [Updated] (FLINK-36011) Generalize RescaleManager to become StateTransitionManager

2024-09-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36011: --- Labels: pull-request-available (was: ) > Generalize RescaleManager to bec

[jira] [Updated] (FLINK-36195) Migrate DDB Streams specific retry configuration to flink-connector-base

2024-09-02 Thread Abhi Gupta (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhi Gupta updated FLINK-36195: --- Component/s: Connectors / DynamoDB (was: API / DataStream) > Migrate

[jira] [Created] (FLINK-36196) Have a UX for customer where customer just gives table name and gets the stream arn which is enabled

2024-09-02 Thread Abhi Gupta (Jira)
Abhi Gupta created FLINK-36196: -- Summary: Have a UX for customer where customer just gives table name and gets the stream arn which is enabled Key: FLINK-36196 URL: https://issues.apache.org/jira/browse/FLINK-36196

[jira] [Created] (FLINK-36195) Migrate DDB Streams specific retry configuration to flink-connector-base

2024-09-02 Thread Abhi Gupta (Jira)
Abhi Gupta created FLINK-36195: -- Summary: Migrate DDB Streams specific retry configuration to flink-connector-base Key: FLINK-36195 URL: https://issues.apache.org/jira/browse/FLINK-36195 Project: Flink

[jira] [Updated] (FLINK-24078) Remove brackets around variables

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24078: - Fix Version/s: 2.0-preview (was: 2.0.0) > Remove brackets aro

[jira] [Updated] (FLINK-19034) Remove deprecated StreamExecutionEnvironment#set/getNumberOfExecutionRetries

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-19034: - Fix Version/s: 2.0-preview (was: 2.0.0) > Remove depreca

[jira] [Updated] (FLINK-13926) `ProcessingTimeSessionWindows` and `EventTimeSessionWindows` should be generic

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13926: - Fix Version/s: 2.0-preview (was: 2.0.0) > `ProcessingTimeSessionWind

[jira] [Updated] (FLINK-6375) Fix LongValue hashCode

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-6375: Fix Version/s: 2.0-preview > Fix LongValue hashC

[jira] [Updated] (FLINK-9529) Do not expose keyed operations on ProcessFunction.Context

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-9529: Fix Version/s: 2.0-preview > Do not expose keyed operations on ProcessFunction.Cont

[jira] [Updated] (FLINK-36194) Shutdown hook for ExecutionGraphInfo store runs concurrently to cluster shutdown hook causing race conditions

2024-09-02 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-36194: -- Labels: starter (was: ) > Shutdown hook for ExecutionGraphInfo store runs concurrently

[jira] [Updated] (FLINK-14658) Drop ".returns()" for TypeInformation in the DataStream API

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14658: - Fix Version/s: 2.0-preview (was: 2.0.0) > Drop ".return

[jira] [Updated] (FLINK-9798) Drop canEqual() from TypeInformation, TypeSerializer, etc.

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-9798: Fix Version/s: 2.0-preview > Drop canEqual() from TypeInformation, TypeSerializer,

[jira] [Updated] (FLINK-5875) Use TypeComparator.hash() instead of Object.hashCode() for keying in DataStream API

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-5875: Fix Version/s: 2.0-preview (was: 2.0.0) > Use TypeComparator.hash() inst

[jira] [Updated] (FLINK-5346) Remove all ad-hoc config loading via GlobalConfiguration

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-5346: Fix Version/s: 2.0-preview (was: 2.0.0) > Remove all ad-hoc config load

[jira] [Updated] (FLINK-6912) Consider changing the RichFunction#open method signature to take no arguments.

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-6912: Fix Version/s: 2.0-preview (was: 2.0.0) > Consider changing

[jira] [Updated] (FLINK-7691) Remove ClassTag in Scala DataSet API

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-7691: Fix Version/s: 2.0-preview (was: 2.0.0) > Remove ClassTag in Scala Data

[jira] [Updated] (FLINK-5336) Make Path immutable

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-5336: Fix Version/s: 2.0-preview (was: 2.0.0) > Make Path immuta

[jira] [Updated] (FLINK-5337) Introduce backwards compatible state to task assignment

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-5337: Fix Version/s: 2.0-preview (was: 2.0.0) > Introduce backwards compati

[jira] [Created] (FLINK-36194) Shutdown hook for ExecutionGraphInfo store runs concurrently to cluster shutdown hook causing race conditions

2024-09-02 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-36194: - Summary: Shutdown hook for ExecutionGraphInfo store runs concurrently to cluster shutdown hook causing race conditions Key: FLINK-36194 URL: https://issues.apache.org/jira

[jira] [Updated] (FLINK-4971) Unify Stream Sinks and OutputFormats

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-4971: Fix Version/s: 2.0-preview (was: 2.0.0) > Unify Stream Sinks

[jira] [Updated] (FLINK-4758) Remove IOReadableWritable from classes where not needed

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-4758: Fix Version/s: 2.0-preview (was: 2.0.0) > Remove IOReadableWritable f

[jira] [Updated] (FLINK-4757) Unify "GlobalJobParameters" and "Configuration"

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-4757: Fix Version/s: 2.0-preview (was: 2.0.0) > Unify "GlobalJobParamet

[jira] [Updated] (FLINK-4503) Remove with method from CoGroupedStream and JoinedStream, and change apply method return type

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-4503: Fix Version/s: 2.0-preview (was: 2.0.0) > Remove with method f

[jira] [Updated] (FLINK-4675) Remove Parameter from WindowAssigner.getDefaultTrigger()

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-4675: Fix Version/s: 2.0-preview (was: 2.0.0) > Remove Parameter f

[jira] [Updated] (FLINK-5130) Remove Deprecated Methods from WindowedStream

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-5130: Fix Version/s: 2.0-preview (was: 2.0.0) > Remove Deprecated Methods f

[jira] [Updated] (FLINK-5126) Remove Checked Exceptions from State Interfaces

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-5126: Fix Version/s: 2.0-preview (was: 2.0.0) > Remove Checked Exceptions f

[jira] [Updated] (FLINK-4367) Offer separate API for watermark generation and timestamp extraction

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-4367: Fix Version/s: 2.0-preview (was: 2.0.0) > Offer separate API for waterm

[jira] [Updated] (FLINK-3992) Remove Key interface

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-3992: Fix Version/s: 2.0-preview (was: 2.0.0) > Remove Key interf

[jira] [Updated] (FLINK-3986) Rename readFileStream from the StreamExecutionEnvironment

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-3986: Fix Version/s: 2.0-preview (was: 2.0.0) > Rename readFileStream from

[jira] [Updated] (FLINK-3959) Remove implicit sinks

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-3959: Fix Version/s: 2.0-preview (was: 2.0.0) > Remove implicit si

[jira] [Updated] (FLINK-3991) Remove deprecated configuration keys from ConfigConstants

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-3991: Fix Version/s: 2.0-preview (was: 2.0.0) > Remove deprecated configurat

[jira] [Updated] (FLINK-4330) Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-4330: Fix Version/s: 2.0-preview (was: 2.0.0) > Consider removing min()/mi

[jira] [Updated] (FLINK-4147) Consider moving the file sources from the StreamExecutionEnvironment to the flink-connector-filesystem

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-4147: Fix Version/s: 2.0-preview (was: 2.0.0) > Consider moving the file sour

[jira] [Updated] (FLINK-3957) Breaking changes for Flink 2.0

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-3957: Fix Version/s: 2.0-preview (was: 2.0.0) > Breaking changes for Flink

<    5   6   7   8   9   10   11   12   13   14   >