[jira] [Created] (FLINK-33475) yarn parameters cannot be set using flink.yarn.

2023-11-06 Thread zhengzhili (Jira)
zhengzhili created FLINK-33475: -- Summary: yarn parameters cannot be set using flink.yarn. Key: FLINK-33475 URL: https://issues.apache.org/jira/browse/FLINK-33475 Project: Flink Issue Type: Bug

Re: [VOTE] FLIP-376: Add DISTRIBUTED BY clause

2023-11-06 Thread Dawid Wysakowicz
+1 Best, Dawid On Mon, 6 Nov 2023 at 12:38, Timo Walther wrote: > Hi everyone, > > I'd like to start a vote on FLIP-376: Add DISTRIBUTED BY clause[1] which > has been discussed in this thread [2]. > > The vote will be open for at least 72 hours unless there is an objection > or not enough

[jira] [Created] (FLINK-33474) ShowPlan throws undefined exception In Flink Web Submit Page

2023-11-06 Thread Yu Chen (Jira)
Yu Chen created FLINK-33474: --- Summary: ShowPlan throws undefined exception In Flink Web Submit Page Key: FLINK-33474 URL: https://issues.apache.org/jira/browse/FLINK-33474 Project: Flink Issue

[jira] [Created] (FLINK-33473) Update Flink client to 1.18.0

2023-11-06 Thread Prabhu Joseph (Jira)
Prabhu Joseph created FLINK-33473: - Summary: Update Flink client to 1.18.0 Key: FLINK-33473 URL: https://issues.apache.org/jira/browse/FLINK-33473 Project: Flink Issue Type: Improvement

Re: [VOTE] Release flink-connector-gcp-pubsub v3.0.2, release candidate #1

2023-11-06 Thread Samrat Deb
+1(non-binding) - Checked release notes - Verified checksums and signatures - Verified no binaries in release - Build connector from source Bests, Samrat On Mon, 6 Nov 2023 at 8:20 PM, Ryan Skraba wrote: > Hello! +1 (non-binding) > > One note: the parent pom still has 1.16.0 for the Maven

[jira] [Created] (FLINK-33472) Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded

2023-11-06 Thread zhengzhili (Jira)
zhengzhili created FLINK-33472: -- Summary: Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded Key: FLINK-33472 URL: https://issues.apache.org/jira/browse/FLINK-33472

[VOTE] FLIP-377: Support configuration to disable filter push down for Table/SQL Sources

2023-11-06 Thread Jiabao Sun
Hi Devs, I'd like to start a vote on FLIP-377: Support configuration to disable filter pushdown for Table/SQL Sources[1] which has been discussed in this thread [2]. The vote will be open for at least 72 hours unless there is an objection or not enough votes. [1]

Re: [DISCUSS] Release 1.17.2

2023-11-06 Thread liu ron
+1 Best, Ron Jing Ge 于2023年11月6日周一 22:07写道: > +1 > Thanks for your effort! > > Best regards, > Jing > > On Mon, Nov 6, 2023 at 1:15 AM Konstantin Knauf wrote: > > > Thank you for picking it up! +1 > > > > Cheers, > > > > Konstantin > > > > Am Mo., 6. Nov. 2023 um 03:48 Uhr schrieb Yun Tang :

Re: [DISCUSS] Connector releases for Flink 1.18

2023-11-06 Thread mystic lama
Hi, I looked into both connectors, they both are failing at archunit. I tried a few things but with my limited experience couldn't make much progress. Don't want to block the release. If anyone knows what needs to be done, please move forward with the fixes. Hopefully, shall be able to help more

Re: [VOTE] FLIP-376: Add DISTRIBUTED BY clause

2023-11-06 Thread Benchao Li
+1 (binding) Lincoln Lee 于2023年11月7日周二 08:50写道: > > +1 (binding) > > Best, > Lincoln Lee > > > Martijn Visser 于2023年11月7日周二 01:02写道: > > > +1 (binding) > > > > Thanks for driving this Timo > > > > On Mon, Nov 6, 2023 at 12:40 PM Timo Walther wrote: > > > > > > Hi everyone, > > > > > > I'd like

Re: [VOTE] FLIP-376: Add DISTRIBUTED BY clause

