[jira] [Commented] (FLINK-3034) Redis SInk Connector

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359975#comment-15359975 ] ASF GitHub Bot commented on FLINK-3034: --- Github user subhankarb commented on a diff

[jira] [Commented] (FLINK-3034) Redis SInk Connector

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359974#comment-15359974 ] ASF GitHub Bot commented on FLINK-3034: --- Github user subhankarb commented on a diff

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

2016-07-01 Thread subhankarb
Github user subhankarb commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69372418 --- Diff: flink-streaming-connectors/flink-connector-redis/pom.xml --- @@ -0,0 +1,86 @@ + + +http://maven.apache.org/POM/4.0.0"; + x

[GitHub] flink pull request #1813: [FLINK-3034] Redis Sink Connector

2016-07-01 Thread subhankarb
Github user subhankarb commented on a diff in the pull request: https://github.com/apache/flink/pull/1813#discussion_r69372416 --- Diff: flink-streaming-connectors/flink-connector-redis/pom.xml --- @@ -0,0 +1,86 @@ + + +http://maven.apache.org/POM/4.0.0"; + x

[jira] [Closed] (FLINK-3965) Delegating GraphAlgorithm

2016-07-01 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-3965. - Resolution: Implemented Implemented in 149e7a01445b4ba494409472dc8b0b15c7221e9e > Delegating GraphAlgorit

[jira] [Closed] (FLINK-4135) Replace ChecksumHashCode as GraphAnalytic

2016-07-01 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4135. - Resolution: Implemented Implemented in 0efa6441420ba4a74ecb9a7d70d0a0d80e25e292 > Replace ChecksumHashCod

[GitHub] flink pull request #2188: [FLINK-4135] [gelly] Replace ChecksumHashCode as G...

2016-07-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2188 --- 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 enab

[jira] [Commented] (FLINK-3965) Delegating GraphAlgorithm

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359498#comment-15359498 ] ASF GitHub Bot commented on FLINK-3965: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-4135) Replace ChecksumHashCode as GraphAnalytic

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359499#comment-15359499 ] ASF GitHub Bot commented on FLINK-4135: --- Github user asfgit closed the pull request

[GitHub] flink pull request #2032: [FLINK-3965] [gelly] Delegating GraphAlgorithm

2016-07-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2032 --- 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 enab

[jira] [Resolved] (FLINK-4144) Yarn properties file: replace hostname/port with Yarn application id

2016-07-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4144. --- Resolution: Fixed Resolved with 7ab6837fde3adb588273ef6bb8f4f7a215fe9c03 > Yarn prope

[jira] [Commented] (FLINK-4144) Yarn properties file: replace hostname/port with Yarn application id

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359397#comment-15359397 ] ASF GitHub Bot commented on FLINK-4144: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-3675) YARN ship folder incosistent behavior

2016-07-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359399#comment-15359399 ] Maximilian Michels commented on FLINK-3675: --- Additional fix with 16cdb61225d78c8

[jira] [Commented] (FLINK-4141) TaskManager failures not always recover when killed during an ApplicationMaster failure in HA mode on Yarn

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359398#comment-15359398 ] ASF GitHub Bot commented on FLINK-4141: --- Github user asfgit closed the pull request

[jira] [Resolved] (FLINK-4141) TaskManager failures not always recover when killed during an ApplicationMaster failure in HA mode on Yarn

2016-07-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4141. --- Resolution: Fixed Fix Version/s: 1.1.0 Resolved with f722b73772eb66cdb79a288300

[GitHub] flink pull request #2191: [FLINK-4144] Yarn properties file: replace hostnam...

2016-07-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2191 --- 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 enab

[GitHub] flink pull request #2190: [FLINK-4141] remove leaderUpdated() method from Re...

2016-07-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2190 --- 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 enab

[jira] [Commented] (FLINK-3630) Little mistake in documentation

2016-07-01 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359318#comment-15359318 ] Greg Hogan commented on FLINK-3630: --- Hi [~riccardo_91], I see you were working on this i

[jira] [Commented] (FLINK-4144) Yarn properties file: replace hostname/port with Yarn application id

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359262#comment-15359262 ] ASF GitHub Bot commented on FLINK-4144: --- GitHub user mxm opened a pull request:

[GitHub] flink pull request #2191: [FLINK-4144] Yarn properties file: replace hostnam...

