[jira] [Comment Edited] (FLINK-36279) RescaleOnCheckpointITCase.testRescaleOnCheckpoint fails

[ https://issues.apache.org/jira/browse/FLINK-36279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881982#comment-17881982 ] Matthias Pohl edited comment on FLINK-36279 at 9/16/24 9:3

[jira] [Comment Edited] (FLINK-36279) RescaleOnCheckpointITCase.testRescaleOnCheckpoint fails

[ https://issues.apache.org/jira/browse/FLINK-36279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881982#comment-17881982 ] Matthias Pohl edited comment on FLINK-36279 at 9/16/24 9:3

[jira] [Commented] (FLINK-36279) RescaleOnCheckpointITCase.testRescaleOnCheckpoint fails

[ https://issues.apache.org/jira/browse/FLINK-36279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881982#comment-17881982 ] Matthias Pohl commented on FLINK-36279: --- The issue is caused by the alignmen

[jira] [Created] (FLINK-36287) Sink with topologies should not participate in UC

Arvid Heise created FLINK-36287: --- Summary: Sink with topologies should not participate in UC Key: FLINK-36287 URL: https://issues.apache.org/jira/browse/FLINK-36287 Project: Flink Issue Type

[jira] [Updated] (FLINK-36278) Fix Kafka connector logs getting too big

[ https://issues.apache.org/jira/browse/FLINK-36278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36278: --- Labels: pull-request-available (was: ) > Fix Kafka connector logs getting too

[jira] [Assigned] (FLINK-36279) RescaleOnCheckpointITCase.testRescaleOnCheckpoint fails

[ https://issues.apache.org/jira/browse/FLINK-36279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-36279: - Assignee: Matthias Pohl > RescaleOnCheckpointITCase.testRescaleOnCheckpoint fa

[jira] [Updated] (FLINK-36286) Set up validation workflows

[ https://issues.apache.org/jira/browse/FLINK-36286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36286: --- Labels: pull-request-available (was: ) > Set up validation workfl

[jira] [Updated] (FLINK-36286) Set up validation workflows

[ https://issues.apache.org/jira/browse/FLINK-36286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-36286: Summary: Set up validation workflows (was: Set up pull request template) > Set

[jira] [Created] (FLINK-36286) Set up pull request template

Hong Liang Teoh created FLINK-36286: --- Summary: Set up pull request template Key: FLINK-36286 URL: https://issues.apache.org/jira/browse/FLINK-36286 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager

[ https://issues.apache.org/jira/browse/FLINK-36146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36146: --- Labels: pull-request-available (was: ) > NoSuchElement exception f

[jira] [Commented] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager

[ https://issues.apache.org/jira/browse/FLINK-36146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881941#comment-17881941 ] Kim Gräsman commented on FLINK-36146: - Thanks for your support, I posted: h

[jira] [Comment Edited] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager

[ https://issues.apache.org/jira/browse/FLINK-36146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881867#comment-17881867 ] Kim Gräsman edited comment on FLINK-36146 at 9/16/24 7:0

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

[ https://issues.apache.org/jira/browse/FLINK-36194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881936#comment-17881936 ] Eaugene Thomas commented on FLINK-36194: Sure [~mapohl]  . Will go over

[jira] [Commented] (FLINK-36279) RescaleOnCheckpointITCase.testRescaleOnCheckpoint fails

[ https://issues.apache.org/jira/browse/FLINK-36279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881931#comment-17881931 ] Matthias Pohl commented on FLINK-36279: --- https://dev.azure.com/apache-f

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

[ https://issues.apache.org/jira/browse/FLINK-36194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881929#comment-17881929 ] Matthias Pohl edited comment on FLINK-36194 at 9/16/24 6:2

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

[ https://issues.apache.org/jira/browse/FLINK-36194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881929#comment-17881929 ] Matthias Pohl commented on FLINK-36194: --- You might want to start a discussio

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

[ https://issues.apache.org/jira/browse/FLINK-36194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-36194: - Assignee: Matthias Pohl > Shutdown hook for ExecutionGraphInfo store runs concurren

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

[ https://issues.apache.org/jira/browse/FLINK-36194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-36194: - Assignee: Eaugene Thomas (was: Matthias Pohl) > Shutdown hook for ExecutionGraphI

[jira] [Commented] (FLINK-36279) RescaleOnCheckpointITCase.testRescaleOnCheckpoint fails

[ https://issues.apache.org/jira/browse/FLINK-36279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881928#comment-17881928 ] Matthias Pohl commented on FLINK-36279: --- https://dev.azure.com/apache-f

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

[ https://issues.apache.org/jira/browse/FLINK-36194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881914#comment-17881914 ] Eaugene Thomas commented on FLINK-36194: Can you assign this to me ?  Th

[jira] [Commented] (FLINK-35780) Support state migration between disabling and enabling ttl in RocksDBKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-35780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881913#comment-17881913 ] xiangyu feng commented on FLINK-35780: -- Also cc: [~tzulitai]  [~maste

[jira] [Commented] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager

[ https://issues.apache.org/jira/browse/FLINK-36146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881867#comment-17881867 ] Kim Gräsman commented on FLINK-36146: - Thank you! Hmm, yeah, I don't u

[jira] [Comment Edited] (FLINK-36240) Incorrect Port display in the PrometheusReporter constructor

[ https://issues.apache.org/jira/browse/FLINK-36240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881865#comment-17881865 ] Arkadiusz Dankiewicz edited comment on FLINK-36240 at 9/15/24 6:0

[jira] [Commented] (FLINK-36240) Incorrect Port display in the PrometheusReporter constructor

[ https://issues.apache.org/jira/browse/FLINK-36240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881865#comment-17881865 ] Arkadiusz Dankiewicz commented on FLINK-36240: -- Thanks for the tas

[jira] [Commented] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager

[ https://issues.apache.org/jira/browse/FLINK-36146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881864#comment-17881864 ] Jiangjie Qin commented on FLINK-36146: -- Hi Kim, yes, the ConcurrentHas

[jira] [Updated] (FLINK-36240) Incorrect Port display in the PrometheusReporter constructor

[ https://issues.apache.org/jira/browse/FLINK-36240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36240: --- Labels: pull-request-available (was: ) > Incorrect Port display in the PrometheusRepor

[jira] [Commented] (FLINK-35780) Support state migration between disabling and enabling ttl in RocksDBKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-35780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881851#comment-17881851 ] xiangyu feng commented on FLINK-35780: -- Hi [~Zakelly], I've finished

[jira] [Updated] (FLINK-35780) Support state migration between disabling and enabling ttl in RocksDBKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-35780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-35780: - Summary: Support state migration between disabling and enabling ttl in RocksDBKeyedStateBackend

[jira] [Updated] (FLINK-35780) Support state migration between disabling and enabling ttl in RocksDBState

[ https://issues.apache.org/jira/browse/FLINK-35780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-35780: - Summary: Support state migration between disabling and enabling ttl in RocksDBState (was

[jira] [Updated] (FLINK-36282) Incorrect data type in mysql pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-36282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36282: --- Labels: pull-request-available (was: ) > Incorrect data type in mysql pipeline connec

[jira] [Created] (FLINK-36285) Modify column type failed when downstream's column with defalut value

linqigeng created FLINK-36285: - Summary: Modify column type failed when downstream's column with defalut value Key: FLINK-36285 URL: https://issues.apache.org/jira/browse/FLINK-36285 Project:

[jira] [Commented] (FLINK-36272) YarnFileStageTestS3ITCase fails on master

[ https://issues.apache.org/jira/browse/FLINK-36272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881828#comment-17881828 ] Luke Chen commented on FLINK-36272: --- We can close this ticket now since it is

[jira] [Resolved] (FLINK-36258) testRecursiveUploadForYarnS3n failed due to no AWS Credentials provided

[ https://issues.apache.org/jira/browse/FLINK-36258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuannan Su resolved FLINK-36258. Resolution: Fixed > testRecursiveUploadForYarnS3n failed due to no AWS Credentials provi

[jira] [Commented] (FLINK-36258) testRecursiveUploadForYarnS3n failed due to no AWS Credentials provided

[ https://issues.apache.org/jira/browse/FLINK-36258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881776#comment-17881776 ] Xuannan Su commented on FLINK-36258: master

[jira] [Updated] (FLINK-36240) Incorrect Port display in the PrometheusReporter constructor

[ https://issues.apache.org/jira/browse/FLINK-36240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arkadiusz Dankiewicz updated FLINK-36240: - Summary: Incorrect Port display in the PrometheusReporter constructor (was

[jira] [Commented] (FLINK-36240) Incorrect Port display in the debug log message for PrometheusReporter constructor

[ https://issues.apache.org/jira/browse/FLINK-36240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881769#comment-17881769 ] Ferenc Csaky commented on FLINK-36240: -- Thank you for reporting the problem

[jira] [Assigned] (FLINK-36240) Incorrect Port display in the debug log message for PrometheusReporter constructor

[ https://issues.apache.org/jira/browse/FLINK-36240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky reassigned FLINK-36240: Assignee: Arkadiusz Dankiewicz > Incorrect Port display in the debug log message

[jira] [Updated] (FLINK-36240) Incorrect Port display in the debug log message for PrometheusReporter constructor

[ https://issues.apache.org/jira/browse/FLINK-36240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky updated FLINK-36240: - Affects Version/s: 1.19.1 1.20.0 1.18.1

[jira] [Updated] (FLINK-36284) StreamTableEnvironment#toDataStream(Table table, Class targetClass) is not suitable for setting targetClass as a class generated by Avro.

[ https://issues.apache.org/jira/browse/FLINK-36284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36284: --- Labels: pull-request-available (was: ) > StreamTableEnvironment#toDataStream(Table ta

[jira] [Updated] (FLINK-36283) The new PERCENTILE function doesn't follow user function first behavior when it encounters a user function with same name

[ https://issues.apache.org/jira/browse/FLINK-36283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36283: --- Labels: pull-request-available (was: ) > The new PERCENTILE function doesn't fol

[jira] [Updated] (FLINK-36284) StreamTableEnvironment#toDataStream(Table table, Class targetClass) is not suitable for setting targetClass as a class generated by Avro.

[ https://issues.apache.org/jira/browse/FLINK-36284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36284: --- Priority: Blocker (was: Minor) > StreamTableEnvironment#toDataStream(Table table, Class targetClass)

[jira] [Created] (FLINK-36284) StreamTableEnvironment#toDataStream(Table table, Class targetClass) is not suitable for setting targetClass as a class generated by Avro.

://issues.apache.org/jira/browse/FLINK-36284 Project: Flink Issue Type: Improvement Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table SQL / API Reporter: xuyang Fix For: 2.0-preview Attachments: image-2024-09-14-17-39-16-698.png

[jira] [Commented] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager

[ https://issues.apache.org/jira/browse/FLINK-36146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881762#comment-17881762 ] Kim Gräsman commented on FLINK-36146: - [~becket_qin] Thanks! That suggestion

[jira] [Commented] (FLINK-29739) [FLIP-265] Deprecate and remove Scala API support

[ https://issues.apache.org/jira/browse/FLINK-29739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881753#comment-17881753 ] xuyang commented on FLINK-29739: If we keep the `{{{}flink-table-api-scala-br

[jira] [Updated] (FLINK-36283) The new PERCENTILE function doesn't follow user function first behavior when it encounters a user function with same name

[ https://issues.apache.org/jira/browse/FLINK-36283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-36283: Issue Type: Bug (was: Improvement) > The new PERCENTILE function doesn't follow user

[jira] [Created] (FLINK-36283) The new PERCENTILE function doesn't follow user function first behavior when it encounters a user function with same name

e.org/jira/browse/FLINK-36283 Project: Flink Issue Type: Improvement Affects Versions: 2.0-preview Reporter: lincoln lee Assignee: Dylan He Fix For: 2.0.0 The new PERCENTILE function doesn't follow user function first behavi

[jira] [Updated] (FLINK-36273) Remove deprecated Table/SQL configuration in 2.0

[ https://issues.apache.org/jira/browse/FLINK-36273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36273: --- Labels: pull-request-available (was: ) > Remove deprecated Table/SQL configuration in

[jira] [Updated] (FLINK-36282) Incorrect data type in mysql pipeline connector

[ https://issues.apache.org/jira/browse/FLINK-36282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linqigeng updated FLINK-36282: -- Summary: Incorrect data type in mysql pipeline connector (was: Incorrect data type mysql pipeline

[jira] [Created] (FLINK-36282) Incorrect data type mysql pipeline connector

linqigeng created FLINK-36282: - Summary: Incorrect data type mysql pipeline connector Key: FLINK-36282 URL: https://issues.apache.org/jira/browse/FLINK-36282 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-29739) [FLIP-265] Deprecate and remove Scala API support

[ https://issues.apache.org/jira/browse/FLINK-29739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881744#comment-17881744 ] xuyang edited comment on FLINK-29739 at 9/14/24 5:28 AM: -

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

[ https://issues.apache.org/jira/browse/FLINK-36281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36281: --- Labels: pull-request-available (was: ) > resourceSpec repl

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

Caican Cai created FLINK-36281: -- Summary: resourceSpec replace SlotSharingGroupUtils.extractResourceSpec(slotSharingGroup) Key: FLINK-36281 URL: https://issues.apache.org/jira/browse/FLINK-36281 Project

[jira] [Updated] (FLINK-36280) Snapshot scan mode do not support batch execution mode, and not as expected in mode streaming

[ https://issues.apache.org/jira/browse/FLINK-36280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HunterXHunter updated FLINK-36280: -- Description: [https://github.com/apache/flink-cdc/pull/2901]   I've encountered

[jira] [Updated] (FLINK-36280) Snapshot scan mode do not support batch execution mode, and not as expected in mode streaming

[ https://issues.apache.org/jira/browse/FLINK-36280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HunterXHunter updated FLINK-36280: -- Description: [https://github.com/apache/flink-cdc/pull/2901]   I've encountered

[jira] [Created] (FLINK-36280) Snapshot scan mode do not support batch execution mode, and not as expected in mode streaming

HunterXHunter created FLINK-36280: - Summary: Snapshot scan mode do not support batch execution mode, and not as expected in mode streaming Key: FLINK-36280 URL: https://issues.apache.org/jira/browse/FLINK-36280

[jira] [Comment Edited] (FLINK-29739) [FLIP-265] Deprecate and remove Scala API support

[ https://issues.apache.org/jira/browse/FLINK-29739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881739#comment-17881739 ] xuhuang edited comment on FLINK-29739 at 9/14/24 3:12 AM: --

[jira] [Commented] (FLINK-29739) [FLIP-265] Deprecate and remove Scala API support

[ https://issues.apache.org/jira/browse/FLINK-29739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881739#comment-17881739 ] xuhuang commented on FLINK-29739: - Hi, [~lincoln.86xy] I attempted to relocate

[jira] [Commented] (FLINK-36279) RescaleOnCheckpointITCase.testRescaleOnCheckpoint fails

[ https://issues.apache.org/jira/browse/FLINK-36279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881738#comment-17881738 ] Junrui Li commented on FLINK-36279: --- https://dev.azure.com/apache-flink/apache-f

[jira] [Resolved] (FLINK-35927) Make ForStFlinkFileSystem save misc file in local filesystem

[ https://issues.apache.org/jira/browse/FLINK-35927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-35927. Resolution: Resolved > Make ForStFlinkFileSystem save misc file in local filesys

[jira] [Commented] (FLINK-35667) Implement Reducing Async State API for ForStStateBackend

[ https://issues.apache.org/jira/browse/FLINK-35667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881737#comment-17881737 ] Yanfei Lei commented on FLINK-35667: Merged into master via d8b3243 > Im

[jira] [Resolved] (FLINK-35667) Implement Reducing Async State API for ForStStateBackend

[ https://issues.apache.org/jira/browse/FLINK-35667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-35667. Assignee: Yanfei Lei Resolution: Resolved > Implement Reducing Async State API

[jira] [Commented] (FLINK-35927) Make ForStFlinkFileSystem save misc file in local filesystem

[ https://issues.apache.org/jira/browse/FLINK-35927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881736#comment-17881736 ] Yanfei Lei commented on FLINK-35927: Merged into master via f520674 &g

[jira] [Commented] (FLINK-36001) Store operator name and UID in state metadata

[ https://issues.apache.org/jira/browse/FLINK-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881701#comment-17881701 ] Gabor Somogyi commented on FLINK-36001: --- 60beed9 on master > Store operat

[jira] [Commented] (FLINK-36001) Store operator name and UID in state metadata

[ https://issues.apache.org/jira/browse/FLINK-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881700#comment-17881700 ] Gabor Somogyi commented on FLINK-36001: --- 02110ce on master > Store operat

[jira] [Closed] (FLINK-36001) Store operator name and UID in state metadata

[ https://issues.apache.org/jira/browse/FLINK-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-36001. - Resolution: Fixed > Store operator name and UID in state metad

[jira] [Updated] (FLINK-36001) Store operator name and UID in state metadata

[ https://issues.apache.org/jira/browse/FLINK-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-36001: -- Release Note: (was: 02110ce on master) > Store operator name and UID in state metad

[jira] [Commented] (FLINK-36279) RescaleOnCheckpointITCase.testRescaleOnCheckpoint fails

[ https://issues.apache.org/jira/browse/FLINK-36279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881681#comment-17881681 ] Matthias Pohl commented on FLINK-36279: --- [~ztison] I remember you ran into

[jira] [Created] (FLINK-36279) RescaleOnCheckpointITCase.testRescaleOnCheckpoint fails

Matthias Pohl created FLINK-36279: - Summary: RescaleOnCheckpointITCase.testRescaleOnCheckpoint fails Key: FLINK-36279 URL: https://issues.apache.org/jira/browse/FLINK-36279 Project: Flink

[jira] [Commented] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager

[ https://issues.apache.org/jira/browse/FLINK-36146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881648#comment-17881648 ] Jiangjie Qin commented on FLINK-36146: -- Yes, this is an apparent race condi

[jira] [Reopened] (FLINK-36001) Store operator name and UID in state metadata

[ https://issues.apache.org/jira/browse/FLINK-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reopened FLINK-36001: --- > Store operator name and UID in state metad

[jira] [Resolved] (FLINK-33138) Prometheus Connector Sink - DataStream API implementation

[ https://issues.apache.org/jira/browse/FLINK-33138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-33138. - Resolution: Fixed  merged commit [{{a6c8cd5}}|https://github.com/apache/flink

[jira] [Commented] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager

[ https://issues.apache.org/jira/browse/FLINK-36146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881576#comment-17881576 ] Kim Gräsman commented on FLINK-36146: - cc [~becket_qin], I saw you've mad

[jira] [Closed] (FLINK-36001) Store operator name and UID in state metadata

[ https://issues.apache.org/jira/browse/FLINK-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-36001. - > Store operator name and UID in state metad

[jira] [Resolved] (FLINK-36001) Store operator name and UID in state metadata

[ https://issues.apache.org/jira/browse/FLINK-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-36001. --- Release Note: 02110ce on master Resolution: Fixed > Store operator name and UID

[jira] [Updated] (FLINK-36001) Store operator name and UID in state metadata

[ https://issues.apache.org/jira/browse/FLINK-36001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-36001: -- Fix Version/s: 2.0.0 > Store operator name and UID in state metad

[jira] [Created] (FLINK-36278) Fix Kafka connector logs getting too big

Arvid Heise created FLINK-36278: --- Summary: Fix Kafka connector logs getting too big Key: FLINK-36278 URL: https://issues.apache.org/jira/browse/FLINK-36278 Project: Flink Issue Type: Technical

[jira] [Commented] (FLINK-34470) Transactional message + Table api kafka source with 'latest-offset' scan bound mode causes indefinitely hanging

[ https://issues.apache.org/jira/browse/FLINK-34470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881536#comment-17881536 ] Arvid Heise commented on FLINK-34470: - [~dongwoo.kim] I have added a [review|h

[jira] [Updated] (FLINK-36245) Remove legacy SourceFunction / SinkFunction / Sink V1 API in 2.0

[ https://issues.apache.org/jira/browse/FLINK-36245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36245: --- Labels: 2.0-related pull-request-available (was: 2.0-related) > Remove leg

[jira] [Assigned] (FLINK-36208) use ThreadLocalRandom in AbstractID

[ https://issues.apache.org/jira/browse/FLINK-36208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ferenc Csaky reassigned FLINK-36208: Assignee: Sean Sullivan > use ThreadLocalRandom in Abstrac

[jira] [Updated] (FLINK-36277) Remove all direct uses of `TableEnvironmentInternal#registerTableSourceInternal` in table module

[ https://issues.apache.org/jira/browse/FLINK-36277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36277: --- Labels: pull-request-available (was: ) > Remove all direct uses

[jira] [Updated] (FLINK-36277) Remove all direct uses of `TableEnvironmentInternal#registerTableSourceInternal` in table module

[ https://issues.apache.org/jira/browse/FLINK-36277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36277: --- Summary: Remove all direct uses of `TableEnvironmentInternal#registerTableSourceInternal` in table module

[jira] [Created] (FLINK-36277) Remove all direct uses of `TableEnvironmentInternal#registerTableSourceInternal`

xuyang created FLINK-36277: -- Summary: Remove all direct uses of `TableEnvironmentInternal#registerTableSourceInternal` Key: FLINK-36277 URL: https://issues.apache.org/jira/browse/FLINK-36277 Project: Flink

[jira] [Updated] (FLINK-36270) DDB Streams Connector performance issue due to splitsAvailableForAssignment function

[ https://issues.apache.org/jira/browse/FLINK-36270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-36270: Fix Version/s: aws-connector-4.4.0 > DDB Streams Connector performance issue due

[jira] [Resolved] (FLINK-36270) DDB Streams Connector performance issue due to splitsAvailableForAssignment function

[ https://issues.apache.org/jira/browse/FLINK-36270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-36270. - Resolution: Fixed  merged commit [{{9b0d983}}|https://github.com/apache/flink

[jira] [Updated] (FLINK-36276) Fix the description of MySqlDataSourceOptions.`scan.startup.mode`.

[ https://issues.apache.org/jira/browse/FLINK-36276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36276: --- Labels: pull-request-available (was: ) > Fix the description of MySqlDataSourceOpti

[jira] [Created] (FLINK-36276) Fix the description of MySqlDataSourceOptions.`scan.startup.mode`.

HunterXHunter created FLINK-36276: - Summary: Fix the description of MySqlDataSourceOptions.`scan.startup.mode`. Key: FLINK-36276 URL: https://issues.apache.org/jira/browse/FLINK-36276 Project: Flink

[jira] [Commented] (FLINK-36272) YarnFileStageTestS3ITCase fails on master

[ https://issues.apache.org/jira/browse/FLINK-36272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881515#comment-17881515 ] Luke Chen commented on FLINK-36272: --- PR: https://github.com/apache/flink/pull/2

[jira] [Commented] (FLINK-36258) testRecursiveUploadForYarnS3n failed due to no AWS Credentials provided

[ https://issues.apache.org/jira/browse/FLINK-36258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881514#comment-17881514 ] Luke Chen commented on FLINK-36258: --- PR: https://github.com/apache/flink/pull/2

[jira] [Updated] (FLINK-36258) testRecursiveUploadForYarnS3n failed due to no AWS Credentials provided

[ https://issues.apache.org/jira/browse/FLINK-36258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36258: --- Labels: pull-request-available test-stability (was: test-stability

[jira] [Resolved] (FLINK-36242) Fix unstable test in MaterializedTableITCase

[ https://issues.apache.org/jira/browse/FLINK-36242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu resolved FLINK-36242. --- Assignee: Feng Jin Resolution: Fixed > Fix unstable test in MaterializedTableITC

[jira] [Commented] (FLINK-36242) Fix unstable test in MaterializedTableITCase

[ https://issues.apache.org/jira/browse/FLINK-36242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881503#comment-17881503 ] dalongliu commented on FLINK-36242: --- Merged in ma

[jira] [Commented] (FLINK-29739) [FLIP-265] Deprecate and remove Scala API support

[ https://issues.apache.org/jira/browse/FLINK-29739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881486#comment-17881486 ] lincoln lee commented on FLINK-29739: - We've been working on code cleanu

[jira] [Updated] (FLINK-29741) [FLIP-265] Remove all Scala APIs

[ https://issues.apache.org/jira/browse/FLINK-29741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29741: --- Labels: 2.0-related pull-request-available (was: 2.0-related) > [FLIP-265] Remove

[jira] [Updated] (FLINK-35634) Add a CDC quickstart utility

[ https://issues.apache.org/jira/browse/FLINK-35634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35634: --- Labels: pull-request-available (was: ) > Add a CDC quickstart util

[jira] [Updated] (FLINK-36275) Remove deprecated ProgramArgsQueryParameter

[ https://issues.apache.org/jira/browse/FLINK-36275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36275: --- Labels: pull-request-available (was: ) > Remove deprecated ProgramArgsQueryParame

[jira] [Updated] (FLINK-36275) Remove deprecated ProgramArgsQueryParameter

[ https://issues.apache.org/jira/browse/FLINK-36275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36275: --- Priority: Blocker (was: Major) > Remove deprecated ProgramArgsQueryParame

[jira] [Updated] (FLINK-36275) Remove deprecated ProgramArgsQueryParameter

[ https://issues.apache.org/jira/browse/FLINK-36275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36275: --- Parent: FLINK-3957 Issue Type: Sub-task (was: Technical Debt) > Remove depreca

[jira] (FLINK-36275) Remove deprecated ProgramArgsQueryParameter

[ https://issues.apache.org/jira/browse/FLINK-36275 ] Weijie Guo deleted comment on FLINK-36275: was (Author: weijie guo): ProgramArgsQueryParameter has been deprecated in Flink 1.7(see https://issues.apache.org/jira/browse/FLINK-10295). We

[jira] [Commented] (FLINK-36275) Remove deprecated ProgramArgsQueryParameter

[ https://issues.apache.org/jira/browse/FLINK-36275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881474#comment-17881474 ] Weijie Guo commented on FLINK-36275: ProgramArgsQueryParameter has been deprec

[jira] [Updated] (FLINK-36275) Remove deprecated ProgramArgsQueryParameter

[ https://issues.apache.org/jira/browse/FLINK-36275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36275: --- Description: ProgramArgsQueryParameter has been deprecated in Flink 1.7(see https

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