[jira] [Created] (FLINK-37308) HybridSourceReader doesn't support pauseOrResumeSplits

Xingcan Cui created FLINK-37308: --- Summary: HybridSourceReader doesn't support pauseOrResumeSplits Key: FLINK-37308 URL: https://issues.apache.org/jira/browse/FLINK-37308 Project: Flink Issue Ty

[jira] [Created] (FLINK-37307) Flink CDC CI failed due to OceanBaseE2eITCase

JunboWang created FLINK-37307: - Summary: Flink CDC CI failed due to OceanBaseE2eITCase Key: FLINK-37307 URL: https://issues.apache.org/jira/browse/FLINK-37307 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-37306) Flink CDC CI failed due to timezone shift

Leonard Xu created FLINK-37306: -- Summary: Flink CDC CI failed due to timezone shift Key: FLINK-37306 URL: https://issues.apache.org/jira/browse/FLINK-37306 Project: Flink Issue Type: Bug Aff

[jira] [Created] (FLINK-37305) JDBC Connector CI failed due to network issue

Leonard Xu created FLINK-37305: -- Summary: JDBC Connector CI failed due to network issue Key: FLINK-37305 URL: https://issues.apache.org/jira/browse/FLINK-37305 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-37304) Dynamic Kafka Source logs credentials in plaintext under INFO

Leonard Xu created FLINK-37304: -- Summary: Dynamic Kafka Source logs credentials in plaintext under INFO Key: FLINK-37304 URL: https://issues.apache.org/jira/browse/FLINK-37304 Project: Flink Is

