[GitHub] flink pull request: [FLINK-1771] Add support for submitting single...

2015-03-31 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/542#issuecomment-87967427 Thank you very much for the review Henry! I addressed your feedback where applicable. I'll merge the change now. --- If your project is set up for it, you can

[GitHub] flink pull request: [FLINK-1771] Add support for submitting single...

2015-03-31 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/542#discussion_r27456302 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java --- @@ -106,70 +111,129 @@ public FlinkYarnCluster(final YarnClient

[jira] [Commented] (FLINK-1771) Add support for submitting single jobs to a detached YARN session

2015-03-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388140#comment-14388140 ] ASF GitHub Bot commented on FLINK-1771: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request: [FLINK-1771] Add support for submitting single...

2015-03-31 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/542#discussion_r27456202 --- Diff: flink-test-utils/src/main/java/org/apache/flink/test/util/TestEnvironment.java --- @@ -80,7 +80,7 @@ public String getExecutionPlan() throws

[jira] [Commented] (FLINK-1771) Add support for submitting single jobs to a detached YARN session

2015-03-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388133#comment-14388133 ] ASF GitHub Bot commented on FLINK-1771: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request: [FLINK-1771] Add support for submitting single...

2015-03-31 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/542#discussion_r27456299 --- Diff: flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java --- @@ -265,12 +266,32 @@ protected int run(String[] args) { }

[jira] [Commented] (FLINK-1771) Add support for submitting single jobs to a detached YARN session

2015-03-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388138#comment-14388138 ] ASF GitHub Bot commented on FLINK-1771: --- Github user rmetzger commented on a diff in

[jira] [Commented] (FLINK-1771) Add support for submitting single jobs to a detached YARN session

2015-03-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388137#comment-14388137 ] ASF GitHub Bot commented on FLINK-1771: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request: [FLINK-1771] Add support for submitting single...

2015-03-31 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/542#discussion_r27456233 --- Diff: flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java --- @@ -89,15 +89,20 @@ public void setPrintStatusDuringExecution(boolean

[GitHub] flink pull request: [FLINK-1771] Add support for submitting single...

2015-03-31 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/542#discussion_r27456244 --- Diff: flink-clients/src/main/java/org/apache/flink/client/CliFrontend.java --- @@ -569,15 +590,33 @@ protected int executeProgram(PackagedProgram

[jira] [Commented] (FLINK-1771) Add support for submitting single jobs to a detached YARN session

2015-03-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388135#comment-14388135 ] ASF GitHub Bot commented on FLINK-1771: --- Github user rmetzger commented on a diff in

[GitHub] flink pull request: [FLINK-1771] Add support for submitting single...

2015-03-31 Thread rmetzger
Github user rmetzger commented on a diff in the pull request: https://github.com/apache/flink/pull/542#discussion_r27456228 --- Diff: flink-tests/src/test/scala/org/apache/flink/api/scala/operators/translation/CustomPartitioningGroupingTupleTest.scala --- @@ -18,12 +18,12 @@

[jira] [Resolved] (FLINK-1771) Add support for submitting single jobs to a detached YARN session

2015-03-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1771. --- Resolution: Fixed Fix Version/s: 0.9 Implemented in

[GitHub] flink pull request: [FLINK-1771] Add support for submitting single...

2015-03-31 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/542 --- 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] [Created] (FLINK-1807) Stochastic gradient descent optimizer for ML library

2015-03-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1807: Summary: Stochastic gradient descent optimizer for ML library Key: FLINK-1807 URL: https://issues.apache.org/jira/browse/FLINK-1807 Project: Flink Issue

[jira] [Created] (FLINK-1806) Improve S3 file system error message when no access/secret key provided

2015-03-31 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-1806: -- Summary: Improve S3 file system error message when no access/secret key provided Key: FLINK-1806 URL: https://issues.apache.org/jira/browse/FLINK-1806 Project: Flink

[jira] [Resolved] (FLINK-1806) Improve S3 file system error message when no access/secret key provided

