[jira] [Created] (FLINK-7169) Support AFTER MATCH SKIP function in CEP library API

Yueting Chen created FLINK-7169: --- Summary: Support AFTER MATCH SKIP function in CEP library API Key: FLINK-7169 URL: https://issues.apache.org/jira/browse/FLINK-7169 Project: Flink Issue Type:

[jira] [Created] (FLINK-7168) Add support for Table API & SQL steam-stream inner/left join

Ruidong Li created FLINK-7168: - Summary: Add support for Table API & SQL steam-stream inner/left join Key: FLINK-7168 URL: https://issues.apache.org/jira/browse/FLINK-7168 Project: Flink Issue

[jira] [Created] (FLINK-7167) Job can set checkpoint meta directory to cover the system setting state.checkpoints.dir

yuqi created FLINK-7167: --- Summary: Job can set checkpoint meta directory to cover the system setting state.checkpoints.dir Key: FLINK-7167 URL: https://issues.apache.org/jira/browse/FLINK-7167 Project: Flink

Re: [POLL] Who still uses Java 7 with Flink ?

+1 for dropping Java 7 2017-07-13 9:34 GMT+08:00 ☼ R Nair (रविशंकर नायर) < ravishankar.n...@gmail.com>: > +1 for dropping Java 1.7. > > On Wed, Jul 12, 2017 at 9:10 PM, Kurt Young wrote: > >> +1 for droppint Java 7, we have been using Java 8 for more than one year >> in Alibaba and everything wo

Re: [POLL] Who still uses Java 7 with Flink ?

+1 for dropping Java 1.7. On Wed, Jul 12, 2017 at 9:10 PM, Kurt Young wrote: > +1 for droppint Java 7, we have been using Java 8 for more than one year > in Alibaba and everything work fine. > > Best, > Kurt > > On Thu, Jul 13, 2017 at 2:53 AM, Bowen Li wrote: > >> +1 for dropping Java 7 >> >>

Re: [POLL] Who still uses Java 7 with Flink ?

+1 for droppint Java 7, we have been using Java 8 for more than one year in Alibaba and everything work fine. Best, Kurt On Thu, Jul 13, 2017 at 2:53 AM, Bowen Li wrote: > +1 for dropping Java 7 > > On Wed, Jul 12, 2017 at 9:04 AM, Gyula Fóra wrote: > > > +1 for dropping 1.7 from me as well. >

Re: [ANNOUNCE] New Flink PMC member: Tzu-Li (Gordon) Tai

Congrats! On Wed, Jul 12, 2017 at 3:30 AM, Stavros Kontopoulos < st.kontopou...@gmail.com> wrote: > Congrats Gordon! > > On Wed, Jul 12, 2017 at 5:29 AM, Evans Ye wrote: > > > Congrats Gordon! > > > > Tzu-Li (Gordon) Tai 於 2017年7月12日 週三，上午2:28寫道： > > > > > Thanks everyone :) > > > It has always

Re: [POLL] Who still uses Java 7 with Flink ?

+1 for dropping Java 7 On Wed, Jul 12, 2017 at 9:04 AM, Gyula Fóra wrote: > +1 for dropping 1.7 from me as well. > > Gyula > > On Wed, Jul 12, 2017, 17:53 Ted Yu wrote: > > > +1 on dropping support for Java 1.7 > > > > Original message > > From: Robert Metzger > > Date: 7/12/

Re: [POLL] Who still uses Java 7 with Flink ?

+1 for dropping 1.7 from me as well. Gyula On Wed, Jul 12, 2017, 17:53 Ted Yu wrote: > +1 on dropping support for Java 1.7 > > Original message > From: Robert Metzger > Date: 7/12/17 8:36 AM (GMT-08:00) > To: dev@flink.apache.org > Cc: user > Subject: Re: [POLL] Who still us

Re: [POLL] Who still uses Java 7 with Flink ?

+1 on dropping support for Java 1.7 Original message From: Robert Metzger Date: 7/12/17 8:36 AM (GMT-08:00) To: dev@flink.apache.org Cc: user Subject: Re: [POLL] Who still uses Java 7 with Flink ? +1 to drop Java 7 support I believe that we can move to Java 8 for the argumen

Re: [POLL] Who still uses Java 7 with Flink ?

+1 to drop Java 7 support I believe that we can move to Java 8 for the argument you've stated. ElasticSearch 5, Spark 2.2 require Java 8 already, Hadoop 3.0.0 will require it as well. On Wed, Jul 12, 2017 at 4:02 PM, Driesprong, Fokko wrote: > Hi, > > I would be in favor of dropping Java 7 as

Use Flink's actor system

Hello everybody, I want to do some experiments with communication across operators. Even if arguable, I wondered if it is possible to directly use the clustered actor system used by Flink. If so, how can I get an instance of the actor system in an Operator? Thank you in advance Lorenzo Affetti

Use Flink's actor system

Hello everybody, I want to do some experiments with communication across operators. Even if arguable, I wondered if it is possible to directly use the clustered actor system used by Flink. If so, how can I get an instance of the actor system in an Operator? Thank you in advance Lorenzo Affetti

Re: Re: [DISCUSS] FLIP-22: Eager State Declaration

