[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16024239#comment-16024239 ] ASF GitHub Bot commented on FLINK-6075: --- Github user rtudoran commented on a diff in the pull

[GitHub] flink pull request #3889: [FLINK-6075] - Support Limit/Top(Sort) for Stream ...

2017-05-24 Thread rtudoran
Github user rtudoran commented on a diff in the pull request: https://github.com/apache/flink/pull/3889#discussion_r118423723 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala --- @@ -0,0 +1,345 @@ +/* + *

[jira] [Updated] (FLINK-6713) Document how to allow multiple Kafka consumers / producers to authenticate using different credentials

2017-05-24 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6713: --- Description: The doc improvements should include: 1. Clearly state that the built-in

[jira] [Created] (FLINK-6713) Document how to allow multiple Kafka consumers / producers to authenticate using different credentials

2017-05-24 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6713: -- Summary: Document how to allow multiple Kafka consumers / producers to authenticate using different credentials Key: FLINK-6713 URL:

[jira] [Created] (FLINK-6712) Bump Kafka010 version to 0.10.2.0

2017-05-24 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6712: -- Summary: Bump Kafka010 version to 0.10.2.0 Key: FLINK-6712 URL: https://issues.apache.org/jira/browse/FLINK-6712 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6707) Activate strict checkstyle for flink-examples

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023979#comment-16023979 ] ASF GitHub Bot commented on FLINK-6707: --- GitHub user greghogan opened a pull request:

[GitHub] flink pull request #3986: [FLINK-6707] [examples] Activate strict checkstyle...

2017-05-24 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/3986 [FLINK-6707] [examples] Activate strict checkstyle for flink-examples You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/flink

[GitHub] flink pull request #3967: [FLINK-6669] Scala style check errror on Windows

2017-05-24 Thread lingjinjiang
Github user lingjinjiang closed the pull request at: https://github.com/apache/flink/pull/3967 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Commented] (FLINK-6669) [Build] Scala style check errror on Windows

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023937#comment-16023937 ] ASF GitHub Bot commented on FLINK-6669: --- Github user lingjinjiang commented on the issue:

[jira] [Commented] (FLINK-6669) [Build] Scala style check errror on Windows

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023938#comment-16023938 ] ASF GitHub Bot commented on FLINK-6669: --- Github user lingjinjiang closed the pull request at:

[GitHub] flink issue #3967: [FLINK-6669] Scala style check errror on Windows

2017-05-24 Thread lingjinjiang
Github user lingjinjiang commented on the issue: https://github.com/apache/flink/pull/3967 @zentol Thank for your review. I'll close it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[jira] [Commented] (FLINK-6689) Remote StreamExecutionEnvironment fails to submit jobs against LocalFlinkMiniCluster

2017-05-24 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023797#comment-16023797 ] Till Rohrmann commented on FLINK-6689: -- When trying to submit a job to a {{LocalFlinkMiniCluster}},

[jira] [Commented] (FLINK-6699) Activate strict-checkstyle in flink-yarn-tests

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023645#comment-16023645 ] ASF GitHub Bot commented on FLINK-6699: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3985: [FLINK-6699] Activate strict checkstyle for flink-yarn-te...

2017-05-24 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3985 +1 with green from Travis --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and

[jira] [Commented] (FLINK-6038) Add deep links to Apache Bahir Flink streaming connector documentations

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023637#comment-16023637 ] ASF GitHub Bot commented on FLINK-6038: --- Github user greghogan commented on a diff in the pull

[GitHub] flink pull request #3975: [FLINK-6038][docs] Added deep links to Bahir conne...

2017-05-24 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/3975#discussion_r118245299 --- Diff: docs/dev/connectors/index.md --- @@ -54,6 +54,16 @@ Note also that while the streaming connectors listed in this section are part of Flink

[jira] [Created] (FLINK-6711) Activate strict checkstyle for flink-connectors

2017-05-24 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6711: --- Summary: Activate strict checkstyle for flink-connectors Key: FLINK-6711 URL: https://issues.apache.org/jira/browse/FLINK-6711 Project: Flink Issue

[GitHub] flink pull request #3985: [FLINK-6699] Activate strict checkstyle for flink-...

2017-05-24 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3985 [FLINK-6699] Activate strict checkstyle for flink-yarn-tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink 6699_checkstyle_yarnt

[jira] [Commented] (FLINK-6699) Activate strict-checkstyle in flink-yarn-tests

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023602#comment-16023602 ] ASF GitHub Bot commented on FLINK-6699: --- GitHub user zentol opened a pull request:

[jira] [Commented] (FLINK-6137) Activate strict checkstyle for flink-cep

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023596#comment-16023596 ] ASF GitHub Bot commented on FLINK-6137: --- Github user zentol commented on the issue:

[GitHub] flink issue #3976: [FLINK-6137][cep] Activate strict checkstyle for flink-ce...

2017-05-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3976 You can rebase this PR now to get rid of the scala import block commit. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[jira] [Commented] (FLINK-6692) The flink-dist jar contains unshaded netty jar

2017-05-24 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023587#comment-16023587 ] Haohui Mai commented on FLINK-6692: --- The issue also presents in Flink 1.2.0. > The flink-dist jar

[jira] [Commented] (FLINK-6710) Remove twitter-inputformat

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023584#comment-16023584 ] ASF GitHub Bot commented on FLINK-6710: --- Github user zentol commented on the issue:

[GitHub] flink issue #3984: [FLINK-6710] Remove Twitter-InputFormat

2017-05-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3984 sure. no problem. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or

[jira] [Closed] (FLINK-6691) Add checkstyle import block rule for scala imports

2017-05-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6691. --- Resolution: Fixed 1.4: bf92055afb4f76299caa8496dfe0fbdeb3305d78 > Add checkstyle import

[jira] [Commented] (FLINK-6687) Activate strict checkstyle for flink-runtime-web

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023576#comment-16023576 ] ASF GitHub Bot commented on FLINK-6687: --- Github user zentol closed the pull request at:

[jira] [Closed] (FLINK-6687) Activate strict checkstyle for flink-runtime-web

2017-05-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6687. --- Resolution: Fixed 1.4: d481f295005461b31c952e9f1d45aa175d803b01 > Activate strict checkstyle

[GitHub] flink pull request #3973: [FLINK-6687] [web] Activate strict checkstyle for ...

2017-05-24 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/3973 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-6710) Remove twitter-inputformat

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023571#comment-16023571 ] ASF GitHub Bot commented on FLINK-6710: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #3984: [FLINK-6710] Remove Twitter-InputFormat