2015-03-31 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-1806. Resolution: Fixed Fix Version/s: 0.9 Fixed in c0b2975. Improve S3 file system error

[jira] [Commented] (FLINK-1788) Extend Table API to allow logical plan optimisations

2015-03-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388324#comment-14388324 ] ASF GitHub Bot commented on FLINK-1788: --- GitHub user aljoscha opened a pull request:

[GitHub] flink pull request: [FLINK-1788] [table] Make logical plans transf...

2015-03-31 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/550 [FLINK-1788] [table] Make logical plans transformable You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink flinq-mutable-plans

[GitHub] flink pull request: Add --abbrev-ref to get the right branch name ...

2015-03-31 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/548#issuecomment-88071167 Looks good to merge --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[GitHub] flink pull request: [FLINK-1741][gelly] Adds Jaccard Similarity Me...

2015-03-31 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/544#issuecomment-88062186 Hey @andralungu, I'm not sure I understand what's the problem with reduceOnEdges and EmitOneEdgePerNode. Can you elaborate a little bit please? Thanks :) --- If your

[jira] [Commented] (FLINK-1741) Add Jaccard Similarity Metric Example

2015-03-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388427#comment-14388427 ] ASF GitHub Bot commented on FLINK-1741: --- Github user vasia commented on the pull

[jira] [Commented] (FLINK-1808) Omit sending checkpoint barriers when the execution graph is not running

2015-03-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388450#comment-14388450 ] ASF GitHub Bot commented on FLINK-1808: --- GitHub user senorcarbone opened a pull

[GitHub] flink pull request: [FLINK-1808] Send barrier requests only when t...

2015-03-31 Thread senorcarbone
GitHub user senorcarbone opened a pull request: https://github.com/apache/flink/pull/551 [FLINK-1808] Send barrier requests only when the execution graph is running This is a simple optimisation for the current StreamCheckpointCoordinator that makes it skip barriers whent he

[jira] [Updated] (FLINK-1052) Access to stdout and log information of Taskmanagers from the web interface

2015-03-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1052: -- Assignee: (was: Robert Metzger) Access to stdout and log information of Taskmanagers from

[jira] [Updated] (FLINK-1052) Access to stdout and log information of Taskmanagers from the web interface

2015-03-31 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1052: -- Component/s: Webfrontend Access to stdout and log information of Taskmanagers from the web

[GitHub] flink pull request: [FLINK-1741][gelly] Adds Jaccard Similarity Me...

2015-03-31 Thread vasia
Github user vasia commented on the pull request: https://github.com/apache/flink/pull/544#issuecomment-88104306 Yes, actually that is the correct behavior imo. I mean, if you have a directed edge [4, 5], 4 is the source and 5 is the target and these should not be swapped.

[GitHub] flink pull request: [FLINK-1718] Adds sparse matrix and sparse vec...

2015-03-31 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/539#issuecomment-88123548 I rebased the code on the current master and unified some of the tests. When Travis confirms that everything works and if there are no objections, I'll merge the PR.

[GitHub] flink pull request: [FLINK-1771] Add support for submitting single...

2015-03-31 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/542#issuecomment-88136878 Awesome! --- 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

[jira] [Created] (FLINK-1809) Add standard scaler to ML library

2015-03-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-1809: Summary: Add standard scaler to ML library Key: FLINK-1809 URL: https://issues.apache.org/jira/browse/FLINK-1809 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-1718) Add sparse vector and sparse matrix types to machine learning library

2015-03-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388671#comment-14388671 ] ASF GitHub Bot commented on FLINK-1718: --- Github user tillrohrmann commented on the

[jira] [Commented] (FLINK-1807) Stochastic gradient descent optimizer for ML library