2016-07-01 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2191 [FLINK-4144] Yarn properties file: replace hostname/port with Yarn application id You can merge this pull request into a Git repository by running: $ git pull https://github.com/mxm/flink FLINK-4

[jira] [Created] (FLINK-4144) Yarn properties file: replace hostname/port with Yarn application id

2016-07-01 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4144: - Summary: Yarn properties file: replace hostname/port with Yarn application id Key: FLINK-4144 URL: https://issues.apache.org/jira/browse/FLINK-4144 Project:

[jira] [Updated] (FLINK-3801) Upgrade Joda-Time library to 2.9.3

2016-07-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3801: -- Description: Currently yoda-time 2.5 is used which was very old. We should upgrade to 2.9.3 was: Currently

[jira] [Updated] (FLINK-3753) KillerWatchDog should not use kill on toKill thread

2016-07-01 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-3753: -- Description: {code} // this is harsh, but this watchdog is a last resort if (toKill.isAlive()) { t

[jira] [Commented] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359165#comment-15359165 ] ASF GitHub Bot commented on FLINK-3231: --- Github user rmetzger commented on the issue

[jira] [Assigned] (FLINK-4141) TaskManager failures not always recover when killed during an ApplicationMaster failure in HA mode on Yarn

2016-07-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reassigned FLINK-4141: - Assignee: Maximilian Michels > TaskManager failures not always recover when kille

[GitHub] flink issue #2131: [FLINK-3231][streaming-connectors] FlinkKinesisConsumer r...

2016-07-01 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2131 Thank you for the quick fix. I hope I can take a look tonight. Otherwise, I'll look at it early next week. Thanks a lot for addressing my comments to quickly. --- If your project is set up for

[jira] [Commented] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359105#comment-15359105 ] ASF GitHub Bot commented on FLINK-3231: --- Github user tzulitai commented on the issue

[GitHub] flink issue #2131: [FLINK-3231][streaming-connectors] FlinkKinesisConsumer r...

2016-07-01 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2131 @rmetzger Thank you for your review. I hope I've addressed your last comments with the last commit. For the documentation, I added a bit more apart from the threading model: 1) enabling che

[jira] [Commented] (FLINK-4141) TaskManager failures not always recover when killed during an ApplicationMaster failure in HA mode on Yarn

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359090#comment-15359090 ] ASF GitHub Bot commented on FLINK-4141: --- GitHub user mxm opened a pull request:

[GitHub] flink pull request #2190: [FLINK-4141] remove leaderUpdated() method from Re...

2016-07-01 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2190 [FLINK-4141] remove leaderUpdated() method from ResourceManager This removes the leaderUpdated method from the framework. Further it lets the RM client thread communicate directly with the Resour

[jira] [Created] (FLINK-4143) Configurable delimiter for metric identifier

2016-07-01 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-4143: --- Summary: Configurable delimiter for metric identifier Key: FLINK-4143 URL: https://issues.apache.org/jira/browse/FLINK-4143 Project: Flink Issue Type:

[jira] [Updated] (FLINK-4143) Configurable delimiter for metric identifier

2016-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-4143: Issue Type: Improvement (was: Bug) > Configurable delimiter for metric identifier > ---

[jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359079#comment-15359079 ] ASF GitHub Bot commented on FLINK-4118: --- Github user iemejia commented on the issue:

[GitHub] flink issue #2176: [FLINK-4118] The docker-flink image is outdated (1.0.2) a...

2016-07-01 Thread iemejia
Github user iemejia commented on the issue: https://github.com/apache/flink/pull/2176 Great, thanks for your review. --- 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 w

[jira] [Commented] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.4.1

2016-07-01 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359073#comment-15359073 ] Stefan Richter commented on FLINK-4142: --- I have a log for the problem here: https:/

[jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359060#comment-15359060 ] ASF GitHub Bot commented on FLINK-4118: --- Github user aljoscha commented on the issue

[GitHub] flink issue #2176: [FLINK-4118] The docker-flink image is outdated (1.0.2) a...

2016-07-01 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2176 That's great to hear! I'll write something on the Beam ML thread. --- 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-4017) [py] Add Aggregation support to Python API

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359054#comment-15359054 ] ASF GitHub Bot commented on FLINK-4017: --- Github user zentol commented on the issue:

[GitHub] flink issue #2115: [FLINK-4017] [py] Add Aggregation support to Python API

2016-07-01 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2115 I'll have to try it out to be sure, but i can't a problem looking through the code. --- 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] [Updated] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.5.0

