Re: Flink as a Service (FaaS)

Hi Radu/jinkui, Thanks for your input! I filed a master task to track discussion on this front https://issues.apache.org/jira/browse/FLINK-6085 Since this is a very broad topic, I would like to kick start with a tiny deployment helper project. What it try to address is to leverage various of

[jira] [Created] (FLINK-6148) The Zookeeper client occur SASL error when the sasl is disable

zhangrucong1982 created FLINK-6148: -- Summary: The Zookeeper client occur SASL error when the sasl is disable Key: FLINK-6148 URL: https://issues.apache.org/jira/browse/FLINK-6148 Project: Flink

Re: [DISCUSS] FLIP-17 Side Inputs

Hi, Aljoscha, Thanks for the analysis. I also agree with the separated window handling. I am also grad to contribute too. Is there any issue which is not picked yet? Feel free to count me in. We have removed the restriction that connected stream cannot be one side keyed and the other unkeyed to

[jira] [Created] (FLINK-6147) flink client can't detect cluster is down

Yelei Feng created FLINK-6147: - Summary: flink client can't detect cluster is down Key: FLINK-6147 URL: https://issues.apache.org/jira/browse/FLINK-6147 Project: Flink Issue Type: Bug

Re: [ANNOUNCE] New committer: Theodore Vasiloudis

Congrats On Wed, Mar 22, 2017, 10:45 AM Chen Qin wrote: > Congrats and looking forward to see great stuff in flink ml side! > > Chen > > > On Mar 21, 2017, at 19:13, 伍翀(云邪) wrote: > > > > Congrats, Theo! > > > >> 在 2017年3月22日，上午8:30，Chiwan Park

Re: [ANNOUNCE] New committer: Theodore Vasiloudis

Congrats and looking forward to see great stuff in flink ml side! Chen > On Mar 21, 2017, at 19:13, 伍翀(云邪) wrote: > > Congrats, Theo! > >> 在 2017年3月22日，上午8:30，Chiwan Park 写道： >> >> Congratulations, Theo! >> >> Regards, >> Chiwan Park >>

Re: [ANNOUNCE] New committer: Theodore Vasiloudis

Congrats, Theo! > 在 2017年3月22日，上午8:30，Chiwan Park 写道： > > Congratulations, Theo! > > Regards, > Chiwan Park > > On 03/22/2017 03:06 AM, Ted Yu wrote: >> Congratulations ! >> >> >> On Tue, Mar 21, 2017 at 11:00 AM, Matthias J. Sax wrote: >> >>>

Re: [ANNOUNCE] New committer: Theodore Vasiloudis

Congratulations, Theo! Regards, Chiwan Park On 03/22/2017 03:06 AM, Ted Yu wrote: Congratulations ! On Tue, Mar 21, 2017 at 11:00 AM, Matthias J. Sax wrote: -BEGIN PGP SIGNED MESSAGE- Hash: SHA512 Congrats! On 3/21/17 8:59 AM, Greg Hogan wrote: Welcome, Theo,

[jira] [Created] (FLINK-6146) Incorrect function name given in exception thrown by DataSet.getType()

Luke Hutchison created FLINK-6146: - Summary: Incorrect function name given in exception thrown by DataSet.getType() Key: FLINK-6146 URL: https://issues.apache.org/jira/browse/FLINK-6146 Project:

Re: [DISCUSS] TravisCI status on GitHub Page

ok, fair enough On Tue, Mar 21, 2017 at 11:00 AM, Stephan Ewen wrote: > @Bowen Li > > There are various discussions currently about reworking repository > structure, tests, even switching CI services. > I would be up for revisiting this questions once we care confident that

Re: [DISCUSS] FLIP-18: Code Generation for improving sorting performance

Hi Pat, thanks a lot for this great proposal! I think it is very well structured and has the right level of detail. The improvements of your performance benchmarks look very promising and I think code-gen'd sorters would be a very nice improvement. I like that you plan to add a switch to activate

Re: [ANNOUNCE] New committer: Theodore Vasiloudis

