[jira] [Commented] (FLINK-35030) Introduce Epoch Manager for watermark under async execution

2024-04-23 Thread Yunfeng Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840257#comment-17840257 ] Yunfeng Zhou commented on FLINK-35030: -- [~Yanfei Lei] According to the description in FLIP-425, Non

[jira] [Updated] (FLINK-34064) Expose JobManagerOperatorMetrics via REST API

2024-04-23 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mason Chen updated FLINK-34064: --- Component/s: Runtime / Web Frontend > Expose JobManagerOperatorMetrics via REST

[jira] [Commented] (FLINK-34445) Integrate new endpoint with Flink UI metrics section

2024-04-23 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840247#comment-17840247 ] Mason Chen commented on FLINK-34445: [~ruanhang1993] I reassigned to you. Thank you for volunteering

[jira] [Resolved] (FLINK-34444) Add new endpoint handler to flink

2024-04-23 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mason Chen resolved FLINK-3. Resolution: Fixed Master CI passes > Add new endpoint handler to fl

[jira] [Updated] (FLINK-34444) Add new endpoint handler to flink

2024-04-23 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mason Chen updated FLINK-3: --- Description: Add new endpoint handler to flink > Add new endpoint handler to fl

[jira] [Assigned] (FLINK-34445) Integrate new endpoint with Flink UI metrics section

2024-04-23 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mason Chen reassigned FLINK-34445: -- Assignee: Hang Ruan (was: Mason Chen) > Integrate new endpoint with Flink UI metr

[jira] [Assigned] (FLINK-34444) Add new endpoint handler to flink

2024-04-23 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mason Chen reassigned FLINK-3: -- Assignee: Mason Chen (was: Mason Chen) > Add new endpoint handler to fl

[jira] [Assigned] (FLINK-34064) Expose JobManagerOperatorMetrics via REST API

2024-04-23 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mason Chen reassigned FLINK-34064: -- Assignee: Mason Chen (was: Mason Chen) > Expose JobManagerOperatorMetrics via REST

[jira] [Commented] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed

2024-04-23 Thread Qinghui Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840230#comment-17840230 ] Qinghui Xu commented on FLINK-35215: Hello [~fanrui]  I have a few questions: * I'm trying

[jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

2024-04-23 Thread Ethan Fritz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840221#comment-17840221 ] Ethan Fritz commented on FLINK-23886: - Encountered a similar issue with deserializing user keys

[jira] [Commented] (FLINK-34869) [Bug][mysql] Remove all previous table and add new added table will throw Exception.

2024-04-23 Thread Josh Mahonin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840201#comment-17840201 ] Josh Mahonin commented on FLINK-34869: -- We seem to be hitting this issue as well. Is this issue

[jira] [Commented] (FLINK-35217) Missing fsync in FileSystemCheckpointStorage

2024-04-23 Thread Marc Aurel Fritz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840154#comment-17840154 ] Marc Aurel Fritz commented on FLINK-35217: -- Hey there, thanks for the quick response! I've

[jira] [Updated] (FLINK-35216) Support for RETURNING clause of JSON_QUERY

2024-04-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35216: --- Labels: pull-request-available (was: ) > Support for RETURNING clause of JSON_QU

[jira] [Commented] (FLINK-35217) Missing fsync in FileSystemCheckpointStorage

2024-04-23 Thread Stefan Richter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840115#comment-17840115 ] Stefan Richter commented on FLINK-35217: Hi, the code is calling close on the output stream

[jira] [Commented] (FLINK-35218) Duplicated values caused by expired state TTL

2024-04-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840111#comment-17840111 ] Martijn Visser commented on FLINK-35218: >From what the docs state >

[jira] [Updated] (FLINK-35218) Duplicated values caused by expired state TTL

2024-04-23 Thread garcia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] garcia updated FLINK-35218: --- Description: Hi, We utilize the state TTL to clean our Flink input tables through

[jira] [Created] (FLINK-35218) Duplicated values caused by expired state TTL

2024-04-23 Thread garcia (Jira)
garcia created FLINK-35218: -- Summary: Duplicated values caused by expired state TTL Key: FLINK-35218 URL: https://issues.apache.org/jira/browse/FLINK-35218 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35217) Missing fsync in FileSystemCheckpointStorage

