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

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

[jira] [Commented] (FLINK-4535) ResourceManager registration with TaskExecutor

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

[GitHub] flink pull request #2451: [FLINK-4535] [cluster management] resourceManager ...

2016-09-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2451#discussion_r77335982 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/UnmatchedLeaderSessionIDException.java --- @@ -0,0 +1,59 @@ +/* + * Licensed

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

2016-09-02 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2275 Yarn tests still not passing: ``` 2016-09-02 11:35:04,244 ERROR org.apache.flink.yarn.YarnApplicationMasterRunner - YARN Application Master initialization failed java.lang.Il

[jira] [Commented] (FLINK-4535) ResourceManager registration with TaskExecutor

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

[GitHub] flink pull request #2451: [FLINK-4535] [cluster management] resourceManager ...

2016-09-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2451#discussion_r77336516 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java --- @@ -138,22 +150,46 @@ public SlotAssignment

[jira] [Commented] (FLINK-4535) ResourceManager registration with TaskExecutor

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

[GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup...

2016-09-02 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2452 @liuyuzhong Should be caused by bumping the Scalastyle version from 0.5.0 to 0.8.0. Doesn't occur on my machine though :( Investigating. Probably lowering the Scalastyle version again. --- If your proj

[GitHub] flink pull request #2451: [FLINK-4535] [cluster management] resourceManager ...

2016-09-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2451#discussion_r77336702 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java --- @@ -138,22 +150,46 @@ public SlotAssignment

[jira] [Commented] (FLINK-4535) ResourceManager registration with TaskExecutor

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

[GitHub] flink pull request #2451: [FLINK-4535] [cluster management] resourceManager ...

2016-09-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2451#discussion_r77337006 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java --- @@ -138,22 +150,46 @@ public SlotAssignment

[jira] [Commented] (FLINK-4535) ResourceManager registration with TaskExecutor

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

[GitHub] flink pull request #2451: [FLINK-4535] [cluster management] resourceManager ...

2016-09-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2451#discussion_r77337149 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManager.java --- @@ -53,14 +56,23 @@ */ public cla

[jira] [Commented] (FLINK-4535) ResourceManager registration with TaskExecutor

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

[GitHub] flink pull request #2451: [FLINK-4535] [cluster management] resourceManager ...

2016-09-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2451#discussion_r77339204 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManagerTest.java --- @@ -0,0 +1,85 @@ +package org.apache

[jira] [Commented] (FLINK-4535) ResourceManager registration with TaskExecutor

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

[GitHub] flink issue #2451: [FLINK-4535] [cluster management] resourceManager process...

2016-09-02 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2451 Thanks for the contribution @beyond1920. I've had some minor inline comments. After addressing them, it should be good to merge. --- If your project is set up for it, you can reply to this emai

[jira] [Created] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

2016-09-02 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4570: - Summary: Scalastyle Maven plugin fails undeterministically Key: FLINK-4570 URL: https://issues.apache.org/jira/browse/FLINK-4570 Project: Flink Iss

[jira] [Commented] (FLINK-4535) ResourceManager registration with TaskExecutor

2016-09-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15458422#comment-15458422 ] ASF GitHub Bot commented on FLINK-4535: --- Github user tillrohrmann commented on the i

[jira] [Commented] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

2016-09-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15458430#comment-15458430 ] Maximilian Michels commented on FLINK-4570: --- Also reported here: https://github

[GitHub] flink issue #2453: [FLINK-4510] [checkpoint] Always create CheckpointCoordin...

2016-09-02 Thread wuchong
Github user wuchong commented on the issue: https://github.com/apache/flink/pull/2453 Make sense. I will update this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[jira] [Commented] (FLINK-4510) Always create CheckpointCoordinator

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

[GitHub] flink pull request #2462: [FLINK-4570] revert Scalastyle version to 0.5.0

2016-09-02 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2462 [FLINK-4570] revert Scalastyle version to 0.5.0 Due to very involved bugs in the 0.8.0 version, we revert back to the 0.5.0 version. You can merge this pull request into a Git repository by running:

[GitHub] flink pull request #2462: [FLINK-4570] revert Scalastyle version to 0.5.0

2016-09-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2462 --- 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 issue #2449: [FLINK-4455] [FLINK-4424] [networkenv] Make NetworkEnviro...

2016-09-02 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2449 Build has passed on Travis with local repo. 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 your project doe

[jira] [Commented] (FLINK-4455) Replace ActorGateways in NetworkEnvironment by interfaces

2016-09-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15458460#comment-15458460 ] ASF GitHub Bot commented on FLINK-4455: --- Github user tillrohrmann commented on the i

[jira] [Updated] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

2016-09-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-4570: -- Affects Version/s: 1.2.0 > Scalastyle Maven plugin fails undeterministically > -

[jira] [Resolved] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

2016-09-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4570. --- Resolution: Fixed Fix Version/s: 1.2.0 Reverted to 0.5.0 in bc9d52391957c1a1150

[jira] [Commented] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

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

[GitHub] flink issue #2452: [Flink-4450] add a new module "flink-apache-storm" to sup...

2016-09-02 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2452 @liuyuzhong Try rebasing on the latest master, should be fixed with https://issues.apache.org/jira/browse/FLINK-4570 --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

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

[jira] [Commented] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

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

[jira] [Closed] (FLINK-4455) Replace ActorGateways in NetworkEnvironment by interfaces

2016-09-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4455. Resolution: Fixed Fixed via 78f2a15867734055a9712ea3a27f54d9bed3e43b > Replace ActorGateways in Net

[jira] [Commented] (FLINK-4455) Replace ActorGateways in NetworkEnvironment by interfaces

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

[GitHub] flink pull request #2449: [FLINK-4455] [FLINK-4424] [networkenv] Make Networ...

2016-09-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2449 --- 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-4424) Make network environment start-up/shutdown independent of JobManager association

2016-09-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-4424. Resolution: Fixed Fixed via 78f2a15867734055a9712ea3a27f54d9bed3e43b > Make network environment sta

[jira] [Updated] (FLINK-4489) Implement TaskManager's SlotAllocationTable

2016-09-02 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4489: - Summary: Implement TaskManager's SlotAllocationTable (was: Implement TaskManager's SlotManager)

[GitHub] flink pull request #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allo...

2016-09-02 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2463 [FLINK-4538][FLINK-4348] ResourceManager slot allocation protcol This implements and tests the ResourceManager part of the protocol for slot allocation. - associates JobMasters with JobID inste

[jira] [Commented] (FLINK-4538) Implement slot allocation protocol with JobMaster

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

[GitHub] flink issue #2463: [FLINK-4538][FLINK-4348] ResourceManager slot allocation ...

2016-09-02 Thread mxm
Github user mxm commented on the issue: https://github.com/apache/flink/pull/2463 CC @tillrohrmann @StephanEwen --- 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 wishe

[jira] [Commented] (FLINK-4538) Implement slot allocation protocol with JobMaster

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

[jira] [Assigned] (FLINK-4522) Gelly link broken in homepage

2016-09-02 Thread Greg Hogan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan reassigned FLINK-4522: - Assignee: Greg Hogan > Gelly link broken in homepage > - > >

[jira] [Reopened] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

2016-09-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened FLINK-4570: --- Switching from Scalastyle 0.5.0 to 0.8.0 did not cause the issue because the issue also o

[GitHub] flink pull request #2464: [FLINK-4522] [docs] Gelly link broken in homepage

2016-09-02 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/2464 [FLINK-4522] [docs] Gelly link broken in homepage The Gelly documentation was recently split in multiple pages in FLINK-4104 but was missing a redirect. This commit updates the Gelly redirect to p

[jira] [Commented] (FLINK-4522) Gelly link broken in homepage

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

[jira] [Closed] (FLINK-4536) Possible thread leak in Task Manager

2016-09-02 Thread Scott Kidder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Scott Kidder closed FLINK-4536. --- Resolution: Not A Bug > Possible thread leak in Task Manager > >

[GitHub] flink issue #2397: [FLINK-4439] Validate 'bootstrap.servers' config in flink...

2016-09-02 Thread gheo21
Github user gheo21 commented on the issue: https://github.com/apache/flink/pull/2397 done, green build! https://travis-ci.org/apache/flink/builds/157038347 thx! --- 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

[jira] [Commented] (FLINK-4439) Error message KafkaConsumer08 when all 'bootstrap.servers' are invalid

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

[GitHub] flink issue #2441: [FLINK-3580] [table] Add current time point functions

2016-09-02 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2441 Merging this... --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

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

[GitHub] flink pull request #2465: [FLINK-4447] [docs] Include NettyConfig options on...

2016-09-02 Thread greghogan
GitHub user greghogan opened a pull request: https://github.com/apache/flink/pull/2465 [FLINK-4447] [docs] Include NettyConfig options on Configurations page You can merge this pull request into a Git repository by running: $ git pull https://github.com/greghogan/flink 4447_i

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

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

[jira] [Resolved] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

2016-09-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4570. --- Resolution: Fixed Reverted back to Scalastyle version 0.8.0 and disabled Scalastyle fo

[GitHub] flink pull request #2465: [FLINK-4447] [docs] Include NettyConfig options on...

2016-09-02 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2465#discussion_r77363499 --- Diff: docs/setup/config.md --- @@ -169,58 +169,111 @@ Default value is the `akka.ask.timeout`. These parameters configure the default HDFS used by F

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

2016-09-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15458793#comment-15458793 ] ASF GitHub Bot commented on FLINK-4447: --- Github user greghogan commented on a diff i

[GitHub] flink pull request #2465: [FLINK-4447] [docs] Include NettyConfig options on...

2016-09-02 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2465#discussion_r77363711 --- Diff: docs/setup/config.md --- @@ -169,58 +169,111 @@ Default value is the `akka.ask.timeout`. These parameters configure the default HDFS used by F

[GitHub] flink pull request #2465: [FLINK-4447] [docs] Include NettyConfig options on...

2016-09-02 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2465#discussion_r77363847 --- Diff: docs/setup/config.md --- @@ -169,58 +169,111 @@ Default value is the `akka.ask.timeout`. These parameters configure the default HDFS used by F

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

2016-09-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15458801#comment-15458801 ] ASF GitHub Bot commented on FLINK-4447: --- Github user greghogan commented on a diff i

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

2016-09-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15458798#comment-15458798 ] ASF GitHub Bot commented on FLINK-4447: --- Github user greghogan commented on a diff i

[GitHub] flink pull request #2465: [FLINK-4447] [docs] Include NettyConfig options on...

2016-09-02 Thread greghogan
Github user greghogan commented on a diff in the pull request: https://github.com/apache/flink/pull/2465#discussion_r77364407 --- Diff: docs/setup/config.md --- @@ -169,58 +169,111 @@ Default value is the `akka.ask.timeout`. These parameters configure the default HDFS used by F

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

2016-09-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15458812#comment-15458812 ] ASF GitHub Bot commented on FLINK-4447: --- Github user greghogan commented on a diff i

[GitHub] flink issue #2459: [FLINK-4561] replace all the scala version as a `scala.bi...

