[jira] [Resolved] (FLINK-35446) FileMergingSnapshotManagerBase throws a NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-35446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-35446. - Fix Version/s: 1.20.0 Assignee: Zakelly Lan Resolution: Fixed

[jira] [Commented] (FLINK-35446) FileMergingSnapshotManagerBase throws a NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-35446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849563#comment-17849563 ] Zakelly Lan commented on FLINK-35446: - Merged into master via

[jira] [Created] (FLINK-35455) Non-idempotent unit tests

Kaiyao Ke created FLINK-35455: - Summary: Non-idempotent unit tests Key: FLINK-35455 URL: https://issues.apache.org/jira/browse/FLINK-35455 Project: Flink Issue Type: Bug Reporter

[jira] [Commented] (FLINK-35424) Elasticsearch connector 8 supports SSL context

[ https://issues.apache.org/jira/browse/FLINK-35424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849556#comment-17849556 ] Sergey Nuyanzin commented on FLINK-35424: - Merged as [50327f84d46ac2af10d352730ab0dfd0432249bd

[jira] [Resolved] (FLINK-35424) Elasticsearch connector 8 supports SSL context

[ https://issues.apache.org/jira/browse/FLINK-35424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-35424. - Fix Version/s: elasticsearch-3.2.0 Resolution: Fixed > Elasticsearch connecto

[jira] [Updated] (FLINK-35348) Implement materialized table refresh rest api

[ https://issues.apache.org/jira/browse/FLINK-35348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35348: --- Labels: pull-request-available (was: ) > Implement materialized table refresh rest

[jira] [Updated] (FLINK-35454) Connector ArchTests fails due to dependency on fink.util.Preconditions

[ https://issues.apache.org/jira/browse/FLINK-35454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35454: --- Labels: pull-request-available (was: ) > Connector ArchTests fails due to depende

[jira] [Commented] (FLINK-35454) Connector ArchTests fails due to dependency on fink.util.Preconditions

[ https://issues.apache.org/jira/browse/FLINK-35454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849505#comment-17849505 ] Ahmed Hamdy commented on FLINK-35454: - https://dev.azure.com/apache-flink/apache-flink/_build

[jira] [Created] (FLINK-35454) Connector ArchTests fails due to dependency on fink.util.Preconditions

Ahmed Hamdy created FLINK-35454: --- Summary: Connector ArchTests fails due to dependency on fink.util.Preconditions Key: FLINK-35454 URL: https://issues.apache.org/jira/browse/FLINK-35454 Project: Flink

[jira] [Updated] (FLINK-35453) StreamReader Charset fix with UTF8 in core files

[ https://issues.apache.org/jira/browse/FLINK-35453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35453: --- Labels: pull-request-available (was: ) > StreamReader Charset fix with UTF8 in core fi

[jira] [Created] (FLINK-35453) StreamReader Charset fix with UTF8 in core files

xy created FLINK-35453: -- Summary: StreamReader Charset fix with UTF8 in core files Key: FLINK-35453 URL: https://issues.apache.org/jira/browse/FLINK-35453 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-35452) MySQL CDC is not tracking newly added tables when a failure happens after the snapshot phase

[ https://issues.apache.org/jira/browse/FLINK-35452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-35452: --- Description: We've seen some cases where a MySQL CDC job is restarted with some newly added tables

[jira] [Updated] (FLINK-35452) MySQL CDC is not tracking newly added tables when a failure happens after the snapshot phase

[ https://issues.apache.org/jira/browse/FLINK-35452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-35452: --- Summary: MySQL CDC is not tracking newly added tables when a failure happens after the snapshot

[jira] [Updated] (FLINK-35452) MySQL CDC not tracking newly added tables after snapshot

[ https://issues.apache.org/jira/browse/FLINK-35452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-35452: --- Description: We've seen some cases where a MySQL CDC job is restarted with some newly added tables

[jira] [Updated] (FLINK-35452) MySQL CDC not tracking newly added tables after snapshot

[ https://issues.apache.org/jira/browse/FLINK-35452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-35452: --- Description: We've seen some cases where a MySQL CDC job is restarted with some newly added tables

[jira] [Created] (FLINK-35452) MySQL CDC not tracking newly added tables after snapshot

Sharon Xie created FLINK-35452: -- Summary: MySQL CDC not tracking newly added tables after snapshot Key: FLINK-35452 URL: https://issues.apache.org/jira/browse/FLINK-35452 Project: Flink Issue

[jira] [Created] (FLINK-35451) Support `ALTER CATALOG COMMENT` syntax

Yubin Li created FLINK-35451: Summary: Support `ALTER CATALOG COMMENT` syntax Key: FLINK-35451 URL: https://issues.apache.org/jira/browse/FLINK-35451 Project: Flink Issue Type: Sub-task

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

[ https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849467#comment-17849467 ] Keith Lee commented on FLINK-33251: --- Adding IntelliJ scratch file that can reliably reproduce

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

[ https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Keith Lee updated FLINK-33251: -- Attachment: reproduce_FLINK-33251.java > SQL Client query execution aborts after a few seco

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

[ https://issues.apache.org/jira/browse/FLINK-35215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848416#comment-17848416 ] Rui Fan edited comment on FLINK-35215 at 5/25/24 3:17 PM: -- Merged to master via

[jira] [Created] (FLINK-35450) Introduce Tikv pipeline DataSource

ouyangwulin created FLINK-35450: --- Summary: Introduce Tikv pipeline DataSource Key: FLINK-35450 URL: https://issues.apache.org/jira/browse/FLINK-35450 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-34841) [3.1][pipeline-connectors] Add jdbc pipeline sink

[ https://issues.apache.org/jira/browse/FLINK-34841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849443#comment-17849443 ] ouyangwulin commented on FLINK-34841: - [~gongzhongqiang] Looks like a very good job, cdc data entry

[jira] [Commented] (FLINK-34688) CDC framework split snapshot chunks asynchronously

[ https://issues.apache.org/jira/browse/FLINK-34688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849441#comment-17849441 ] ouyangwulin commented on FLINK-34688: - When the size of the data is relatively large, this feature

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

[ https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849440#comment-17849440 ] Keith Lee commented on FLINK-33251: --- It seems that reproducing this on M1 Mac is not difficult, also

[jira] [Created] (FLINK-35449) MySQL CDC Flink SQL column names are case-sensitive

linweijiang created FLINK-35449: --- Summary: MySQL CDC Flink SQL column names are case-sensitive Key: FLINK-35449 URL: https://issues.apache.org/jira/browse/FLINK-35449 Project: Flink Issue Type

[jira] [Comment Edited] (FLINK-35285) Autoscaler key group optimization can interfere with scale-down.max-factor

[ https://issues.apache.org/jira/browse/FLINK-35285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849352#comment-17849352 ] Trystan edited comment on FLINK-35285 at 5/24/24 8:41 PM: -- [~gyfora

[jira] [Comment Edited] (FLINK-35285) Autoscaler key group optimization can interfere with scale-down.max-factor

[ https://issues.apache.org/jira/browse/FLINK-35285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849352#comment-17849352 ] Trystan edited comment on FLINK-35285 at 5/24/24 5:34 PM: -- [~gyfora

[jira] [Commented] (FLINK-35285) Autoscaler key group optimization can interfere with scale-down.max-factor

[ https://issues.apache.org/jira/browse/FLINK-35285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849352#comment-17849352 ] Trystan commented on FLINK-35285: - [~gyfora] is there maybe another setting that can help tune

[jira] [Commented] (FLINK-34333) Fix FLINK-34007 LeaderElector bug in 1.18

[ https://issues.apache.org/jira/browse/FLINK-34333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849337#comment-17849337 ] Pedro Mázala commented on FLINK-34333: -- I've just done it. Thank you for porting it back >

[jira] [Commented] (FLINK-35411) Optimize wait logic in draining of async state requests

[ https://issues.apache.org/jira/browse/FLINK-35411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849336#comment-17849336 ] Zakelly Lan commented on FLINK-35411: - [~spoon-lz] sure, will do. Thanks for your volunteering

[jira] [Commented] (FLINK-35355) Async aggregating state

[ https://issues.apache.org/jira/browse/FLINK-35355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849335#comment-17849335 ] Zakelly Lan commented on FLINK-35355: - Merged into master via

[jira] [Resolved] (FLINK-35355) Async aggregating state

[ https://issues.apache.org/jira/browse/FLINK-35355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-35355. - Fix Version/s: 2.0.0 Assignee: Jie Pu Resolution: Fixed > Async aggregat

[jira] [Updated] (FLINK-35446) FileMergingSnapshotManagerBase throws a NullPointerException

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

[jira] [Commented] (FLINK-35446) FileMergingSnapshotManagerBase throws a NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-35446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849323#comment-17849323 ] Zakelly Lan commented on FLINK-35446: - [~rskraba] Thanks for letting me know! I'll fix

[jira] [Updated] (FLINK-35052) Webhook validator should reject unsupported Flink versions

[ https://issues.apache.org/jira/browse/FLINK-35052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35052: --- Labels: pull-request-available (was: ) > Webhook validator should reject unsupported Fl

[jira] [Updated] (FLINK-35448) Translate pod templates documentation into Chinese

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

[jira] [Created] (FLINK-35448) Translate pod templates documentation into Chinese

Caican Cai created FLINK-35448: -- Summary: Translate pod templates documentation into Chinese Key: FLINK-35448 URL: https://issues.apache.org/jira/browse/FLINK-35448 Project: Flink Issue Type

[jira] [Commented] (FLINK-35446) FileMergingSnapshotManagerBase throws a NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-35446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849285#comment-17849285 ] Ryan Skraba commented on FLINK-35446: - [~lijinzhong] or [~zakelly] Do you think this needs a similar

[jira] [Commented] (FLINK-35446) FileMergingSnapshotManagerBase throws a NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-35446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849284#comment-17849284 ] Ryan Skraba commented on FLINK-35446: - * 1.20 Java 11 / Test (module: tests) https://github.com

[jira] [Commented] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status

[ https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849283#comment-17849283 ] Ryan Skraba commented on FLINK-35342: - * 1.20 AdaptiveScheduler / Test (module: table) https

[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849282#comment-17849282 ] Ryan Skraba commented on FLINK-28440: - * 1.19 Hadoop 3.1.3 / Test (module: tests) https

[jira] [Updated] (FLINK-35447) Flink CDC Document document file had removed but website can access

[ https://issues.apache.org/jira/browse/FLINK-35447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35447: --- Labels: pull-request-available (was: ) > Flink CDC Document document file had remo

[jira] [Created] (FLINK-35447) Flink CDC Document document file had removed but website can access

Zhongqiang Gong created FLINK-35447: --- Summary: Flink CDC Document document file had removed but website can access Key: FLINK-35447 URL: https://issues.apache.org/jira/browse/FLINK-35447 Project

[jira] [Commented] (FLINK-35435) [FLIP-451] Introduce timeout configuration to AsyncSink

[ https://issues.apache.org/jira/browse/FLINK-35435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849272#comment-17849272 ] Ahmed Hamdy commented on FLINK-35435: - [~danny.cranmer] Could you please take a look when you have

[jira] [Updated] (FLINK-35435) [FLIP-451] Introduce timeout configuration to AsyncSink

[ https://issues.apache.org/jira/browse/FLINK-35435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35435: --- Labels: pull-request-available (was: ) > [FLIP-451] Introduce timeout configurat

[jira] [Created] (FLINK-35446) FileMergingSnapshotManagerBase throws a NullPointerException

Ryan Skraba created FLINK-35446: --- Summary: FileMergingSnapshotManagerBase throws a NullPointerException Key: FLINK-35446 URL: https://issues.apache.org/jira/browse/FLINK-35446 Project: Flink

[jira] [Updated] (FLINK-35445) Update Async Sink documentation for Timeout configuration

[ https://issues.apache.org/jira/browse/FLINK-35445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmed Hamdy updated FLINK-35445: Parent: FLINK-35435 Issue Type: Sub-task (was: Improvement) > Update Async S

[jira] [Created] (FLINK-35445) Update Async Sink documentation for Timeout configuration

Ahmed Hamdy created FLINK-35445: --- Summary: Update Async Sink documentation for Timeout configuration Key: FLINK-35445 URL: https://issues.apache.org/jira/browse/FLINK-35445 Project: Flink

[jira] [Commented] (FLINK-35435) [FLIP-451] Introduce timeout configuration to AsyncSink

[ https://issues.apache.org/jira/browse/FLINK-35435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849270#comment-17849270 ] Ahmed Hamdy commented on FLINK-35435: - h1. Non-Functional Backward compatibility To assure that we

[jira] [Updated] (FLINK-35435) [FLIP-451] Introduce timeout configuration to AsyncSink

[ https://issues.apache.org/jira/browse/FLINK-35435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmed Hamdy updated FLINK-35435: Attachment: Screenshot 2024-05-24 at 11.06.30.png Screenshot 2024-05-24

[jira] [Closed] (FLINK-34746) Switching to the Apache CDN for Dockerfile

[ https://issues.apache.org/jira/browse/FLINK-34746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-34746. -- Resolution: Fixed Fixed in apache/flink-docker@master

[jira] [Updated] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting

[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35408: --- Affects Version/s: cdc-3.1.0 > Add 30 min tolerance value when validating the time-zone sett

[jira] [Updated] (FLINK-35409) Request more splits if all splits are filtered from addSplits method

[ https://issues.apache.org/jira/browse/FLINK-35409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35409: --- Fix Version/s: cdc-3.2.0 > Request more splits if all splits are filtered from addSplits met

[jira] [Updated] (FLINK-35409) Request more splits if all splits are filtered from addSplits method

[ https://issues.apache.org/jira/browse/FLINK-35409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35409: --- Affects Version/s: cdc-3.1.0 > Request more splits if all splits are filtered from addSplits met

[jira] [Updated] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting

[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35408: --- Fix Version/s: cdc-3.2.0 > Add 30 min tolerance value when validating the time-zone sett

[jira] [Updated] (FLINK-35409) Request more splits if all splits are filtered from addSplits method

[ https://issues.apache.org/jira/browse/FLINK-35409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35409: --- Issue Type: Bug (was: Improvement) > Request more splits if all splits are filtered from addSpl

[jira] [Updated] (FLINK-35409) Request more splits if all splits are filtered from addSplits method

[ https://issues.apache.org/jira/browse/FLINK-35409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35409: --- Description: Suppose this scenario: A job is still in the snapshot phase, and the remaining

[jira] [Updated] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting

[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35408: --- Description: Now, MySQL CDC connector will retrieve the offset seconds between the configured

[jira] [Updated] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting

[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35408: --- Description: Now, MySQL CDC connector will retrieve the number of seconds the database-configured

[jira] [Resolved] (FLINK-35298) Improve metric reporter logic

[ https://issues.apache.org/jira/browse/FLINK-35298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35298. Resolution: Implemented via master: 8e8fd304afdd9668247a8869698e0949806cad7b > Improve met

[jira] [Assigned] (FLINK-35298) Improve metric reporter logic

[ https://issues.apache.org/jira/browse/FLINK-35298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35298: -- Assignee: Xiao Huang > Improve metric reporter lo

[jira] [Updated] (FLINK-35298) Improve metric reporter logic

[ https://issues.apache.org/jira/browse/FLINK-35298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35298: --- Fix Version/s: cdc-3.2.0 > Improve metric reporter lo

[jira] [Updated] (FLINK-35298) Improve metric reporter logic

[ https://issues.apache.org/jira/browse/FLINK-35298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35298: --- Affects Version/s: cdc-3.1.0 > Improve metric reporter lo

[jira] [Updated] (FLINK-35300) Improve MySqlStreamingChangeEventSource to skip null events in event deserializer

[ https://issues.apache.org/jira/browse/FLINK-35300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35300: --- Description: As described in title. > Improve MySqlStreamingChangeEventSource to skip null eve

[jira] [Updated] (FLINK-35297) Add validation for option connect.timeout

[ https://issues.apache.org/jira/browse/FLINK-35297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35297: --- Description: the value of option `connector.timeout` needs to be checked at compile time. >

[jira] [Updated] (FLINK-35298) Improve metric reporter logic

[ https://issues.apache.org/jira/browse/FLINK-35298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35298: --- Description: * In snapshot phase, set -1 as the value of currentFetchEventTimeLag metric

[jira] [Updated] (FLINK-35295) Improve jdbc connection pool initialization failure message

[ https://issues.apache.org/jira/browse/FLINK-35295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35295: --- Description: As described in ticket title. > Improve jdbc connection pool initialization fail

[jira] [Updated] (FLINK-35294) Use source config to check if the filter should be applied in timestamp starting mode

[ https://issues.apache.org/jira/browse/FLINK-35294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35294: --- Fix Version/s: cdc-3.2.0 > Use source config to check if the filter should be applied in timest

[jira] [Updated] (FLINK-35294) Use source config to check if the filter should be applied in timestamp starting mode

[ https://issues.apache.org/jira/browse/FLINK-35294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35294: --- Affects Version/s: cdc-3.1.0 > Use source config to check if the filter should be appl

[jira] [Commented] (FLINK-34582) release build tools lost the newly added py3.11 packages for mac

[ https://issues.apache.org/jira/browse/FLINK-34582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849229#comment-17849229 ] Muhammet Orazov commented on FLINK-34582: - Ohh no. Yes indeed you are right [~mapohl] , thanks

[jira] [Updated] (FLINK-35294) Use source config to check if the filter should be applied in timestamp starting mode

[ https://issues.apache.org/jira/browse/FLINK-35294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35294: --- Description: Since MySQL does not support the ability to quickly locate an binlog offset through

[jira] [Updated] (FLINK-35294) Use source config to check if the filter should be applied in timestamp starting mode

[ https://issues.apache.org/jira/browse/FLINK-35294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35294: --- Affects Version/s: 3.1.0 > Use source config to check if the filter should be applied in timest

[jira] [Updated] (FLINK-35301) Fix deadlock when loading driver classes

[ https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35301: --- Affects Version/s: cdc-3.1.0 (was: 3.1.0) > Fix deadlock when load

[jira] [Updated] (FLINK-35301) Fix deadlock when loading driver classes

[ https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35301: --- Fix Version/s: cdc-3.2.0 > Fix deadlock when loading driver clas

[jira] [Assigned] (FLINK-35301) Fix deadlock when loading driver classes

[ https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35301: -- Assignee: Xiao Huang > Fix deadlock when loading driver clas

[jira] [Commented] (FLINK-35301) Fix deadlock when loading driver classes

[ https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849226#comment-17849226 ] Leonard Xu commented on FLINK-35301: Thanks [~ShawnHx] for report this issue, I saw you've opened

[jira] [Updated] (FLINK-35301) Fix deadlock when loading driver classes

[ https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35301: --- Description: In JDK 8 and earlier version, if multiple threads invoke Class.forName("com.xx.D

[jira] [Updated] (FLINK-35301) Fix deadlock when loading driver classes

[ https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35301: --- Description: In JDK 8 and earlier version, if multiple threads invoking Class.forName

[jira] [Updated] (FLINK-35301) Fix deadlock when loading driver classes

[ https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35301: --- Description: In JDK 8 and earlier version, if multiple threads invoking Class.forName

[jira] [Updated] (FLINK-35301) Fix deadlock when loading driver classes

[ https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiao Huang updated FLINK-35301: --- Affects Version/s: 3.1.0 > Fix deadlock when loading driver clas

[jira] [Commented] (FLINK-35272) Pipeline Transform job supports omitting / renaming calculation column

[ https://issues.apache.org/jira/browse/FLINK-35272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849224#comment-17849224 ] Leonard Xu commented on FLINK-35272: Thanks [~xiqian_yu] for taking this ticket, assigned it to you

[jira] [Assigned] (FLINK-35272) Pipeline Transform job supports omitting / renaming calculation column

[ https://issues.apache.org/jira/browse/FLINK-35272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35272: -- Assignee: yux > Pipeline Transform job supports omitting / renaming calculation col

[jira] [Resolved] (FLINK-35437) BlockStatementGrouper uses lots of memory

[ https://issues.apache.org/jira/browse/FLINK-35437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-35437. -- Resolution: Fixed Fixed in 3d40bd7dd197b12b7b156bd758b4129148e885d1

[jira] [Created] (FLINK-35444) Paimon Pipeline Connector support changing column names to lowercase for Hive metastore

LvYanquan created FLINK-35444: - Summary: Paimon Pipeline Connector support changing column names to lowercase for Hive metastore Key: FLINK-35444 URL: https://issues.apache.org/jira/browse/FLINK-35444

[jira] [Commented] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849209#comment-17849209 ] xuyang commented on FLINK-34380: Hi, [~rovboyko] . +1 to fix the wrong order. I'll take a look for your

[jira] [Updated] (FLINK-34545) Add OceanBase pipeline connector to Flink CDC

[ https://issues.apache.org/jira/browse/FLINK-34545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34545: --- Labels: pull-request-available (was: ) > Add OceanBase pipeline connector to Flink

[jira] [Updated] (FLINK-35430) ZoneId is not passed to DebeziumJsonSerializationSchema

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

[jira] [Commented] (FLINK-35430) ZoneId is not passed to DebeziumJsonSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-35430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849192#comment-17849192 ] tianzhu.wen commented on FLINK-35430: - Please assgined this to me, thanks. > ZoneId is not pas

[jira] [Commented] (FLINK-34582) release build tools lost the newly added py3.11 packages for mac

[ https://issues.apache.org/jira/browse/FLINK-34582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849185#comment-17849185 ] Matthias Pohl commented on FLINK-34582: --- You're checking [~hxb]'s fork where the {{master}} branch

[jira] [Resolved] (FLINK-35431) Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0

[ https://issues.apache.org/jira/browse/FLINK-35431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35431. Resolution: Fixed Fixed via master:644b5c2ce1dea17df93bac6ddf5afd816c33fffb release-3.1

[jira] [Updated] (FLINK-35431) Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0

[ https://issues.apache.org/jira/browse/FLINK-35431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35431: --- Fix Version/s: cdc-3.2.0 > Migrate references in Flink CDC documentation from Debezium 1.9 to

[jira] [Assigned] (FLINK-35431) Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0

[ https://issues.apache.org/jira/browse/FLINK-35431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35431: -- Assignee: Zhongqiang Gong > Migrate references in Flink CDC documentation from Debezium

[jira] [Assigned] (FLINK-35434) Support pass exception in StateExecutor to runtime

[ https://issues.apache.org/jira/browse/FLINK-35434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-35434: Assignee: Feifan Wang > Support pass exception in StateExecutor to runt

[jira] [Commented] (FLINK-35067) Support metadata 'op_type' virtual column for Postgres CDC Connector.

[ https://issues.apache.org/jira/browse/FLINK-35067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849161#comment-17849161 ] Hongshun Wang commented on FLINK-35067: --- [~walls.flink.m], I hope you’re doing well. I’ve been

[jira] [Commented] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status

[ https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849160#comment-17849160 ] Weijie Guo commented on FLINK-35342: 1.20 test_cron_adaptive_scheduler: https://dev.azure.com

[jira] [Updated] (FLINK-35443) ChangelogLocalRecoveryITCase failed fatally with 239 exit code

[ https://issues.apache.org/jira/browse/FLINK-35443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35443: --- Description: {code:java} May 24 01:55:13 01:55:13.114 [ERROR] Error occurred in starting fork

[jira] [Created] (FLINK-35443) ChangelogLocalRecoveryITCase failed fatally with 239 exit code

Weijie Guo created FLINK-35443: -- Summary: ChangelogLocalRecoveryITCase failed fatally with 239 exit code Key: FLINK-35443 URL: https://issues.apache.org/jira/browse/FLINK-35443 Project: Flink

[jira] [Updated] (FLINK-35443) ChangelogLocalRecoveryITCase failed fatally with 239 exit code

[ https://issues.apache.org/jira/browse/FLINK-35443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35443: --- Description: {code:java} May 24 01:55:13 01:55:13.115 [ERROR

[jira] [Comment Edited] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849151#comment-17849151 ] Roman Boyko edited comment on FLINK-34380 at 5/24/24 4:18 AM: -- Hi

[jira] [Comment Edited] (FLINK-34380) Strange RowKind and records about intermediate output when using minibatch join

[ https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849151#comment-17849151 ] Roman Boyko edited comment on FLINK-34380 at 5/24/24 4:17 AM: -- Hi

  1   2   3   4   5   6   7   8   9   10   >