Re: [VOTE] Release flink-connector-dynamodb v3.0.0, release candidate #0

+1 (non-binding) * Hashes and Signatures look good * All required files on dist.apache.org * Tag is present in Github * Verified source archive does not contain any binary files * Source archive builds using maven * Started packaged example SQL job using SQL client. Verified that it writes succes

[jira] [Created] (FLINK-30237) Only bundle a single Zookeeper version

Chesnay Schepler created FLINK-30237: Summary: Only bundle a single Zookeeper version Key: FLINK-30237 URL: https://issues.apache.org/jira/browse/FLINK-30237 Project: Flink Issue Type: Te

Re: [VOTE] Release flink-connector-cassandra, release candidate #1

+1 (binding) - Downloaded artifacts - Checked hash and signature - No binaries in source archive found - Verified NOTICE files - Built from source code - Verified that no SNAPSHOT versions exist, all versions point to 3.0.0 in POM files - Tag is OK - Reviewed the Web PR Few notes: - the link to

Re: [VOTE] Release flink-connector-cassandra, release candidate #1

> the link to a tag in the initial message is wrong Whoops, small bug in the message generator. > Did we ever consider having the `flink-version` always as part of the connector version? Not specifically, no. I think it makes sense though that if you take the "3.0.0" source that you get "3.0

[jira] [Created] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

Fabian Paul created FLINK-30238: --- Summary: Unified Sink committer does not clean up state on final savepoint Key: FLINK-30238 URL: https://issues.apache.org/jira/browse/FLINK-30238 Project: Flink

Re: [VOTE] Release flink-connector-dynamodb v3.0.0, release candidate #0

+1 (non-binding) On 29/11/2022, 08:27, "Teoh, Hong" wrote: CAUTION: This email originated from outside of the organization. Do not click links or open attachments unless you can confirm the sender and know the content is safe. +1 (non-binding) * Hashes and Signatures look good

[SUMMARY] Flink 1.17 Release Sync 11/29/2022

Hi devs and users, I'd like to share some highlights from the release sync on 11/29/2022. 1. @Contributors please update your progress on the release 1.17 wiki page [1] before the sync meeting so that everyone could track it. 2. We have new CI stability tickets and owners should have been pinged

Re: [ANNOUNCE] Performance Daily Monitoring Moved from Ververica to Apache Flink Slack Channel

Hi Martijn, Thanks for bringing this up. In the past two months, this channel has helped us find many benchmark fail issues, like FLINK-29883 [1], FLINK-29886 [2], FLINK-30015

Re: [jira] [Created] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

This seems scary -- am I interpreting it correctly to mean that unified FileSink doesn't work properly with jobs that need to be stopped-with-savepoints and restarted? Should one use the deprecated StreamingFileSink until this is resolved? On Tue, Nov 29, 2022 at 6:02 AM Fabian Paul (Jira) wrote

Re: [jira] [Created] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

Let's loop in Fabian to clarify. I'm not sure if this only occurs when using a post-commit topology (like compaction), but he can definitely clarify :) On Tue, Nov 29, 2022 at 2:19 PM Galen Warren wrote: > This seems scary -- am I interpreting it correctly to mean that unified > FileSink doesn't

Re: [jira] [Created] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

Hi folks, I did some initial investigation, and the problem seems twofold. If no post-commit topology is used, we do not run into a problem where we could lose data but since we do not clean up the state correctly, we will hit this [1] when trying to stop the pipeline with a savepoint after we ha

Re: [VOTE] Release flink-connector-cassandra, release candidate #1

+1 (binding) - Validated hashes - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven - Verified licenses - Verified web PR On Tue, Nov 29, 2022 at 11:50 AM Chesnay Schepler wrote: > > the link to a tag in the initial message is wrong > > Wh

Re: [VOTE] Release flink-connector-cassandra, release candidate #1

+1 (binding) - Verified signature/hashes - Build the source with Maven (tests pass) - Verified NOTICE files - Verified that no binaries exist in the source archive - Verified artifacts in repository.apache.org are as expected - Verified tag exists on github - Approved web PR I noticed the incorre

Re: Kubernetes Operator 1.3.0 release

Hi all, Thanks for volunteering, Matyas and +1 for the 1.3 operator release. The modified timeline suggested by Gyula sounds good to me. On Tue, Nov 29, 2022 at 7:04 AM Őrhidi Mátyás wrote: > Thanks Gyula! Sounds good. > > On Mon, Nov 28, 2022 at 9:59 PM Gyula Fóra wrote: > > > Hi Matyas! > >

Re: [DISCUSS] OLM Bundles for Flink Kubernetes Operator

Hi folks, I'm going to shepherd the upcoming 1.3.0 release. I'll also try to find some time to review the OLM integration proposal, and see how much extra effort it would be. Best, Matyas On Wed, Nov 23, 2022 at 5:45 PM Yang Wang wrote: > Improving the visibility of Flink Kubernetes Operator i

Re: [VOTE] FLIP-271: Autoscaling

