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

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

[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

[jira] [Created] (FLINK-6371) Return matched patterns as Map<String, List> instead of Map<String, T>

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:

[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

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

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

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

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

[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 Aljoscha Krettek
It means that users cannot restore from 1.2.0 to 1.2.0, 1.2.0 to 1.2.1, or 1.2.1 to 1.2.1. However, this only happens when using the CheckpointedRestoring interface, which you have to do when you want to migrate away form the Checkpointed interface. tl;dr It’s not a new bug but one that was