Congratulations ! On Tue, Mar 21, 2017 at 11:00 AM, Matthias J. Sax wrote: > -BEGIN PGP SIGNED MESSAGE- > Hash: SHA512 > > Congrats! > > On 3/21/17 8:59 AM, Greg Hogan wrote: > > Welcome, Theo, and great to have you onboard with Flink and ML! > > > > > >> On Mar 21,

Re: [ANNOUNCE] New committer: Theodore Vasiloudis

Congrats! On Tue, Mar 21, 2017 at 11:01 AM Matthias J. Sax wrote: > -BEGIN PGP SIGNED MESSAGE- > Hash: SHA512 > > Congrats! > > On 3/21/17 8:59 AM, Greg Hogan wrote: > > Welcome, Theo, and great to have you onboard with Flink and ML! > > > > > >> On Mar 21, 2017, at

Re: [ANNOUNCE] New committer: Theodore Vasiloudis

-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 Congrats! On 3/21/17 8:59 AM, Greg Hogan wrote: > Welcome, Theo, and great to have you onboard with Flink and ML! > > >> On Mar 21, 2017, at 4:35 AM, Robert Metzger >> wrote: >> >> Hi everybody, >> >> On behalf of the PMC

Re: [DISCUSS] TravisCI status on GitHub Page

@Bowen Li There are various discussions currently about reworking repository structure, tests, even switching CI services. I would be up for revisiting this questions once we care confident that the CI infrastructure does not mark "good state" as "broken". On Tue, Mar 21, 2017 at 3:02 PM, Ufuk

Re: Issue assign right

Hi, done. I gave you contributor permissions. You can now assign issues to yourself. Best, Fabian 2017-03-21 16:19 GMT+01:00 zhengcanbin : > Hi, all > I have created two issues and fix them > > https://issues.apache.org/jira/browse/FLINK-6117 > >

Re: [DISCUSS] Release Flink 1.1.5 / Flink 1.2.1

Sorry, I missed one other pending issue for Flink 1.2.1: - https://issues.apache.org/jira/browse/FLINK-5972 Disallow shrinking merging windows. This would replace  https://issues.apache.org/jira/browse/FLINK-5713, which was previously listed as a blocker for 1.2.1. Status: PR review pending - 

Re: [DISCUSS] Release Flink 1.1.5 / Flink 1.2.1

Update for Flink 1.2.1: There’s only one PR pending that is LGTM - https://issues.apache.org/jira/browse/FLINK-6084 Fix for Cassandra connector dropping metrics-core dependency. We can proceed to create the release candidate very soon :-) Release 1.1.5 RC1 seems to be in good shape so far, so

[jira] [Created] (FLINK-6145) Add [non-partitioned] event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL

sunjincheng created FLINK-6145: -- Summary: Add [non-partitioned] event time OVER ROWS BETWEEN x PRECEDING aggregation to SQL Key: FLINK-6145 URL: https://issues.apache.org/jira/browse/FLINK-6145 Project:

[jira] [Created] (FLINK-6144) Port job manager related configuration options to ConfigOption

Till Rohrmann created FLINK-6144: Summary: Port job manager related configuration options to ConfigOption Key: FLINK-6144 URL: https://issues.apache.org/jira/browse/FLINK-6144 Project: Flink

Issue assign right

Hi, all I have created two issues and fix them https://issues.apache.org/jira/browse/FLINK-6117 https://issues.apache.org/jira/browse/FLINK-6132 there are two things now 1) Can assign these issues to me? 2) Can I get rights to create and assigning jira issues ?

Re: [ANNOUNCE] New committer: Theodore Vasiloudis

Welcome, Theo, and great to have you onboard with Flink and ML! > On Mar 21, 2017, at 4:35 AM, Robert Metzger wrote: > > Hi everybody, > > On behalf of the PMC I am delighted to announce Theodore Vasiloudis as a > new Flink committer! > > Theo has been a community member

[jira] [Created] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

Ted Yu created FLINK-6143: - Summary: Unprotected access to this.flink in LocalExecutor#endSession() Key: FLINK-6143 URL: https://issues.apache.org/jira/browse/FLINK-6143 Project: Flink Issue Type:

