[jira] [Created] (FLINK-35467) The flink-cdc.sh script of flink-cdc-3.1.0 cannot read the correct Flink configuration information specified by the flink-conf.yaml through the FLINK_CONF_DIR environmen

2024-05-27 Thread Justin.Liu (Jira)
: FLINK-35467 URL: https://issues.apache.org/jira/browse/FLINK-35467 Project: Flink Issue Type: Improvement Components: Flink CDC Affects Versions: cdc-3.1.0 Environment: Environment Information: flink-1.17.1 flink-cdc-3.1.0

[jira] [Commented] (FLINK-35418) EventTimeWindowCheckpointingITCase fails with an NPE

2024-05-27 Thread Rob Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849841#comment-17849841 ] Rob Young commented on FLINK-35418: --- looks like the same issue as https://issues.apache.org/jira

[jira] [Resolved] (FLINK-33759) flink parquet writer support write nested array or map type

2024-05-27 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-33759. - Fix Version/s: 1.20.0 Resolution: Fixed > flink parquet writer support write nested array or

[jira] [Updated] (FLINK-33759) flink parquet writer support write nested array or map type

2024-05-27 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33759: Affects Version/s: 1.19.0 > flink parquet writer support write nested array or map t

[jira] [Commented] (FLINK-33759) flink parquet writer support write nested array or map type

2024-05-27 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849837#comment-17849837 ] Jing Ge commented on FLINK-33759: - master: https://github.com/apache/flink/commit

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

2024-05-27 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849767#comment-17849767 ] Ryan Skraba commented on FLINK-35446: - Thanks for the fix! There were a bunch of failures over

[jira] [Commented] (FLINK-35380) ResumeCheckpointManuallyITCase hanging on tests

2024-05-27 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849765#comment-17849765 ] Ryan Skraba commented on FLINK-35380: - * 1.20 Java 21 / Test (module: tests) https://github.com

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

2024-05-27 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849759#comment-17849759 ] Ryan Skraba commented on FLINK-28440: - * 1.19 Java 21 / Test (module: tests) https://github.com

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

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

[jira] [Commented] (FLINK-35012) ChangelogNormalizeRestoreTest.testRestore failure

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

[jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out

2024-05-27 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849760#comment-17849760 ] Ryan Skraba commented on FLINK-34224: - * 1.20 Hadoop 3.1.3 / Test (module: core) https://github.com

[jira] [Commented] (FLINK-34645) StreamArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByCount fails

2024-05-27 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849762#comment-17849762 ] Ryan Skraba commented on FLINK-34645: - * 1.18 Hadoop 3.1.3 / Test (module: misc) https://github.com

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

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

[jira] [Commented] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails

2024-05-27 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849758#comment-17849758 ] Ryan Skraba commented on FLINK-18476: - * 1.20 Java 21 / Test (module: misc) https://github.com

[jira] [Commented] (FLINK-34379) table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryError

2024-05-27 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849740#comment-17849740 ] Jing Ge commented on FLINK-34379: - master: 87b7193846090897b2feabf716ee5378bcd7585b

[jira] [Updated] (FLINK-35425) Support convert Freshness to cron expression for full refresh mode

2024-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35425: --- Labels: pull-request-available (was: ) > Support convert Freshness to cron express

[jira] [Created] (FLINK-35466) Cannot pass all columns to SQL UDFs using `*`

2024-05-27 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-35466: -- Summary: Cannot pass all columns to SQL UDFs using `*` Key: FLINK-35466 URL: https://issues.apache.org/jira/browse/FLINK-35466 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35465) Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster failures.

2024-05-27 Thread Junrui Li (Jira)
Junrui Li created FLINK-35465: - Summary: Introduce BatchJobRecoveryHandler for recovery of batch jobs from JobMaster failures. Key: FLINK-35465 URL: https://issues.apache.org/jira/browse/FLINK-35465

[jira] [Commented] (FLINK-35464) Flink CDC 3.1 breaks operator state compatiblity

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849705#comment-17849705 ] Leonard Xu commented on FLINK-35464: Thanks [~xiqian_yu] for the investigation, and I improve

[jira] [Assigned] (FLINK-35464) Flink CDC 3.1 breaks operator state compatiblity

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35464: -- Assignee: yux > Flink CDC 3.1 breaks operator state compatibl

[jira] [Updated] (FLINK-35464) Flink CDC 3.1 breaks operator state compatiblity

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35464: --- Priority: Blocker (was: Critical) > Flink CDC 3.1 breaks operator state compatibl

[jira] [Commented] (FLINK-35464) Flink CDC 3.1 breaks operator state compatiblity

2024-05-27 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849704#comment-17849704 ] yux commented on FLINK-35464: - [~Leonard] I'm willing to investigate this. > Flink CDC 3.1 breaks opera

[jira] [Created] (FLINK-35464) Flink CDC 3.1 breaks operator state compatiblity

2024-05-27 Thread yux (Jira)
yux created FLINK-35464: --- Summary: Flink CDC 3.1 breaks operator state compatiblity Key: FLINK-35464 URL: https://issues.apache.org/jira/browse/FLINK-35464 Project: Flink Issue Type: Bug

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

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-35300. -- Resolution: Invalid > Improve MySqlStreamingChangeEventSource to skip null events in ev

[jira] [Updated] (FLINK-35323) Only the schema of the first hit table is recorded when the source-table of the transformer hits multiple tables

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35323: --- Affects Version/s: cdc-3.1.0 > Only the schema of the first hit table is recorded when the sou

[jira] [Assigned] (FLINK-35323) Only the schema of the first hit table is recorded when the source-table of the transformer hits multiple tables

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35323: -- Assignee: yux > Only the schema of the first hit table is recorded when the source-ta

[jira] [Updated] (FLINK-35323) Only the schema of the first hit table is recorded when the source-table of the transformer hits multiple tables

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35323: --- Fix Version/s: cdc-3.1.1 cdc-3.2.0 > Only the schema of the first hit ta

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

2024-05-27 Thread Xiao Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849700#comment-17849700 ] Xiao Huang commented on FLINK-35408: [~davidradl] I have provided the background for this pr

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

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35300: -- Assignee: Xiao Huang > Improve MySqlStreamingChangeEventSource to skip null events in ev

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

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35409: -- Assignee: Xiao Huang > Request more splits if all splits are filtered from addSplits met

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

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35408. Resolution: Implemented Implemented in master: b2cb30f2406502b5672f8ed8a3a8eaef1d6d6a07 > Add

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

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849698#comment-17849698 ] Leonard Xu commented on FLINK-35408: I merged the PR after saw your comments [~davidradl],and I

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

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849697#comment-17849697 ] Leonard Xu commented on FLINK-35408: [~davidradl] I think a FLIP is not necessary as this minor

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

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35408: --- Priority: Minor (was: Major) > Add 30 min tolerance value when validating the time-zone sett

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

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35408: -- Assignee: Xiao Huang > Add 30 min tolerance value when validating the time-zone sett

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

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35408: --- Priority: Major (was: Minor) > Add 30 min tolerance value when validating the time-zone sett

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

2024-05-27 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35301. Resolution: Fixed master via: 6350eec66c80a4c3815dce604305d417ee862e14 > Fix deadlock w

[jira] [Updated] (FLINK-35427) Support fail-on-unknown-field config in json format

2024-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35427: --- Labels: pull-request-available (was: ) > Support fail-on-unknown-field config in j

[jira] [Closed] (FLINK-35310) Replace RBAC verb wildcards with actual verbs

2024-05-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35310. -- Fix Version/s: kubernetes-operator-1.9.0 Resolution: Fixed merged to main

[jira] [Assigned] (FLINK-35310) Replace RBAC verb wildcards with actual verbs

2024-05-27 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-35310: -- Assignee: Tim > Replace RBAC verb wildcards with actual ve

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

2024-05-27 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-35434. -- Fix Version/s: 1.20.0 Resolution: Fixed Merged f926d2a5 and 2f7099e7 into master

[jira] [Updated] (FLINK-35360) [Feature] Submit Flink CDC pipeline job yarn Application mode

2024-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35360: --- Labels: pull-request-available (was: ) > [Feature] Submit Flink CDC pipeline job y

[jira] [Closed] (FLINK-32063) AWS CI mvn compile fails to cast objects to parent type.

2024-05-27 Thread Ahmed Hamdy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ahmed Hamdy closed FLINK-32063. --- Resolution: Not A Problem > AWS CI mvn compile fails to cast objects to parent t

[jira] [Updated] (FLINK-35441) Add CDC upgrade compatibility tests

2024-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35441: --- Labels: pull-request-available (was: ) > Add CDC upgrade compatibility te

[jira] [Closed] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

2024-05-27 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-35040. --- Resolution: Won't Fix Close this Jira first, you can get more details from https://lists.apache.org/thread

[jira] [Updated] (FLINK-35463) CDC job failed when restored from checkpoint when route rule changed.

2024-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35463: --- Labels: pull-request-available (was: ) > CDC job failed when restored from checkpoint w

[jira] [Created] (FLINK-35463) CDC job failed when restored from checkpoint when route rule changed.

2024-05-27 Thread hk__lrzy (Jira)
hk__lrzy created FLINK-35463: Summary: CDC job failed when restored from checkpoint when route rule changed. Key: FLINK-35463 URL: https://issues.apache.org/jira/browse/FLINK-35463 Project: Flink

[jira] [Updated] (FLINK-35462) Introduce a parameter to control the chaining mode between a Flink SQL connector sink or source and its adjacent operator.

2024-05-27 Thread yuanfenghu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuanfenghu updated FLINK-35462: --- Description: When using the flinksql connector, we can set the parallelism of the sink. However

[jira] [Updated] (FLINK-35462) Introduce a parameter to control the chaining mode between a Flink SQL connector sink or source and its adjacent operator.

2024-05-27 Thread yuanfenghu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuanfenghu updated FLINK-35462: --- Description: When using the flinksql connector, we can set the parallelism of the sink. However

[jira] [Created] (FLINK-35462) Introduce a parameter to control the chaining mode between a Flink SQL connector sink or source and its adjacent operator.

2024-05-27 Thread yuanfenghu (Jira)
/jira/browse/FLINK-35462 Project: Flink Issue Type: Improvement Components: Table SQL / Planner Reporter: yuanfenghu When using the flinksql connector, we can set the parallelism of the sink. However, when we modify the parallelism of the sink

[jira] [Updated] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

2024-05-27 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35040: Priority: Major (was: Blocker) > The performance of serializerHeavyString regresses since Apri

[jira] [Closed] (FLINK-35403) FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding

2024-05-27 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-35403. Fix Version/s: 1.20.0 Resolution: Fixed Fixed in master

[jira] [Updated] (FLINK-34993) Support MODEL syntax in parser

2024-05-27 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-34993: - Description: Adds all parser changes required for FLIP-437. > Support MODEL syntax in par

[jira] [Closed] (FLINK-34993) Support MODEL syntax in parser

2024-05-27 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-34993. Fix Version/s: 1.20.0 Resolution: Fixed Fixed in master

[jira] [Updated] (FLINK-34993) Support MODEL syntax in parser

2024-05-27 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-34993: - Summary: Support MODEL syntax in parser (was: Support Model CRUD in parser) > Support MO

[jira] [Updated] (FLINK-35460) Check file size when position read for ForSt

2024-05-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35460: --- Labels: pull-request-available (was: ) > Check file size when position read for Fo

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

2024-05-27 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849624#comment-17849624 ] dalongliu commented on FLINK-35342: --- Merged in master: 90e2d6cfeea44f6302b9d1f1ee4396c5a5c69b8f

[jira] [Commented] (FLINK-34840) [3.1][pipeline-connectors] Add Implementation of DataSink in Iceberg.

2024-05-26 Thread Peter Vary (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849623#comment-17849623 ] Peter Vary commented on FLINK-34840: If you need help with Iceberg reviews, feel free to ping me

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

2024-05-26 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-35295. Resolution: Fixed master: 18b0627e343ddd218adcbccef8fb5f5f65813479 > Improve jdbc connect

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

2024-05-26 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35295: -- Assignee: Xiao Huang > Improve jdbc connection pool initialization failure mess

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

2024-05-26 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35295: --- Fix Version/s: cdc-3.2.0 > Improve jdbc connection pool initialization failure mess

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

2024-05-26 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-35295: --- Affects Version/s: cdc-3.1.0 > Improve jdbc connection pool initialization failure mess

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

2024-05-26 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-35294. -- Resolution: Implemented Implemented master via : bddcaae7846671c0447b2aa6c7d8e96638988f99 >

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

2024-05-26 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35294: -- Assignee: Xiao Huang > Use source config to check if the filter should be appl

[jira] [Closed] (FLINK-35426) Change the distribution of DynamicFilteringDataCollector to Broadcast

2024-05-26 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-35426. --- Resolution: Done master: 4b342da6d149113dde821b370a136beef3430fff > Change the distribut

[jira] [Comment Edited] (FLINK-35456) Many tests fails on AZP as NPE related to FileMerging

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849612#comment-17849612 ] Weijie Guo edited comment on FLINK-35456 at 5/27/24 4:04 AM: - https

[jira] [Comment Edited] (FLINK-35456) Many tests fails on AZP as NPE related to FileMerging

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849612#comment-17849612 ] Weijie Guo edited comment on FLINK-35456 at 5/27/24 4:03 AM: - https

[jira] [Commented] (FLINK-35456) Many tests fails on AZP as NPE related to FileMerging

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849612#comment-17849612 ] Weijie Guo commented on FLINK-35456: https://dev.azure.com/apache-flink/apache-flink/_build/results

[jira] [Created] (FLINK-35461) Improve Runtime Configuration for Flink 2.0

2024-05-26 Thread Xuannan Su (Jira)
Xuannan Su created FLINK-35461: -- Summary: Improve Runtime Configuration for Flink 2.0 Key: FLINK-35461 URL: https://issues.apache.org/jira/browse/FLINK-35461 Project: Flink Issue Type

[jira] [Updated] (FLINK-35457) EventTimeWindowCheckpointingITCase fails on AZP as NPE

2024-05-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35457: --- Labels: pull-request-available (was: ) > EventTimeWindowCheckpointingITCase fails on

[jira] [Created] (FLINK-35460) Check file size when position read for ForSt

2024-05-26 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-35460: Summary: Check file size when position read for ForSt Key: FLINK-35460 URL: https://issues.apache.org/jira/browse/FLINK-35460 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35459) Use Incremental Source Framework in Flink CDC TiKV Source Connector

2024-05-26 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-35459: --- Summary: Use Incremental Source Framework in Flink CDC TiKV Source Connector Key: FLINK-35459 URL: https://issues.apache.org/jira/browse/FLINK-35459 Project: Flink

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

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849607#comment-17849607 ] Weijie Guo commented on FLINK-35342: 1.20 test_cron_adaptive_scheduler table https://dev.azure.com

[jira] [Commented] (FLINK-34239) Introduce a deep copy method of SerializerConfig for merging with Table configs in org.apache.flink.table.catalog.DataTypeFactoryImpl

2024-05-26 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849606#comment-17849606 ] Zhanghao Chen commented on FLINK-34239: --- [~mallikarjuna] Hi could you help rebase the code

[jira] [Updated] (FLINK-35456) Many tests fails on AZP as NPE related to FileMerging

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35456: --- Priority: Blocker (was: Major) > Many tests fails on AZP as NPE related to FileMerg

[jira] [Commented] (FLINK-35456) Many tests fails on AZP as NPE related to FileMerging

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849605#comment-17849605 ] Weijie Guo commented on FLINK-35456: SplitAggregateITCase.testMultipleDistinctAggOnSameColumn https

[jira] [Commented] (FLINK-35456) Many tests fails on AZP as NPE related to FileMerging

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849604#comment-17849604 ] Weijie Guo commented on FLINK-35456: testTop1WithGroupByCount:535->testTopNthWithGroupByCountB

[jira] [Created] (FLINK-35458) Add serializer upgrade test for set serializer

2024-05-26 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-35458: - Summary: Add serializer upgrade test for set serializer Key: FLINK-35458 URL: https://issues.apache.org/jira/browse/FLINK-35458 Project: Flink Issue Type

[jira] [Updated] (FLINK-35456) Many tests fails on AZP as NPE related to FileMerging

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35456: --- Summary: Many tests fails on AZP as NPE related to FileMerging

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

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849602#comment-17849602 ] Weijie Guo commented on FLINK-35342: 1.20 test_cron_adaptive_scheduler https://dev.azure.com/apache

[jira] [Commented] (FLINK-35456) WindowAggregateITCase.testEventTimeHopWindow fails on AZP as NPE

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849601#comment-17849601 ] Weijie Guo commented on FLINK-35456: WindowJoinITCase.testInnerJoinOnWTFWithOffset also has same

[jira] [Updated] (FLINK-35068) Introduce built-in serialization support for Set

2024-05-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35068: --- Labels: pull-request-available (was: ) > Introduce built-in serialization support for

[jira] [Updated] (FLINK-35457) EventTimeWindowCheckpointingITCase fails on AZP as NPE

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35457: --- Description: {code:java} Caused by: java.lang.NullPointerException

[jira] [Created] (FLINK-35457) EventTimeWindowCheckpointingITCase fails on AZP as NPE

2024-05-26 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35457: -- Summary: EventTimeWindowCheckpointingITCase fails on AZP as NPE Key: FLINK-35457 URL: https://issues.apache.org/jira/browse/FLINK-35457 Project: Flink Issue

[jira] [Updated] (FLINK-35456) WindowAggregateITCase.testEventTimeHopWindow fails on AZP as NPE

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35456: --- Description: {code:java} May 25 02:12:16 Caused by: java.lang.NullPointerException May 25 02:12:16

[jira] [Created] (FLINK-35456) WindowAggregateITCase.testEventTimeHopWindow fails on AZP as NPE

2024-05-26 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35456: -- Summary: WindowAggregateITCase.testEventTimeHopWindow fails on AZP as NPE Key: FLINK-35456 URL: https://issues.apache.org/jira/browse/FLINK-35456 Project: Flink

[jira] [Commented] (FLINK-35068) Introduce built-in serialization support for Set

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849599#comment-17849599 ] Weijie Guo commented on FLINK-35068: Thanks [~Zhanghao Chen], you are assigned. > Introduce bu

[jira] [Assigned] (FLINK-35068) Introduce built-in serialization support for Set

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-35068: -- Assignee: Zhanghao Chen > Introduce built-in serialization support for

[jira] [Closed] (FLINK-34123) Introduce built-in serialization support for Map and List

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-34123. -- Resolution: Done master(1.20) via f860631c523c1d446c0d01046f0fbe6055174dc6. > Introduce bu

[jira] [Commented] (FLINK-35324) Avro format can not perform projection pushdown for specific fields

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17849596#comment-17849596 ] Weijie Guo commented on FLINK-35324: Does 1.20 has the same problem? > Avro format can not perf

[jira] [Updated] (FLINK-35423) ARRAY_EXCEPT should support set semantics

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35423: --- Affects Version/s: 1.20.0 > ARRAY_EXCEPT should support set semant

[jira] [Comment Edited] (FLINK-35429) We don't need introduce getFlinkConfigurationOptions for SqlGatewayRestEndpointFactory#Context

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848927#comment-17848927 ] Weijie Guo edited comment on FLINK-35429 at 5/27/24 1:42 AM: - master(1.20

[jira] [Updated] (FLINK-35429) We don't need introduce getFlinkConfigurationOptions for SqlGatewayRestEndpointFactory#Context

2024-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35429: --- Fix Version/s: 1.20.0 1.19.1 > We don't need introd

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

2024-05-26 Thread Zakelly Lan (Jira)
[ 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

2024-05-26 Thread Zakelly Lan (Jira)
[ 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

2024-05-26 Thread Kaiyao Ke (Jira)
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

2024-05-26 Thread Sergey Nuyanzin (Jira)
[ 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

2024-05-26 Thread Sergey Nuyanzin (Jira)
[ 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

2024-05-26 Thread ASF GitHub Bot (Jira)
[ 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

2024-05-26 Thread ASF GitHub Bot (Jira)
[ 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

  1   2   3   4   5   6   7   8   9   10   >