2017-05-24 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/3984 +1 to remove it (however, please merge this only after at least one other PMC member also +1ed and after some time passed. I don't want to cause any discussions afterwards) --- If your project is

[jira] [Comment Edited] (FLINK-6692) The flink-dist jar contains unshaded netty jar

2017-05-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023552#comment-16023552 ] Robert Metzger edited comment on FLINK-6692 at 5/24/17 7:53 PM: Did you

[jira] [Commented] (FLINK-6692) The flink-dist jar contains unshaded netty jar

2017-05-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023552#comment-16023552 ] Robert Metzger commented on FLINK-6692: --- Did you check if the classes are present in Flink 1.2.0 ?

[jira] [Commented] (FLINK-6569) flink-table KafkaJsonTableSource example doesn't work

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023549#comment-16023549 ] ASF GitHub Bot commented on FLINK-6569: --- Github user haohui closed the pull request at:

[jira] [Commented] (FLINK-6688) Activate strict checkstyle in flink-test-utils

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023550#comment-16023550 ] ASF GitHub Bot commented on FLINK-6688: --- Github user greghogan commented on the issue:

[GitHub] flink issue #3983: [FLINK-6688] Activate strict checkstyle for flink-test-ut...

2017-05-24 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3983 +1 if Travis --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if

[jira] [Commented] (FLINK-6710) Remove twitter-inputformat

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023548#comment-16023548 ] ASF GitHub Bot commented on FLINK-6710: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #3890: [FLINK-6569] flink-table KafkaJsonTableSource exam...

2017-05-24 Thread haohui
Github user haohui closed the pull request at: https://github.com/apache/flink/pull/3890 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #3984: [FLINK-6710] Remove Twitter-InputFormat

2017-05-24 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3984 [FLINK-6710] Remove Twitter-InputFormat This PR removes the twitter InputFormat as it doesn't provide any significant functionality. You can merge this pull request into a Git repository by

[jira] [Created] (FLINK-6710) Remove twitter-inputformat

2017-05-24 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6710: --- Summary: Remove twitter-inputformat Key: FLINK-6710 URL: https://issues.apache.org/jira/browse/FLINK-6710 Project: Flink Issue Type: Improvement

[jira] [Comment Edited] (FLINK-6698) Activate strict checkstyle

2017-05-24 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023154#comment-16023154 ] Greg Hogan edited comment on FLINK-6698 at 5/24/17 7:18 PM: Rebasing to master

[jira] [Commented] (FLINK-6688) Activate strict checkstyle in flink-test-utils

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023471#comment-16023471 ] ASF GitHub Bot commented on FLINK-6688: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #3983: [FLINK-6688] Activate strict checkstyle for flink-...

2017-05-24 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/3983 [FLINK-6688] Activate strict checkstyle for flink-test-utils You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink 6688_checkstyle_tutils

[jira] [Created] (FLINK-6709) Activate strict checkstyle for flink-gellies

2017-05-24 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6709: - Summary: Activate strict checkstyle for flink-gellies Key: FLINK-6709 URL: https://issues.apache.org/jira/browse/FLINK-6709 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-6691) Add checkstyle import block rule for scala imports

2017-05-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6691: Issue Type: Sub-task (was: Improvement) Parent: FLINK-6698 > Add checkstyle import

[jira] [Updated] (FLINK-6688) Activate strict checkstyle in flink-test-utils

2017-05-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6688: Issue Type: Sub-task (was: Improvement) Parent: FLINK-6698 > Activate strict

[jira] [Commented] (FLINK-6658) Use scala Collections in scala CEP API

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023339#comment-16023339 ] ASF GitHub Bot commented on FLINK-6658: --- Github user dawidwys commented on a diff in the pull

[GitHub] flink pull request #3963: [FLINK-6658][cep] Use scala Collections in scala C...

2017-05-24 Thread dawidwys
Github user dawidwys commented on a diff in the pull request: https://github.com/apache/flink/pull/3963#discussion_r118322678 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/conditions/Context.scala --- @@ -0,0 +1,33 @@ +/* + * Licensed

[jira] [Commented] (FLINK-6698) Activate strict checkstyle

2017-05-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023317#comment-16023317 ] Chesnay Schepler commented on FLINK-6698: - >From what I've observer so far the majority of

[jira] [Commented] (FLINK-6646) YARN session doesn't work with HA

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023200#comment-16023200 ] ASF GitHub Bot commented on FLINK-6646: --- Github user tedyu commented on a diff in the pull request:

[GitHub] flink pull request #3981: [FLINK-6646] [yarn] Let YarnJobManager delete Yarn...

2017-05-24 Thread tedyu
Github user tedyu commented on a diff in the pull request: https://github.com/apache/flink/pull/3981#discussion_r118304278 --- Diff: flink-yarn/src/main/scala/org/apache/flink/yarn/YarnJobManager.scala --- @@ -89,5 +92,37 @@ class YarnJobManager(

[jira] [Commented] (FLINK-6708) Don't let the FlinkYarnSessionCli fail if it cannot retrieve the ClusterStatus

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023176#comment-16023176 ] ASF GitHub Bot commented on FLINK-6708: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #3982: [FLINK-6708] [yarn] Harden FlinkYarnSessionCli to ...

2017-05-24 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/3982 [FLINK-6708] [yarn] Harden FlinkYarnSessionCli to handle GetClusterStatusResponse exceptions This PR is based on #3981. This PR hardens the FlinkYarnSessionCli by handling exceptions

[jira] [Created] (FLINK-6708) Don't let the FlinkYarnSessionCli fail if it cannot retrieve the ClusterStatus

2017-05-24 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-6708: Summary: Don't let the FlinkYarnSessionCli fail if it cannot retrieve the ClusterStatus Key: FLINK-6708 URL: https://issues.apache.org/jira/browse/FLINK-6708

[jira] [Created] (FLINK-6707) Activate strict checkstyle for flink-examples

2017-05-24 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6707: - Summary: Activate strict checkstyle for flink-examples Key: FLINK-6707 URL: https://issues.apache.org/jira/browse/FLINK-6707 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-6698) Activate strict checkstyle

2017-05-24 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023154#comment-16023154 ] Greg Hogan commented on FLINK-6698: --- Rebasing to master and running the strict checkstyle analysis

[jira] [Commented] (FLINK-6658) Use scala Collections in scala CEP API

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023152#comment-16023152 ] ASF GitHub Bot commented on FLINK-6658: --- Github user kl0u commented on a diff in the pull request:

[GitHub] flink pull request #3963: [FLINK-6658][cep] Use scala Collections in scala C...

2017-05-24 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/3963#discussion_r118297586 --- Diff: flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/conditions/Context.scala --- @@ -0,0 +1,33 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-6646) YARN session doesn't work with HA

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023151#comment-16023151 ] ASF GitHub Bot commented on FLINK-6646: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #3981: [FLINK-6646] [yarn] Let YarnJobManager delete Yarn...

2017-05-24 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/3981 [FLINK-6646] [yarn] Let YarnJobManager delete Yarn application files Before the YarnClusterClient decided when to delete the Yarn application files. This is problematic because the client

[jira] [Assigned] (FLINK-6594) Implement Flink Dispatcher for Kubernetes

2017-05-24 Thread Larry Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Larry Wu reassigned FLINK-6594: --- Assignee: Larry Wu > Implement Flink Dispatcher for Kubernetes >

[jira] [Commented] (FLINK-6685) SafetyNetCloseableRegistry is closed prematurely in Task::triggerCheckpointBarrier

2017-05-24 Thread Gyula Fora (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023140#comment-16023140 ] Gyula Fora commented on FLINK-6685: --- Thanks Stefan, awesome job! I can confirm that this solves our

[jira] [Updated] (FLINK-6646) YARN session doesn't work with HA

2017-05-24 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6646: - Priority: Blocker (was: Critical) > YARN session doesn't work with HA >

[jira] [Commented] (FLINK-6646) YARN session doesn't work with HA

2017-05-24 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023123#comment-16023123 ] Till Rohrmann commented on FLINK-6646: -- Actually, I have to correct myself wrt to the severity of the

[jira] [Commented] (FLINK-6669) [Build] Scala style check errror on Windows

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023098#comment-16023098 ] ASF GitHub Bot commented on FLINK-6669: --- Github user zentol commented on the issue:

[GitHub] flink issue #3967: [FLINK-6669] Scala style check errror on Windows

2017-05-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3967 @jinmingjian I've merged the change to master, could you close this PR? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[jira] [Updated] (FLINK-6689) Remote StreamExecutionEnvironment fails to submit jobs against LocalFlinkMiniCluster

2017-05-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6689: Component/s: Client > Remote StreamExecutionEnvironment fails to submit jobs against >

[jira] [Commented] (FLINK-6515) KafkaConsumer checkpointing fails because of ClassLoader issues

2017-05-24 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023073#comment-16023073 ] Aljoscha Krettek commented on FLINK-6515: - We should double check, this not working would

[jira] [Commented] (FLINK-6706) remove ChaosMonkeyITCase

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023058#comment-16023058 ] ASF GitHub Bot commented on FLINK-6706: --- Github user zentol commented on the issue:

[GitHub] flink issue #3980: [FLINK-6706] remove outdated/unused ChaosMonkeyITCase

2017-05-24 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3980 +1. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Commented] (FLINK-6494) Migrate ResourceManager configuration options

2017-05-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023038#comment-16023038 ] Chesnay Schepler commented on FLINK-6494: - yes, the yarn and mesos options should be migrated as

[jira] [Commented] (FLINK-6706) remove ChaosMonkeyITCase

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023031#comment-16023031 ] ASF GitHub Bot commented on FLINK-6706: --- GitHub user NicoK opened a pull request:

[GitHub] flink pull request #3980: [FLINK-6706] remove outdated/unused ChaosMonkeyITC...

2017-05-24 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/3980 [FLINK-6706] remove outdated/unused ChaosMonkeyITCase This test was disabled in Dec 2015 due to its instability and never made it back again. It is probably outdated and may not even work anymore

[jira] [Created] (FLINK-6706) remove ChaosMonkeyITCase

2017-05-24 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-6706: -- Summary: remove ChaosMonkeyITCase Key: FLINK-6706 URL: https://issues.apache.org/jira/browse/FLINK-6706 Project: Flink Issue Type: Improvement

[jira] [Reopened] (FLINK-6669) [Build] Scala style check errror on Windows

2017-05-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-6669: - adding it to 1.3 as well. > [Build] Scala style check errror on Windows >

[jira] [Closed] (FLINK-6431) Activate strict checkstyle for flink-metrics

2017-05-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6431. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: ce573c65e2573ae12c8f6a76cc580445886a0a74

[jira] [Closed] (FLINK-6432) Activate strict checkstyle for flink-python

2017-05-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6432. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 04fae5362bdc933c111c92a9cc3b3b2c1d71850e

[jira] [Closed] (FLINK-6675) Activate strict checkstyle for flink-annotations

2017-05-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6675. --- Resolution: Fixed 1.4: dbcc456a652e980323b1b23692578e3c22e25e68 > Activate strict checkstyle

[jira] [Reopened] (FLINK-6320) Flakey JobManagerHAJobGraphRecoveryITCase

2017-05-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-6320: - I'll also push this one to 1.3. > Flakey JobManagerHAJobGraphRecoveryITCase >

[jira] [Assigned] (FLINK-6320) Flakey JobManagerHAJobGraphRecoveryITCase

2017-05-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6320: --- Assignee: Nico Kruber > Flakey JobManagerHAJobGraphRecoveryITCase >

[jira] [Closed] (FLINK-6320) Flakey JobManagerHAJobGraphRecoveryITCase

2017-05-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6320. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: 6ad3d140f35722055c9011dbee88d19319cfbfbe

[jira] [Commented] (FLINK-6432) Activate strict checkstyle for flink-python

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023002#comment-16023002 ] ASF GitHub Bot commented on FLINK-6432: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-6669) [Build] Scala style check errror on Windows

2017-05-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-6669. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: f827d730e40ac1c71fe974d4fd674e55ad530cdb

[jira] [Commented] (FLINK-6320) Flakey JobManagerHAJobGraphRecoveryITCase

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023006#comment-16023006 ] ASF GitHub Bot commented on FLINK-6320: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-5376) Misleading log statements in UnorderedStreamElementQueue

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023007#comment-16023007 ] ASF GitHub Bot commented on FLINK-5376: --- Github user asfgit closed the pull request at:

[jira] [Closed] (FLINK-5376) Misleading log statements in UnorderedStreamElementQueue

2017-05-24 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5376. --- Resolution: Fixed Fix Version/s: 1.4.0 1.4: ed65c253478e688fdfbb149a1a75dc01b8537cab

[jira] [Commented] (FLINK-6675) Activate strict checkstyle for flink-annotations

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023005#comment-16023005 ] ASF GitHub Bot commented on FLINK-6675: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6659) RocksDBMergeIteratorTest, SavepointITCase leave temporary directories behind

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023004#comment-16023004 ] ASF GitHub Bot commented on FLINK-6659: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-6431) Activate strict checkstyle for flink-metrics

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16023003#comment-16023003 ] ASF GitHub Bot commented on FLINK-6431: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #3969: [FLINK-6432] [py] Activate strict checkstyle for f...

2017-05-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3969 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #3970: [FLINK-6675] Activate strict checkstyle for flink-...

2017-05-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3970 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #3966: [FLINK-6320] fix unit test failing sometimes when ...

2017-05-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3966 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #3968: [FLINK-6431] [metrics] Activate strict checkstyle ...

2017-05-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3968 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #3948: [FLINK-5376] Fix log statement in UnorderedStreamE...

2017-05-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3948 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #3962: [FLINK-6659] fix (some) unit tests leaving tempora...

2017-05-24 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3962 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Created] (FLINK-6705) Check visibility of methods in Table API classes

