[jira] [Created] (FLINK-37419) ForStMapState serializeValue may get wrong result

Yue Ma created FLINK-37419: -- Summary: ForStMapState serializeValue may get wrong result Key: FLINK-37419 URL: https://issues.apache.org/jira/browse/FLINK-37419 Project: Flink Issue Type: Bug

Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0

This has been merged now (both master and release-2.0). Thank you all for your feedback! Gyula On Thu, Feb 27, 2025 at 3:41 AM Zakelly Lan wrote: > Sry for the late reply, also +1 to have this in 2.0 given that we don't > guarantee backwards compatibility, and it is already not compatible in m

[jira] [Created] (FLINK-37420) AbstractAggregatingState add may return wrong result

Yue Ma created FLINK-37420: -- Summary: AbstractAggregatingState add may return wrong result Key: FLINK-37420 URL: https://issues.apache.org/jira/browse/FLINK-37420 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-37418) caugth array out of index exception while using RowData.getArray method

Spongebob created FLINK-37418: - Summary: caugth array out of index exception while using RowData.getArray method Key: FLINK-37418 URL: https://issues.apache.org/jira/browse/FLINK-37418 Project: Flink

Re: Flink CDC to Paimon

Hi Devs, Any response here? On Tue, 11 Feb 2025 at 11:59 AM, Taher Koitawala wrote: > Hi Devs, >As a POC we are trying to create a steaming pipeline from MSSQL cdc > to Paimon: > > To do this we are doing > 1. msSql server cdc operator > 2. Transform operator > 3. paimon si

Re: Flink vs beam-flink-runner benchmark

Any help here? On Sun, 2 Mar 2025 at 1:40 PM, Taher Koitawala wrote: > Hi All, > Curious question! Has someone done a benchmark on native flink > vs beam-flink-runner? > > Im wanting to know or ask, if there are differences in the following > areas( Consider Streaming only) > 1. Netwo

RE: Flink Operator 1.11 release planning

Hi Gyula, Thanks for responding, that sounds reasonable, Kind regards, David. From: Gyula Fóra Date: Monday, 24 February 2025 at 10:31 To: dev@flink.apache.org Subject: [EXTERNAL] Re: Flink Operator 1.11 release planning Hi David! Thanks for the feedback. This change has been already merged a

Re: Flink vs beam-flink-runner benchmark

>From the Beam side, I am not aware we have any benchmark about the native Flink vs FlinkRunner. Beam does regularly run some benchmarks with FlinkRunner using the GitHub workflows: https://github.com/apache/beam/tree/master/.github/workflows On Tue, Mar 4, 2025 at 9:42 AM Taher Koitawala wrote:

Re: [DISCUSS] Pluggable Batching for Async Sink in Flink

Hey everyone, Before raising a vote thread, can anyone please help with copying the contents of the modified doc to this FLIP

Question on usage of SQL Gateway with a remote Flink cluster

Hi everyone, I am trying to run a SQL script through SQL Client in gateway mode. The gateway is running in a separate container not associated with the Flink cluster. When trying to issue a command from SQL Client locally to the gateway resulted in a connection error something like : WARN o

[jira] [Created] (FLINK-37417) Implement better exception message to explain why KinesisSource doesn't support partial recovery

Hong Liang Teoh created FLINK-37417: --- Summary: Implement better exception message to explain why KinesisSource doesn't support partial recovery Key: FLINK-37417 URL: https://issues.apache.org/jira/browse/FLINK-3

[jira] [Created] (FLINK-37416) DDB Streams connector flink state inconsistency issue

Abhi Gupta created FLINK-37416: -- Summary: DDB Streams connector flink state inconsistency issue Key: FLINK-37416 URL: https://issues.apache.org/jira/browse/FLINK-37416 Project: Flink Issue Type:

[KINDLY REMINDER] Flink 2.0 Release Sync 03/05/2025

The next release sync will be held at the following time. - 15:00, Mar 4, BJT (GMT+8) - 08:00, Mar 4, CET (GMT+1) - 23:00, Mar 3, PT (GMT-8) Everyone is welcome to join via Google Meet [1]. The topics to be discussed can be found at the Status / Follow-ups section of the release wiki page [2]. If

[jira] [Created] (FLINK-37421) [flink-operator][FlinkDeployment] Doesn't provide a mechanism to label the deployment

Julian created FLINK-37421: -- Summary: [flink-operator][FlinkDeployment] Doesn't provide a mechanism to label the deployment Key: FLINK-37421 URL: https://issues.apache.org/jira/browse/FLINK-37421 Project: Fl

Re: Flink CDC to Paimon

Hey Taher, Xianqian has replied your email, did you subscribe Flink dev mailing-list? Best, Leonard > 2025年2月11日 16:52，Xiqian YU 写道： > > Hi Taher, > > Since we’re creating a DataStream-based pipeline job with SQL Server CDC, > schema change events must be handled manually. A possible approac

[jira] [Created] (FLINK-37422) Typo in streaming analytics zh document

ronghangye created FLINK-37422: -- Summary: Typo in streaming analytics zh document Key: FLINK-37422 URL: https://issues.apache.org/jira/browse/FLINK-37422 Project: Flink Issue Type: Bug

Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner

Hi all, After offline discussion with lincoln, weijie and ron, we decide to make a few changes to the FLIP[1] to make the new introduced connector ability more understandable. 1, Migrate TargetColumns From `DynamicTableSink.Context` to new Connector ability `SupportsTargetColumnWriting` Currentl