+1 (binding) On Tue, Nov 29, 2022 at 6:13 AM Chenya Zhang wrote: > +1 (non-binding) > > On Sun, Nov 27, 2022 at 5:49 PM Jiangang Liu > wrote: > > > +1 (non-binding) > > > > Best, > > Jiangang Liu > > > > Thomas Weise 于2022年11月28日周一 06:23写道： > > > > > +1 (binding) > > > > > > > > > On Sat, Nov

Re: [VOTE] Release flink-connector-cassandra, release candidate #1

The usage of the artifact shortcode was somewhat intentional; the connector_artifact shortcode does not support scala suffixes, which the cassandra connector unfortunately needs On 29/11/2022 15:16, Danny Cranmer wrote: +1 (binding) - Verified signature/hashes - Build the source with Mave

[jira] [Created] (FLINK-30239) The flame graph doesn't work due to groupExecutionsByLocation has bug

Rui Fan created FLINK-30239: --- Summary: The flame graph doesn't work due to groupExecutionsByLocation has bug Key: FLINK-30239 URL: https://issues.apache.org/jira/browse/FLINK-30239 Project: Flink

[jira] [Created] (FLINK-30240) Fix Doc error pointing to TableKind#MANAGED

Samrat Deb created FLINK-30240: -- Summary: Fix Doc error pointing to TableKind#MANAGED Key: FLINK-30240 URL: https://issues.apache.org/jira/browse/FLINK-30240 Project: Flink Issue Type: Bug

Re: [VOTE] Release flink-connector-cassandra, release candidate #1

Hello! +1 (non-binding) 1. Verified signature and SHA512 checksum in svn 2. Verified that the tag exists on the source git repository and is (mostly) identical to the source tar release - Some .-prefixed files like .idea/ and .gitignore in the repo under the tag that are not in the tar (but

Re: [VOTE] FLIP-271: Autoscaling

+1 (non-binding) --- Original Message --- On Tuesday, November 29th, 2022 at 15:39, Márton Balassi wrote: > > > +1 (binding) > > On Tue, Nov 29, 2022 at 6:13 AM Chenya Zhang chenyazhangche...@gmail.com > > wrote: > > > +1 (non-binding) > > > > On Sun, Nov 27, 2022 at 5:49 PM J

Re: [VOTE] Release flink-connector-dynamodb v3.0.0, release candidate #0

Hi Danny, +1 (binding) - Validated hashes - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven - Verified licenses - Verified web PR Best regards, Martijn On Tue, Nov 29, 2022 at 8:37 PM Martijn Visser wrote: > Hi Danny, > > +1 (binding)

[jira] [Created] (FLINK-30241) Flink ML Iteration ConcurrentModificationException

Yunfeng Zhou created FLINK-30241: Summary: Flink ML Iteration ConcurrentModificationException Key: FLINK-30241 URL: https://issues.apache.org/jira/browse/FLINK-30241 Project: Flink Issue Type

Re: [VOTE] FLIP-271: Autoscaling

+1 (non-binding) On Tue, Nov 29, 2022 at 11:55 AM Ferenc Csaky wrote: > +1 (non-binding) > > > > > --- Original Message --- > On Tuesday, November 29th, 2022 at 15:39, Márton Balassi < > balassi.mar...@gmail.com> wrote: > > > > > > > > +1 (binding) > > > > On Tue, Nov 29, 2022 at 6:13 AM

[jira] [Created] (FLINK-30242) Push localHashAggregate pass the union node

Aitozi created FLINK-30242: -- Summary: Push localHashAggregate pass the union node Key: FLINK-30242 URL: https://issues.apache.org/jira/browse/FLINK-30242 Project: Flink Issue Type: Improvement

Re: [DISCUSS] FLIP-269: Properly Handling the Processing Timers on Job Termination

Hi Dawid, Thanks for the comments! As a whole I'm also open to the API and I also prefer to use simple but flexible interfaces, but it still looks there are some problem to just let users to implement the termination actions. Let's take the WindowOperator as an example. As seen in [1], in the ti

[jira] [Created] (FLINK-30243) Remove duplicate commas

Shilun Fan created FLINK-30243: -- Summary: Remove duplicate commas Key: FLINK-30243 URL: https://issues.apache.org/jira/browse/FLINK-30243 Project: Flink Issue Type: Improvement Compone

[jira] [Created] (FLINK-30244) When task using udf/udtf with jni, flink on k8s session the old

AlexHu created FLINK-30244: -- Summary: When task using udf/udtf with jni, flink on k8s session the old Key: FLINK-30244 URL: https://issues.apache.org/jira/browse/FLINK-30244 Project: Flink Issue Ty

[jira] [Created] (FLINK-30245) NPE thrown when filtering decimal(18, 4) values after calling DecimalDataUtils.subtract method

Wei Zhong created FLINK-30245: - Summary: NPE thrown when filtering decimal(18, 4) values after calling DecimalDataUtils.subtract method Key: FLINK-30245 URL: https://issues.apache.org/jira/browse/FLINK-30245

[jira] [Created] (FLINK-30246) Registering the same metric object with different name and group will conflict in metric reporter

Qingsheng Ren created FLINK-30246: - Summary: Registering the same metric object with different name and group will conflict in metric reporter Key: FLINK-30246 URL: https://issues.apache.org/jira/browse/FLINK-3024