2017-05-24 Thread Timo Walther (JIRA)
Timo Walther created FLINK-6705: --- Summary: Check visibility of methods in Table API classes Key: FLINK-6705 URL: https://issues.apache.org/jira/browse/FLINK-6705 Project: Flink Issue Type:

[jira] [Updated] (FLINK-6689) Remote StreamExecutionEnvironment fails to submit jobs against LocalFlinkMiniCluster

2017-05-24 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-6689: --- Description: The following Flink programs fails to execute with the current 1.3 branch (1.2 works)

[jira] [Commented] (FLINK-6569) flink-table KafkaJsonTableSource example doesn't work

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022956#comment-16022956 ] ASF GitHub Bot commented on FLINK-6569: --- Github user twalthr commented on the issue:

[GitHub] flink issue #3890: [FLINK-6569] flink-table KafkaJsonTableSource example doe...

2017-05-24 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/3890 @haohui can you close this PR? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and

[jira] [Commented] (FLINK-6137) Activate strict checkstyle for flink-cep

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022953#comment-16022953 ] ASF GitHub Bot commented on FLINK-6137: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-6137) Activate strict checkstyle for flink-cep

2017-05-24 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16022954#comment-16022954 ] ASF GitHub Bot commented on FLINK-6137: --- Github user zentol commented on a diff in the pull request:

  1   2   3   >