Re: [VOTE] FLIP-84: Improve & Refactor API of TableEnvironment

Thanks all for the votes. So far, we have - 3 binding +1 votes (Kurt, Jark, Jingsong) - 2 non-binding +1 votes (Terry, Benchao) - No -1 votes The voting time has past and there is enough +1 votes to consider the FLIP-84 approved. Thank you all. Best, Godfrey godfrey he 于2020年3月2日周一

[jira] [Created] (FLINK-16365) awaitTermination() result is not checked

Roman Leventov created FLINK-16365: -- Summary: awaitTermination() result is not checked Key: FLINK-16365 URL: https://issues.apache.org/jira/browse/FLINK-16365 Project: Flink Issue Type:

Re: [VOTE] FLIP-84: Improve & Refactor API of TableEnvironment

Thanks Jingsong for the reminding. I will update it now. Jingsong Lee 于2020年3月2日周一 下午2:46写道： > Thanks for driving. > > +1 from my side. > > > For current messy Flink table program trigger point, we propose that: for > TableEnvironment and StreamTableEnvironment, you must use >

[jira] [Created] (FLINK-16364) Deprecate the methods in TableEnvironment proposed by FLIP-84

godfrey he created FLINK-16364: -- Summary: Deprecate the methods in TableEnvironment proposed by FLIP-84 Key: FLINK-16364 URL: https://issues.apache.org/jira/browse/FLINK-16364 Project: Flink

[jira] [Created] (FLINK-16363) Correct the execution behavior of TableEnvironment and StreamTableEnvironment

godfrey he created FLINK-16363: -- Summary: Correct the execution behavior of TableEnvironment and StreamTableEnvironment Key: FLINK-16363 URL: https://issues.apache.org/jira/browse/FLINK-16363 Project:

Re: [DISCUSS] FLIP-106: Support Python UDF in SQL Function DDL

Hi Weizhong, Thanks for proposing this feature. In geneal, I'm +1 from the table's view. I have one suggestion: I think the register python function into catalog doesn't need to startup python process (the "High Level Sequence Diagram" in your FLIP). Because only meta-information is persisted

[jira] [Created] (FLINK-16362) remove deprecated method in StreamTableSink

godfrey he created FLINK-16362: -- Summary: remove deprecated method in StreamTableSink Key: FLINK-16362 URL: https://issues.apache.org/jira/browse/FLINK-16362 Project: Flink Issue Type:

[jira] [Created] (FLINK-16361) FLIP-84: Improve & Refactor API of TableEnvironment

godfrey he created FLINK-16361: -- Summary: FLIP-84: Improve & Refactor API of TableEnvironment Key: FLINK-16361 URL: https://issues.apache.org/jira/browse/FLINK-16361 Project: Flink Issue Type:

Re: [VOTE] FLIP-84: Improve & Refactor API of TableEnvironment

Thanks for driving. +1 from my side. > For current messy Flink table program trigger point, we propose that: for TableEnvironment and StreamTableEnvironment, you must use `TableEnvironment.execute()` to trigger table program execution. Looks like this is an incompatible change. You need update

[DISCUSS] FLIP-109: Improve Hive dependencies out-of-box experience

Hi all, I would like to propose a FLIP[1] that improve hive-integration dependencies out-of-box experience. We have discussed in [2]. User can download one single jar to run various versions of hive. The simple conclusion is: - Introduce flink-shaded-hive, Provided download URL in flink-web [3]

[jira] [Created] (FLINK-16360) connector on hive 2.0.1 don't support type conversion from STRING to VARCHAR

wgcn created FLINK-16360: Summary: connector on hive 2.0.1 don't support type conversion from STRING to VARCHAR Key: FLINK-16360 URL: https://issues.apache.org/jira/browse/FLINK-16360 Project: Flink

[jira] [Created] (FLINK-16359) Introduce WritableVectors for abstract writing

Jingsong Lee created FLINK-16359: Summary: Introduce WritableVectors for abstract writing Key: FLINK-16359 URL: https://issues.apache.org/jira/browse/FLINK-16359 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-107: Reading table columns from different parts of source records

Hi, Thanks Dawid for starting such a great discussion. Reaing metadata and key-part information from source is an important feature for streaming users. In general, I agree with the proposal of the FLIP. I will leave my thoughts and comments here: 1) +1 to use connector properties instead of

[DISCUSS] FLIP-108: Add GPU support in Flink