2024-04-23 Thread Marc Aurel Fritz (Jira)
Marc Aurel Fritz created FLINK-35217: Summary: Missing fsync in FileSystemCheckpointStorage Key: FLINK-35217 URL: https://issues.apache.org/jira/browse/FLINK-35217 Project: Flink Issue

[jira] [Updated] (FLINK-35214) Update result partition id for remote input channel when unknown input channel is updated

2024-04-23 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-35214: -- Fix Version/s: 1.20.0 > Update result partition id for remote input channel when unknown in

[jira] [Closed] (FLINK-35214) Update result partition id for remote input channel when unknown input channel is updated

2024-04-23 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-35214. -- Resolution: Fixed master(1.20) via ea2eabe7da555653ac946b185ed62a1d3bfd6c00. > Update res

[jira] [Comment Edited] (FLINK-35212) PyFlink thread mode process just can run once in standalonesession mode

2024-04-23 Thread Wei Yuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840036#comment-17840036 ] Wei Yuan edited comment on FLINK-35212 at 4/23/24 11:10 AM: After debug

[jira] [Created] (FLINK-35216) Support for RETURNING clause of JSON_QUERY

2024-04-23 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-35216: Summary: Support for RETURNING clause of JSON_QUERY Key: FLINK-35216 URL: https://issues.apache.org/jira/browse/FLINK-35216 Project: Flink Issue

[jira] [Commented] (FLINK-35151) Flink mysql cdc will stuck when suspend binlog split and ChangeEventQueue is full

2024-04-23 Thread Guozhen Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840062#comment-17840062 ] Guozhen Yang commented on FLINK-35151: -- We encountered the same issue recently. It may be caused

[jira] [Commented] (FLINK-33251) SQL Client query execution aborts after a few seconds: ConnectTimeoutException

2024-04-23 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840061#comment-17840061 ] Robert Metzger commented on FLINK-33251: I'm having this problem with 1.19.0 as well, on a M1

[jira] [Commented] (FLINK-35097) Table API Filesystem connector with 'raw' format repeats last line

2024-04-23 Thread Kumar Mallikarjuna (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840052#comment-17840052 ] Kumar Mallikarjuna commented on FLINK-35097: [~david.perkins] , the fix has been merged

[jira] [Resolved] (FLINK-35055) Flink CDC connector release contains dependency with incompatible licenses

2024-04-23 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-35055. --- Fix Version/s: cdc-3.1.0 Resolution: Fixed > Flink CDC connector release conta

[jira] [Commented] (FLINK-34969) Error due to Flink CDC using deprecated flink-conf.yaml in light of Flink's full YAML 1.2 support since version 1.19

2024-04-23 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840047#comment-17840047 ] Qingsheng Ren commented on FLINK-34969: --- flink-cdc master

[jira] [Resolved] (FLINK-34969) Error due to Flink CDC using deprecated flink-conf.yaml in light of Flink's full YAML 1.2 support since version 1.19

2024-04-23 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-34969. --- Resolution: Fixed > Error due to Flink CDC using deprecated flink-conf.yaml in li

[jira] [Updated] (FLINK-35167) Introduce MaxCompute pipeline DataSink

2024-04-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35167: --- Labels: pull-request-available (was: ) > Introduce MaxCompute pipeline DataS

[jira] (FLINK-35007) Update Flink Kafka connector to support 1.19

2024-04-23 Thread yazgoo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35007 ] yazgoo deleted comment on FLINK-35007: was (Author: yazgoo): Hi, Do you plan on publishing flink-connector-kafka:3.1.0-1.19 ? Thanks ! > Update Flink Kafka connector to support 1

[jira] (FLINK-35007) Update Flink Kafka connector to support 1.19

2024-04-23 Thread yazgoo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35007 ] yazgoo deleted comment on FLINK-35007: was (Author: yazgoo): Hi [~martijnvisser] , do you have news on my previous question ? > Update Flink Kafka connector to support 1

[jira] [Assigned] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

2024-04-23 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35088: --- Assignee: elon_X > watermark alignment maxAllowedWatermarkDrift and updateInterval param n

[jira] [Commented] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

2024-04-23 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840043#comment-17840043 ] Rui Fan commented on FLINK-35088: - [~elon] thank you for your volunteering, assigned. > waterm

[jira] [Commented] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