2016-07-01 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4142: -- Description: On Hadoop Yarn 2.4.1, recovery in HA fails in the following scenario: 1) Kill appl

[GitHub] flink issue #2176: [FLINK-4118] The docker-flink image is outdated (1.0.2) a...

2016-07-01 Thread iemejia
Github user iemejia commented on the issue: https://github.com/apache/flink/pull/2176 This should be ok now. In further commits I expect to fix the daemon thing + maybe add a HA version using zookeeper of the docker-compose file. One more question aljoscha, I intend to add the Beam

[jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359047#comment-15359047 ] ASF GitHub Bot commented on FLINK-4118: --- Github user iemejia commented on the issue:

[jira] [Updated] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.4.1

2016-07-01 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4142: -- Summary: Recovery problem in HA on Hadoop Yarn 2.4.1 (was: Recovery problem in HA on Hadoop Yar

[jira] [Commented] (FLINK-4017) [py] Add Aggregation support to Python API

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359045#comment-15359045 ] ASF GitHub Bot commented on FLINK-4017: --- Github user zentol commented on the issue:

[GitHub] flink issue #2115: [FLINK-4017] [py] Add Aggregation support to Python API

2016-07-01 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2115 Please write a comment when you update the PR, we don't get any notifications for pushed commits :) --- If your project is set up for it, you can reply to this email and have your reply appear on Git

[jira] [Created] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.5.0

2016-07-01 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-4142: - Summary: Recovery problem in HA on Hadoop Yarn 2.5.0 Key: FLINK-4142 URL: https://issues.apache.org/jira/browse/FLINK-4142 Project: Flink Issue Type: Bug

[GitHub] flink pull request #2176: [FLINK-4118] The docker-flink image is outdated (1...

2016-07-01 Thread iemejia
Github user iemejia commented on a diff in the pull request: https://github.com/apache/flink/pull/2176#discussion_r69306327 --- Diff: flink-contrib/docker-flink/README.md --- @@ -1,80 +1,75 @@ -#Apache Flink cluster deployment on Docker using Docker-Compose +Apache Flink clu

[jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359036#comment-15359036 ] ASF GitHub Bot commented on FLINK-4118: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request #2176: [FLINK-4118] The docker-flink image is outdated (1...

2016-07-01 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2176#discussion_r69307221 --- Diff: flink-contrib/docker-flink/README.md --- @@ -1,80 +1,75 @@ -#Apache Flink cluster deployment on Docker using Docker-Compose +Apache Flink cl

[jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359034#comment-15359034 ] ASF GitHub Bot commented on FLINK-4118: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request #2176: [FLINK-4118] The docker-flink image is outdated (1...

2016-07-01 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2176#discussion_r69307034 --- Diff: flink-contrib/docker-flink/README.md --- @@ -1,80 +1,75 @@ -#Apache Flink cluster deployment on Docker using Docker-Compose +Apache Flink cl

[jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359029#comment-15359029 ] ASF GitHub Bot commented on FLINK-4118: --- Github user iemejia commented on a diff in

[jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359031#comment-15359031 ] ASF GitHub Bot commented on FLINK-4118: --- Github user iemejia commented on a diff in

[GitHub] flink pull request #2176: [FLINK-4118] The docker-flink image is outdated (1...

2016-07-01 Thread iemejia
Github user iemejia commented on a diff in the pull request: https://github.com/apache/flink/pull/2176#discussion_r69306386 --- Diff: flink-contrib/docker-flink/README.md --- @@ -1,80 +1,75 @@ -#Apache Flink cluster deployment on Docker using Docker-Compose +Apache Flink clu

[jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359012#comment-15359012 ] ASF GitHub Bot commented on FLINK-4118: --- Github user aljoscha commented on a diff in

[jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359013#comment-15359013 ] ASF GitHub Bot commented on FLINK-4118: --- Github user aljoscha commented on the issue

[GitHub] flink issue #2176: [FLINK-4118] The docker-flink image is outdated (1.0.2) a...

2016-07-01 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2176 I had two more comments about the README but after that it should be good 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.

[GitHub] flink pull request #2176: [FLINK-4118] The docker-flink image is outdated (1...

2016-07-01 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2176#discussion_r69304962 --- Diff: flink-contrib/docker-flink/README.md --- @@ -1,80 +1,75 @@ -#Apache Flink cluster deployment on Docker using Docker-Compose +Apache Flink cl

[jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359010#comment-15359010 ] ASF GitHub Bot commented on FLINK-4118: --- Github user aljoscha commented on a diff in

[GitHub] flink pull request #2176: [FLINK-4118] The docker-flink image is outdated (1...

2016-07-01 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2176#discussion_r69304467 --- Diff: flink-contrib/docker-flink/README.md --- @@ -1,80 +1,75 @@ -#Apache Flink cluster deployment on Docker using Docker-Compose +Apache Flink cl

[jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359009#comment-15359009 ] ASF GitHub Bot commented on FLINK-4118: --- Github user aljoscha commented on the issue

[GitHub] flink issue #2176: [FLINK-4118] The docker-flink image is outdated (1.0.2) a...

2016-07-01 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2176 You were right, I did exactly the same thing I did on OS X on a new Ubuntu 16.04 installation and it worked. 😃 --- If your project is set up for it, you can reply to this email and have your r

[jira] [Created] (FLINK-4141) TaskManager failures not always recover when killed during an ApplicationMaster failure in HA mode on Yarn

2016-07-01 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-4141: - Summary: TaskManager failures not always recover when killed during an ApplicationMaster failure in HA mode on Yarn Key: FLINK-4141 URL: https://issues.apache.org/jira/browse/FL

[jira] [Commented] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358982#comment-15358982 ] ASF GitHub Bot commented on FLINK-3231: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-4127) Clean up configuration and check breaking API changes

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358981#comment-15358981 ] ASF GitHub Bot commented on FLINK-4127: --- Github user mxm commented on a diff in the

[GitHub] flink pull request #2131: [FLINK-3231][streaming-connectors] FlinkKinesisCon...

2016-07-01 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2131#discussion_r69300764 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java ---

[jira] [Commented] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358979#comment-15358979 ] ASF GitHub Bot commented on FLINK-3231: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request #2177: [FLINK-4127] Check API compatbility for 1.1 in fli...

2016-07-01 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/2177#discussion_r69300607 --- Diff: flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java --- @@ -269,26 +269,26 @@ * Percentage of heap space to remove fro

[GitHub] flink pull request #2131: [FLINK-3231][streaming-connectors] FlinkKinesisCon...

2016-07-01 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/2131#discussion_r69300586 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java ---

[GitHub] flink pull request #2131: [FLINK-3231][streaming-connectors] FlinkKinesisCon...

2016-07-01 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2131#discussion_r69300348 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java ---

[jira] [Commented] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358977#comment-15358977 ] ASF GitHub Bot commented on FLINK-3231: --- Github user tzulitai commented on a diff in

[jira] [Assigned] (FLINK-4140) CheckpointCoordinator fails to discard completed checkpoint

2016-07-01 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-4140: - Assignee: Stefan Richter > CheckpointCoordinator fails to discard completed checkpoint >

[jira] [Updated] (FLINK-4140) CheckpointCoordinator fails to discard completed checkpoint

2016-07-01 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4140: -- Assignee: Ufuk Celebi (was: Stefan Richter) > CheckpointCoordinator fails to discard completed

[jira] [Created] (FLINK-4140) CheckpointCoordinator fails to discard completed checkpoint

2016-07-01 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-4140: - Summary: CheckpointCoordinator fails to discard completed checkpoint Key: FLINK-4140 URL: https://issues.apache.org/jira/browse/FLINK-4140 Project: Flink

[GitHub] flink issue #2189: [FLINK-3667] delay connection to JobManager until job exe...

2016-07-01 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2189 Sorry, didn't see your comments. The test failures should be resolved (I ran `mvn verify`). The changes delay the creation of the ActorSystem and thus any blocking actions until we have executed

[jira] [Commented] (FLINK-3667) Generalize client<->cluster communication

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358971#comment-15358971 ] ASF GitHub Bot commented on FLINK-3667: --- Github user mxm commented on the issue:

[jira] [Commented] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358969#comment-15358969 ] ASF GitHub Bot commented on FLINK-3231: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #2131: [FLINK-3231][streaming-connectors] FlinkKinesisCon...

2016-07-01 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2131#discussion_r69299251 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java ---

[jira] [Commented] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358968#comment-15358968 ] ASF GitHub Bot commented on FLINK-3231: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #2131: [FLINK-3231][streaming-connectors] FlinkKinesisCon...

2016-07-01 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2131#discussion_r69299145 --- Diff: flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java ---

[jira] [Resolved] (FLINK-3675) YARN ship folder incosistent behavior

2016-07-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3675. --- Resolution: Fixed Fixed via 0483ba583c7790d13b8035c2916318a2b58c67d6 > YARN ship fold

[GitHub] flink pull request #2131: [FLINK-3231][streaming-connectors] FlinkKinesisCon...

2016-07-01 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/2131#discussion_r69298876 --- Diff: docs/apis/streaming/connectors/kinesis.md --- @@ -60,10 +60,10 @@ to setup Kinesis streams. Make sure to create the appropriate IAM policy and use

[jira] [Commented] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358962#comment-15358962 ] ASF GitHub Bot commented on FLINK-3231: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-3667) Generalize client<->cluster communication

2016-07-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358960#comment-15358960 ] Maximilian Michels commented on FLINK-3667: --- Fixed via f9b52a3114a2114e6846091ac

[GitHub] flink pull request #2168: [FLINK-3964] add hint to job submission timeout ex...

2016-07-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2168 --- 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 enab

[jira] [Commented] (FLINK-3964) Job submission times out with recursive.file.enumeration

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358953#comment-15358953 ] ASF GitHub Bot commented on FLINK-3964: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-3675) YARN ship folder incosistent behavior

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358952#comment-15358952 ] ASF GitHub Bot commented on FLINK-3675: --- Github user asfgit closed the pull request

[GitHub] flink pull request #2187: [FLINK-3675][yarn] improvements to library shippin...

2016-07-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2187 --- 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 enab

[GitHub] flink pull request #2189: [FLINK-3667] delay connection to JobManager until ...

2016-07-01 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2189 --- 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 enab

[jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358949#comment-15358949 ] ASF GitHub Bot commented on FLINK-4118: --- Github user aljoscha commented on the issue

[jira] [Commented] (FLINK-3667) Generalize client<->cluster communication

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358951#comment-15358951 ] ASF GitHub Bot commented on FLINK-3667: --- Github user asfgit closed the pull request

[jira] [Closed] (FLINK-4139) Yarn: Adjust parallelism and task slots correctly

2016-07-01 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4139. - Resolution: Fixed Fixed via 44b3bc45b382c1f2783e9c17dd76ea2e9bbb40ec > Yarn: Adjust paral

[GitHub] flink issue #2176: [FLINK-4118] The docker-flink image is outdated (1.0.2) a...

2016-07-01 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2176 Yes, this is exactly what I was trying on OS X. I'm quickly setting up a ubuntu VM to see if it works there. --- If your project is set up for it, you can reply to this email and have your reply ap

[jira] [Commented] (FLINK-4122) Cassandra jar contains 2 guava versions

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358943#comment-15358943 ] ASF GitHub Bot commented on FLINK-4122: --- Github user zentol closed the pull request

[GitHub] flink pull request #2167: [FLINK-4122] Disable root shading in Cassandra jar

2016-07-01 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/2167 --- 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 enab

[jira] [Closed] (FLINK-4122) Cassandra jar contains 2 guava versions

2016-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4122. --- Resolution: Fixed Fixed in 96590ffaf650b80e277c3f35d3c63f33362f0cc6 > Cassandra jar contains

[jira] [Created] (FLINK-4139) Yarn: Adjust parallelism and task slots correctly

2016-07-01 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4139: - Summary: Yarn: Adjust parallelism and task slots correctly Key: FLINK-4139 URL: https://issues.apache.org/jira/browse/FLINK-4139 Project: Flink Iss

[jira] [Closed] (FLINK-4057) Expose JobManager Metrics

2016-07-01 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4057. --- Resolution: Fixed Implemented in a3a9fd1147aa926987420057f8305ab498519a45, 8829f97344cd9a7a9c

[GitHub] flink issue #2167: [FLINK-4122] Disable root shading in Cassandra jar

2016-07-01 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2167 merging --- 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 fea

[jira] [Commented] (FLINK-4122) Cassandra jar contains 2 guava versions

2016-07-01 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358934#comment-15358934 ] ASF GitHub Bot commented on FLINK-4122: --- Github user zentol commented on the issue:

  1   2   >