Re: [DISCUSS] Add missing visibility annotation for Table APIs

2023-07-31 Thread Jing Ge
Hi Jane, Hi Jack, Thanks for sharing your thoughts. It makes sense. Did you mean literally all classes in table-api-java, table-api-java-bridge, and table-common modules should have at least one visibility annotations? Any other modules or only these three modules? Agree, we should add ArchUnit

[jira] [Created] (FLINK-32721) agg supports char type

2023-07-31 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-32721: - Summary: agg supports char type Key: FLINK-32721 URL: https://issues.apache.org/jira/browse/FLINK-32721 Project: Flink Issue Type: Improvement

Release 2.0 Status Updates - 08/01/2023

2023-07-31 Thread Xintong Song
Hi devs, As the release 2.0 must-have items being voted and approved, the release managers recently had another discussion on how to move forward. Here's the summary. ## Follow-up of previous discussions - As a follow-up of deciding the must-have items [1], Martijn will help draft an

[jira] [Created] (FLINK-32720) Add GENERATE_SERIES support in SQL & Table API

2023-07-31 Thread Hanyu Zheng (Jira)
Hanyu Zheng created FLINK-32720: --- Summary: Add GENERATE_SERIES support in SQL & Table API Key: FLINK-32720 URL: https://issues.apache.org/jira/browse/FLINK-32720 Project: Flink Issue Type:

[jira] [Created] (FLINK-32719) Block upgrades during checkpoints when LATEST_STATE recovery is configured

2023-07-31 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-32719: - Summary: Block upgrades during checkpoints when LATEST_STATE recovery is configured Key: FLINK-32719 URL: https://issues.apache.org/jira/browse/FLINK-32719

Re: [ANNOUNCE] Flink 1.18 feature freeze

2023-07-31 Thread Leonard Xu
Thank all Release Managers for driving the 1.18 release work! > - Deprecation works for 2.0 > > As discussed in another thread [3], we will not give extra extensions to > deprecation works considering the overhead and potential side effects to > the timeline of 1.18. We can accept tiny changes

Re: [DISCUSS] FLIP-348: Support System Columns in SQL and Table API

2023-07-31 Thread Jark Wu
Hi Timo, Thanks for your proposal. I think this is a nice feature for users and I prefer option 3. I only have one concern about the concept of pseudo-column or system-column, because this is the first time we introduce it in Flink SQL. The confusion is similar to the question of Benchao and

Re: [DISCUSS] Upgrade vendored guava dependency

2023-07-31 Thread Hong Teoh
Sorry - meant to send this to a different mailing list -.- > On 31 Jul 2023, at 15:58, Hong Teoh wrote: > > Hi all, > > The current version of guava that is vendored in Beam is > com.google.guava:guava:26.0-jre. > > This version is really old, and has active vulnerabilities [1] [2] > [1]

[DISCUSS] Upgrade vendored guava dependency

2023-07-31 Thread Hong Teoh
Hi all, The current version of guava that is vendored in Beam is com.google.guava:guava:26.0-jre. This version is really old, and has active vulnerabilities [1] [2] [1] https://mvnrepository.com/artifact/com.google.guava/guava/26.0-jre [2] CVE-2023-2976

Re: [DISCUSS] FLIP-330: Support specifying record timestamp requirement

2023-07-31 Thread Jark Wu
Hi Yunfeng, I think this is a great idea to improve the serialization performance, especially for batch jobs. I'm not sure whether you have considered or tested this optimization for batch jobs. IMO, this optimization can be enabled by default for batch jobs, because they don't have watermarks

Heartbeat of TaskManager with id container

2023-07-31 Thread Y SREEKARA BHARGAVA REDDY
Hi Team, Did any one face the below exception. If yes, please share the resolution. 2023-07-28 22:04:16 j*ava.util.concurrent.TimeoutException: Heartbeat of TaskManager with id container_e19_1690528962823_0382_01_05 timed out.* at org.apache.flink.runtime.jobmaster.

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.6.0, release candidate #1

2023-07-31 Thread Maximilian Michels
+1 (binding) 1. Downloaded the source and helm archives, checksums, and signatures 2. Verified the signatures and checksums 3. Extract and inspect the source code for binaries 4. Compiled and tested the source code via mvn verify 5. Verified license files / headers 6. Deployed helm chart to test

Re: [DISCUSS] Add missing visibility annotation for Table APIs

2023-07-31 Thread Jark Wu
Thanks for the updates. LGTM now. Hi Jing, In my opinion, enforcing visibility annotations for all classes in the API module has a major benefit of simplifying CI checks for missing annotations. Best, Jark On Mon, 31 Jul 2023 at 12:33, liu ron wrote: > Hi, Jane > > Thanks for driving this

[jira] [Created] (FLINK-32718) 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded

2023-07-31 Thread Neha Aggarwal (Jira)
Neha Aggarwal created FLINK-32718: - Summary: 'UNION ALL' with a 'GROUP BY' condition in Flink is causing the checkpoint to become unbounded Key: FLINK-32718 URL: https://issues.apache.org/jira/browse/FLINK-32718

Re: [DISCUSSION] Revival of FLIP-154 (SQL Implicit Type Coercion)

2023-07-31 Thread liu ron
Hi, Sergey Thanks for reviving this FLIP, Implicit type coercion is very useful, and in our company practice, we have allowed this feature to be turned on by way of an option. At one point I was going to push for this part of the work, but didn't care for it because of other things. Feel free to

[jira] [Created] (FLINK-32717) Change of topic list from KafkaSource

2023-07-31 Thread Kwangin (Dennis) Jung (Jira)
Kwangin (Dennis) Jung created FLINK-32717: - Summary: Change of topic list from KafkaSource Key: FLINK-32717 URL: https://issues.apache.org/jira/browse/FLINK-32717 Project: Flink

[jira] [Created] (FLINK-32716) Give 'None' option for 'scheduler-mode'

2023-07-31 Thread Kwangin (Dennis) Jung (Jira)
Kwangin (Dennis) Jung created FLINK-32716: - Summary: Give 'None' option for 'scheduler-mode' Key: FLINK-32716 URL: https://issues.apache.org/jira/browse/FLINK-32716 Project: Flink

[jira] [Created] (FLINK-32715) ProcessFailureCancelingITCase.testCancelingOnProcessFailure

2023-07-31 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-32715: - Summary: ProcessFailureCancelingITCase.testCancelingOnProcessFailure Key: FLINK-32715 URL: https://issues.apache.org/jira/browse/FLINK-32715 Project: Flink

Re: [DISCUSS][2.0] FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package

2023-07-31 Thread liu ron
+1, Best, Ron Yun Tang 于2023年7月26日周三 14:19写道: > +1 (binding) > > Best > Yun Tang > > From: Yu Li > Sent: Wednesday, July 26, 2023 14:10 > To: dev@flink.apache.org > Subject: Re: [DISCUSS][2.0] FLIP-349: Move RocksDB statebackend classes to >

Re: [VOTE][2.0] FLIP-344: Remove parameter in RichFunction#open

2023-07-31 Thread liu ron
+1(no-binding) Best, Ron Jing Ge 于2023年7月26日周三 21:47写道: > +1 (binding) > > On Wed, Jul 26, 2023 at 4:21 PM weijie guo > wrote: > > > +1 (binding) > > > > Best regards, > > > > Weijie > > > > > > Yuxin Tan 于2023年7月26日周三 16:11写道: > > > > > +1 (non-binding) > > > > > > Best, > > > Yuxin > > > >