[jira] [Created] (FLINK-35290) Wrong Instant type conversion TableAPI to Datastream in thread mode

Wouter Zorgdrager created FLINK-35290: - Summary: Wrong Instant type conversion TableAPI to Datastream in thread mode Key: FLINK-35290 URL: https://issues.apache.org/jira/browse/FLINK-35290 Project

[jira] [Created] (FLINK-35291) Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme

LiuZeshan created FLINK-35291: - Summary: Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme Key: FLINK-35291 URL: https://issues.apache.org/jira/browse/FLINK-35291 Proj

Re: Flink stateful functions and Agentic Architecture

Hi David, I'm not very familiar with stateful functions, but I participated in Flink ML, a machine learning infrastructure and algorithm library based on Flink. There we developed functions like iteration based model-training process and hot updating ML model during online prediction. You may chec

[RESULT][VOTE] FLIP-445: Support dynamic parallelism inference for HiveSource

Hi all, FLIP-445: Support dynamic parallelism inference for HiveSource[1] has been accepted and voted through this thread [2]. The proposal has been accepted with 6 approving votes (5 binding) and there is no disapproval: - Muhammet Orazov (non-binding) - Rui Fan (binding) - Ron Liu (binding) -

Re: [DISCUSSION] FLIP-450: Improve Runtime Configuration for Flink 2.0

Thanks for the effort, Xuannan. +1 for the proposal. Best, Yuxin Xintong Song 于2024年4月29日周一 15:40写道： > Thanks for driving this effort, Xuannan. > > +1 for the proposed changes. > > Just one suggestion: Some of the proposed changes involve not solely > changing the configuration options, but a

[VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0

Hi everyone, Thanks for all the feedback, I'd like to start a vote on the FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0 [1]. The discussion thread is here [2]. The vote will be open for at least 72 hours unless there is an objection or insufficient votes. [1] https://cwiki.apache.org/confluen

Re: [DISCUSS] FLIP-444: Native file copy support

Hi Piotr, Thanks for the proposal. It's meaningful to speed up the state download. I get into some questions: 1. What is the semantic of `canCopyPath`? Should it be associated with a specific destination path? e.g. It can be copied to local, but not to the remote FS. 2. Is the existing interface

Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0

+1 (binding) Thanks for driving this! Best, Zakelly On Mon, May 6, 2024 at 10:54 AM yue ma wrote: > Hi everyone, > > Thanks for all the feedback, I'd like to start a vote on the FLIP-447: > Upgrade FRocksDB from 6.20.3 to 8.10.0 [1]. The discussion thread is here > [2]. > > The vote will be o

Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0

+1 (binding) Best, Yanfei Zakelly Lan 于2024年5月6日周一 11:00写道： > > +1 (binding) > > Thanks for driving this! > > > Best, > Zakelly > > On Mon, May 6, 2024 at 10:54 AM yue ma wrote: > > > Hi everyone, > > > > Thanks for all the feedback, I'd like to start a vote on the FLIP-447: > > Upgrade FRocksD

Re: [DISCUSSION] FLIP-450: Improve Runtime Configuration for Flink 2.0

Thanks Xuannan for driving this proposal! > taskmanager.network.memory.max-overdraft-buffers-per-gate will be removed and hard-coded to either 10 or 20. Currently, it's a public option. Could we determine the value of the overdraft buffer in the current FLIP? I vote 20 as the hard code value due

Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0

+1 (binding) Best, Rui On Mon, May 6, 2024 at 11:01 AM Yanfei Lei wrote: > +1 (binding) > > Best, > Yanfei > > Zakelly Lan 于2024年5月6日周一 11:00写道： > > > > +1 (binding) > > > > Thanks for driving this! > > > > > > Best, > > Zakelly > > > > On Mon, May 6, 2024 at 10:54 AM yue ma wrote: > > > > >

RE: Re: [VOTE] Apache Flink CDC Release 3.1.0, release candidate #1

Hi Qingsheng, Thanks! +1 (non-binding) · Compiled & Ran unit tests successfully · Ran ASF Incompatible license check · Tested MySQL -> Doris / StarRocks E2e cases · Tested transform projection & filter feature Regards, Xiqian Yu On 2024/05/04 11:45:28 A

Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0

+1（binding） Best Yuan On Mon, May 6, 2024 at 11:28 AM Rui Fan <1996fan...@gmail.com> wrote: > +1 (binding) > > Best, > Rui > > On Mon, May 6, 2024 at 11:01 AM Yanfei Lei wrote: > > > +1 (binding) > > > > Best, > > Yanfei > > > > Zakelly Lan 于2024年5月6日周一 11:00写道： > > > > > > +1 (binding) > > >

Re: [DISCUSS] FLIP-443: Interruptible watermark processing

Hi Piotr, Thanks for the improvement, overall +1 for this. I'd leave a minor comment: 1. I'd suggest also providing `isInterruptable()` in `Mail`, and the continuation mail will return true. The FLIP-425 will leverage this queue to execute some state requests, and when the cp arrives, the operato

Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0

+1（binding） On Mon, May 6, 2024 at 12:25 PM Yuan Mei wrote: > +1（binding） > > Best > Yuan > > On Mon, May 6, 2024 at 11:28 AM Rui Fan <1996fan...@gmail.com> wrote: > > > +1 (binding) > > > > Best, > > Rui > > > > On Mon, May 6, 2024 at 11:01 AM Yanfei Lei wrote: > > > > > +1 (binding) > > > > >