Re: [VOTE] FLIP-78: Flink Python UDF Environment and Dependency Management

Hi Wei, +1 (non-binding). Thanks for driving this. Thanks, Dian > 在 2019年10月14日，下午1:40，jincheng sun 写道： > > +1 > > Wei Zhong 于2019年10月12日周六 下午8:41写道： > >> Hi all, >> >> I would like to start the vote for FLIP-78[1] which is discussed and >> reached consensus in the discussion thread[2]. >

[jira] [Created] (FLINK-14387) Insert into catalog table failed when catalog table not implement table source factory

Jingsong Lee created FLINK-14387: Summary: Insert into catalog table failed when catalog table not implement table source factory Key: FLINK-14387 URL: https://issues.apache.org/jira/browse/FLINK-14387

Re: [VOTE] FLIP-78: Flink Python UDF Environment and Dependency Management

+1 Wei Zhong 于2019年10月12日周六 下午8:41写道： > Hi all, > > I would like to start the vote for FLIP-78[1] which is discussed and > reached consensus in the discussion thread[2]. > > The vote will be open for at least 72 hours. I'll try to close it by > 2019-10-16 18:00 UTC, unless there is an objection

Re: [VOTE] Drop Python 2 support for 1.10

+1 Thanks a lot for driving this, Dian! On Mon, Oct 14, 2019 at 1:46 PM jincheng sun wrote: > +1 > > Dian Fu 于2019年10月14日周一 下午1:21写道： > > > Hi all, > > > > I would like to start the vote for "Drop Python 2 support for 1.10", > which > > is discussed and reached a consensus in the discussion th

[Discussion] FLIP-79 Flink Function DDL Support

Dear Community, FLIP-79 Flink Function DDL Support This proposal aims to support function DDL with the consideration of SQL syntax, language compliance, and advanced external UDF lib registration. The Flink DD

Re: [VOTE] Drop Python 2 support for 1.10

+1 Dian Fu 于2019年10月14日周一 下午1:21写道： > Hi all, > > I would like to start the vote for "Drop Python 2 support for 1.10", which > is discussed and reached a consensus in the discussion thread[1]. > > The vote will be open for at least 72 hours. Unless there is an objection, > I will try to close it

Re: [DISCUSS] Drop Python 2 support for 1.10

Thanks Jincheng for the remind and everyone for joining the discussion. I have started the vote thread in [1]. Thanks, Dian [1] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/VOTE-Drop-Python-2-support-for-1-10-tt33962.html

[VOTE] Drop Python 2 support for 1.10

Hi all, I would like to start the vote for "Drop Python 2 support for 1.10", which is discussed and reached a consensus in the discussion thread[1]. The vote will be open for at least 72 hours. Unless there is an objection, I will try to close it by Oct 17, 2019 18:00 UTC if we have received su

Re: [DISCUSS] FLIP-67: Global partitions lifecycle

Thanks for these further considerations Chesnay! I guess we might have some misunderstanding. Actually I was not against the previous proposal Till suggested before, and I think it is a formal way to do that. And my previous proposal was not for excluding the ShuffleService completely. The Shu

Re: Mongo Connector

Hi vijay: I developed an append stream sink for Mongo internally, which writes data in batches according to configureable batch size, and also provides asynchronous flush. But only insert not update or upsert. It's a good job. It's been working very well for a long time. (Throughput depends mai

[jira] [Created] (FLINK-14386) Support computed column for create table statement

Danny Chen created FLINK-14386: -- Summary: Support computed column for create table statement Key: FLINK-14386 URL: https://issues.apache.org/jira/browse/FLINK-14386 Project: Flink Issue Type: Im

Re: [DISCUSS] FLIP-67: Global partitions lifecycle

Thanks for the further explanation Till! It is fine for me to run only one ShuffleMaster instance as now, and make RM handle the deletion of cluster partitions in a light-weight way. I also have no concerns of letting TE handle the deletion of cluster partititions as did for job partitions now.

Re: [VOTE] Release 1.9.1, release candidate #1

Thanks @Hequn and @Yun Tang, I set the fixVersion of FLINK-14385 to 1.8.3 and 1.9.2. Btw, I would really appreciate if any PMC member could help with the verification. I hope we can release 1.9.1 this week. The vote will still be open until we reach at least 3 binding votes or any blocker issu

Re: [DISCUSS] FLIP-67: Global partitions lifecycle

I'm quite torn on whether to exclude the ShuffleServices from the proposal. I think I'm now on my third or fourth iteration for a response, so I'll just send both so I can stop thinking for a bit about whether to push for one or the other: Opinion A, aka "Nu Uh": I'm not in favor of exclud

Re: [VOTE] Release 1.9.1, release candidate #1

I think FLINK-14385 is not introduced from release-1.9 but since when we decide to release hadoop-free Flink form 1.8 [1] [1] https://issues.apache.org/jira/browse/FLINK-11266 Best Yun Tang From: Hequn Cheng S

[ANNOUNCE] Weekly Community Update 2019/41

Dear community, happy to share a small community update this week with Flink Forward Europe, "Stateful Functions" and a bit more. Flink Development == * [api] Stephan proposes to contribute* Stateful Function (statefun.io )* to Apache Flink. Stateful Functions wer

Re: [VOTE] Release 1.9.1, release candidate #1

+1 (non-binding) Do the following checks and all are success. - Verified signatures and hashes. - Built from the source archive. - Check repository contains all artifacts. - Test WordCount on a local standalone cluster. a. Both streaming and batch b. Web UI works fine - Test WordCount on y

[jira] [Created] (FLINK-14385) There are ClassNotFoundException when run the example in Local Setup Tutorial

Hequn Cheng created FLINK-14385: --- Summary: There are ClassNotFoundException when run the example in Local Setup Tutorial Key: FLINK-14385 URL: https://issues.apache.org/jira/browse/FLINK-14385 Project:

Re: [DISCUSS] FLIP-67: Global partitions lifecycle

I think we won't necessarily run multiple ShuffleMasters. I think it would be better to pass in a leaner interface into the RM to only handle the deletion of the global result partitions. Letting the TEs handle the deletion of the global result partitions might work as long as we don't have an ext

[jira] [Created] (FLINK-14384) ValidationMatcher in FlinkSqlParserImplTest fails to test negative tests

Jiayi Liao created FLINK-14384: -- Summary: ValidationMatcher in FlinkSqlParserImplTest fails to test negative tests Key: FLINK-14384 URL: https://issues.apache.org/jira/browse/FLINK-14384 Project: Flink