Re: [VOTE] Release Apache Flink 1.1.5 (RC1)

+1 I looked at every commit since 1.1.4. The code looks good and we didn’t introduce any new dependencies, so ,legally speaking, we should be fine. > On 21 Mar 2017, at 14:40, Stephan Ewen wrote: > > +1 > > - Verified the LICENSE and NOTICE (no dependency updates, update on

Re: [ANNOUNCE] New committer: Theodore Vasiloudis

Great to have you now as a committer, Theo! On Tue, Mar 21, 2017 at 1:02 PM, Stephan Ewen wrote: > Good to have you, Theo! > > On Tue, Mar 21, 2017 at 11:51 AM, Ufuk Celebi wrote: > > > Great news! :-) > > > > > > On Tue, Mar 21, 2017 at 10:32 AM, Aljoscha

Re: [DISCUSS] TravisCI status on GitHub Page

The tag says "errored" in case of the timeout. But I don't think it's a worthwhile discussion to have, so I just reverted the commit. On Tue, Mar 21, 2017 at 2:50 PM, Stephan Ewen wrote: > Copying my answer from JIRA: > > Many builds are marked as "failed" these days simply

Re: [VOTE] Release Apache Flink 1.1.5 (RC1)

+1 - Verified the LICENSE and NOTICE (no dependency updates, update on RabbitMQ license) - Release contains no executable binaries - Build and all integration tests pass forHadoop 2.6.1 , Scala 2.11 @Robert The java8 module has only tests, so it should be fine to not have it published. On

Re: [DISCUSS] Project build time and possible restructuring

So what do we want to move to the libraries repository? I would propose to move these modules first: flink-cep-scala flink-cep flink-gelly-examples flink-gelly-scala flink-gelly flink-ml All other modules (e.g. in flink-contrib) are rather connectors. I think it would be better to move those

Re: [ANNOUNCE] New committer: Theodore Vasiloudis

Good to have you, Theo! On Tue, Mar 21, 2017 at 11:51 AM, Ufuk Celebi wrote: > Great news! :-) > > > On Tue, Mar 21, 2017 at 10:32 AM, Aljoscha Krettek > wrote: > > Welcome (to committership)! (Since you’re already with us for such a > long time…) :-) > >>

Re: [ANNOUNCE] New committer: Theodore Vasiloudis

Great news! :-) On Tue, Mar 21, 2017 at 10:32 AM, Aljoscha Krettek wrote: > Welcome (to committership)! (Since you’re already with us for such a long > time…) :-) >> On 21 Mar 2017, at 10:08, Tzu-Li (Gordon) Tai wrote: >> >> Welcome Theodore! Great to

Re: [ANNOUNCE] New committer: Theodore Vasiloudis

Welcome (to committership)! (Since you’re already with us for such a long time…) :-) > On 21 Mar 2017, at 10:08, Tzu-Li (Gordon) Tai wrote: > > Welcome Theodore! Great to have you on board :-) > > > On March 21, 2017 at 4:35:35 PM, Robert Metzger (rmetz...@apache.org)

Re: [ANNOUNCE] New committer: Theodore Vasiloudis

Welcome Theodore! Great to have you on board :-) On March 21, 2017 at 4:35:35 PM, Robert Metzger (rmetz...@apache.org) wrote: Hi everybody, On behalf of the PMC I am delighted to announce Theodore Vasiloudis as a new Flink committer! Theo has been a community member for a very long time

Re: [VOTE] Release Apache Flink 1.1.5 (RC1)

+1 - start-local.sh + some example jobs work (logs are fine, web interface works, scripts are fine) - files in the staging repo look good (quickstart is correct) (except java8 module is missing, but see comment below) Side note: The flink-java8 module is not in the staging repository. I first

[ANNOUNCE] New committer: Theodore Vasiloudis

Hi everybody, On behalf of the PMC I am delighted to announce Theodore Vasiloudis as a new Flink committer! Theo has been a community member for a very long time and he is one of the main drivers of the currently ongoing ML discussions in Flink. Welcome Theo and congratulations again for