[jira] [Created] (FLINK-36336) Remove deprecated dataset API

2024-09-19 Thread xuhuang (Jira)
xuhuang created FLINK-36336: --- Summary: Remove deprecated dataset API Key: FLINK-36336 URL: https://issues.apache.org/jira/browse/FLINK-36336 Project: Flink Issue Type: New Feature Repor

[jira] [Created] (FLINK-36335) Improving Method Reusability in StreamGraphGenerator with JobVertexBuildContext

2024-09-19 Thread Lei Yang (Jira)
Lei Yang created FLINK-36335: Summary: Improving Method Reusability in StreamGraphGenerator with JobVertexBuildContext Key: FLINK-36335 URL: https://issues.apache.org/jira/browse/FLINK-36335 Project: Flin

[jira] [Created] (FLINK-36334) Remove the Disable markers from the tests in the various TypeSerializerUpgradeTestBase subclasses that have been moved from the flink-table-api-scala module

2024-09-19 Thread xuyang (Jira)
xuyang created FLINK-36334: -- Summary: Remove the Disable markers from the tests in the various TypeSerializerUpgradeTestBase subclasses that have been moved from the flink-table-api-scala module Key: FLINK-36334 URL: ht

[jira] [Created] (FLINK-36333) FLIP-475: Support Adaptive Skewed Join Optimization

2024-09-19 Thread Lei Yang (Jira)
Lei Yang created FLINK-36333: Summary: FLIP-475: Support Adaptive Skewed Join Optimization Key: FLINK-36333 URL: https://issues.apache.org/jira/browse/FLINK-36333 Project: Flink Issue Type: New F

[jira] [Created] (FLINK-36332) Allow the Operator http client to be customised

2024-09-19 Thread Sam Barker (Jira)
Sam Barker created FLINK-36332: -- Summary: Allow the Operator http client to be customised Key: FLINK-36332 URL: https://issues.apache.org/jira/browse/FLINK-36332 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-36331) Support multiGet when DB all in local

2024-09-19 Thread Yanfei Lei (Jira)
Yanfei Lei created FLINK-36331: -- Summary: Support multiGet when DB all in local Key: FLINK-36331 URL: https://issues.apache.org/jira/browse/FLINK-36331 Project: Flink Issue Type: Sub-task

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

2024-09-19 Thread Green, David
https://cwiki.apache.org/confluence/display/FLINK/FLIP-477+Amazon+SQS+Source+Connector I'm a Principal Engineer at AWS and work directly with the AWS SQS team. I can provide all kinds of details about the SQS API and SQS semantics in general to help you validate the design for exactly once proce

[jira] [Created] (FLINK-36330) Session Window TVFs with named parameters don't support column expansion

2024-09-19 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-36330: --- Summary: Session Window TVFs with named parameters don't support column expansion Key: FLINK-36330 URL: https://issues.apache.org/jira/browse/FLINK-36330 Projec

[jira] [Created] (FLINK-36329) DDB Streams connector not retrying some SDK exceptions

2024-09-19 Thread Abhi Gupta (Jira)
Abhi Gupta created FLINK-36329: -- Summary: DDB Streams connector not retrying some SDK exceptions Key: FLINK-36329 URL: https://issues.apache.org/jira/browse/FLINK-36329 Project: Flink Issue Type

[RESULT][VOTE] FLIP-475: Support Adaptive Skewed Join Optimization

2024-09-19 Thread Lei Yang
Hi everyone, I'm glad to announce that FLIP-475[1] has been accepted. There are 3 approving votes, 3 of which are binding: - Zhu Zhu (binding) - Rui Fan (binding) - Lincoln Lee (binding) There were no votes against it. Thanks everyone! Best, Lei Yang [1] https://cwiki.apache.org/confluence/di

[jira] [Created] (FLINK-36328) Making the log for child not found as debug

2024-09-19 Thread Abhi Gupta (Jira)
Abhi Gupta created FLINK-36328: -- Summary: Making the log for child not found as debug Key: FLINK-36328 URL: https://issues.apache.org/jira/browse/FLINK-36328 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-36327) Remove the dependencies of the flink-scala and flink-streaming-scala modules from the table module.

2024-09-19 Thread xuyang (Jira)
xuyang created FLINK-36327: -- Summary: Remove the dependencies of the flink-scala and flink-streaming-scala modules from the table module. Key: FLINK-36327 URL: https://issues.apache.org/jira/browse/FLINK-36327

[jira] [Created] (FLINK-36326) Newly added table failed in mysql pipeline connector

2024-09-19 Thread linqigeng (Jira)
linqigeng created FLINK-36326: - Summary: Newly added table failed in mysql pipeline connector Key: FLINK-36326 URL: https://issues.apache.org/jira/browse/FLINK-36326 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-36324) MiscAggFunctionITCase expected to raise Throwable

2024-09-19 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-36324: - Summary: MiscAggFunctionITCase expected to raise Throwable Key: FLINK-36324 URL: https://issues.apache.org/jira/browse/FLINK-36324 Project: Flink Issue Typ

[jira] [Created] (FLINK-36323) Remove deprecated MemoryStateBackend and RocksDBStateBackend

2024-09-19 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-36323: --- Summary: Remove deprecated MemoryStateBackend and RocksDBStateBackend Key: FLINK-36323 URL: https://issues.apache.org/jira/browse/FLINK-36323 Project: Flink I

[jira] [Created] (FLINK-36325) Implement basic restore from checkpoint for ForStStateBackend

2024-09-19 Thread Feifan Wang (Jira)
Feifan Wang created FLINK-36325: --- Summary: Implement basic restore from checkpoint for ForStStateBackend Key: FLINK-36325 URL: https://issues.apache.org/jira/browse/FLINK-36325 Project: Flink