[jira] [Created] (FLINK-6366) KafkaConsumer is not closed in FlinkKafkaConsumer09

2017-04-24 Thread Fang Yong (JIRA)
Fang Yong created FLINK-6366: Summary: KafkaConsumer is not closed in FlinkKafkaConsumer09 Key: FLINK-6366 URL: https://issues.apache.org/jira/browse/FLINK-6366 Project: Flink Issue Type: Bug

Re: [VOTE] Release Apache Flink 1.2.1 (RC2)

2017-04-24 Thread Till Rohrmann
If this bug was already present in 1.2.0, then I guess not many users have used this feature. Otherwise we would have seen complaints on the mailing list. >From the JIRA issue description, it looks as if we have to fix it for 1.3.0 anyway. What about fixing it this week and then backporting it to

Re: Mesos component status for 1.3

2017-04-24 Thread Till Rohrmann
Hi Eron, great to hear that you're volunteering being the shepherd for the Mesos component. I will update the Mesos component description. I've also spotted FLINK-5975 and was planning to merge it. Can do the same for the other PRs. Cheers, Till On Fri, Apr 21, 2017 at 8:26 PM, Eron Wright wro

[jira] [Created] (FLINK-6367) support custom header settings of allow origin

2017-04-24 Thread shijinkui (JIRA)
shijinkui created FLINK-6367: Summary: support custom header settings of allow origin Key: FLINK-6367 URL: https://issues.apache.org/jira/browse/FLINK-6367 Project: Flink Issue Type: Sub-task

Re: Splitting input stream in to multiple windows and process individually

2017-04-24 Thread Ufuk Celebi
Hey! I think this question is better suited for the user mailing list. Your solution should work, but will require a lot of memory if you can't use an incrementally aggregating window (e.g. fold/reduce/etc.). – Ufuk On Thu, Apr 13, 2017 at 7:39 AM, madhairsilence wrote: > I have a Datastream . I

Re: [VOTE] Release Apache Flink 1.2.1 (RC2)

2017-04-24 Thread Ufuk Celebi
I agree with Till and would NOT cancel this release. It has been delayed already quite a bit already and the feature freeze for 1.3.0 is coming up (i.e. most contributors will be busy and not spend a lot of time for 1.2.1). – Ufuk On Mon, Apr 24, 2017 at 9:31 AM, Till Rohrmann wrote: > If this

[jira] [Created] (FLINK-6368) Grouping keys in stream aggregations have wrong order

2017-04-24 Thread Timo Walther (JIRA)
Timo Walther created FLINK-6368: --- Summary: Grouping keys in stream aggregations have wrong order Key: FLINK-6368 URL: https://issues.apache.org/jira/browse/FLINK-6368 Project: Flink Issue Type:

Re: [VOTE] Release Apache Flink 1.2.1 (RC2)

2017-04-24 Thread Aljoscha Krettek
Agreed, as I said above: I have the fix ready but we can do that in Flink 1.2.2. Very quickly, though. Best, Aljoscha > On 24. Apr 2017, at 13:19, Ufuk Celebi wrote: > > I agree with Till and would NOT cancel this release. It has been > delayed already quite a bit already and the fea

[jira] [Created] (FLINK-6369) Better support for overlay networks

2017-04-24 Thread Patrick Lucas (JIRA)
Patrick Lucas created FLINK-6369: Summary: Better support for overlay networks Key: FLINK-6369 URL: https://issues.apache.org/jira/browse/FLINK-6369 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6370) FileAlreadyExistsException on startup

2017-04-24 Thread Andrey (JIRA)
Andrey created FLINK-6370: - Summary: FileAlreadyExistsException on startup Key: FLINK-6370 URL: https://issues.apache.org/jira/browse/FLINK-6370 Project: Flink Issue Type: Bug Components: W

[jira] [Created] (FLINK-6371) Return matched patterns as Map> instead of Map

2017-04-24 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-6371: - Summary: Return matched patterns as Map> instead of Map Key: FLINK-6371 URL: https://issues.apache.org/jira/browse/FLINK-6371 Project: Flink Issue Type:

[jira] [Created] (FLINK-6372) change-scala-version.sh does not change version for flink-gelly-examples

2017-04-24 Thread vishnu viswanath (JIRA)
vishnu viswanath created FLINK-6372: --- Summary: change-scala-version.sh does not change version for flink-gelly-examples Key: FLINK-6372 URL: https://issues.apache.org/jira/browse/FLINK-6372 Project:

[jira] [Created] (FLINK-6373) Add runtime support for distinct aggregation over grouped windows

2017-04-24 Thread Haohui Mai (JIRA)
Haohui Mai created FLINK-6373: - Summary: Add runtime support for distinct aggregation over grouped windows Key: FLINK-6373 URL: https://issues.apache.org/jira/browse/FLINK-6373 Project: Flink Is

[jira] [Created] (FLINK-6374) In yarn cluster model, the -ys parameter is not take effect.

2017-04-24 Thread zhangrucong1982 (JIRA)
zhangrucong1982 created FLINK-6374: -- Summary: In yarn cluster model, the -ys parameter is not take effect. Key: FLINK-6374 URL: https://issues.apache.org/jira/browse/FLINK-6374 Project: Flink

[jira] [Created] (FLINK-6375) Fix LongValue hashCode

2017-04-24 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6375: - Summary: Fix LongValue hashCode Key: FLINK-6375 URL: https://issues.apache.org/jira/browse/FLINK-6375 Project: Flink Issue Type: Improvement Components:

[jira] [Created] (FLINK-6376) when deploy flink cluster on the yarn, it is lack of hdfs delegation token.

2017-04-24 Thread zhangrucong1982 (JIRA)
zhangrucong1982 created FLINK-6376: -- Summary: when deploy flink cluster on the yarn, it is lack of hdfs delegation token. Key: FLINK-6376 URL: https://issues.apache.org/jira/browse/FLINK-6376 Project

[jira] [Created] (FLINK-6377) Support map types in the Table / SQL API

2017-04-24 Thread Haohui Mai (JIRA)
Haohui Mai created FLINK-6377: - Summary: Support map types in the Table / SQL API Key: FLINK-6377 URL: https://issues.apache.org/jira/browse/FLINK-6377 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-6378) Implement FLIP-6 Flink-on-Mesos

2017-04-24 Thread Eron Wright (JIRA)
Eron Wright created FLINK-6378: --- Summary: Implement FLIP-6 Flink-on-Mesos Key: FLINK-6378 URL: https://issues.apache.org/jira/browse/FLINK-6378 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-6379) Implement FLIP-6 Mesos Resource Manager

2017-04-24 Thread Eron Wright (JIRA)
Eron Wright created FLINK-6379: --- Summary: Implement FLIP-6 Mesos Resource Manager Key: FLINK-6379 URL: https://issues.apache.org/jira/browse/FLINK-6379 Project: Flink Issue Type: Sub-task