Hi everyone, We would like to start a discussion thread on "FLIP-108: Add GPU support in Flink"[1]. This FLIP mainly discusses the following issues: - Enable user to configure how many GPUs in a task executor and forward such requirements to the external resource managers (for

Re: [ANNOUNCE] Jingsong Lee becomes a Flink committer

Congratulations! Jingsong Best, Forward Terry Wang 于2020年3月2日周一 上午11:10写道： > Congratulations, well deserved.! > > Best, > Terry Wang > > > > > 2020年2月27日 10:50，Yuan Mei 写道： > > > > Congrats! > > > > Best > > Yuan > > > > On Thu, Feb 27, 2020 at 8:48 AM Guowei Ma wrote: > > > >>

Re: [ANNOUNCE] Jingsong Lee becomes a Flink committer

Congratulations, well deserved.! Best, Terry Wang > 2020年2月27日 10:50，Yuan Mei 写道： > > Congrats! > > Best > Yuan > > On Thu, Feb 27, 2020 at 8:48 AM Guowei Ma wrote: > >> Congratulations !! >> Best, >> Guowei >> >> >> Yun Tang 于2020年2月27日周四 上午2:11写道： >> >>> Congratulations and well

Re: [VOTE] FLIP-93: JDBC catalog and Postgres catalog

+1 (non-binding). With this feature, we can more easily interact traditional database in flink. Best, Terry Wang > 2020年3月1日 18:33，zoudan 写道： > > +1 (non-binding) > > Best, > Dan Zou > > >> 在 2020年2月28日，02:38，Bowen Li 写道： >> >> Hi all, >> >> I'd like to kick off the vote for FLIP-93

Re: [DISCUSS] FLIP-84: Improve & Refactor execute/sqlQuery/sqlUpdate APIS of TableEnvironment

hi godfrey, Thanks for your information, I didn't see that part before. Now the FLIP LGTM, thanks for driving this effort. godfrey he 于2020年3月2日周一 上午9:51写道： > Hi Benchao, > > I think the document has contained both parts: the behavior is explained > when introducing `executeStatement` method,

[jira] [Created] (FLINK-16358) Failed to execute when using rowtime or proctime and table keywords

backbook created FLINK-16358: Summary: Failed to execute when using rowtime or proctime and table keywords Key: FLINK-16358 URL: https://issues.apache.org/jira/browse/FLINK-16358 Project: Flink

Re: [DISCUSS] FLIP-84: Improve & Refactor execute/sqlQuery/sqlUpdate APIS of TableEnvironment

Hi Benchao, I think the document has contained both parts: the behavior is explained when introducing `executeStatement` method, and asynchronous execution methods is explained in the appendix. Bests, Godfrey Benchao Li 于2020年2月28日周五 下午10:09写道： > Hi godfrey, > > Thanks for your explanation. >

[jira] [Created] (FLINK-16357) Extend Checkpoint Coordinator to differentiate between "regional restore" and "full restore".

Stephan Ewen created FLINK-16357: Summary: Extend Checkpoint Coordinator to differentiate between "regional restore" and "full restore". Key: FLINK-16357 URL: https://issues.apache.org/jira/browse/FLINK-16357

[ANNOUNCE] Weekly Community Update 2020/09

Dear community, happy to share this week's community update. It was a relatively quiet week on the dev@ mailing list (mostly votes on previously covered FLIPs), but there is always something to share. Additionally, I have decided to also feature *flink-packages.org *in

[DISCUSS] FLIP-107: Reading table columns from different parts of source records

Hi, I would like to propose an improvement that would enable reading table columns from different parts of source records. Besides the main payload majority (if not all of the sources) expose additional information. It can be simply a read-only metadata such as offset, ingestion time or a read

[jira] [Created] (FLINK-16356) Some dependencies contain CVEs

XuCongying created FLINK-16356: -- Summary: Some dependencies contain CVEs Key: FLINK-16356 URL: https://issues.apache.org/jira/browse/FLINK-16356 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-16355) Inconsistent library versions notice.

Kaifeng Huang created FLINK-16355: - Summary: Inconsistent library versions notice. Key: FLINK-16355 URL: https://issues.apache.org/jira/browse/FLINK-16355 Project: Flink Issue Type:

Re: [VOTE] FLIP-93: JDBC catalog and Postgres catalog

+1 (non-binding) Best, Dan Zou > 在 2020年2月28日，02:38，Bowen Li 写道： > > Hi all, > > I'd like to kick off the vote for FLIP-93 [1] to add JDBC catalog and > Postgres catalog. > > The vote will last for at least 72 hours, following the consensus voting > protocol. > > [1] >