[jira] [Created] (FLINK-3214) WindowCheckpointingITCase

2016-01-10 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-3214: -- Summary: WindowCheckpointingITCase Key: FLINK-3214 URL: https://issues.apache.org/jira/browse/FLINK-3214 Project: Flink Issue Type: Bug Compone

答复: Effort to add SQL / StreamSQL to Flink

2016-01-10 Thread Jiangsong (Hi)
I suggest refering to Esper EPL[1], which is a SQL-standard language extend to offering a cluster of window, pattern matching. EPL can both support Streaming SQL and CEP with one unified syntax. [1] http://www.espertech.com/esper/release-5.2.0/esper-reference/pdf/esper_reference.pdf (Chapt

Re: Effort to add SQL / StreamSQL to Flink

2016-01-10 Thread Chiwan Park
We still don’t have a concensus about the streaming SQL and CEP library on Flink. Some people want to merge these two libraries. Maybe we have to discuss about this in mailing list. > On Jan 11, 2016, at 10:53 AM, Nick Dimiduk wrote: > > What's the relationship between the streaming SQL propos

Re: Effort to add SQL / StreamSQL to Flink

2016-01-10 Thread Nick Dimiduk
What's the relationship between the streaming SQL proposed here and the CEP syntax proposed earlier in the week? On Sunday, January 10, 2016, Henry Saputra wrote: > Awesome! Thanks for the reply, Fabian. > > - Henry > > On Sunday, January 10, 2016, Fabian Hueske > wrote: > > > Hi Henry, > > > >

Re: Dripping the Flink-on-Tez code for Flink 1.0

2016-01-10 Thread Henry Saputra
+1 I am always for simplifying our code base when possible. On Sunday, January 10, 2016, Stephan Ewen wrote: > I was typing with fat fingers again. Meant "dropping code" of course, not > "dripping" ;-) > > On Sun, Jan 10, 2016 at 11:55 AM, Fabian Hueske > wrote: > > > +1 > > > > 2016-01-08 1

Re: Effort to add SQL / StreamSQL to Flink

2016-01-10 Thread Henry Saputra
Awesome! Thanks for the reply, Fabian. - Henry On Sunday, January 10, 2016, Fabian Hueske wrote: > Hi Henry, > > There is https://issues.apache.org/jira/browse/FLINK-2099 and a few > subissues. > I'll reorganize these and add more issues for the tasks described in the > design document in the n

Re: Release tag for 0.10.1

2016-01-10 Thread Stephan Ewen
All build are built equal against Hadoop, but a specific Hadoop version is still part of the Flink lib folder when downloaded. Cross Hadoop-version compatibility is not good, i.e., when Flink has Hadoop 2.4 in the classpath, it does not work with a 2.6 YARN installation. That is why we pre-build m

Re: Add CEP library to Flink

2016-01-10 Thread Paris Carbone
+1 for the cool design proposal. I also agree with Stephan’s point to focus on the Pattern operator. Ultimately in the future this could be merged into the SQL lib. There are a few “standards" you could check out such as Oracle’s Pattern Matching extension on SQL [1], apart from EPL. [1] https

Re: Dripping the Flink-on-Tez code for Flink 1.0

2016-01-10 Thread Stephan Ewen
I was typing with fat fingers again. Meant "dropping code" of course, not "dripping" ;-) On Sun, Jan 10, 2016 at 11:55 AM, Fabian Hueske wrote: > +1 > > 2016-01-08 17:35 GMT+01:00 Till Rohrmann : > > > +1 since it increase maintainability of the code base if it is not really > > used and thus re

[jira] [Created] (FLINK-3213) Union of two streams with different parallelism should adjust parallelism automatically

2016-01-10 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-3213: --- Summary: Union of two streams with different parallelism should adjust parallelism automatically Key: FLINK-3213 URL: https://issues.apache.org/jira/browse/FLINK-3213 P

[jira] [Created] (FLINK-3212) JobManagerCheckpointRecoveryITCase

2016-01-10 Thread Matthias J. Sax (JIRA)
Matthias J. Sax created FLINK-3212: -- Summary: JobManagerCheckpointRecoveryITCase Key: FLINK-3212 URL: https://issues.apache.org/jira/browse/FLINK-3212 Project: Flink Issue Type: Bug

Re: Dripping the Flink-on-Tez code for Flink 1.0

2016-01-10 Thread Fabian Hueske
+1 2016-01-08 17:35 GMT+01:00 Till Rohrmann : > +1 since it increase maintainability of the code base if it is not really > used and thus removed. > > On Fri, Jan 8, 2016 at 5:33 PM, Ufuk Celebi wrote: > > > +1 > > > > I wanted to make a similar proposal. > > > > – Ufuk > > > > > On 08 Jan 2016,

Re: Effort to add SQL / StreamSQL to Flink

2016-01-10 Thread Fabian Hueske
Hi Henry, There is https://issues.apache.org/jira/browse/FLINK-2099 and a few subissues. I'll reorganize these and add more issues for the tasks described in the design document in the next days. Thanks, Fabian 2016-01-10 2:45 GMT+01:00 Henry Saputra : > HI Fabian, > > Have you created JIRA tic