Re:Re: [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join

+1 (non-binding)-- Best！ Xuyang 在 2025-01-30 00:18:47，"Xingcan Cui" 写道： >+1 (binding) > >Best, >Xingcan > >On Mon, Jan 27, 2025 at 8:50 PM Venkatakrishnan Sowrirajan >wrote: > >> +1 (non-binding) >> >> Regards >> Venkata krishnan >> >> >> On Mon, Jan 27, 2025 at 2:05 PM Weiqing Yang

Re: [RESULT] [VOTE] Release 1.19.2, release candidate #1

Thanks Alex for driving this release, Good Job! minor：XXX should be replaced by votes number, i.e. there are 7 approving votes, 4 of which are binding Best, Leonard > 2025年2月11日 23:29，Alexander Fedulov 写道： > > Hi all, > > I'm happy to announce that we have unanimously approved this release.

退订

退订 Replied Message | From | cun8cun8 | | Date | 01/15/2025 10:20 | | To | dev | | Subject | 退 |

[ANNOUNCE] Apache flink-connector-hive 3.0.0 released

The Apache Flink community is very happy to announce the release of Apache flink-connector-hive 3.0.0. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming applications. The release is available for download at

[jira] [Created] (FLINK-37303) Bump guava to 33.4.0

Sergey Nuyanzin created FLINK-37303: --- Summary: Bump guava to 33.4.0 Key: FLINK-37303 URL: https://issues.apache.org/jira/browse/FLINK-37303 Project: Flink Issue Type: Technical Debt Aff

Re: [DISCUSS] FLIP-508: Add support for Smile format for Compiled plans

Thanks for clarifying this Timo! If there is no other feedback, I'm going to start voting in a couple of days On Fri, Feb 7, 2025 at 5:13 PM Gyula Fóra wrote: > Thanks Timo for the extra info on the context of this change. > > +1 > > Gyula > > On Fri, Feb 7, 2025 at 5:05 PM Timo Walther wrote

Re: [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic)

Hi Gyula, Great questions, I’ll track these topics in our docs accordingly as well. > - What will be the naming convention for the created FlinkDeployment A/B? > Should we introduce some logic for the users to control this? Currently, the controller takes the original resource name as the main

[RESULT] [VOTE] Release 1.20.1, release candidate #1

Hi all, I'm happy to announce that we have unanimously approved this release [1]. There are XXX approving votes, XXX of which are binding: * Maximilian Michels (binding) * Weijie Guo (binding) * Gyula Fora (binding) * Leonard Xu (binding) * Rui Fan (binding) * Yanquan Lv (non-binding) * Ferenc Cs

Re: [VOTE] Release 1.20.1, release candidate #1

Thanks everyone for the verification and the votes. The voting is now closed. Best, Alex On Tue, 11 Feb 2025 at 13:51, Leonard Xu wrote: > > +1 (binding) > > - verified signatures > - verified hashsums > - built from source code with JDK 1.8 succeeded > - checked Github release tag > - checked r

[RESULT] [VOTE] Release 1.19.2, release candidate #1

Hi all, I'm happy to announce that we have unanimously approved this release. There are XXX approving votes, XXX of which are binding: * Maximilian Michels (binding) * Marton Balassi (binding) * Leonard Xu (binding) * Robert Merzger (binding) * Yanquan Lv (non-binding) * Ferenc Csaky (non-binding

Re: [VOTE] Release 1.19.2, release candidate #1

Thanks everyone for the verification and the votes. The voting is now closed. Best, Alex On Tue, 11 Feb 2025 at 14:30, Robert Metzger wrote: > > +1 (binding) > > - maven staging repo contents look fine > - src archive looks fine > - local cluster starts on macos from binary release artifacts > >

[jira] [Created] (FLINK-37301) Fix wrong flag returned by ForStStateBackend#supportsSavepointFormat

Zakelly Lan created FLINK-37301: --- Summary: Fix wrong flag returned by ForStStateBackend#supportsSavepointFormat Key: FLINK-37301 URL: https://issues.apache.org/jira/browse/FLINK-37301 Project: Flink

[jira] [Created] (FLINK-37302) Support timers in PTFs

Timo Walther created FLINK-37302: Summary: Support timers in PTFs Key: FLINK-37302 URL: https://issues.apache.org/jira/browse/FLINK-37302 Project: Flink Issue Type: Sub-task Compone

Re: [VOTE] Release 1.19.2, release candidate #1

+1 (binding) - maven staging repo contents look fine - src archive looks fine - local cluster starts on macos from binary release artifacts On Tue, Feb 11, 2025 at 1:38 PM Leonard Xu wrote: > +1 (binding) > > - verified signatures > - verified hashsums > - built from source code with JDK 1.8 s

Re: [VOTE] Release 1.20.1, release candidate #1

+1 (binding) - verified signatures - verified hashsums - built from source code with JDK 1.8 succeeded - checked Github release tag - checked release notes - reviewed the web PR Best, Leonard > 2025年2月7日 19:08，Rui Fan <1996fan...@gmail.com> 写道： > > +1 (binding) > > 1. Verified the archives,

Re: [VOTE] Release 1.19.2, release candidate #1

+1 (binding) - verified signatures - verified hashsums - built from source code with JDK 1.8 succeeded - checked Github release tag - checked release notes - reviewed the web PR Best, Leonard > 2025年2月11日 19:09，Márton Balassi 写道： > > +1 (binding) > > 1. Verified the archives, checksums, and

Re: [VOTE] Release 1.19.2, release candidate #1

+1 (binding) 1. Verified the archives, checksums, and signatures 2. Extracted and inspected the source code for binaries 3. Built the source code 4. Verified license files / headers Best, Marton On Mon, Feb 3, 2025 at 12:37 PM Maximilian Michels wrote: > +1 (binding) > > 1. Verified the archiv

[DISCUSS] Pluggable Batching for Async Sink in Flink

Hey everyone, I’d like to propose adding a pluggable batching mechanism to AsyncSinkWriter to enable custom batch formation strat

[jira] [Created] (FLINK-37300) Add database native type information to Column struct to generate ddl correctly

He Wang created FLINK-37300: --- Summary: Add database native type information to Column struct to generate ddl correctly Key: FLINK-37300 URL: https://issues.apache.org/jira/browse/FLINK-37300 Project: Flink

Re: Flink CDC to Paimon

Hi Taher, Since we’re creating a DataStream-based pipeline job with SQL Server CDC, schema change events must be handled manually. A possible approach would be: 1) Enable schema change events with `.includeSchemaChanges(true)` option, so DDL events will be parsed and encoded in `SourceRecord`s.

Flink CDC to Paimon

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 sink We have written the cdc connector with is a JsonDebeziumDeserialisedSchema String I wish to write this paimon i