2016-09-02 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2459 Yes, @chiwanpark is right. This does not work, we tried it before. As long as the Maven Shade plugin is not fixed, we need to keep it as it is. Could you close this pull request? --- If

[jira] [Commented] (FLINK-4561) replace all the scala version as a `scala.binary.version` property

2016-09-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15458829#comment-15458829 ] ASF GitHub Bot commented on FLINK-4561: --- Github user StephanEwen commented on the is

[jira] [Resolved] (FLINK-4567) Enhance SerializedThrowable to properly preserver cause chains

2016-09-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4567. - Resolution: Fixed Fixed via 761d0a02505c7eaef7a566f978145b187c89cbf8 > Enhance SerializedThrowabl

[jira] [Closed] (FLINK-4567) Enhance SerializedThrowable to properly preserver cause chains

2016-09-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4567. --- > Enhance SerializedThrowable to properly preserver cause chains > ---

[jira] [Resolved] (FLINK-4490) Decouple Slot and Instance

2016-09-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4490. - Resolution: Fixed Assignee: Stephan Ewen Fixed as of eac6088a75e813a015b778f4cfc4cce0cf2a53c

[jira] [Closed] (FLINK-4490) Decouple Slot and Instance

2016-09-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4490. --- > Decouple Slot and Instance > -- > > Key: FLINK-4490 >

[jira] [Commented] (FLINK-4525) Drop the "eager split pre-assignment" code paths

2016-09-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15458851#comment-15458851 ] Stephan Ewen commented on FLINK-4525: - Addendum in fb8f2c935e96c9300a7584e310eb96e8a1f

[jira] [Closed] (FLINK-4566) ProducerFailedException does not properly preserve Exception causes

2016-09-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4566. --- > ProducerFailedException does not properly preserve Exception causes > --

[jira] [Resolved] (FLINK-4566) ProducerFailedException does not properly preserve Exception causes

2016-09-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4566. - Resolution: Fixed Fixed in - 1.2.0 via e227b10134e387f3c49804dc0cc4c223c30702e3 - 1.1.3 via f2

[GitHub] flink pull request #2441: [FLINK-3580] [table] Add current time point functi...

2016-09-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2441 --- 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] [Created] (FLINK-4571) Configurable little parallelism in Gelly drivers

2016-09-02 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4571: - Summary: Configurable little parallelism in Gelly drivers Key: FLINK-4571 URL: https://issues.apache.org/jira/browse/FLINK-4571 Project: Flink Issue Type: Improvem

[jira] [Commented] (FLINK-3580) Reintroduce Date/Time and implement scalar functions for it

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

[jira] [Commented] (FLINK-4458) Remove ForkableFlinkMiniCluster

