[jira] [Commented] (FLINK-4435) Replace Guava's VisibleForTesting annotation with Flink's annotation

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

[GitHub] flink pull request #2404: [FLINK-4435] Replace Guava's VisibleForTesting ann...

2016-08-22 Thread wuchong
GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/2404 [FLINK-4435] Replace Guava's VisibleForTesting annotation with Flink's annotation Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list in

[jira] [Assigned] (FLINK-4435) Replace Guava's VisibleForTesting annotation with Flink's annotation

2016-08-22 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-4435: -- Assignee: Jark Wu > Replace Guava's VisibleForTesting annotation with Flink's annotation >

[jira] [Commented] (FLINK-4363) Implement TaskManager basic startup of all components in java

2016-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432180#comment-15432180 ] ASF GitHub Bot commented on FLINK-4363: --- Github user wangzhijiang999 commented on a

[GitHub] flink pull request #2400: [FLINK-4363] Implement TaskManager basic startup o...

2016-08-22 Thread wangzhijiang999
Github user wangzhijiang999 commented on a diff in the pull request: https://github.com/apache/flink/pull/2400#discussion_r75805009 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutor.java --- @@ -35,27 +79,634 @@ */ public class

[GitHub] flink issue #2342: FLINK-4253 - Rename "recovery.mode" config key to "high-a...

2016-08-22 Thread ramkrish86
Github user ramkrish86 commented on the issue: https://github.com/apache/flink/pull/2342 @uce Thank you very much for checking it out. I can see in the branch that you have created you have updated some doc comment that I had added - from 'config' to 'key' and some missing places

[jira] [Commented] (FLINK-4253) Rename "recovery.mode" config key to "high-availability"

2016-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432131#comment-15432131 ] ASF GitHub Bot commented on FLINK-4253: --- Github user ramkrish86 commented on the iss

[jira] [Updated] (FLINK-4376) Implement job master skeleton for managing single job

2016-08-22 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4376: -- Description: This jira targets to set up a skeleton of the new JobMaster, translate scala codes to java

[jira] [Updated] (FLINK-4376) Implement job master skeleton for managing single job

2016-08-22 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4376: -- Description: This jira targets to set up a skeleton of the new JobMaster, translate scala codes to java

[jira] [Commented] (FLINK-4443) Add support in RpcCompletenessTest for inheritance of RpcGateway and RpcEndpoint

2016-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15432030#comment-15432030 ] ASF GitHub Bot commented on FLINK-4443: --- Github user wenlong88 commented on the issu

[GitHub] flink issue #2401: [FLINK-4443][rpc] Add support in RpcCompletenessTest for ...

2016-08-22 Thread wenlong88
Github user wenlong88 commented on the issue: https://github.com/apache/flink/pull/2401 @tillrohrmann all comments addressed. I have removed the `NativeMethod` annotation. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well.

[jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager

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

[GitHub] flink pull request #2389: [FLINK-4348] [cluster management] Implement commun...

2016-08-22 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2389#discussion_r75793520 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java --- @@ -94,26 +130,218 @@ public RegistrationRespo

[jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager

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

[jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager

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

[GitHub] flink pull request #2389: [FLINK-4348] [cluster management] Implement commun...

2016-08-22 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2389#discussion_r75793072 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java --- @@ -94,26 +130,218 @@ public RegistrationRespo

[GitHub] flink pull request #2389: [FLINK-4348] [cluster management] Implement commun...

2016-08-22 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2389#discussion_r75793093 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java --- @@ -94,26 +130,218 @@ public RegistrationRespo

[GitHub] flink pull request #2389: [FLINK-4348] [cluster management] Implement commun...

2016-08-22 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2389#discussion_r75792397 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManagerToTaskExecutorHeartbeatScheduler.java --- @@ -0,0 +1,242

[jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager

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

[GitHub] flink pull request #2389: [FLINK-4348] [cluster management] Implement commun...

2016-08-22 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2389#discussion_r75792341 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManagerToTaskExecutorHeartbeatScheduler.java --- @@ -0,0 +1,242

[jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager

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

[jira] [Updated] (FLINK-4376) Implement job master skeleton for managing single job

2016-08-22 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4376: -- Description: This jira targets to set up a skeleton of the new JobMaster, translate scala codes to java.

[jira] [Assigned] (FLINK-4376) Implement job master skeleton for managing single job

2016-08-22 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-4376: - Assignee: Kurt Young > Implement job master skeleton for managing single job > -

[jira] [Created] (FLINK-4448) Use Listeners to monitor execution status

2016-08-22 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-4448: --- Summary: Use Listeners to monitor execution status Key: FLINK-4448 URL: https://issues.apache.org/jira/browse/FLINK-4448 Project: Flink Issue Type: Sub-task

[GitHub] flink pull request #2389: [FLINK-4348] [cluster management] Implement commun...

2016-08-22 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2389#discussion_r75790203 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManagerToTaskExecutorHeartbeatScheduler.java --- @@ -0,0 +1,242

[jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager

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

[GitHub] flink pull request #2377: [Flink-4400][cluster management]Leadership Electio...

2016-08-22 Thread shixiaogang
Github user shixiaogang closed the pull request at: https://github.com/apache/flink/pull/2377 --- 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-4348) Implement communication from ResourceManager to TaskManager

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

[GitHub] flink pull request #2389: [FLINK-4348] [cluster management] Implement commun...

2016-08-22 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2389#discussion_r75790043 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java --- @@ -94,26 +130,218 @@ public RegistrationRespo

[GitHub] flink pull request #2389: [FLINK-4348] [cluster management] Implement commun...

2016-08-22 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2389#discussion_r75789610 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java --- @@ -52,18 +61,45 @@ public class Resource

[jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager

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

[jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager

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

[GitHub] flink pull request #2389: [FLINK-4348] [cluster management] Implement commun...

2016-08-22 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2389#discussion_r75789477 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java --- @@ -52,18 +61,45 @@ public class Resource

[jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager

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

[jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager

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

[GitHub] flink pull request #2389: [FLINK-4348] [cluster management] Implement commun...

2016-08-22 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2389#discussion_r75789293 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java --- @@ -52,18 +61,45 @@ public class Resource

[jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager

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

[GitHub] flink pull request #2389: [FLINK-4348] [cluster management] Implement commun...

2016-08-22 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2389#discussion_r75789279 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java --- @@ -52,18 +61,45 @@ public class Resource

[GitHub] flink pull request #2389: [FLINK-4348] [cluster management] Implement commun...

2016-08-22 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2389#discussion_r75789238 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java --- @@ -94,26 +130,218 @@ public RegistrationRespo

[jira] [Commented] (FLINK-4348) Implement communication from ResourceManager to TaskManager

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

[GitHub] flink pull request #2389: [FLINK-4348] [cluster management] Implement commun...

2016-08-22 Thread beyond1920
Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/2389#discussion_r75789222 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java --- @@ -94,26 +130,218 @@ public RegistrationRespo

[jira] [Updated] (FLINK-4376) Implement job master skeleton for managing single job

2016-08-22 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-4376: -- Summary: Implement job master skeleton for managing single job (was: implement job manager init proced

[jira] [Commented] (FLINK-4347) Implement SlotManager core

2016-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15431875#comment-15431875 ] ASF GitHub Bot commented on FLINK-4347: --- Github user KurtYoung commented on the issu

[GitHub] flink issue #2388: [FLINK-4347][cluster management] Implement SlotManager co...

2016-08-22 Thread KurtYoung
Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/2388 hi @tillrohrmann , thanks for the reviewing, all your comments will be addressed. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. I

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

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

[GitHub] flink issue #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-22 Thread delding
Github user delding commented on the issue: https://github.com/apache/flink/pull/2332 Hi @rmetzger , Thanks for your comment. I am totally ok with contributing the connector to Apache Bahir :-) --- If your project is set up for it, you can reply to this email and have your reply appe

[jira] [Commented] (FLINK-4426) Unable to create proxy to the ResourceManager

2016-08-22 Thread Harpreet Sawhney (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15431716#comment-15431716 ] Harpreet Sawhney commented on FLINK-4426: - [~rmetzger] [~mxm] I compiled flink wit

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

2016-08-22 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2275 > YARNSessionFIFOSecuredITCase gives me the following: 17:49:58,097 INFO SecurityLogger.org.apache.hadoop.ipc.Server - Auth successful for appattempt_1471880990715_0001_01 (auth:SIMPLE)

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15431703#comment-15431703 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on the iss

[jira] [Commented] (FLINK-4278) Unclosed FSDataOutputStream in multiple files in the project

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

[GitHub] flink issue #2403: [FLINK-4278]: Unclosed FSDataOutputStream in multiple fil...

2016-08-22 Thread nssalian
Github user nssalian commented on the issue: https://github.com/apache/flink/pull/2403 Hi @rmetzger, @tedyu do you have some time to help review this? I am not sure if the failures are related. --- If your project is set up for it, you can reply to this email and have your reply a

[jira] [Commented] (FLINK-3866) StringArraySerializer claims type is immutable; shouldn't

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

[GitHub] flink issue #2289: [FLINK-3866] StringArraySerializer type should be mutable

2016-08-22 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2289 Sorry for the delay @mushketyk! Will merge it tomorrow. Thanks, Fabian --- 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 proj

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

2016-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15431658#comment-15431658 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on the iss

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

2016-08-22 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2275 The `RollingFileSink` error might be due to https://issues.apache.org/jira/browse/HDFS-9213. The secure MiniDFS cluster requires privileged ports to be used and we need to enable the java process

[jira] [Assigned] (FLINK-4445) Ignore unmatched state when restoring from savepoint

2016-08-22 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-4445: -- Assignee: Ufuk Celebi > Ignore unmatched state when restoring from savepoint >

[jira] [Commented] (FLINK-4440) Make API for edge/vertex creation less verbose

2016-08-22 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15431625#comment-15431625 ] Ivan Mushketyk commented on FLINK-4440: --- [~greghogan] On the second thought, We ca

[jira] [Comment Edited] (FLINK-4440) Make API for edge/vertex creation less verbose

2016-08-22 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15430534#comment-15430534 ] Ivan Mushketyk edited comment on FLINK-4440 at 8/22/16 8:53 PM:

[jira] [Commented] (FLINK-3710) ScalaDocs for org.apache.flink.streaming.scala are missing from the web site

2016-08-22 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15431438#comment-15431438 ] Elias Levy commented on FLINK-3710: --- That's better than the docs not being available at

[jira] [Created] (FLINK-4447) Include NettyConfig options on Configurations page

2016-08-22 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4447: - Summary: Include NettyConfig options on Configurations page Key: FLINK-4447 URL: https://issues.apache.org/jira/browse/FLINK-4447 Project: Flink Issue Type: Improv

[jira] [Commented] (FLINK-4317) Restructure documentation

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

[GitHub] flink issue #2387: [FLINK-4317, FLIP-3] [docs] Restructure docs

2016-08-22 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2387 I'm against merging it to the 1.1.x branch. Its a big change, that we would do between releases. In a few months, we'll have a new release, then users can enjoy the new layout. --- If your pro

[jira] [Commented] (FLINK-4317) Restructure documentation

2016-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15431387#comment-15431387 ] ASF GitHub Bot commented on FLINK-4317: --- Github user greghogan commented on the issu

[GitHub] flink issue #2387: [FLINK-4317, FLIP-3] [docs] Restructure docs

2016-08-22 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2387 @uce this looks very nice, and navigating libraries is much improved with the extra level(s?) of navigation. --- If your project is set up for it, you can reply to this email and have your reply a

[jira] [Commented] (FLINK-4317) Restructure documentation

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

[GitHub] flink issue #2387: [FLINK-4317, FLIP-3] [docs] Restructure docs

2016-08-22 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2387 I've addressed @aljoscha's and @jgrier's comments. @tillrohrmann I could not figure out how to do the centering in a different way, but I'm sure we (someone with more CSS skills) can address this as a fo

[jira] [Commented] (FLINK-4278) Unclosed FSDataOutputStream in multiple files in the project

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

[GitHub] flink pull request #2403: [FLINK-4278]: Unclosed FSDataOutputStream in multi...

2016-08-22 Thread nssalian
GitHub user nssalian opened a pull request: https://github.com/apache/flink/pull/2403 [FLINK-4278]: Unclosed FSDataOutputStream in multiple files in the project Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into cons

[GitHub] flink issue #2314: [FLINK-3298] Implement ActiveMQ streaming connector

2016-08-22 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2314 @rmetzger Thank you for your help. I'll try to make the change today. --- 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-3298) Streaming connector for ActiveMQ

2016-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15431117#comment-15431117 ] ASF GitHub Bot commented on FLINK-3298: --- Github user mushketyk commented on the issu

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

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

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

2016-08-22 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2275 Seems like this is not yet in a mergeable state and needs another pass. --- 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 doe

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

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

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

2016-08-22 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2275 `RollingFileSink` ``` --- T E S T S --- Running org.apache.flink.streaming.

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

2016-08-22 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2275 YARNSessionFIFOSecuredITCase gives me the following: >17:49:58,097 INFO SecurityLogger.org.apache.hadoop.ipc.Server - Auth successful for appattempt_1471880990715_0001_01 (

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

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

[jira] [Commented] (FLINK-4253) Rename "recovery.mode" config key to "high-availability"

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

[GitHub] flink issue #2342: FLINK-4253 - Rename "recovery.mode" config key to "high-a...

2016-08-22 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2342 I had to address some things when reviewing this: https://github.com/uce/flink/tree/ram In general the changes were good, but overlooked many occurrences that are not possible to catch with auto

[jira] [Commented] (FLINK-4317) Restructure documentation

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

[GitHub] flink issue #2387: [FLINK-4317, FLIP-3] [docs] Restructure docs

2016-08-22 Thread jgrier
Github user jgrier commented on the issue: https://github.com/apache/flink/pull/2387 This looks great! I really like the left side navigation. I think this is a big improvement. One suggestion: Can we change the name of the "Testing & Debugging" section to something like "

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

2016-08-22 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2275 Hi @vijikarthi! Sorry for the late reply. I intend to merge this as soon as possible. When I run the secure test cases from IntelliJ I get >java.lang.NoClassDefFoundError: jdbm/helper/CachePolicy

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

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

[jira] [Commented] (FLINK-4347) Implement SlotManager core

2016-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15431001#comment-15431001 ] ASF GitHub Bot commented on FLINK-4347: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2388: [FLINK-4347][cluster management] Implement SlotMan...

2016-08-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2388#discussion_r75699662 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/SlotManager.java --- @@ -0,0 +1,519 @@ +/* + * Licensed to the A

[jira] [Commented] (FLINK-4347) Implement SlotManager core

2016-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15430999#comment-15430999 ] ASF GitHub Bot commented on FLINK-4347: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2388: [FLINK-4347][cluster management] Implement SlotMan...

2016-08-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2388#discussion_r75699254 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/SlotManager.java --- @@ -0,0 +1,519 @@ +/* + * Licensed to the A

[GitHub] flink pull request #2388: [FLINK-4347][cluster management] Implement SlotMan...

2016-08-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2388#discussion_r75698687 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/SlotManager.java --- @@ -0,0 +1,519 @@ +/* + * Licensed to the A

[jira] [Commented] (FLINK-4347) Implement SlotManager core

2016-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15430992#comment-15430992 ] ASF GitHub Bot commented on FLINK-4347: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4347) Implement SlotManager core

2016-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15430988#comment-15430988 ] ASF GitHub Bot commented on FLINK-4347: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2388: [FLINK-4347][cluster management] Implement SlotMan...

2016-08-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2388#discussion_r75698545 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/SlotManager.java --- @@ -0,0 +1,519 @@ +/* + * Licensed to the A

[jira] [Commented] (FLINK-4347) Implement SlotManager core

2016-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15430985#comment-15430985 ] ASF GitHub Bot commented on FLINK-4347: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2388: [FLINK-4347][cluster management] Implement SlotMan...

2016-08-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2388#discussion_r75698435 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/SlotManager.java --- @@ -0,0 +1,519 @@ +/* + * Licensed to the A

[jira] [Commented] (FLINK-4347) Implement SlotManager core

2016-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15430975#comment-15430975 ] ASF GitHub Bot commented on FLINK-4347: --- Github user tillrohrmann commented on a dif

[GitHub] flink pull request #2388: [FLINK-4347][cluster management] Implement SlotMan...

2016-08-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2388#discussion_r75697458 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/SlotManager.java --- @@ -0,0 +1,519 @@ +/* + * Licensed to the A

[GitHub] flink pull request #2388: [FLINK-4347][cluster management] Implement SlotMan...

2016-08-22 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2388#discussion_r75697328 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/SlotManager.java --- @@ -0,0 +1,519 @@ +/* + * Licensed to the A

[jira] [Commented] (FLINK-4347) Implement SlotManager core

2016-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15430970#comment-15430970 ] ASF GitHub Bot commented on FLINK-4347: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-4347) Implement SlotManager core

2016-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15430947#comment-15430947 ] ASF GitHub Bot commented on FLINK-4347: --- Github user tillrohrmann commented on a dif

[jira] [Commented] (FLINK-3298) Streaming connector for ActiveMQ

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

[GitHub] flink issue #2314: [FLINK-3298] Implement ActiveMQ streaming connector

2016-08-22 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2314 Okay, can do. It would be good if you could address the comment first. Sent from my iPhone > On 22.08.2016, at 16:53, Ivan Mushketyk wrote: > > @rmetzger Please op

[jira] [Commented] (FLINK-4347) Implement SlotManager core

2016-08-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15430954#comment-15430954 ] ASF GitHub Bot commented on FLINK-4347: --- Github user tillrohrmann commented on a dif

  1   2   3   4   5   >