[VOTE] FLIP-419: Optimize multi-sink query plan generation

2024-02-21 Thread Jeyhun Karimov
Hi everyone, I'd like to start a vote on the FLIP-419: Optimize multi-sink query plan generation [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/confluence/display/FLINK/FLIP-419%

Re: [DISCUSS]FLIP-420: Add API annotations for RocksDB StateBackend user-facing classes

2024-02-21 Thread Yanfei Lei
Hi Jinzhong, Thanks for driving this! 1. I'm wondering if `ConfigurableRocksDBOptionsFactory` will be used by users, currently it looks like only developers use it in rocksdb state backend module. And Its only non-testing subclass "DefaultConfigurableOptionsFactory" is marked @Deprecated. 2. Rega

[jira] [Created] (FLINK-34495) Resuming Savepoint (rocks, scale up, heap timers) end-to-end test failure

2024-02-21 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34495: - Summary: Resuming Savepoint (rocks, scale up, heap timers) end-to-end test failure Key: FLINK-34495 URL: https://issues.apache.org/jira/browse/FLINK-34495 Project:

[jira] [Created] (FLINK-34494) Migrate ReplaceIntersectWithSemiJoinRule

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

[jira] [Created] (FLINK-34493) Migrate ReplaceMinusWithAntiJoinRule

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

[jira] [Created] (FLINK-34492) fix scala style comment link when migrate scala to java

2024-02-21 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-34492: - Summary: fix scala style comment link when migrate scala to java Key: FLINK-34492 URL: https://issues.apache.org/jira/browse/FLINK-34492 Project: Flink Issue Type:

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

2024-02-21 Thread Jingsong Li
Congratulations! Well deserved! On Wed, Feb 21, 2024 at 4:36 PM Yuepeng Pan wrote: > > Congratulations~ :) > > Best, > Yuepeng Pan > > > > > > > > > > > 在 2024-02-21 09:52:17,"Hongshun Wang" 写道: > >Congratulations, Jiabao :) > >Congratulations Jiabao! > > > >Best, > >Hongshun > >Best regards, >

[jira] [Created] (FLINK-34491) Move from experimental support to production support for Java 17

2024-02-21 Thread Dhruv Patel (Jira)
Dhruv Patel created FLINK-34491: --- Summary: Move from experimental support to production support for Java 17 Key: FLINK-34491 URL: https://issues.apache.org/jira/browse/FLINK-34491 Project: Flink

[jira] [Created] (FLINK-34490) flink-connector-kinesis not correctly supporting credential chaining

2024-02-21 Thread Eddie Ramirez (Jira)
Eddie Ramirez created FLINK-34490: - Summary: flink-connector-kinesis not correctly supporting credential chaining Key: FLINK-34490 URL: https://issues.apache.org/jira/browse/FLINK-34490 Project: Flink

[DISCUSS] FLINK-34440 Support Debezium Protobuf Confluent Format

2024-02-21 Thread Kevin Lam
I would love to get some feedback from the community on this JIRA issue: https://issues.apache.org/jira/projects/FLINK/issues/FLINK-34440 I am looking into creating a PR and would appreciate some review on the approach. In terms of design I think we can mirror the `debezium-avro-confluent` and `a

[jira] [Created] (FLINK-34489) New File Sink end-to-end test timed out

2024-02-21 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34489: - Summary: New File Sink end-to-end test timed out Key: FLINK-34489 URL: https://issues.apache.org/jira/browse/FLINK-34489 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34488) Integrate snapshot deployment into GHA nightly workflow

2024-02-21 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34488: - Summary: Integrate snapshot deployment into GHA nightly workflow Key: FLINK-34488 URL: https://issues.apache.org/jira/browse/FLINK-34488 Project: Flink Iss

[jira] [Created] (FLINK-34487) Integrate tools/azure-pipelines/build-python-wheels.yml into GHA nightly workflow

2024-02-21 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34487: - Summary: Integrate tools/azure-pipelines/build-python-wheels.yml into GHA nightly workflow Key: FLINK-34487 URL: https://issues.apache.org/jira/browse/FLINK-34487 P

[jira] [Created] (FLINK-34486) Add documentation on how to add the shared utils as a submodule to the connector repo

2024-02-21 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34486: - Summary: Add documentation on how to add the shared utils as a submodule to the connector repo Key: FLINK-34486 URL: https://issues.apache.org/jira/browse/FLINK-34486

[jira] [Created] (FLINK-34485) Token delegation doesn't work with Presto S3 filesystem

2024-02-21 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-34485: Summary: Token delegation doesn't work with Presto S3 filesystem Key: FLINK-34485 URL: https://issues.apache.org/jira/browse/FLINK-34485 Project: Flink

Re: [DISCUSS] FLIP-414: Support Retry Mechanism in RocksDBStateDataTransfer

2024-02-21 Thread xiangyu feng
Hi Mayue, Hangxiangyu and Piotr, Sorry for the late reply and thanks a lot for your feedback. After careful thoughts, I agree with your opinions in following ways: 1, Instead of introducing a specific retry mechanism for RocksDB data transfer, we should introduce a more fine-grained retry mechani

[jira] [Created] (FLINK-34484) Split 'state.backend.local-recovery' into two options for checkpointing and recovery

2024-02-21 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-34484: --- Summary: Split 'state.backend.local-recovery' into two options for checkpointing and recovery Key: FLINK-34484 URL: https://issues.apache.org/jira/browse/FLINK-34484 Pr

[jira] [Created] (FLINK-34483) Merge 'state.checkpoints.dir' and 'state.checkpoints-storage' into one

2024-02-21 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-34483: --- Summary: Merge 'state.checkpoints.dir' and 'state.checkpoints-storage' into one Key: FLINK-34483 URL: https://issues.apache.org/jira/browse/FLINK-34483 Project: Flink

[jira] [Created] (FLINK-34482) Rename options for checkpointing

2024-02-21 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-34482: --- Summary: Rename options for checkpointing Key: FLINK-34482 URL: https://issues.apache.org/jira/browse/FLINK-34482 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34481) Migrate SetOpRewriteUtil

2024-02-21 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-34481: - Summary: Migrate SetOpRewriteUtil Key: FLINK-34481 URL: https://issues.apache.org/jira/browse/FLINK-34481 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-34480) Add method to support user jar overwrite flink inner jar class when same class

2024-02-21 Thread JinxinTang (Jira)
JinxinTang created FLINK-34480: -- Summary: Add method to support user jar overwrite flink inner jar class when same class Key: FLINK-34480 URL: https://issues.apache.org/jira/browse/FLINK-34480 Project: F

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

2024-02-21 Thread Yuepeng Pan
Congratulations~ :) Best, Yuepeng Pan 在 2024-02-21 09:52:17,"Hongshun Wang" 写道: >Congratulations, Jiabao :) >Congratulations Jiabao! > >Best, >Hongshun >Best regards, > >Weijie > >On Tue, Feb 20, 2024 at 2:19 PM Runkang He wrote: > >> Congratulations Jiabao! >> >> Best, >> Runkang He >