2024-04-23 Thread elon_X (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840041#comment-17840041 ] elon_X commented on FLINK-35088: [~fanrui] I am very happy to fix this issue, please assign it to me

[jira] [Commented] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

2024-04-23 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840040#comment-17840040 ] Rui Fan commented on FLINK-35088: - Hi [~elon] , thanks for reporting this issue. It makes sense to add

[jira] [Commented] (FLINK-35212) PyFlink thread mode process just can run once in standalonesession mode

2024-04-23 Thread Wei Yuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840036#comment-17840036 ] Wei Yuan commented on FLINK-35212: -- After debug this test case, I found an "Native Library

[jira] [Commented] (FLINK-35138) Release flink-connector-kafka v3.2.0 for Flink 1.19

2024-04-23 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840028#comment-17840028 ] Danny Cranmer commented on FLINK-35138: --- RC1 Vote: https://lists.apache.org/thread

[jira] [Closed] (FLINK-34913) ConcurrentModificationException SubTaskInitializationMetricsBuilder.addDurationMetric

2024-04-23 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-34913. -- Fix Version/s: 1.20.0 (was: 2.0.0) Resolution: Fixed

[jira] [Commented] (FLINK-35210) Give the option to set automatically the parallelism of the KafkaSource to the number of kafka partitions

2024-04-23 Thread Nicolas Perrin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839979#comment-17839979 ] Nicolas Perrin commented on FLINK-35210: I see your point. Unfortunately, the issue only

[jira] [Commented] (FLINK-35187) FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines

2024-04-23 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839977#comment-17839977 ] Rui Fan commented on FLINK-35187: - Thank you very much for the feedback and update! > FLIP-

[jira] [Commented] (FLINK-35184) Hash collision inside MiniBatchStreamingJoin operator

2024-04-23 Thread Roman Boyko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839978#comment-17839978 ] Roman Boyko commented on FLINK-35184: - I've found even simplier solution without changing

[jira] [Closed] (FLINK-35009) Change on getTransitivePredecessors breaks connectors

2024-04-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-35009. -- Resolution: Won't Fix Closing this as Won't Fix, since we'll change the Flink Kafka connector

[jira] [Updated] (FLINK-35184) Hash collision inside MiniBatchStreamingJoin operator

2024-04-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35184: --- Labels: pull-request-available (was: ) > Hash collision inside MiniBatchStreamingJ

[jira] [Commented] (FLINK-35187) FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines

2024-04-23 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839967#comment-17839967 ] dalongliu commented on FLINK-35187: --- [~fanrui]Thanks for your reminder, we will complete the MVP

[jira] [Commented] (FLINK-35007) Update Flink Kafka connector to support 1.19

2024-04-23 Thread yazgoo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839963#comment-17839963 ] yazgoo commented on FLINK-35007: Hi [~martijnvisser] , do you have news on my previous question

[jira] [Commented] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed

2024-04-23 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839949#comment-17839949 ] Rui Fan commented on FLINK-35215: - Hi [~q.xu] , would you mind taking a look this issue in your free

[jira] [Created] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed

2024-04-22 Thread Rui Fan (Jira)
Rui Fan created FLINK-35215: --- Summary: The performance of serializerKryo and serializerKryoWithoutRegistration are regressed Key: FLINK-35215 URL: https://issues.apache.org/jira/browse/FLINK-35215 Project

[jira] [Updated] (FLINK-35214) Update result partition id for remote input channel when unknown input channel is updated

2024-04-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35214: --- Labels: pull-request-available (was: ) > Update result partition id for remote in

[jira] [Commented] (FLINK-35184) Hash collision inside MiniBatchStreamingJoin operator

2024-04-22 Thread Shuai Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839947#comment-17839947 ] Shuai Xu commented on FLINK-35184: -- Absolutely, please feel free to start the implementation. > H

[jira] [Comment Edited] (FLINK-35184) Hash collision inside MiniBatchStreamingJoin operator

2024-04-22 Thread Shuai Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839947#comment-17839947 ] Shuai Xu edited comment on FLINK-35184 at 4/23/24 5:46 AM: --- [~rovboyko

[jira] [Comment Edited] (FLINK-35169) Recycle buffers to freeSegments before releasing data buffer for sort accumulator

2024-04-22 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839463#comment-17839463 ] Weijie Guo edited comment on FLINK-35169 at 4/23/24 5:17 AM: - master via

[jira] [Updated] (FLINK-35169) Recycle buffers to freeSegments before releasing data buffer for sort accumulator

2024-04-22 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35169: --- Fix Version/s: 1.18.2 1.19.1 > Recycle buffers to freeSegments before releas

[jira] [Updated] (FLINK-35211) when synchronize LOB fields using oracle cdc, an error occurs

2024-04-22 Thread wangsw (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangsw updated FLINK-35211: --- Environment: Flink 18.1  Oracle12c Oracle cdc 3.0.1 was: Flink 18.1  Oracle cdc 3.0.1 > w

[jira] [Commented] (FLINK-34970) Translate architecture documents into Chinese

2024-04-22 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839931#comment-17839931 ] Rui Fan commented on FLINK-34970: - Merged to main(1.9.0) via: 9ea69eb1c15b9424fb08d8152e79b2b560d53a5c

[jira] [Resolved] (FLINK-34970) Translate architecture documents into Chinese

2024-04-22 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34970. - Fix Version/s: kubernetes-operator-1.9.0 (was: 1.9.1) Resolution: Fixed

[jira] [Assigned] (FLINK-35214) Update result partition id for remote input channel when unknown input channel is updated

2024-04-22 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan reassigned FLINK-35214: - Assignee: Yuxin Tan > Update result partition id for remote input channel when unknown in

[jira] [Created] (FLINK-35214) Update result partition id for remote input channel when unknown input channel is updated

2024-04-22 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-35214: - Summary: Update result partition id for remote input channel when unknown input channel is updated Key: FLINK-35214 URL: https://issues.apache.org/jira/browse/FLINK-35214

[jira] [Commented] (FLINK-35184) Hash collision inside MiniBatchStreamingJoin operator

2024-04-22 Thread Roman Boyko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839928#comment-17839928 ] Roman Boyko commented on FLINK-35184: - [~xu_shuai_] , Ok agree with you. So may I start

[jira] [Created] (FLINK-35213) A potential inconsistent table structure issue

2024-04-22 Thread LvYanquan (Jira)
LvYanquan created FLINK-35213: - Summary: A potential inconsistent table structure issue Key: FLINK-35213 URL: https://issues.apache.org/jira/browse/FLINK-35213 Project: Flink Issue Type

[jira] [Commented] (FLINK-35212) PyFlink thread mode process just can run once in standalonesession mode

2024-04-22 Thread Wei Yuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839926#comment-17839926 ] Wei Yuan commented on FLINK-35212: -- I also tested this issue with Java8 and Python 3.8.6 and another

[jira] [Created] (FLINK-35212) PyFlink thread mode process just can run once in standalonesession mode

2024-04-22 Thread Wei Yuan (Jira)
Wei Yuan created FLINK-35212: Summary: PyFlink thread mode process just can run once in standalonesession mode Key: FLINK-35212 URL: https://issues.apache.org/jira/browse/FLINK-35212 Project: Flink

[jira] [Updated] (FLINK-35172) DDL statement is added to the Schema Change Event

2024-04-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35172: --- Labels: pull-request-available (was: ) > DDL statement is added to the Schema Change Ev

[jira] [Commented] (FLINK-34727) RestClusterClient.requestJobResult throw ConnectionClosedException when the accumulator data is large

2024-04-22 Thread Wancheng Xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839922#comment-17839922 ] Wancheng Xiao commented on FLINK-34727: --- [~Weijie Guo] Hello, can you help find someone to take

[jira] [Commented] (FLINK-35187) FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines

2024-04-22 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839921#comment-17839921 ] Rui Fan commented on FLINK-35187: - Hi [~lsy] , I wanna check with you, will this great feature

[jira] [Commented] (FLINK-35184) Hash collision inside MiniBatchStreamingJoin operator

2024-04-22 Thread Shuai Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839920#comment-17839920 ] Shuai Xu commented on FLINK-35184: -- Hi [~rovboyko] , actually it can't be avoid hash collision even

[jira] [Assigned] (FLINK-32086) Cleanup non-reported managed directory on exit of TM

2024-04-22 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-32086: --- Assignee: Feifan Wang (was: Zakelly Lan) > Cleanup non-reported managed directory on e

[jira] [Assigned] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed

2024-04-22 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-35041: -- Assignee: Feifan Wang > IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistrat

[jira] [Commented] (FLINK-32086) Cleanup non-reported managed directory on exit of TM

2024-04-22 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839917#comment-17839917 ] xiaogang zhou commented on FLINK-32086: --- [~Zakelly] yes no problem > Cleanup non-reported mana

[jira] [Commented] (FLINK-32086) Cleanup non-reported managed directory on exit of TM

2024-04-22 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839916#comment-17839916 ] Zakelly Lan commented on FLINK-32086: - [~Feifan Wang] I'm not working on this. And [~zhoujira86

[jira] [Updated] (FLINK-35188) Introduce CatalogMaterializedTable and related interface to support materialized table

2024-04-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35188: --- Labels: pull-request-available (was: ) > Introduce CatalogMaterializedTable and rela

[jira] [Created] (FLINK-35211) when synchronize LOB fields using oracle cdc, an error occurs

2024-04-22 Thread wangsw (Jira)
wangsw created FLINK-35211: -- Summary: when synchronize LOB fields using oracle cdc, an error occurs Key: FLINK-35211 URL: https://issues.apache.org/jira/browse/FLINK-35211 Project: Flink Issue

[jira] [Commented] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

2024-04-22 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839906#comment-17839906 ] Rui Fan commented on FLINK-35088: - Thanks [~martijnvisser] for the ping, I will take a look in detail

[jira] [Commented] (FLINK-35210) Give the option to set automatically the parallelism of the KafkaSource to the number of kafka partitions

2024-04-22 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839816#comment-17839816 ] Martijn Visser commented on FLINK-35210: There isn't enough information about used/tested

[jira] [Commented] (FLINK-35165) AdaptiveBatch Scheduler should not restrict the default source parallelism to the max parallelism set

2024-04-22 Thread Venkata krishnan Sowrirajan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839806#comment-17839806 ] Venkata krishnan Sowrirajan commented on FLINK-35165: - JFYI, I am working on the fix

[jira] [Commented] (FLINK-35210) Give the option to set automatically the parallelism of the KafkaSource to the number of kafka partitions

2024-04-22 Thread Nicolas Perrin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839756#comment-17839756 ] Nicolas Perrin commented on FLINK-35210: That's indeed how I proceeded in our case.  I'm sorry

[jira] [Comment Edited] (FLINK-35210) Give the option to set automatically the parallelism of the KafkaSource to the number of kafka partitions

2024-04-22 Thread Nicolas Perrin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839756#comment-17839756 ] Nicolas Perrin edited comment on FLINK-35210 at 4/22/24 3:45 PM: - That's

[jira] [Commented] (FLINK-35210) Give the option to set automatically the parallelism of the KafkaSource to the number of kafka partitions

2024-04-22 Thread Oleksandr Nitavskyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839739#comment-17839739 ] Oleksandr Nitavskyi commented on FLINK-35210: - Thanks [~npfp] for suggestion. I believe what

[jira] [Comment Edited] (FLINK-35178) Checkpoint CLAIM mode does not fully control snapshot ownership

2024-04-22 Thread elon_X (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839522#comment-17839522 ] elon_X edited comment on FLINK-35178 at 4/22/24 3:20 PM: - [~lijinzhong]  Thank

[jira] [Created] (FLINK-35210) Give the option to set automatically the parallelism of the KafkaSource to the number of kafka partitions

2024-04-22 Thread Nicolas Perrin (Jira)
Nicolas Perrin created FLINK-35210: -- Summary: Give the option to set automatically the parallelism of the KafkaSource to the number of kafka partitions Key: FLINK-35210 URL: https://issues.apache.org/jira/browse

[jira] [Updated] (FLINK-33722) MATCH_RECOGNIZE in batch mode ignores events order

2024-04-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33722: --- Labels: pull-request-available (was: ) > MATCH_RECOGNIZE in batch mode ignores eve

[jira] [Updated] (FLINK-35158) Error handling in StateFuture's callback

2024-04-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35158: --- Labels: pull-request-available (was: ) > Error handling in StateFuture's callb

[jira] [Commented] (FLINK-35027) Implement checkpoint drain in AsyncExecutionController

2024-04-22 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839662#comment-17839662 ] Yanfei Lei commented on FLINK-35027: Merged into master via 9336760 > Implement checkpoint dr

[jira] [Commented] (FLINK-35028) Timer firing under async execution model

2024-04-22 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839659#comment-17839659 ] Yanfei Lei commented on FLINK-35028: Merged into master via 0b2e988 > Timer firing under as

[jira] [Updated] (FLINK-35138) Release flink-connector-kafka v3.2.0 for Flink 1.19

2024-04-22 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35138: -- Fix Version/s: kafka-3.2.0 > Release flink-connector-kafka v3.2.0 for Flink 1

[jira] [Resolved] (FLINK-35028) Timer firing under async execution model

2024-04-22 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-35028. Resolution: Resolved > Timer firing under async execution mo

[jira] [Updated] (FLINK-35138) Release flink-connector-kafka v3.2.0 for Flink 1.19

2024-04-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35138: --- Labels: pull-request-available (was: ) > Release flink-connector-kafka v3.2.0 for Fl

[jira] [Assigned] (FLINK-35138) Release flink-connector-kafka v3.2.0 for Flink 1.19

2024-04-22 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-35138: - Assignee: Danny Cranmer > Release flink-connector-kafka v3.2.0 for Flink 1

[jira] [Updated] (FLINK-35138) Release flink-connector-kafka v3.2.0 for Flink 1.19

2024-04-22 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35138: -- Summary: Release flink-connector-kafka v3.2.0 for Flink 1.19 (was: Release flink-connector

[jira] [Commented] (FLINK-35133) Release flink-connector-cassandra v3.2.0 for Flink 1.19

2024-04-22 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839651#comment-17839651 ] Danny Cranmer commented on FLINK-35133: --- 3.2.0-RC1 Vote thread: https://lists.apache.org/thread

[jira] [Created] (FLINK-35209) Add a DeserializationSchema decorator that counts deserialize errors

2024-04-22 Thread Nicolas Perrin (Jira)
Nicolas Perrin created FLINK-35209: -- Summary: Add a DeserializationSchema decorator that counts deserialize errors Key: FLINK-35209 URL: https://issues.apache.org/jira/browse/FLINK-35209 Project

[jira] [Commented] (FLINK-34227) Job doesn't disconnect from ResourceManager

2024-04-22 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839630#comment-17839630 ] Ryan Skraba commented on FLINK-34227: - 1.18 AdaptiveScheduler / Test (module: table) https

[jira] [Commented] (FLINK-35175) HadoopDataInputStream can't compile with Hadoop 3.2.3

2024-04-22 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839628#comment-17839628 ] Ryan Skraba commented on FLINK-35175: - Not including the fix: 1.20 Hadoop 3.1.3 / Compile https

[jira] [Commented] (FLINK-35002) GitHub action request timeout to ArtifactService

2024-04-22 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839631#comment-17839631 ] Ryan Skraba commented on FLINK-35002: - 1.20 Java 21 / Compile https://github.com/apache/flink

[jira] [Commented] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed

2024-04-22 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839629#comment-17839629 ] Ryan Skraba commented on FLINK-35041: - 1.20 Default (Java 8) / Test (module: core) https

[jira] [Assigned] (FLINK-35189) Introduce test-filesystem Catalog based on FileSystem Connector to support materialized table

2024-04-22 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-35189: - Assignee: dalongliu > Introduce test-filesystem Catalog based on FileSystem Connec

[jira] [Assigned] (FLINK-35187) FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines

2024-04-22 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-35187: - Assignee: dalongliu > FLIP-435: Introduce a New Materialized Table for Simplifying D

[jira] [Assigned] (FLINK-35188) Introduce CatalogMaterializedTable and related interface to support materialized table

2024-04-22 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-35188: - Assignee: dalongliu > Introduce CatalogMaterializedTable and related interface to supp

[jira] [Commented] (FLINK-32086) Cleanup non-reported managed directory on exit of TM

2024-04-22 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839592#comment-17839592 ] Feifan Wang commented on FLINK-32086: - Hi [~Zakelly] , are you still work on this ticket ? We want

[jira] [Updated] (FLINK-35206) Desc table syntax support materialized table

2024-04-22 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-35206: -- Description: The desc syntax supports materialized table: {code:SQL} DESC Orders {code} Return

[jira] [Commented] (FLINK-35191) Support alter materialized table related syntaxes: suspend, resume, refresh, set and reset

2024-04-22 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839585#comment-17839585 ] dalongliu commented on FLINK-35191: --- Thanks for taking this ticket, assign to you. > Support al

  1   2   3   4   5   6   7   8   9   10   >