[GitHub] flink issue #2550: [FLINK-4657] Implement HighAvailabilityServices based on ...

2016-09-27 Thread KurtYoung
Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/2550 For "cluster-id" thing, actually there is some similar functionality in current Flink, configed by "high-availability.zookeeper.path.namespace". It will work with another config

[jira] [Commented] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15528274#comment-15528274 ] ASF GitHub Bot commented on FLINK-4657: --- Github user KurtYoung commented on the issue:

[jira] [Commented] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15528245#comment-15528245 ] ASF GitHub Bot commented on FLINK-4657: --- Github user KurtYoung commented on a diff in the pull

[GitHub] flink pull request #2550: [FLINK-4657] Implement HighAvailabilityServices ba...

2016-09-27 Thread KurtYoung
Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/2550#discussion_r80837572 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -467,6 +487,128 @@ public void

[jira] [Commented] (FLINK-4670) Add watch mechanism on current RPC framework

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15528226#comment-15528226 ] ASF GitHub Bot commented on FLINK-4670: --- Github user beyond1920 closed the pull request at:

[GitHub] flink pull request #2543: [FLINK-4670] [cluster management] Add watch mechan...

2016-09-27 Thread beyond1920
Github user beyond1920 closed the pull request at: https://github.com/apache/flink/pull/2543 --- 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-4606) Integrate the new ResourceManager with the existing FlinkResourceManager

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15528211#comment-15528211 ] ASF GitHub Bot commented on FLINK-4606: --- Github user beyond1920 commented on a diff in the pull

[jira] [Assigned] (FLINK-4679) Add TumbleRow row-windows for streaming tables

2016-09-27 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4679: -- Assignee: Jark Wu > Add TumbleRow row-windows for streaming tables >

[GitHub] flink pull request #2540: [FLINK-4606] [cluster management] Integrate the ne...

2016-09-27 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2540#discussion_r80836325 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java --- @@ -324,6 +337,158 @@ public void

[jira] [Commented] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15528198#comment-15528198 ] ASF GitHub Bot commented on FLINK-4657: --- Github user KurtYoung commented on a diff in the pull

[GitHub] flink pull request #2550: [FLINK-4657] Implement HighAvailabilityServices ba...

2016-09-27 Thread KurtYoung
Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/2550#discussion_r80835773 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -467,6 +487,128 @@ public void

[jira] [Commented] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15528193#comment-15528193 ] ASF GitHub Bot commented on FLINK-4657: --- Github user KurtYoung commented on a diff in the pull

[jira] [Commented] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15528189#comment-15528189 ] ASF GitHub Bot commented on FLINK-4657: --- Github user KurtYoung commented on a diff in the pull

[GitHub] flink pull request #2550: [FLINK-4657] Implement HighAvailabilityServices ba...

2016-09-27 Thread KurtYoung
Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/2550#discussion_r80835559 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -467,6 +487,128 @@ public void

[GitHub] flink pull request #2550: [FLINK-4657] Implement HighAvailabilityServices ba...

2016-09-27 Thread KurtYoung
Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/2550#discussion_r80835462 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -467,6 +487,128 @@ public void

[GitHub] flink pull request #2550: [FLINK-4657] Implement HighAvailabilityServices ba...

2016-09-27 Thread KurtYoung
Github user KurtYoung commented on a diff in the pull request: https://github.com/apache/flink/pull/2550#discussion_r80834516 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -467,6 +487,128 @@ public void

[jira] [Commented] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15528167#comment-15528167 ] ASF GitHub Bot commented on FLINK-4657: --- Github user KurtYoung commented on a diff in the pull

[jira] [Commented] (FLINK-4068) Move constant computations out of code-generated `flatMap` functions.

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15528157#comment-15528157 ] ASF GitHub Bot commented on FLINK-4068: --- GitHub user wuchong opened a pull request:

[GitHub] flink pull request #2560: [FLINK-4068] [table] Move constant computations ou...

