[jira] [Created] (FLINK-36887) Add support for Flink 1.20 in Flink Hive connector

2024-12-11 Thread Yanquan Lv (Jira)
Yanquan Lv created FLINK-36887: -- Summary: Add support for Flink 1.20 in Flink Hive connector Key: FLINK-36887 URL: https://issues.apache.org/jira/browse/FLINK-36887 Project: Flink Issue Type: N

[jira] [Created] (FLINK-36888) Building flink-shaded-netty-tcnative-static for the OpenSSL e2e tests timed out

2024-12-11 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-36888: - Summary: Building flink-shaded-netty-tcnative-static for the OpenSSL e2e tests timed out Key: FLINK-36888 URL: https://issues.apache.org/jira/browse/FLINK-36888 Pro

[jira] [Created] (FLINK-36889) Mention locking down a Flink cluster in the 'Production Readiness Checklist'

2024-12-11 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-36889: -- Summary: Mention locking down a Flink cluster in the 'Production Readiness Checklist' Key: FLINK-36889 URL: https://issues.apache.org/jira/browse/FLINK-36889 Proj

[jira] [Created] (FLINK-36890) ObservedGeneration is not updated on NOOP spec updates

2024-12-11 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-36890: -- Summary: ObservedGeneration is not updated on NOOP spec updates Key: FLINK-36890 URL: https://issues.apache.org/jira/browse/FLINK-36890 Project: Flink

[jira] [Created] (FLINK-36891) MySQL CDC connector produces corrupted state in case of serialization failure

2024-12-11 Thread Sergei Morozov (Jira)
Sergei Morozov created FLINK-36891: -- Summary: MySQL CDC connector produces corrupted state in case of serialization failure Key: FLINK-36891 URL: https://issues.apache.org/jira/browse/FLINK-36891 Pro

[jira] [Created] (FLINK-36886) Support interruptible timers with async state processing

2024-12-11 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-36886: --- Summary: Support interruptible timers with async state processing Key: FLINK-36886 URL: https://issues.apache.org/jira/browse/FLINK-36886 Project: Flink Issue

Re: [DISCUSS] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs

2024-12-11 Thread Zakelly Lan
Hi Yanfei, Thanks for your response! The `SingleOutputStreamOperator` is the return type of `process()` or `sum()`, so the example would be invoking `enableAsyncState()` after the processing methods, which has been included in the examples within this FLIP. Best, Zakelly On Wed, Dec 11, 2024 a

[jira] [Created] (FLINK-36885) Multiple tests are incorrectly migrated to JUnit 5

2024-12-11 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-36885: Summary: Multiple tests are incorrectly migrated to JUnit 5 Key: FLINK-36885 URL: https://issues.apache.org/jira/browse/FLINK-36885 Project: Flink Is

Re: cannot locate classes in flink-release-2.0-preview1 source

2024-12-11 Thread Zakelly Lan
Hi Enric, This may be because your IDE has not indexed the dependency. Please try reloading the maven project, by right clicking the project root -> Maven -> Reload project. Best, Zakelly On Wed, Dec 11, 2024 at 5:30 PM Enric Ott <243816...@qq.com> wrote: > Hello,Community: > When I import f

[DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation

2024-12-11 Thread Alan Sheinberg
I'd like to start a discussion of FLIP-491: BundledAggregateFunction for batched aggregation [1] This feature proposes adding a new interface BundledAggregateFunction that can be implemented by AggregateFunction UDFs. This allows the use of a batched method call so that users can handle many rows

[jira] [Created] (FLINK-36893) Support periodic full checkpoint

2024-12-11 Thread Xingcan Cui (Jira)
Xingcan Cui created FLINK-36893: --- Summary: Support periodic full checkpoint Key: FLINK-36893 URL: https://issues.apache.org/jira/browse/FLINK-36893 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-36894) rowId comparision is incorrect in oracle connector

2024-12-11 Thread shaohui hong (Jira)
shaohui hong created FLINK-36894: Summary: rowId comparision is incorrect in oracle connector Key: FLINK-36894 URL: https://issues.apache.org/jira/browse/FLINK-36894 Project: Flink Issue Type

[jira] [Created] (FLINK-36895) The JdbcSourceChunkSplitter#queryMin method passed a parameter with tableName/coiumnName reversed.

2024-12-11 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-36895: --- Summary: The JdbcSourceChunkSplitter#queryMin method passed a parameter with tableName/coiumnName reversed. Key: FLINK-36895 URL: https://issues.apache.org/jira/browse/FLINK-36895

[jira] [Created] (FLINK-36892) Properly handle the watermark status

2024-12-11 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-36892: --- Summary: Properly handle the watermark status Key: FLINK-36892 URL: https://issues.apache.org/jira/browse/FLINK-36892 Project: Flink Issue Type: Sub-task