Hi, First of all, I like the idea of eagerly defined state for user functions, this makes for very nice API, as can be seen in the Beam state API. I also agree with previous posters that completely banning lazy state makes certain use cases very tricky to implement, basically putting the burden

Re: [DISCUSS] First release of flink-shaded

I've opened a PR to include non-apache licenses in the jars: https://github.com/apache/flink-shaded/pull/7 On 12.07.2017 16:25, Stephan Ewen wrote: +1 I chatted with Chesnay privately, bringing up the issue that we need to have the License files added to the shaded jar files to properly obey B

Re: [DISCUSS] Backwards compatibility policy.

Bumping this thread again. I think it would help Flink development a lot to drop 1.1.x savepoint format compatibility in 1.4.0. That means NOT dropping API compatibility, only not further supporting the old savepoint format version. I'll start a poll on the users list. On Fri, Jun 30, 2017 at 7:

Re: [DISCUSS] NOTICE

Hi! I general, adopting code from other Apache projects is okay and needs no special notice (per the Apache License 2.0). It is good style to add comments above the copied code, definitely. As far as I understand it, you add an entry to the NOTICE file when you find other NOTICE files, or when th

Re: [DISCUSS] First release of flink-shaded

+1 I chatted with Chesnay privately, bringing up the issue that we need to have the License files added to the shaded jar files to properly obey BSD / MIT licenses (similarly as we did in Flink for the 1.3.0 release). Other than that, good to go! On Mon, Jul 10, 2017 at 8:42 PM, Robert Metzger

Re: [POLL] Who still uses Java 7 with Flink ?

Hi, I would be in favor of dropping Java 7 as we don't use it in our hadoop infra (and we are a bank). Also, Spark 2.2 has been released today, which doesn't support Java 7 anymore, and Flink should not lack behind :-) Cheers, Fokko 201

Re: [POLL] Who still uses Java 7 with Flink ?

Bumping this thread again. There are several strong points for dropping Java 7 support, apart from the fact that it is not maintained - We could really use the Java 8 default methods feature in interfaces to evolve the API without breaking backwards compatibility - Easier build setup for Sca

Re: [DISCUSS] FLIP-21 - Improve object Copying/Reuse Mode for Streaming Runtime

Thanks for the feedback. Will leave this open for some more days, and adopt it as a FLIP, taking Greg's and Aljoscha's comments into account. On Sun, Jul 2, 2017 at 10:13 PM, Ufuk Celebi wrote: > Thanks for the write up and illustrations. :-) +1 to do this. > > I'm fine with both proposed "chang

Re: [DISCUSS] FLIP-21 - Improve object Copying/Reuse Mode for Streaming Runtime

Hi Zhenzhong! The difference is as follows: DEFAULT means that at the beginning of a chain, an object is created per record, and that object travels through the chain. The total number of instantiated objects is as many as records, but only one lives at the same time. FULL_REUSE is only applicab

Re: [ANNOUNCE] New Flink PMC member: Tzu-Li (Gordon) Tai

Congrats Gordon! On Wed, Jul 12, 2017 at 5:29 AM, Evans Ye wrote: > Congrats Gordon! > > Tzu-Li (Gordon) Tai 於 2017年7月12日 週三，上午2:28寫道： > > > Thanks everyone :) > > It has always been great working with you all! > > Looking forward to all the future endeavors to be done in continuing to > > push

Re: [DISCUSS] Release 1.3.2 planning

Short update, we resolved some blockers and discovered some new ones. There’s this nifty Jira page if you want to keep track: https://issues.apache.org/jira/projects/FLINK/versions/12340984 Once again, could everyone please updat

[jira] [Created] (FLINK-7166) generated avro sources not cleaned up or re-created after changes

Nico Kruber created FLINK-7166: -- Summary: generated avro sources not cleaned up or re-created after changes Key: FLINK-7166 URL: https://issues.apache.org/jira/browse/FLINK-7166 Project: Flink

[jira] [Created] (FLINK-7165) Flink can't deploy on hadoop 2.6.0-cdh5.5.1 yarn

刘喆 created FLINK-7165: - Summary: Flink can't deploy on hadoop 2.6.0-cdh5.5.1 yarn Key: FLINK-7165 URL: https://issues.apache.org/jira/browse/FLINK-7165 Project: Flink Issue Type: Bug Components

[jira] [Created] (FLINK-7164) Extend integration tests for (externalised) checkpoints, checkpoint store

Aljoscha Krettek created FLINK-7164: --- Summary: Extend integration tests for (externalised) checkpoints, checkpoint store Key: FLINK-7164 URL: https://issues.apache.org/jira/browse/FLINK-7164 Project

[jira] [Created] (FLINK-7163) Make LogicalTableFunctionCall immutable

Ruidong Li created FLINK-7163: - Summary: Make LogicalTableFunctionCall immutable Key: FLINK-7163 URL: https://issues.apache.org/jira/browse/FLINK-7163 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7162) Tests should not write outside 'target' directory.

mingleizhang created FLINK-7162: --- Summary: Tests should not write outside 'target' directory. Key: FLINK-7162 URL: https://issues.apache.org/jira/browse/FLINK-7162 Project: Flink Issue Type: Bu