2016-09-27 Thread wuchong
GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/2560 [FLINK-4068] [table] Move constant computations out of code-generated Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[jira] [Commented] (FLINK-4450) update storm version to 1.0.0

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15528031#comment-15528031 ] ASF GitHub Bot commented on FLINK-4450: --- Github user liuyuzhong commented on the issue:

[GitHub] flink issue #2439: [FLINK-4450]update storm verion to 1.0.0 in flink-storm a...

2016-09-27 Thread liuyuzhong
Github user liuyuzhong commented on the issue: https://github.com/apache/flink/pull/2439 Jenkins run successful, but CI fail. ![image](https://cloud.githubusercontent.com/assets/12843176/18897594/2c9e40e2-855e-11e6-8d3c-0397b33d5d8f.png) --- If your project is set up for

[jira] [Assigned] (FLINK-4646) Add BipartiteGraph class

2016-09-27 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-4646: - Assignee: Ivan Mushketyk > Add BipartiteGraph class > > >

[GitHub] flink pull request #2430: [FLINK-3874] Rewrite Kafka JSON Table sink tests

2016-09-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2430#discussion_r80784331 --- Diff: flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkTestBase.java --- @@

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15527303#comment-15527303 ] ASF GitHub Bot commented on FLINK-3874: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #2430: [FLINK-3874] Rewrite Kafka JSON Table sink tests

2016-09-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2430#discussion_r80783113 --- Diff: flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkTestBase.java --- @@

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15527304#comment-15527304 ] ASF GitHub Bot commented on FLINK-3874: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #2430: [FLINK-3874] Rewrite Kafka JSON Table sink tests

2016-09-27 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2430#discussion_r80783750 --- Diff: flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkTestBase.java --- @@

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15527305#comment-15527305 ] ASF GitHub Bot commented on FLINK-3874: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #2559: [FLINK-4702] [kafka connector] Commit offets to Ka...

2016-09-27 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/2559 [FLINK-4702] [kafka connector] Commit offets to Kafka asynchronously The offset commit calls to Kafka may occasionally take very long. In that case, the notifyCheckpointComplete() method blocks

[jira] [Commented] (FLINK-4702) Kafka consumer must commit offsets asynchronously

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15527146#comment-15527146 ] ASF GitHub Bot commented on FLINK-4702: --- GitHub user StephanEwen opened a pull request:

[jira] [Created] (FLINK-4702) Kafka consumer must commit offsets asynchronously

2016-09-27 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4702: --- Summary: Kafka consumer must commit offsets asynchronously Key: FLINK-4702 URL: https://issues.apache.org/jira/browse/FLINK-4702 Project: Flink Issue Type:

[jira] [Commented] (FLINK-4675) Remove Parameter from WindowAssigner.getDefaultTrigger()

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15527122#comment-15527122 ] Stephan Ewen commented on FLINK-4675: - It would be okay to break it now (from what we defined as

[jira] [Commented] (FLINK-4699) Convert Kafka TableSource/TableSink tests to unit tests

2016-09-27 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15527013#comment-15527013 ] Fabian Hueske commented on FLINK-4699: -- There is a pull request to convert the KafkaJSONSinkITCases

[jira] [Commented] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526962#comment-15526962 ] ASF GitHub Bot commented on FLINK-4657: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #2550: [FLINK-4657] Implement HighAvailabilityServices based on ...

