[jira] [Created] (FLINK-36375) Missing default value in AddColumnEvent

2024-09-25 Thread linqigeng (Jira)
linqigeng created FLINK-36375: - Summary: Missing default value in AddColumnEvent Key: FLINK-36375 URL: https://issues.apache.org/jira/browse/FLINK-36375 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-36374) Bundle forst statebackend in flink-dist and provide shortcut to enable

2024-09-25 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-36374: --- Summary: Bundle forst statebackend in flink-dist and provide shortcut to enable Key: FLINK-36374 URL: https://issues.apache.org/jira/browse/FLINK-36374 Project: Flink

[jira] [Created] (FLINK-36373) Support distribute state requests in task thread

2024-09-25 Thread Yanfei Lei (Jira)
Yanfei Lei created FLINK-36373: -- Summary: Support distribute state requests in task thread Key: FLINK-36373 URL: https://issues.apache.org/jira/browse/FLINK-36373 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-36372) Can not insert data to sink with reserved keywords column name

2024-09-25 Thread Tan Nguyen (Jira)
Tan Nguyen created FLINK-36372: -- Summary: Can not insert data to sink with reserved keywords column name Key: FLINK-36372 URL: https://issues.apache.org/jira/browse/FLINK-36372 Project: Flink I

[jira] [Created] (FLINK-36371) Field BinaryStringData as keySelector would lead the same records hash shuffle into different tumble windows

2024-09-25 Thread Eason Ye (Jira)
Eason Ye created FLINK-36371: Summary: Field BinaryStringData as keySelector would lead the same records hash shuffle into different tumble windows Key: FLINK-36371 URL: https://issues.apache.org/jira/browse/FLINK-363

[jira] [Created] (FLINK-36370) Flink 1.18 fails with Empty server certificate chain when High Availability and mTLS both enabled

2024-09-25 Thread Aniruddh J (Jira)
Aniruddh J created FLINK-36370: -- Summary: Flink 1.18 fails with Empty server certificate chain when High Availability and mTLS both enabled Key: FLINK-36370 URL: https://issues.apache.org/jira/browse/FLINK-36370

[jira] [Created] (FLINK-36369) Move deprecated user-visible classes in table modules to the legacy package to make it easier to delete them later

2024-09-25 Thread xuyang (Jira)
xuyang created FLINK-36369: -- Summary: Move deprecated user-visible classes in table modules to the legacy package to make it easier to delete them later Key: FLINK-36369 URL: https://issues.apache.org/jira/browse/FLINK-3

Re: [DISCUSS] FLIP-XXX Amazon SQS Source Connector

2024-09-25 Thread Saurabh Singh
Hi Flink Devs, Thanks a lot for the valuable feedback from Arvid, Danny and David on the design of this SQS Connector. We had an in-depth discussion on Slack regarding the semantics and stages of implementation. Below is the *conclusion* of our conversation. - Currently, FLIP will concentrate

[SUMMARY] Flink 2.0 Sync 09/25/2024

2024-09-25 Thread Xintong Song
Hi devs, Here's a TL;DR summary of today's release sync. See the wiki page [1] for more details. - Breaking changes - *All breaking changes* are expected to complete by *Sep 30*. For anything that may not finish on-time, please reach out to the release managers. - Curre

[jira] [Created] (FLINK-36368) Fix subtask management in CommittableCollector

2024-09-25 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-36368: --- Summary: Fix subtask management in CommittableCollector Key: FLINK-36368 URL: https://issues.apache.org/jira/browse/FLINK-36368 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-36367) Use RexNormalize in EquivalentExprShuttle

2024-09-25 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-36367: --- Summary: Use RexNormalize in EquivalentExprShuttle Key: FLINK-36367 URL: https://issues.apache.org/jira/browse/FLINK-36367 Project: Flink Issue Type: B

[jira] [Created] (FLINK-36366) Remove deprecate API in flink-core exclude connector and state part

2024-09-25 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-36366: -- Summary: Remove deprecate API in flink-core exclude connector and state part Key: FLINK-36366 URL: https://issues.apache.org/jira/browse/FLINK-36366 Project: Flink

FW: RE: [DISCUSS] FLIP-XXX Apicurio-avro format

2024-09-25 Thread David Radley
Hi Arvid, I realise that the reason I did not follow the approach you suggested, is that the config I had in the Kafka connector was that of the connector (not the format) – so I could not get hold of the format name to do a lookup of a factory based on the format name. I will do some more test