2023-11-06 Thread Lincoln Lee
+1 (binding) Best, Lincoln Lee Martijn Visser 于2023年11月7日周二 01:02写道: > +1 (binding) > > Thanks for driving this Timo > > On Mon, Nov 6, 2023 at 12:40 PM Timo Walther wrote: > > > > Hi everyone, > > > > I'd like to start a vote on FLIP-376: Add DISTRIBUTED BY clause[1] which > > has been

[jira] [Created] (FLINK-33471) Kubernetes operator supports compiling with Java 21

2023-11-06 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-33471: --- Summary: Kubernetes operator supports compiling with Java 21 Key: FLINK-33471 URL: https://issues.apache.org/jira/browse/FLINK-33471 Project: Flink

[jira] [Created] (FLINK-33470) Implement restore tests for Join node

2023-11-06 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-33470: -- Summary: Implement restore tests for Join node Key: FLINK-33470 URL: https://issues.apache.org/jira/browse/FLINK-33470 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33469) Implement restore tests for Limit node

2023-11-06 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-33469: -- Summary: Implement restore tests for Limit node Key: FLINK-33469 URL: https://issues.apache.org/jira/browse/FLINK-33469 Project: Flink Issue Type: Sub-task

Re: [VOTE] FLIP-376: Add DISTRIBUTED BY clause

2023-11-06 Thread Martijn Visser
+1 (binding) Thanks for driving this Timo On Mon, Nov 6, 2023 at 12:40 PM Timo Walther wrote: > > Hi everyone, > > I'd like to start a vote on FLIP-376: Add DISTRIBUTED BY clause[1] which > has been discussed in this thread [2]. > > The vote will be open for at least 72 hours unless there is an

[jira] [Created] (FLINK-33468) Run Kubernetes IT test fails due to wrong Maven version

2023-11-06 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-33468: - Summary: Run Kubernetes IT test fails due to wrong Maven version Key: FLINK-33468 URL: https://issues.apache.org/jira/browse/FLINK-33468 Project: Flink

Re: [VOTE] Release flink-connector-opensearch v1.1.0, release candidate #1

2023-11-06 Thread Ryan Skraba
Hello! +1 (non-binding) Thanks for the release! I've validated the source for the RC1: * flink-connector-opensearch-1.1.0-src.tgz at r64995 * The sha512 checksum is OK. * The source file is signed correctly. * The signature 0F79F2AFB2351BC29678544591F9C1EC125FD8DB is found in the KEYS file, and

Re: [VOTE] Release flink-connector-gcp-pubsub v3.0.2, release candidate #1

2023-11-06 Thread Ryan Skraba
Hello! +1 (non-binding) One note: the parent pom still has 1.16.0 for the Maven property of flink.version for both 1.17 and 1.18 releases. I've validated the source for the RC1: flink-connector-gcp-pubsub-3.0.2-src.tgz at r65060 * The sha512 checksum is OK. * The source file is signed correctly.

Re: [DISCUSS] Release 1.17.2

2023-11-06 Thread Jing Ge
+1 Thanks for your effort! Best regards, Jing On Mon, Nov 6, 2023 at 1:15 AM Konstantin Knauf wrote: > Thank you for picking it up! +1 > > Cheers, > > Konstantin > > Am Mo., 6. Nov. 2023 um 03:48 Uhr schrieb Yun Tang : > > > Hi all, > > > > I would like to discuss creating a new 1.17 patch

Re: [DISCUSS] Release Flink 1.16.3

2023-11-06 Thread Jing Ge
+1 for the final bug fix for Flink 1.16. Thanks for your effort! Best regards, Jing On Mon, Nov 6, 2023 at 1:14 AM Konstantin Knauf wrote: > +1. Thank you for picking it up. Yes, this will be the final bug fix for > Flink 1.16. > > Am Mo., 6. Nov. 2023 um 03:47 Uhr schrieb Rui Fan

Re: [DISCUSS] FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2023-11-06 Thread Jing Ge
Hi Junrui, Thanks for updating the FLIP! It looks good and clear now. Appreciate it! Best regards, Jing On Sun, Nov 5, 2023 at 7:35 PM Junrui Lee wrote: > Hi Jing, > > Thank you for your feedback on the proposal. I appreciate your input and > understand your concerns. > > Regarding your

Review request