2016-09-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2550 Can we try and unify the structure / paths under which all this information is stored in ZooKeeper? ``` /flink +/cluster_id_1/resource_manager_lock ||

[jira] [Created] (FLINK-4701) Unprotected access to cancelables in StreamTask

2016-09-27 Thread Ted Yu (JIRA)
Ted Yu created FLINK-4701: - Summary: Unprotected access to cancelables in StreamTask Key: FLINK-4701 URL: https://issues.apache.org/jira/browse/FLINK-4701 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-4543) Race Deadlock in SpilledSubpartitionViewTest

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4543. --- > Race Deadlock in SpilledSubpartitionViewTest > > >

[jira] [Resolved] (FLINK-4543) Race Deadlock in SpilledSubpartitionViewTest

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4543. - Resolution: Fixed Fixed via 90902914ac4b11f9554b67ad49e0d697a0d02f93 > Race Deadlock in

[jira] [Commented] (FLINK-4543) Race Deadlock in SpilledSubpartitionViewTest

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

[GitHub] flink pull request #2444: [FLINK-4543] [network] Fix potential deadlock in S...

2016-09-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2444 --- 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] [Closed] (FLINK-4560) enforcer java version as 1.7

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4560. --- > enforcer java version as 1.7 > > > Key: FLINK-4560 >

[jira] [Resolved] (FLINK-4560) enforcer java version as 1.7

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4560. - Resolution: Fixed Fix Version/s: 1.2.0 Fixed via b928935b8c5be02b23dd2cb87144ae1ea001278c

[jira] [Commented] (FLINK-4560) enforcer java version as 1.7

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

[GitHub] flink pull request #2458: [FLINK-4560] enforcer java version as 1.7

2016-09-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2458 --- 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-4695) Separate configuration parsing from MetricRegistry

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

[GitHub] flink issue #2510: FLINK-3322 Allow drivers and iterators to reuse the memor...

2016-09-27 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2510 Sounds good @StephanEwen . Thank you. --- 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

[GitHub] flink pull request #2555: [FLINK-4695] Introduce MetricRegistryConfiguration...

2016-09-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2555 --- 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] [Closed] (FLINK-4695) Separate configuration parsing from MetricRegistry

2016-09-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4695. Resolution: Fixed Added via f1b5b35f595e7ae53001a4c46edbf0c9b78ee376 > Separate configuration

[jira] [Commented] (FLINK-4695) Separate configuration parsing from MetricRegistry

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526805#comment-15526805 ] ASF GitHub Bot commented on FLINK-4695: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #2555: [FLINK-4695] Introduce MetricRegistryConfiguration to enc...

2016-09-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2555 Thanks for the review @StephanEwen. Build passed locally. Will merge the 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

[jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526787#comment-15526787 ] ASF GitHub Bot commented on FLINK-3322: --- Github user ramkrish86 commented on the issue:

[jira] [Commented] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526751#comment-15526751 ] ASF GitHub Bot commented on FLINK-4657: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526750#comment-15526750 ] ASF GitHub Bot commented on FLINK-4657: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526753#comment-15526753 ] ASF GitHub Bot commented on FLINK-4657: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526754#comment-15526754 ] ASF GitHub Bot commented on FLINK-4657: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526752#comment-15526752 ] ASF GitHub Bot commented on FLINK-4657: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-4657) Implement HighAvailabilityServices based on zookeeper

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526749#comment-15526749 ] ASF GitHub Bot commented on FLINK-4657: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #2550: [FLINK-4657] Implement HighAvailabilityServices ba...

2016-09-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2550#discussion_r80734121 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -467,6 +487,128 @@ public void

[GitHub] flink pull request #2550: [FLINK-4657] Implement HighAvailabilityServices ba...

2016-09-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2550#discussion_r80733402 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -467,6 +487,128 @@ public void

[GitHub] flink pull request #2550: [FLINK-4657] Implement HighAvailabilityServices ba...

2016-09-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2550#discussion_r80740850 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -467,6 +487,128 @@ public void

[GitHub] flink pull request #2550: [FLINK-4657] Implement HighAvailabilityServices ba...

2016-09-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2550#discussion_r80740727 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -467,6 +487,128 @@ public void

[GitHub] flink pull request #2550: [FLINK-4657] Implement HighAvailabilityServices ba...

2016-09-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2550#discussion_r80733924 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -467,6 +487,128 @@ public void

[GitHub] flink pull request #2550: [FLINK-4657] Implement HighAvailabilityServices ba...

2016-09-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2550#discussion_r80742192 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java --- @@ -467,6 +487,128 @@ public void

[GitHub] flink pull request #2552: [FLINK-4690] Replace SlotAllocationFuture with fli...

2016-09-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2552 --- 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] [Resolved] (FLINK-4690) Replace SlotAllocationFuture with flink's own future

2016-09-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-4690. -- Resolution: Fixed Added via 84672c22f8088a70caf35b54d74eee458bf600dd > Replace

[jira] [Commented] (FLINK-4361) Introduce Flink's own future abstraction

2016-09-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526671#comment-15526671 ] Till Rohrmann commented on FLINK-4361: -- Added to the master via

[jira] [Commented] (FLINK-4361) Introduce Flink's own future abstraction

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

[jira] [Commented] (FLINK-4690) Replace SlotAllocationFuture with flink's own future

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

[GitHub] flink pull request #2554: [FLINK-4361] Introduce Flink's own future abstract...

2016-09-27 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2554 --- 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-4690) Replace SlotAllocationFuture with flink's own future

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1552#comment-1552 ] ASF GitHub Bot commented on FLINK-4690: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #2552: [FLINK-4690] Replace SlotAllocationFuture with flink's ow...

2016-09-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2552 I've merged it into the master branch. You can close the 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

[jira] [Commented] (FLINK-4669) scala api createLocalEnvironment() function add default Configuration parameter

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526621#comment-15526621 ] ASF GitHub Bot commented on FLINK-4669: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #2541: [FLINK-4669] scala api createLocalEnvironment() fu...

2016-09-27 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2541#discussion_r80730795 --- Diff: flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamExecutionEnvironment.scala --- @@ -124,7 +125,7 @@ class

[jira] [Closed] (FLINK-4583) NullPointerException in CliFrontend

2016-09-27 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4583. - Resolution: Duplicate > NullPointerException in CliFrontend > --- > >

[jira] [Created] (FLINK-4700) Harden the TimeProvider test

2016-09-27 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-4700: - Summary: Harden the TimeProvider test Key: FLINK-4700 URL: https://issues.apache.org/jira/browse/FLINK-4700 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4677) Jars with no job executions produces NullPointerException in ClusterClient

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526575#comment-15526575 ] ASF GitHub Bot commented on FLINK-4677: --- Github user greghogan commented on the issue:

[GitHub] flink issue #2548: [FLINK-4677] fail if user jar contains no executions

2016-09-27 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2548 Do we have a standard way for user programs to print usage and exit without triggering this message? This is certainly preferable to the `NullPointerException`. --- If your project is set up for

[jira] [Created] (FLINK-4699) Convert Kafka TableSource/TableSink tests to unit tests

2016-09-27 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4699: --- Summary: Convert Kafka TableSource/TableSink tests to unit tests Key: FLINK-4699 URL: https://issues.apache.org/jira/browse/FLINK-4699 Project: Flink Issue

[GitHub] flink issue #2548: [FLINK-4677] fail if user jar contains no executions

2016-09-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2548 Looks good to me, +1 to merge --- 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

[jira] [Commented] (FLINK-4677) Jars with no job executions produces NullPointerException in ClusterClient

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526523#comment-15526523 ] ASF GitHub Bot commented on FLINK-4677: --- Github user StephanEwen commented on the issue:

[jira] [Created] (FLINK-4698) Visualize additional checkpoint information

2016-09-27 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4698: --- Summary: Visualize additional checkpoint information Key: FLINK-4698 URL: https://issues.apache.org/jira/browse/FLINK-4698 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-4685) Gather operator checkpoint durations data sizes from the runtime

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4685. --- > Gather operator checkpoint durations data sizes from the runtime >

[jira] [Closed] (FLINK-4696) Limit the number of Akka Dispatcher Threads in LocalMiniCluster

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4696. --- > Limit the number of Akka Dispatcher Threads in LocalMiniCluster >

[jira] [Resolved] (FLINK-4685) Gather operator checkpoint durations data sizes from the runtime

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4685. - Resolution: Implemented Implemented in b1642e32c2f69c60c2b212260c3479feb66a9165 > Gather

[jira] [Created] (FLINK-4697) Gather more detailed checkpoint stats in CheckpointStatsTracker

2016-09-27 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-4697: --- Summary: Gather more detailed checkpoint stats in CheckpointStatsTracker Key: FLINK-4697 URL: https://issues.apache.org/jira/browse/FLINK-4697 Project: Flink

[jira] [Resolved] (FLINK-4696) Limit the number of Akka Dispatcher Threads in LocalMiniCluster

2016-09-27 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4696. - Resolution: Fixed Fixed via 6ea9284d29ec79576f073441a5de681019720ab0 > Limit the number of Akka

[jira] [Commented] (FLINK-4630) add netty tcp/restful pushed source support

2016-09-27 Thread shijinkui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526424#comment-15526424 ] shijinkui commented on FLINK-4630: -- Some business system such as risk online management. They need the

[jira] [Commented] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState()

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526303#comment-15526303 ] ASF GitHub Bot commented on FLINK-3734: --- Github user lw-lin commented on a diff in the pull request:

[GitHub] flink pull request #2557: [FLINK-3734] Close stream state handles after stat...

2016-09-27 Thread lw-lin
Github user lw-lin commented on a diff in the pull request: https://github.com/apache/flink/pull/2557#discussion_r80704455 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java --- @@ -568,8 +568,8 @@ public void

[jira] [Commented] (FLINK-3734) Unclosed DataInputView in AbstractAlignedProcessingTimeWindowOperator#restoreState()

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526278#comment-15526278 ] ASF GitHub Bot commented on FLINK-3734: --- GitHub user lw-lin opened a pull request:

[GitHub] flink pull request #2557: [FLINK-3734] Close stream state handles after stat...

2016-09-27 Thread lw-lin
GitHub user lw-lin opened a pull request: https://github.com/apache/flink/pull/2557 [FLINK-3734] Close stream state handles after state restorations Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[GitHub] flink pull request #2556: [FLINK-4573] Fix potential resource leak due to un...

2016-09-27 Thread lw-lin
GitHub user lw-lin opened a pull request: https://github.com/apache/flink/pull/2556 [FLINK-4573] Fix potential resource leak due to unclosed RandomAccess… …File in TaskManagerLogHandler -- Thanks for contributing to Apache Flink. Before you open your pull

[jira] [Commented] (FLINK-4573) Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526276#comment-15526276 ] ASF GitHub Bot commented on FLINK-4573: --- GitHub user lw-lin opened a pull request:

[GitHub] flink issue #2544: [FLINK-4218] [checkpoints] Do not rely on FileSystem to d...

2016-09-27 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2544 Manually merged in 95e9004e36fffae755eab7aa3d5d0d5e8bfb7113 --- 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

[GitHub] flink pull request #2544: [FLINK-4218] [checkpoints] Do not rely on FileSyst...

2016-09-27 Thread StephanEwen
Github user StephanEwen closed the pull request at: https://github.com/apache/flink/pull/2544 --- 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-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526247#comment-15526247 ] ASF GitHub Bot commented on FLINK-4218: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-4554) Add support for array types

2016-09-27 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526259#comment-15526259 ] Timo Walther commented on FLINK-4554: - [~kirill-morozov-epam] thanks for your interest. Unfortunately,

[jira] [Commented] (FLINK-4218) Sporadic "java.lang.RuntimeException: Error triggering a checkpoint..." causes task restarting

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526248#comment-15526248 ] ASF GitHub Bot commented on FLINK-4218: --- Github user StephanEwen closed the pull request at:

[GitHub] flink issue #2555: [FLINK-4695] Introduce MetricRegistryConfiguration to enc...

2016-09-27 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2555 True, the benefit of this is only marginal in the current master. It is actually part of the `TaskManager` services start up logic in Flip-6. In this branch, the services will be generated by

[jira] [Commented] (FLINK-4695) Separate configuration parsing from MetricRegistry

2016-09-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526182#comment-15526182 ] ASF GitHub Bot commented on FLINK-4695: --- Github user tillrohrmann commented on the issue:

  1   2   >