Re: [Discussion] FLIP-79 Flink Function DDL Support

2019-11-01 Thread Bowen Li
Re 1) I'd prefer syntax of [LANGUAGE JVM|PYTHON|...]. It's also adopted by Postgres [1] and MySQL [2] "USING 'python .' " seems need extra parsing of the content in single quotes, which is not very ideal. Re 2) I agree. Besides, the doc proposes new field to be a string. I think it's better

Re: [ANNOUNCE] Progress of Apache Flink 1.10 #2

2019-11-01 Thread Steven Wu
Gary, FLIP-27 seems to get omitted in the 2nd update. below is the info from update #1. - FLIP-27: Refactor Source Interface [20] - FLIP accepted. Implementation is in progress. On Fri, Nov 1, 2019 at 7:01 AM Gary Yao wrote: > Hi community, > > Because we have approximately one month

Re: [ANNOUNCE] Progress of Apache Flink 1.10 #2

2019-11-01 Thread Thomas Weise
Is there any activity on FLIP-27 that would make it relevant for 1.10 release? Thanks Gary for the update, it provides excellent visibility on current activity and what we can expect with the release. On Fri, Nov 1, 2019 at 1:52 PM Steven Wu wrote: > Gary, FLIP-27 seems to get omitted in the

[jira] [Created] (FLINK-14592) FlinkKafkaInternalProducerITCase fails with BindException

2019-11-01 Thread Gary Yao (Jira)
Gary Yao created FLINK-14592: Summary: FlinkKafkaInternalProducerITCase fails with BindException Key: FLINK-14592 URL: https://issues.apache.org/jira/browse/FLINK-14592 Project: Flink Issue

Re: [DISCUSS] Semantic and implementation of per-job mode

2019-11-01 Thread tison
Hi all, Thanks for your participation! First of all I have to clarify two confusion in this thread. 1. The proposed "pre-program" mode is definitely a new mode opt-in. It is described in "Compatibility" section of the original email. 2. The documentation linked in the original email "Flink

Re: RemoteEnvironment cannot execute job from local.

2019-11-01 Thread Till Rohrmann
No it is the expected behaviour. As I've said, you should give the createRemoteEnvironment the user code jar of your program. Otherwise Flink cannot find your filter function. Hence, it works if you comment it out because it is not needed. Cheers, Till On Thu, Oct 31, 2019 at 11:41 AM Simon Su

Re: [DISCUSS] Reducing build times

2019-11-01 Thread Robert Metzger
Hi, we have not decided how to proceed on the issue yet. I'm currently in the process of setting up some metrics for understanding the impact on the end-to-end build times of Travis vs Azure Pipelines. In my current PoC [1], we are also using self-hosted pipeline agents. Feel free to reach out to

Re: [DISCUSS] FLIP-83: Flink End-to-end Performance Testing Framework

2019-11-01 Thread Piotr Nowojski
Hi Yu, Thanks for the answers, it makes sense to me :) Piotrek > On 31 Oct 2019, at 11:25, Yu Li wrote: > > Hi Piotr, > > Thanks for the comments! > > bq. How are you planning to execute the end-to-end benchmarks and integrate > them with our build process? > Great question! We plan to

Re: [DISCUSS] FLIP-83: Flink End-to-end Performance Testing Framework

2019-11-01 Thread Yun Tang
+1, I like the idea of this improvement which acts as a watchdog for developers' code change. By the way, do you think it's worthy to add a checkpoint mode which just disable checkpoint to run end-to-end jobs? And when will stage2 and stage3 be discussed in more details? Best Yun Tang On

[jira] [Created] (FLINK-14593) Make ClusterClient an interface

2019-11-01 Thread Zili Chen (Jira)
Zili Chen created FLINK-14593: - Summary: Make ClusterClient an interface Key: FLINK-14593 URL: https://issues.apache.org/jira/browse/FLINK-14593 Project: Flink Issue Type: Sub-task

Re: [VOTE] Accept Stateful Functions into Apache Flink

2019-11-01 Thread Konstantin Knauf
+1 (non-binding) Stateful Functions, already in its current initial release, simplifies the development of event-driven application on Flink quite significantly. On Thu, Oct 31, 2019 at 9:24 AM Vijay Bhaskar wrote: > +1 from me > > Regards > Bhaskar > > On Thu, Oct 31, 2019 at 11:42 AM Gyula

[ANNOUNCE] Progress of Apache Flink 1.10 #2

2019-11-01 Thread Gary Yao
Hi community, Because we have approximately one month of development time left until the targeted Flink 1.10 feature freeze, we thought now would be a good time to give another progress update. Below we have included a list of the ongoing efforts that have made progress since our last release