2023-11-06 Thread Etienne Chauchot
Hi everyone, Is there anyone available to review this PR (1) that I opened 1,5 month ago ? People I've pinged seem to be unavailable at the moment. Thanks [1] https://github.com/apache/flink/pull/23443 Best Etienne

Re: [VOTE] FLIP-376: Add DISTRIBUTED BY clause

2023-11-06 Thread Jing Ge
+1 (binding) Thanks! Best regards, Jing On Mon, Nov 6, 2023 at 3:40 AM Timo Walther wrote: > Hi everyone, > > I'd like to start a vote on FLIP-376: Add DISTRIBUTED BY clause[1] which > has been discussed in this thread [2]. > > The vote will be open for at least 72 hours unless there is an

[jira] [Created] (FLINK-33467) Support concurrent serialization in akka

2023-11-06 Thread dizhou cao (Jira)
dizhou cao created FLINK-33467: -- Summary: Support concurrent serialization in akka Key: FLINK-33467 URL: https://issues.apache.org/jira/browse/FLINK-33467 Project: Flink Issue Type: Sub-task

[VOTE] FLIP-376: Add DISTRIBUTED BY clause

2023-11-06 Thread Timo Walther
Hi everyone, I'd like to start a vote on FLIP-376: Add DISTRIBUTED BY clause[1] which has been discussed in this thread [2]. The vote will be open for at least 72 hours unless there is an objection or not enough votes. [1]

[jira] [Created] (FLINK-33466) Bounded Kafka source never finishes after restore from savepoint

2023-11-06 Thread Jonas Weile (Jira)
Jonas Weile created FLINK-33466: --- Summary: Bounded Kafka source never finishes after restore from savepoint Key: FLINK-33466 URL: https://issues.apache.org/jira/browse/FLINK-33466 Project: Flink

Re: [VOTE] Release flink-connector-gcp-pubsub v3.0.2, release candidate #1

2023-11-06 Thread Ahmed Hamdy
+1(non-binding) -Checked release notes - Verified checksums and signatures - Verified no binaries in release - Build connector from source - Reviewed web PR. Best Regards Ahmed Hamdy On Fri, 3 Nov 2023 at 11:23, Danny Cranmer wrote: > Hi everyone, > > Please review and vote on the release

Re: [VOTE] Release flink-connector-opensearch v1.1.0, release candidate #1

2023-11-06 Thread Ahmed Hamdy
Hi Danny, +1 (non-binding) - Checked release notes - Verified Checksums and Signature - Checked no binaries in release. - Reviewed web PR - Build Connector from source. Best Regards Ahmed Hamdy On Fri, 3 Nov 2023 at 13:05, Andriy Redko wrote: > +1 (non-binding), thanks a lot Danny! > > Best

Re: [DISCUSS] Release Flink 1.16.3

2023-11-06 Thread Konstantin Knauf
+1. Thank you for picking it up. Yes, this will be the final bug fix for Flink 1.16. Am Mo., 6. Nov. 2023 um 03:47 Uhr schrieb Rui Fan <1996fan...@gmail.com>: > Hi all, > > I would like to discuss creating a new 1.16 patch release (1.16.3). The > last 1.16 release is over five months old, and

Re: [DISCUSS] Release 1.17.2

2023-11-06 Thread Konstantin Knauf
Thank you for picking it up! +1 Cheers, Konstantin Am Mo., 6. Nov. 2023 um 03:48 Uhr schrieb Yun Tang : > Hi all, > > I would like to discuss creating a new 1.17 patch release (1.17.2). The > last 1.17 release is near half a year old, and since then, 79 tickets have > been closed [1], of which

[jira] [Created] (FLINK-33465) Make SingleThreadFetcherManager and FutureCompletingBlockingQueue as PublicEvolving.

2023-11-06 Thread Hongshun Wang (Jira)
Hongshun Wang created FLINK-33465: - Summary: Make SingleThreadFetcherManager and FutureCompletingBlockingQueue as PublicEvolving. Key: FLINK-33465 URL: https://issues.apache.org/jira/browse/FLINK-33465

[jira] [Created] (FLINK-33464) JoinITCase.testRightOuterJoin failed due to heartbeat timeout

2023-11-06 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-33464: - Summary: JoinITCase.testRightOuterJoin failed due to heartbeat timeout Key: FLINK-33464 URL: https://issues.apache.org/jira/browse/FLINK-33464 Project: Flink