[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

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

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

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寫道： > > > >

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 >

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

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

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

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

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 ?

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

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

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

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

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

[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

[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

[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:

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

pengwenlong? 2017-07-12 hzyuemeng1 发件人："wenlong.lwl" 发送时间：2017-07-05 10:27 主题：Re: [DISCUSS] FLIP-22: Eager State Declaration 收件人："dev" 抄送： Hi, all, we have jobs which create state according to type of the key and a dynamic configuration:

[jira] [Created] (FLINK-7161) Fix misusage of Double.MIN_VALUE and Float.MIN_VALUE

Kurt Young created FLINK-7161: - Summary: Fix misusage of Double.MIN_VALUE and Float.MIN_VALUE Key: FLINK-7161 URL: https://issues.apache.org/jira/browse/FLINK-7161 Project: Flink Issue Type: Bug