Re: [ANNOUNCE] New Apache Flink Committer - Jiabao Sun

2024-02-22 Thread Weihua Hu
Congratulations, Jiabao! Best, Weihua On Thu, Feb 22, 2024 at 10:34 AM Jingsong Li wrote: > Congratulations! Well deserved! > > On Wed, Feb 21, 2024 at 4:36 PM Yuepeng Pan wrote: > > > > Congratulations~ :) > > > > Best, > > Yuepeng Pan > > > > > > > > > > > > > > > > > > > > > > 在 2024-02-21

[jira] [Created] (FLINK-34496) Classloading deadlock between ExecNodeMetadataUtil and JsonSerdeUtil

2024-02-22 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-34496: Summary: Classloading deadlock between ExecNodeMetadataUtil and JsonSerdeUtil Key: FLINK-34496 URL: https://issues.apache.org/jira/browse/FLINK-34496 Project:

[jira] [Created] (FLINK-34497) Avoid using system classloader in SerializedThrowableDeserializer

2024-02-22 Thread jrthe42 (Jira)
jrthe42 created FLINK-34497: --- Summary: Avoid using system classloader in SerializedThrowableDeserializer Key: FLINK-34497 URL: https://issues.apache.org/jira/browse/FLINK-34497 Project: Flink Is

[DISCUSS] Apache Bahir retired

2024-02-22 Thread Ferenc Csaky
Hello devs, Just saw that the Bahir project is retired [1]. Any plans on what's happening with the Flink connectors that were part of this project? We specifically use the Kudu connector and integrate it to our platform at Cloudera, so we would be okay to maintain it. Would it be possible to ca

[jira] [Created] (FLINK-34498) GSFileSystemFactory logs full Flink config

2024-02-22 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-34498: Summary: GSFileSystemFactory logs full Flink config Key: FLINK-34498 URL: https://issues.apache.org/jira/browse/FLINK-34498 Project: Flink Issue Type

[jira] [Created] (FLINK-34499) Configuration#toString should hide sensitive values

2024-02-22 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-34499: Summary: Configuration#toString should hide sensitive values Key: FLINK-34499 URL: https://issues.apache.org/jira/browse/FLINK-34499 Project: Flink I

Re: Temporal join on rolling aggregate

2024-02-22 Thread Gyula Fóra
Posting this to dev as well as it potentially has some implications on development effort. What seems to be the problem here is that we cannot control/override Timestamps/Watermarks/Primary key on VIEWs. It's understandable that you cannot create a PRIMARY KEY on the view but I think the temporal

Re: [DISCUSS] FLINK-34440 Support Debezium Protobuf Confluent Format

2024-02-22 Thread David Radley
Hi Kevin, Some thoughts on this. I suggested an Apicurio registry format in the dev list, and was advised to raise a FLIP for this, I suggest the same would apply here (or the alternative to FLIPs if you cannot raise one). I am prototyping an Avro Apicurio format, prior to raising the Flip, and

[ANNOUNCE] Apache flink-connector-jdbc 3.1.2 released

2024-02-22 Thread Sergey Nuyanzin
The Apache Flink community is very happy to announce the release of Apache flink-connector-jdbc 3.1.2. This release is compatible with Apache Flink 1.16, 1.17 and 1.18. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data

Re: [VOTE] Release flink-connector-parent 1.1.0 release candidate #2

2024-02-22 Thread Etienne Chauchot
Thanks everyone for your vote. So far we are one binding vote short for the release to pass. Best Etienne Le 20/02/2024 à 09:20, Sergey Nuyanzin a écrit : Thanks for driving this, Etienne! +1 (non-binding) - Verified checksum and signature - Verified pom - Built from source - Verified no bi

[jira] [Created] (FLINK-34500) Release Testing: Verify FLINK-33261 Support Setting Parallelism for Table/SQL Sources

2024-02-22 Thread SuDewei (Jira)
SuDewei created FLINK-34500: --- Summary: Release Testing: Verify FLINK-33261 Support Setting Parallelism for Table/SQL Sources Key: FLINK-34500 URL: https://issues.apache.org/jira/browse/FLINK-34500 Project:

[jira] [Created] (FLINK-34501) In AsyncWaitOperator, ResultHandler.completeExceptionally() triggeres task/job restarts after max retry is reached

2024-02-22 Thread Dinesh (Jira)
Dinesh created FLINK-34501: -- Summary: In AsyncWaitOperator, ResultHandler.completeExceptionally() triggeres task/job restarts after max retry is reached Key: FLINK-34501 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Created] (FLINK-34502) Support calculating network memory for forward and rescale edge

2024-02-22 Thread Rui Fan (Jira)
Rui Fan created FLINK-34502: --- Summary: Support calculating network memory for forward and rescale edge Key: FLINK-34502 URL: https://issues.apache.org/jira/browse/FLINK-34502 Project: Flink Issue

[jira] [Created] (FLINK-34503) Migrate JoinDeriveNullFilterRule

2024-02-22 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-34503: - Summary: Migrate JoinDeriveNullFilterRule Key: FLINK-34503 URL: https://issues.apache.org/jira/browse/FLINK-34503 Project: Flink Issue Type: Sub-task Com

Re: FW: RE: [DISCUSS] FLIP-314: Support Customized Job Lineage Listener

2024-02-22 Thread Yong Fang
Hi Martijn, If there're no more comments, I will start a vote for this, thanks Best, Fang Yong On Tue, Feb 20, 2024 at 4:53 PM Yong Fang wrote: > Hi Martijn, > > Thank you for your attention. Let me first explain the specific situation > of FLIP-314. FLIP-314 is currently in an accepted state,

Re: Temporal join on rolling aggregate

2024-02-22 Thread mayaming1983
+1 for supporting defining time attributes on views. I once encountered the same problem as yours. I did some regular joins and lost time attribute, and hence I could no longer do window operations in subsequent logics. I had to output the joined view to Kafka, read from it again, and define wa