[jira] [Created] (FLINK-37208) Properly notify a new key is selected for async state operators

Zakelly Lan created FLINK-37208: --- Summary: Properly notify a new key is selected for async state operators Key: FLINK-37208 URL: https://issues.apache.org/jira/browse/FLINK-37208 Project: Flink

[jira] [Created] (FLINK-37207) Distributed cache set in the DataStream API does not work if a job use both the Table API & DataStream API

Dian Fu created FLINK-37207: --- Summary: Distributed cache set in the DataStream API does not work if a job use both the Table API & DataStream API Key: FLINK-37207 URL: https://issues.apache.org/jira/browse/FLINK-37207

[jira] [Created] (FLINK-37206) Initialization issue of batching timer service in async state operators

Zakelly Lan created FLINK-37206: --- Summary: Initialization issue of batching timer service in async state operators Key: FLINK-37206 URL: https://issues.apache.org/jira/browse/FLINK-37206 Project: Flink

[jira] [Created] (FLINK-37205) Correct the state cache behavior during bump beam version

Dian Fu created FLINK-37205: --- Summary: Correct the state cache behavior during bump beam version Key: FLINK-37205 URL: https://issues.apache.org/jira/browse/FLINK-37205 Project: Flink Issue Type: B

[jira] [Created] (FLINK-37204) Add missing StarRocks connector options for 1.2.10.

ChaomingZhang created FLINK-37204: - Summary: Add missing StarRocks connector options for 1.2.10. Key: FLINK-37204 URL: https://issues.apache.org/jira/browse/FLINK-37204 Project: Flink Issue T

Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join

Hi Weiqing, Thanks, that makes sense! Looks like I missed it. Regards Venkata krishnan On Tue, Jan 21, 2025 at 10:55 PM Weiqing Yang wrote: > Hi Venkata, > > * > where only one earlyFire is fired The DELAY * > > The DELAY option mentioned in the Public Interfaces section > < > https://urldefe

Re: [Discuss] Flink CDC 3.4 Kick Off

+1, looking forward to these changes! Best, Ferenc On Wednesday, January 22nd, 2025 at 10:56, Leonard Xu wrote: > > > +1 for the proposed code freeze date > > Best, > Leonard > > > 2025年1月22日 15:41，ConradJam jam.gz...@gmail.com 写道： > > > > +1 > > > > Yanquan Lv decq12y...@gmail.com 于20

[jira] [Created] (FLINK-37203) Support AltertableCommentEvent and AlterColumnCommentEvent.

Yanquan Lv created FLINK-37203: -- Summary: Support AltertableCommentEvent and AlterColumnCommentEvent. Key: FLINK-37203 URL: https://issues.apache.org/jira/browse/FLINK-37203 Project: Flink Issu

Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases)

+1 for option (2) Marton On Wed, Jan 22, 2025 at 2:10 PM Maximilian Michels wrote: > +1 for option (2), looks like the best compromise given the constraints. > > -Max > > On Tue, Jan 21, 2025 at 2:27 PM Ferenc Csaky > wrote: > > > > FYI, I opened a PR about documenting the fine-tuning options

Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases)

+1 for option (2), looks like the best compromise given the constraints. -Max On Tue, Jan 21, 2025 at 2:27 PM Ferenc Csaky wrote: > > FYI, I opened a PR about documenting the fine-tuning options for > Netty4, feel free to check it out [1]. If content LG, I'll open > PRs against the prev release

Re: [jira] [Created] (FLINK-37202) Introduce TDengine connector

Hi there, I think a new connector is an improvement that requires a Flip https://cwiki.apache.org/confluence/display/FLINK/Flink+Improvement+Proposals so this can be discussed and voted on by the community, Kind regards, David. From: kevinmen (Jira) Date: Wednesday, 22 January 2025 at 1

[jira] [Created] (FLINK-37202) Introduce TDengine connector

kevinmen created FLINK-37202: Summary: Introduce TDengine connector Key: FLINK-37202 URL: https://issues.apache.org/jira/browse/FLINK-37202 Project: Flink Issue Type: New Feature Repo

[jira] [Created] (FLINK-37201) FlinkCDC Pipeline transform arithmetic functions support parameters of null and more numerical types.

Wenkai Qi created FLINK-37201: - Summary: FlinkCDC Pipeline transform arithmetic functions support parameters of null and more numerical types. Key: FLINK-37201 URL: https://issues.apache.org/jira/browse/FLINK-37201

[jira] [Created] (FLINK-37200) Add e2e test for ElasticSearch Sink.

Yanquan Lv created FLINK-37200: -- Summary: Add e2e test for ElasticSearch Sink. Key: FLINK-37200 URL: https://issues.apache.org/jira/browse/FLINK-37200 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-37199) Update document in quickly start to guide user to add checkpoint configuration

Yanquan Lv created FLINK-37199: -- Summary: Update document in quickly start to guide user to add checkpoint configuration Key: FLINK-37199 URL: https://issues.apache.org/jira/browse/FLINK-37199 Project: F

[jira] [Created] (FLINK-37198) AvroToRowDataConverters factory omits legacyTimestampMapping option for nested Row.

Juliusz Nadberezny created FLINK-37198: -- Summary: AvroToRowDataConverters factory omits legacyTimestampMapping option for nested Row. Key: FLINK-37198 URL: https://issues.apache.org/jira/browse/FLINK-37198

Re: [Discuss] Flink CDC 3.4 Kick Off

+1 for the proposed code freeze date Best, Leonard > 2025年1月22日 15:41，ConradJam 写道： > > +1 > > Yanquan Lv 于2025年1月22日周三 15:35写道： > >> Hi devs, >> >> As FlinkCDC 3.3 was released recently, it's a good time to kick off the >> upcoming Flink CDC 3.4 release cycle. >> >> In past community disc

[jira] [Created] (FLINK-37197) Release flink-connector-mongodb v2.0.0 for Flink 1.20

Jiabao Sun created FLINK-37197: -- Summary: Release flink-connector-mongodb v2.0.0 for Flink 1.20 Key: FLINK-37197 URL: https://issues.apache.org/jira/browse/FLINK-37197 Project: Flink Issue Type: