[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

[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=15458686#comment-15458686 ] ASF GitHub Bot commented on FLINK-4538: --- GitHub user mxm opened a pull request:

[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

[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=15458801#comment-15458801 ] ASF GitHub Bot commented on FLINK-4447: --- Github user greghogan commented on a diff in the pull

[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=15458798#comment-15458798 ] ASF GitHub Bot commented on FLINK-4447: --- Github user greghogan commented on a diff in the pull

[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

[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

[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

[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

[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

[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=15458793#comment-15458793 ] ASF GitHub Bot commented on FLINK-4447: --- Github user greghogan commented on a diff in the pull

[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] [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=15458765#comment-15458765 ] ASF GitHub Bot commented on FLINK-4439: --- Github user gheo21 commented on the issue:

[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

[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=15458479#comment-15458479 ] ASF GitHub Bot commented on FLINK-4455: --- Github user asfgit closed the pull request at:

[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

[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)

[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 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

[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=15458782#comment-15458782 ] ASF GitHub Bot commented on FLINK-4447: --- GitHub user greghogan opened a pull request:

[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

[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=15458692#comment-15458692 ] ASF GitHub Bot commented on FLINK-4538: --- Github user mxm commented on the issue:

[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=15458746#comment-15458746 ] ASF GitHub Bot commented on FLINK-4522: --- GitHub user greghogan opened a pull request:

[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=15458778#comment-15458778 ] ASF GitHub Bot commented on FLINK-3580: --- Github user twalthr commented on the issue:

[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

[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

[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

[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=15458812#comment-15458812 ] ASF GitHub Bot commented on FLINK-4447: --- Github user greghogan commented on a diff in the pull

[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=15458876#comment-15458876 ] ASF GitHub Bot commented on FLINK-4458: --- Github user tillrohrmann commented on the issue:

[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-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=15458829#comment-15458829 ] ASF GitHub Bot commented on FLINK-4561: --- Github user StephanEwen 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=15458916#comment-15458916 ] ASF GitHub Bot commented on FLINK-4570: --- Github user asfgit closed the pull request at:

[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.

[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=15459017#comment-15459017 ] Stephan Ewen commented on FLINK-3947: - [~elevy] I think we can approach this two ways - Add another

[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=15459051#comment-15459051 ] ASF GitHub Bot commented on FLINK-3921: --- Github user greghogan commented on the issue:

[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:

[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=15458870#comment-15458870 ] ASF GitHub Bot commented on FLINK-3580: --- Github user asfgit closed the pull request at:

[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=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 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

[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=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.

[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

[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

[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

[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

[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

[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

[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? ---

[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=15458851#comment-15458851 ] Stephan Ewen commented on FLINK-4525: - Addendum in fb8f2c935e96c9300a7584e310eb96e8a1f32f7f > Drop

[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

[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=15459066#comment-15459066 ] Elias Levy commented on FLINK-3947: --- I'd go with the first choice, higher level abstractions for state

[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=15458974#comment-15458974 ] ASF GitHub Bot commented on FLINK-4265: --- Github user greghogan commented on the issue:

[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

[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=15459062#comment-15459062 ] Ted Yu commented on FLINK-4482: --- [~StephanEwen]: All checks passed. Should be ready to go. >

[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

[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

[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=15459081#comment-15459081 ] ASF GitHub Bot commented on FLINK-3929: --- Github user vijikarthi commented on the issue:

[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

[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-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=15459635#comment-15459635 ] Ivan Mushketyk commented on FLINK-3427: --- I'll work on this if no one minds. > Add watermark

[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=15459639#comment-15459639 ] Ivan Mushketyk commented on FLINK-3624: --- [~aljoscha] I think another option could be to have to sets

[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=15459829#comment-15459829 ] ASF GitHub Bot commented on FLINK-3719: --- GitHub user mushketyk opened a pull request:

[GitHub] flink pull request #2467: [FLINK-3719][web frontend] Moving the barrier betw...

2016-09-02 Thread mushketyk
GitHub user mushketyk opened a pull request: https://github.com/apache/flink/pull/2467 [FLINK-3719][web frontend] Moving the barrier between graph and stats Added a moving split barrier between graph and stats. It looks like this:

[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

[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

[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] [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] [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

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

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

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

2016-09-02 Thread delding
Github user delding commented on the issue: https://github.com/apache/flink/pull/2332 Hi @ramkrish86 , I squashed my recent commit into the one you reviewed before, then merged the upstream and pushed --force the commits which is why you only see two commits. The first commit

[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

[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=15458419#comment-15458419 ] ASF GitHub Bot commented on FLINK-4535: --- Github user tillrohrmann commented on a diff in the pull

[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

[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

[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=15458422#comment-15458422 ] ASF GitHub Bot commented on FLINK-4535: --- Github user tillrohrmann commented on the issue:

[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=15458430#comment-15458430 ] Maximilian Michels commented on FLINK-4570: --- Also reported here:

[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=15458445#comment-15458445 ] ASF GitHub Bot commented on FLINK-4510: --- Github user wuchong commented on the issue:

[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

[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

[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

[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=15458460#comment-15458460 ] ASF GitHub Bot commented on FLINK-4455: --- Github user tillrohrmann commented on the issue:

[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

[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=15458459#comment-15458459 ] ASF GitHub Bot commented on FLINK-4570: --- Github user asfgit closed the pull request at:

[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

[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=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=15458452#comment-15458452 ] ASF GitHub Bot commented on FLINK-4570: --- GitHub user mxm opened a pull request:

[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=15457905#comment-15457905 ] ASF GitHub Bot commented on FLINK-4439: --- Github user rmetzger commented on the issue:

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

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

[GitHub] flink pull request #2447: [FLINK-4490] [distributed coordination] Decouple t...

2016-09-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2447#discussion_r77310357 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/deployment/PartialInputChannelDeploymentDescriptor.java --- @@ -44,15 +44,15 @@

[jira] [Commented] (FLINK-4544) TaskManager metrics are vulnerable to custom JMX bean installation

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

[jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix

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

[GitHub] flink issue #2152: [FLINK-3920] Distributed Linear Algebra: block-based matr...

2016-09-02 Thread chobeat
Github user chobeat commented on the issue: https://github.com/apache/flink/pull/2152 Is travis still broken? I see it worked for one build but failed for the others. Is there anything more to review on this PR or we can proceed? --- If your project is set up for it, you can reply

[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=15457997#comment-15457997 ] ASF GitHub Bot commented on FLINK-4439: --- Github user gheo21 commented on the issue:

[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 Sure, did it. Let's see if it get's green! Thanks. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

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

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

[GitHub] flink pull request #2447: [FLINK-4490] [distributed coordination] Decouple t...

2016-09-02 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2447#discussion_r77317670 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/slots/SlotOwner.java --- @@ -0,0 +1,29 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-4245) Metric naming improvements

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

  1   2   3   >