2016-09-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15458876#comment-15458876 ] ASF GitHub Bot commented on FLINK-4458: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #2450: [FLINK-4458] Replace ForkableFlinkMiniCluster by LocalFli...

2016-09-02 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2450 Builds are passing on Travis (own repository). Would like to merge this PR if there are no objections. --- If your project is set up for it, you can reply to this email and have your reply appe

[jira] [Created] (FLINK-4572) Convert to negative in LongValueToIntValue

2016-09-02 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4572: - Summary: Convert to negative in LongValueToIntValue Key: FLINK-4572 URL: https://issues.apache.org/jira/browse/FLINK-4572 Project: Flink Issue Type: Bug

[GitHub] flink pull request #2466: [FLINK-4570] remove conflicting Unicode character

2016-09-02 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2466 [FLINK-4570] remove conflicting Unicode character This caused Scalastyle to fail, presumably depending on the locale used. After a bit of debugging on the Scalastyle plugin I found out that the n

[jira] [Commented] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

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

[GitHub] flink pull request #2466: [FLINK-4570] remove conflicting Unicode character

2016-09-02 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2466 --- 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-4570) Scalastyle Maven plugin fails undeterministically

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

[jira] [Closed] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

2016-09-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-4570. - Resolution: Fixed After some debugging, finally fixed by removing a Unicode character. Cra

[jira] [Reopened] (FLINK-4570) Scalastyle Maven plugin fails undeterministically

2016-09-02 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels reopened FLINK-4570: --- > Scalastyle Maven plugin fails undeterministically >

[jira] [Commented] (FLINK-4546) Remove STREAM keyword in Stream SQL

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

[GitHub] flink issue #2454: [FLINK-4546] [table] Remove STREAM keyword in Stream SQL

2016-09-02 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2454 Thank @wuchong. Looks good to merge. @fhueske do you also want to have a look at it? --- 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-4265) Add a NoOpOperator

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

[GitHub] flink issue #2294: [FLINK-4265] [dataset api] Add a NoOpOperator

2016-09-02 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2294 @fhueske what is your analysis? --- 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 an

[GitHub] flink issue #2066: Updated ssh configuration in base Dockerfile

2016-09-02 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2066 Is there a JIRA ticket for this PR? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enable

[jira] [Commented] (FLINK-3947) Provide low level access to RocksDB state backend

2016-09-02 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15459017#comment-15459017 ] Stephan Ewen commented on FLINK-3947: - [~elevy] I think we can approach this two ways

[GitHub] flink issue #2060: [FLINK-3921] StringParser encoding

2016-09-02 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/2060 Hi @rekhajoshm have you had a chance to look at the last two comments? --- 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 projec

[jira] [Commented] (FLINK-3921) StringParser not specifying encoding to use

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

[jira] [Commented] (FLINK-4482) numUnsuccessfulCheckpointsTriggers is accessed without holding triggerLock

2016-09-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15459062#comment-15459062 ] Ted Yu commented on FLINK-4482: --- [~StephanEwen]: All checks passed. Should be ready to go.

[jira] [Commented] (FLINK-3947) Provide low level access to RocksDB state backend

2016-09-02 Thread Elias Levy (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15459066#comment-15459066 ] Elias Levy commented on FLINK-3947: --- I'd go with the first choice, higher level abstract

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

2016-09-02 Thread vijikarthi
Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2275 @mxm, I am not seeing the error messages when I run the Yarn test. Could you please run "secure" test case alone and share the logs? > mvn test integration-test -Dtest="YARNSessionFIFO

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

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

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

2016-09-02 Thread Ted Yu (JIRA)
Ted Yu created FLINK-4573: - Summary: Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler# Key: FLINK-4573 URL: https://issues.apache.org/jira/browse/FLINK-4573 Project: Flink

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

2016-09-02 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-4573: -- Summary: Potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler (was: Potential reso

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

2016-09-02 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15459635#comment-15459635 ] Ivan Mushketyk commented on FLINK-3427: --- I'll work on this if no one minds. > Add w

[jira] [Assigned] (FLINK-3427) Add watermark monitoring to JobManager web frontend

2016-09-02 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Mushketyk reassigned FLINK-3427: - Assignee: Ivan Mushketyk > Add watermark monitoring to JobManager web frontend >

[jira] [Commented] (FLINK-3624) Use camelCase naming of JSON attributes generated by the REST API instead of dash

2016-09-02 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15459639#comment-15459639 ] Ivan Mushketyk commented on FLINK-3624: --- [~aljoscha] I think another option could be

[jira] [Commented] (FLINK-3719) WebInterface: Moving the barrier between graph and stats

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

<    1   2   3   >