Mongo Connector

2019-10-12 Thread Vijay Srinivasaraghavan
Hello, Do we know how much of support we have for Mongo? The documentation page is pointing to a connector repo that was very old (last updated 5 years ago) and looks like that was just a sample code to showcase the integration. https://ci.apache.org/projects/flink/flink-docs-stable/dev/batch/con

Re: [PROPOSAL] Contribute Stateful Functions to Apache Flink

2019-10-12 Thread Hequn Cheng
Hi Stephan, Big +1 for adding this to Apache Flink! As for the problem of whether this should be added to the Flink main repository, from my side, I prefer to put it in the main repository. Not only Stateful Functions shares very close relations with the current Flink, but also other libs or modu

Re: [PROPOSAL] Contribute Stateful Functions to Apache Flink

2019-10-12 Thread Biao Liu
Hi Stehpan, +1 for having Stateful Functions in Flink. Before discussing which repository it should belong, I was wondering if we have reached an agreement of "splitting flink repository" as Piotr mentioned or not. It seems that it's just no more further discussion. It's OK for me to add it to co

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

2019-10-12 Thread Wei Zhong
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 or not enough votes. Thanks, Wei [1] https://cwi

[jira] [Created] (FLINK-14383) Support python UDFs with constant value of time interval types

2019-10-12 Thread Hequn Cheng (Jira)
Hequn Cheng created FLINK-14383: --- Summary: Support python UDFs with constant value of time interval types Key: FLINK-14383 URL: https://issues.apache.org/jira/browse/FLINK-14383 Project: Flink

[jira] [Created] (FLINK-14382) Wrong local FLINK_PLUGINS_DIR is set to flink-conf.yaml of jobmanager and taskmanager on Yarn

2019-10-12 Thread Yang Wang (Jira)
Yang Wang created FLINK-14382: - Summary: Wrong local FLINK_PLUGINS_DIR is set to flink-conf.yaml of jobmanager and taskmanager on Yarn Key: FLINK-14382 URL: https://issues.apache.org/jira/browse/FLINK-14382

Re: [PROPOSAL] Contribute Stateful Functions to Apache Flink

2019-10-12 Thread Yu Li
Hi Stephan, Big +1 for adding stateful functions to Flink. I believe a lot of user would be interested to try this out and I could imagine how this could contribute to reduce the TCO for business requiring both streaming processing and stateful functions. And my 2 cents is to put it into flink co

Re: [DISCUSS] Flink Python UDF Environment and Dependency Management

2019-10-12 Thread jincheng sun
Hi Wei Zhong, I have given you edit permission, could you please re-login and check it. :) Best, Jincheng Wei Zhong 于2019年10月12日周六 下午6:06写道： > Hi Jincheng, > > As communicated in this email thread, I’m proposing to convert the design > doc to a FLIP and bring up the VOTE. It would be great if

Re: [DISCUSS] Flink Python UDF Environment and Dependency Management

2019-10-12 Thread Wei Zhong
Thank you Jincheng. I have got the permission. > 在 2019年10月12日，18:09，jincheng sun 写道： > > Hi Wei Zhong, > > I have given you edit permission, could you please re-login and check it. :) > > Best, > Jincheng > > > Wei Zhong mailto:weizhong0...@gmail.com>> > 于2019年10月12日周六 下午6:06写道： > Hi Jinch

Re: [DISCUSS] Flink Python UDF Environment and Dependency Management

2019-10-12 Thread Wei Zhong
Hi Jincheng, As communicated in this email thread, I’m proposing to convert the design doc to a FLIP and bring up the VOTE. It would be great if you can grant me the write access to Confluence :). My Confluence ID is zhongwei. Thanks, Wei Zhong > 在 2019年10月12日，17:41，jincheng sun 写道： > > Hi,

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

2019-10-12 Thread Jark Wu
Hi Jingsong, Thanks for verifying. I updated the fixVersion to 1.9.2 for these issues. Best, Jark > 在 2019年10月12日，16:45，Jingsong Li 写道： > > +1 (non-binding) > > - Check if checksums files match the corresponding release files > - Check if GPG files match the corresponding release files > -

Re: [DISCUSS] Drop Python 2 support for 1.10

2019-10-12 Thread jincheng sun
Hi Dian, I think it's better to bring up the VOTE for this proposal. Then push this forward.:) Thanks, Jincheng Timo Walther 于2019年10月10日周四 下午8:07写道： > I also heard from other companies that upgrading to Python 3 is in > progress for data teams. > > +1 for simplifying the code base with option

Re: [DISCUSS] Flink Python UDF Environment and Dependency Management

2019-10-12 Thread jincheng sun
Hi, + 1 to bring up the VOTE and create the FLIP. Best, Jincheng Dian Fu 于2019年10月12日周六 上午10:12写道： > Hi Wei, > > Thanks for the great work! It seems that it has reached an agreement on > the design. Should we start VOTE on this design? I'm also wondering if a > FLIP is deserved as it introduce

Re: [PROPOSAL] Contribute Stateful Functions to Apache Flink

2019-10-12 Thread jincheng sun
Hi Stephan, bit +1 for adding this great features to Apache Flink. Regarding where we should place it, put it into Flink core repository or create a separate repository? I prefer put it into main repository and looking forward the more detail discussion for this decision. Best, Jincheng Jingso

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

2019-10-12 Thread Jingsong Li
+1 (non-binding) - Check if checksums files match the corresponding release files - Check if GPG files match the corresponding release files - Verify that the source archives do not contains any binaries - Build the source with Maven to ensure all source files have Apache headers - Check that all