2015-03-31 Thread Theodore Vasiloudis (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388616#comment-14388616 ] Theodore Vasiloudis commented on FLINK-1807: I think it would make sense to

[GitHub] flink pull request: [FLINK-1805]The class IOManagerAsync should us...

2015-03-31 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/546 --- 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 pull request: Add --abbrev-ref to get the right branch name ...

2015-03-31 Thread hsaputra
Github user hsaputra closed the pull request at: https://github.com/apache/flink/pull/548 --- 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-1805) The class IOManagerAsync(in org.apache.flink.runtime.io.disk.iomanager) should use its own Log

2015-03-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388825#comment-14388825 ] ASF GitHub Bot commented on FLINK-1805: --- Github user asfgit closed the pull request

[GitHub] flink pull request: Add --abbrev-ref to get the right branch name ...

2015-03-31 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/548#issuecomment-88171159 I saw some error with certain branch names, will check it out and retry the PR. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-1741) Add Jaccard Similarity Metric Example

2015-03-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388570#comment-14388570 ] ASF GitHub Bot commented on FLINK-1741: --- Github user vasia commented on the pull

[jira] [Commented] (FLINK-1771) Add support for submitting single jobs to a detached YARN session

2015-03-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388720#comment-14388720 ] ASF GitHub Bot commented on FLINK-1771: --- Github user hsaputra commented on the pull

[GitHub] flink pull request: [FLINK-1766]Fix the bug of equals function of ...

2015-03-31 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/511#issuecomment-88183433 LGTM. Will merge later today. 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

[jira] [Commented] (FLINK-1766) Fix the bug of equals function of FSKey

2015-03-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388971#comment-14388971 ] ASF GitHub Bot commented on FLINK-1766: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-1766) Fix the bug of equals function of FSKey

2015-03-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388912#comment-14388912 ] ASF GitHub Bot commented on FLINK-1766: --- Github user hsaputra commented on the pull

[jira] [Resolved] (FLINK-1766) Fix the bug of equals function of FSKey

2015-03-31 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra resolved FLINK-1766. -- Resolution: Cannot Reproduce committed to master. Thanks! Fix the bug of equals function of

[jira] [Resolved] (FLINK-1805) The class IOManagerAsync(in org.apache.flink.runtime.io.disk.iomanager) should use its own Log

2015-03-31 Thread Henry Saputra (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Henry Saputra resolved FLINK-1805. -- Resolution: Fixed Merge to master. Thanks! The class IOManagerAsync(in

[GitHub] flink pull request: [FLINK-1766]Fix the bug of equals function of ...

2015-03-31 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/511 --- 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 pull request: Add --abbrev-ref to get the right branch name ...

2015-03-31 Thread hsaputra
Github user hsaputra commented on the pull request: https://github.com/apache/flink/pull/552#issuecomment-88189532 Will push this EOD if no objection. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Commented] (FLINK-1794) Add test base for scalatest and adapt flink-ml test cases

2015-03-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14388506#comment-14388506 ] ASF GitHub Bot commented on FLINK-1794: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-1794] [test-utils] Adds test base for s...

2015-03-31 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/540 --- 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 pull request: [FLINK-1741][gelly] Adds Jaccard Similarity Me...

2015-03-31 Thread andralungu
Github user andralungu commented on the pull request: https://github.com/apache/flink/pull/544#issuecomment-88088234 Sure, I thought it was obvious from the ugly if :) In EmitOneEdgePerNode we have: public void flatMap(EdgeK, EV edge, CollectorTuple2K, EdgeK, EV

[jira] [Resolved] (FLINK-1794) Add test base for scalatest and adapt flink-ml test cases

2015-03-31 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-1794. -- Resolution: Fixed Fixed with b8aa49ce7d806c52183ab79c17c6024b60d0eaaf Add test base for

[jira] [Commented] (FLINK-1792) Improve TM Monitoring: CPU utilization, hide graphs by default and show summary only

2015-03-31 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14389510#comment-14389510 ] ASF GitHub Bot commented on FLINK-1792: --- GitHub user bhatsachin opened a pull

[GitHub] flink pull request: [FLINK-1792] TM Monitoring: CPU utilization, h...

2015-03-31 Thread bhatsachin
GitHub user bhatsachin opened a pull request: https://github.com/apache/flink/pull/553 [FLINK-1792] TM Monitoring: CPU utilization, hide graphs by default and show summary only Added CPU Load %, show/hide button for detailed graph and summary for the metrics You can merge this