[jira] [Commented] (FLINK-2156) Scala modules cannot create logging file

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948236#comment-14948236 ] ASF GitHub Bot commented on FLINK-2156: --- Github user tillrohrmann commented on the pull request:

[GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al...

2015-10-08 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1220#discussion_r41492356 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/nn/QuadTree.scala --- @@ -0,0 +1,305 @@ + +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

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

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

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

[GitHub] flink pull request: [FLINK-2611] YARN reports failed final state f...

2015-10-08 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/1240 [FLINK-2611] YARN reports failed final state for successful jobs You can merge this pull request into a Git repository by running: $ git pull https://github.com/mxm/flink FLINK-2611

[jira] [Commented] (FLINK-2611) YARN reports failed final state for successful jobs

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948371#comment-14948371 ] ASF GitHub Bot commented on FLINK-2611: --- GitHub user mxm opened a pull request:

[GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al...

2015-10-08 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1220#issuecomment-146474169 A more scalaesque solution for the `partitionBox` method without using vars and for loops would be ``` def partitionBox(center: Vector, width: Vector):

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948385#comment-14948385 ] ASF GitHub Bot commented on FLINK-1745: --- Github user tillrohrmann commented on the pull request:

[jira] [Commented] (FLINK-2808) Rework / Extend the StatehandleProvider

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948368#comment-14948368 ] ASF GitHub Bot commented on FLINK-2808: --- Github user senorcarbone commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2808] Rework state abstraction and clea...

2015-10-08 Thread senorcarbone
Github user senorcarbone commented on a diff in the pull request: https://github.com/apache/flink/pull/1239#discussion_r41493576 --- Diff: flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java --- @@ -322,73

[jira] [Commented] (FLINK-2731) Add JobManager log file access

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948158#comment-14948158 ] ASF GitHub Bot commented on FLINK-2731: --- Github user sachingoel0101 commented on the pull request:

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

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

[jira] [Commented] (FLINK-2808) Rework / Extend the StatehandleProvider

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948376#comment-14948376 ] ASF GitHub Bot commented on FLINK-2808: --- Github user senorcarbone commented on the pull request:

[jira] [Commented] (FLINK-2730) Add CPU/Network utilization graphs to new web dashboard

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948187#comment-14948187 ] ASF GitHub Bot commented on FLINK-2730: --- Github user sachingoel0101 commented on the pull request:

[GitHub] flink pull request: [FLINK-2156] Scala modules cannot create loggi...

2015-10-08 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1234#issuecomment-146449913 FlinkML uses scalatest to run its tests. Scalatest didn't use the fork number and simply executed all tests sequentially. This shouldn't be a big problem,

[GitHub] flink pull request: [FLINK-1789] [core] [runtime] [java-api] Allow...

2015-10-08 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/593#discussion_r41488791 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/RemoteEnvironment.java --- @@ -55,21 +59,8 @@ /** Optional shutdown hook, used in session

[jira] [Commented] (FLINK-1789) Allow adding of URLs to the usercode class loader

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948287#comment-14948287 ] ASF GitHub Bot commented on FLINK-1789: --- Github user mxm commented on a diff in the pull request:

[GitHub] flink pull request: [FLINK-2808] Rework state abstraction and clea...

2015-10-08 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/1239#issuecomment-146465524 Overall looks very good. :+1: I personally like having the non-partitioned operator states and I use them in my programs, so I would prefer keeping them. ---

[jira] [Commented] (FLINK-2156) Scala modules cannot create logging file

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948336#comment-14948336 ] ASF GitHub Bot commented on FLINK-2156: --- Github user chiwanpark commented on the pull request:

[GitHub] flink pull request: [FLINK-2156] Scala modules cannot create loggi...

2015-10-08 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1234#issuecomment-146465380 If we need to parallelize tests run by scalatest, the test cases should extend

[GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al...

2015-10-08 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1220#discussion_r41492287 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/nn/QuadTree.scala --- @@ -0,0 +1,305 @@ + +/* + * Licensed to the Apache

[GitHub] flink pull request: [FLINK-2730][web-dashboard] Adds cpu and memor...

2015-10-08 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1236#issuecomment-146439447 @aljoscha FYI I've added a new Job Manager message which returns the metrics only for one particular instance to minimize unnecessary traffic for a single

[GitHub] flink pull request: [FLINK-1789] [core] [runtime] [java-api] Allow...

2015-10-08 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/593#issuecomment-146460197 +1 for removing the factory methods from ExecutionEnvironment. Most users won't even think about using this feature and be rather confused by the additional methods. Let's

[jira] [Commented] (FLINK-2730) Add CPU/Network utilization graphs to new web dashboard

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948171#comment-14948171 ] ASF GitHub Bot commented on FLINK-2730: --- Github user aljoscha commented on the pull request:

[GitHub] flink pull request: [FLINK-2730][web-dashboard] Adds cpu and memor...

2015-10-08 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1236#issuecomment-146438040 Thanks for the review @iampeter :smile: --- 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 pull request: [FLINK-2730][web-dashboard] Adds cpu and memor...

2015-10-08 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1236#issuecomment-146439104 @iampeter , thanks for the review. I've addressed all your comments. I removed the `No such task ...` thing entirely. It doesn't have a use case anyways. We

[jira] [Commented] (FLINK-2730) Add CPU/Network utilization graphs to new web dashboard

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948182#comment-14948182 ] ASF GitHub Bot commented on FLINK-2730: --- Github user sachingoel0101 commented on the pull request:

[GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al...

2015-10-08 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1220#discussion_r41491996 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/nn/QuadTree.scala --- @@ -0,0 +1,305 @@ + +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-2808) Rework / Extend the StatehandleProvider

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948347#comment-14948347 ] ASF GitHub Bot commented on FLINK-2808: --- Github user gyfora commented on the pull request:

[GitHub] flink pull request: [FLINK-2808] Rework state abstraction and clea...

2015-10-08 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/1239#issuecomment-146467354 So my argument is that the overhead of implementing the Checkpointed interface for simple counters , offsets and the like is simply too much (and annoying). We

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

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

[jira] [Created] (FLINK-2833) Unstage Gelly and Module refactoring

2015-10-08 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-2833: Summary: Unstage Gelly and Module refactoring Key: FLINK-2833 URL: https://issues.apache.org/jira/browse/FLINK-2833 Project: Flink Issue Type: Task

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

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

[GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al...

2015-10-08 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1220#discussion_r41492452 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/nn/QuadTree.scala --- @@ -0,0 +1,305 @@ + +/* + * Licensed to the Apache

[GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al...

2015-10-08 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1220#discussion_r41492529 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/nn/QuadTree.scala --- @@ -0,0 +1,305 @@ + +/* + * Licensed to the Apache

[GitHub] flink pull request: [FLINK-2731][web-dashboard] Adds access to Job...

2015-10-08 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1233#issuecomment-146433225 @rmetzger , I looked at your changes to enable the dashboard on yarn. Looks good. :) A few comments to make sure this PR can directly start working after

[jira] [Commented] (FLINK-2808) Rework / Extend the StatehandleProvider

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948337#comment-14948337 ] ASF GitHub Bot commented on FLINK-2808: --- Github user gyfora commented on the pull request:

[GitHub] flink pull request: [FLINK-2808] Rework state abstraction and clea...

2015-10-08 Thread senorcarbone
Github user senorcarbone commented on the pull request: https://github.com/apache/flink/pull/1239#issuecomment-146472181 on a related note, is anyone planning to complete snapshotting for cyclc graphs for the 0.10 release? Unfortunately I do not have time to work on it this week but

[jira] [Commented] (FLINK-2730) Add CPU/Network utilization graphs to new web dashboard

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948185#comment-14948185 ] ASF GitHub Bot commented on FLINK-2730: --- Github user sachingoel0101 commented on the pull request:

[jira] [Commented] (FLINK-2779) Update documentation to reflect new Stream/Window API

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948328#comment-14948328 ] ASF GitHub Bot commented on FLINK-2779: --- Github user fhueske commented on the pull request:

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

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

[jira] [Commented] (FLINK-2611) YARN reports failed final state for successful jobs

2015-10-08 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948343#comment-14948343 ] Maximilian Michels commented on FLINK-2611: --- The CliFrontend doesn't shutdown the YarnCluster

[jira] [Commented] (FLINK-2731) Add JobManager log file access

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948382#comment-14948382 ] ASF GitHub Bot commented on FLINK-2731: --- Github user sachingoel0101 commented on the pull request:

[GitHub] flink pull request: [FLINK-2731][web-dashboard] Adds access to Job...

2015-10-08 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1233#issuecomment-146473400 @uce Since the web frontend isn't integrated yet, I have verified correct logs directory paths by examining container logs by deploying on yarn. This will now

[jira] [Commented] (FLINK-2779) Update documentation to reflect new Stream/Window API

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948431#comment-14948431 ] ASF GitHub Bot commented on FLINK-2779: --- Github user ktzoumas commented on the pull request:

[jira] [Commented] (FLINK-2808) Rework / Extend the StatehandleProvider

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948437#comment-14948437 ] ASF GitHub Bot commented on FLINK-2808: --- Github user gyfora commented on the pull request:

[GitHub] flink pull request: [FLINK-2808] Rework state abstraction and clea...

2015-10-08 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/1239#issuecomment-146486097 Other important thing: I think it would be very useful to add some extra context information to the snapshot methods. Something that can be used to identify the

[GitHub] flink pull request: [FLINK-2808] Rework state abstraction and clea...

2015-10-08 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/1239#issuecomment-146486750 I can live without the non-partitioned OperatorStates, but the context info for the snapshots is very hard to work around I think. --- If your project is set up for it,

[GitHub] flink pull request: [FLINK-2613] Print usage information for Scala...

2015-10-08 Thread chiwanpark
Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/1106#discussion_r41503795 --- Diff: flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala --- @@ -68,38 +94,62 @@ object FlinkShell {

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948534#comment-14948534 ] ASF GitHub Bot commented on FLINK-2613: --- Github user chiwanpark commented on a diff in the pull

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948533#comment-14948533 ] ASF GitHub Bot commented on FLINK-2613: --- Github user chiwanpark commented on a diff in the pull

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948531#comment-14948531 ] ASF GitHub Bot commented on FLINK-2613: --- Github user chiwanpark commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2613] Print usage information for Scala...

2015-10-08 Thread chiwanpark
Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/1106#discussion_r41503815 --- Diff: flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala --- @@ -68,38 +94,62 @@ object FlinkShell {

[GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al...

2015-10-08 Thread danielblazevski
Github user danielblazevski commented on the pull request: https://github.com/apache/flink/pull/1220#issuecomment-146519265 Thanks a lot @tillrohrmann, will make adjustments in the next few days. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948558#comment-14948558 ] ASF GitHub Bot commented on FLINK-2613: --- Github user chiwanpark commented on the pull request:

[jira] [Commented] (FLINK-1966) Add support for predictive model markup language (PMML)

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948428#comment-14948428 ] ASF GitHub Bot commented on FLINK-1966: --- Github user chiwanpark commented on a diff in the pull

[GitHub] flink pull request: [FLINK-1966][ml]Add support for Predictive Mod...

2015-10-08 Thread chiwanpark
Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/1186#discussion_r41496701 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/SVM.scala --- @@ -18,23 +18,20 @@ package

[GitHub] flink pull request: [FLINK-1966][ml]Add support for Predictive Mod...

2015-10-08 Thread chiwanpark
Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/1186#discussion_r41497880 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/regression/MultipleLinearRegression.scala --- @@ -124,6 +121,52 @@ class

[jira] [Commented] (FLINK-1966) Add support for predictive model markup language (PMML)

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948446#comment-14948446 ] ASF GitHub Bot commented on FLINK-1966: --- Github user chiwanpark commented on a diff in the pull

[GitHub] flink pull request: [FLINK-1966][ml]Add support for Predictive Mod...

2015-10-08 Thread chiwanpark
Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/1186#discussion_r41497844 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/regression/MultipleLinearRegression.scala --- @@ -18,15 +18,12 @@ package

[jira] [Commented] (FLINK-1966) Add support for predictive model markup language (PMML)

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948444#comment-14948444 ] ASF GitHub Bot commented on FLINK-1966: --- Github user chiwanpark commented on a diff in the pull

[jira] [Commented] (FLINK-2804) Support blocking job submission with Job Manager recovery

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948489#comment-14948489 ] ASF GitHub Bot commented on FLINK-2804: --- Github user uce commented on the pull request:

[GitHub] flink pull request: [FLINK-2804] [client, runtime] Add blocking jo...

2015-10-08 Thread uce
Github user uce closed the pull request at: https://github.com/apache/flink/pull/1230 --- 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-2804] [client, runtime] Add blocking jo...

2015-10-08 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1230#issuecomment-146507072 Closing this in favour of Tills upcoming 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-2804) Support blocking job submission with Job Manager recovery

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948490#comment-14948490 ] ASF GitHub Bot commented on FLINK-2804: --- Github user uce closed the pull request at:

[GitHub] flink pull request: [FLINK-2613] Print usage information for Scala...

2015-10-08 Thread chiwanpark
Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/1106#discussion_r41503634 --- Diff: flink-staging/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala --- @@ -18,48 +18,74 @@ package

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948529#comment-14948529 ] ASF GitHub Bot commented on FLINK-2613: --- Github user chiwanpark commented on a diff in the pull

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948526#comment-14948526 ] ASF GitHub Bot commented on FLINK-2613: --- Github user chiwanpark commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2576] Add Outer Join operator to Optimi...

2015-10-08 Thread r-pogalz
Github user r-pogalz commented on a diff in the pull request: https://github.com/apache/flink/pull/1138#discussion_r41505034 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/base/OuterJoinOperatorBase.java --- @@ -0,0 +1,314 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-2611) YARN reports failed final state for successful jobs

2015-10-08 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948589#comment-14948589 ] Maximilian Michels commented on FLINK-2611: --- Turns out, the YarnCluster is shutdown correctly. I

[jira] [Comment Edited] (FLINK-2611) YARN reports failed final state for successful jobs

2015-10-08 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948589#comment-14948589 ] Maximilian Michels edited comment on FLINK-2611 at 10/8/15 12:32 PM: -

[GitHub] flink pull request: [FLINK-2833] [gelly] unstage Gelly and move to...

2015-10-08 Thread vasia
GitHub user vasia opened a pull request: https://github.com/apache/flink/pull/1241 [FLINK-2833] [gelly] unstage Gelly and move to flink-libraries You can merge this pull request into a Git repository by running: $ git pull https://github.com/vasia/flink gelly-restructure

[jira] [Commented] (FLINK-1966) Add support for predictive model markup language (PMML)

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948475#comment-14948475 ] ASF GitHub Bot commented on FLINK-1966: --- Github user sachingoel0101 commented on the pull request:

[GitHub] flink pull request: [FLINK-1966][ml]Add support for Predictive Mod...

2015-10-08 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1186#issuecomment-146501909 The PMML model is quite extensive, and there isn't enough support in the ML library for utilizing most of the things [like FieldUsageType, DataTypes etc.]. I had

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948493#comment-14948493 ] ASF GitHub Bot commented on FLINK-2613: --- Github user nikste commented on the pull request:

[GitHub] flink pull request: [FLINK-2808] Rework state abstraction and clea...

2015-10-08 Thread senorcarbone
Github user senorcarbone commented on the pull request: https://github.com/apache/flink/pull/1239#issuecomment-146511645 @ktzoumas that's understandable! We could consider it for the maintenance release maybe if there is enough time --- If your project is set up for it, you can

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948545#comment-14948545 ] ASF GitHub Bot commented on FLINK-2613: --- Github user chiwanpark commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2613] Print usage information for Scala...

2015-10-08 Thread chiwanpark
Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/1106#discussion_r41504281 --- Diff: flink-staging/flink-scala-shell/src/test/scala/org/apache/flink/api/scala/ScalaShellITSuite.scala --- @@ -225,8 +223,50 @@ class

[jira] [Commented] (FLINK-2576) Add outer joins to API and Optimizer

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948555#comment-14948555 ] ASF GitHub Bot commented on FLINK-2576: --- Github user r-pogalz commented on a diff in the pull

[jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948559#comment-14948559 ] ASF GitHub Bot commented on FLINK-1745: --- Github user danielblazevski commented on the pull request:

[GitHub] flink pull request: [FLINK-2613] Print usage information for Scala...

2015-10-08 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1106#issuecomment-146519237 Hi @nikste, thanks for update. It looks good to merge except some style issues. --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink pull request: [FLINK-2613] Print usage information for Scala...

2015-10-08 Thread nikste
Github user nikste commented on the pull request: https://github.com/apache/flink/pull/1106#issuecomment-146520283 @chiwanpark, white line issues are now fixed. --- 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-2613) Print usage information for Scala Shell

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948571#comment-14948571 ] ASF GitHub Bot commented on FLINK-2613: --- Github user nikste commented on the pull request:

[GitHub] flink pull request: [FLINK-2790] [yarn] [ha] Adds high availabilit...

2015-10-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1213 --- 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] [Resolved] (FLINK-2790) Add high availability support for Yarn

2015-10-08 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-2790. Resolution: Fixed Fixed via fa2bb8f > Add high availability support for Yarn >

[GitHub] flink pull request: [FLINK-2611] YARN reports failed final state f...

2015-10-08 Thread mxm
Github user mxm closed the pull request at: https://github.com/apache/flink/pull/1240 --- 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-1966) Add support for predictive model markup language (PMML)

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948447#comment-14948447 ] ASF GitHub Bot commented on FLINK-1966: --- Github user chiwanpark commented on a diff in the pull

[jira] [Commented] (FLINK-1966) Add support for predictive model markup language (PMML)

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948455#comment-14948455 ] ASF GitHub Bot commented on FLINK-1966: --- Github user chiwanpark commented on a diff in the pull

[GitHub] flink pull request: [FLINK-2808] Rework state abstraction and clea...

2015-10-08 Thread gyfora
Github user gyfora commented on the pull request: https://github.com/apache/flink/pull/1239#issuecomment-146507802 Also in the StateBackend interface a close method would come in handy, similarly to the initialize to close connections etc. in case of failures. --- If your project is

[jira] [Commented] (FLINK-2808) Rework / Extend the StatehandleProvider

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948496#comment-14948496 ] ASF GitHub Bot commented on FLINK-2808: --- Github user gyfora commented on the pull request:

[jira] [Commented] (FLINK-2611) YARN reports failed final state for successful jobs

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948586#comment-14948586 ] ASF GitHub Bot commented on FLINK-2611: --- Github user mxm closed the pull request at:

[jira] [Commented] (FLINK-2833) Unstage Gelly and Module refactoring

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948402#comment-14948402 ] ASF GitHub Bot commented on FLINK-2833: --- GitHub user vasia opened a pull request:

[GitHub] flink pull request: [FLINK-2779][FLINK-2794][streaming][docs] New ...

2015-10-08 Thread ktzoumas
Github user ktzoumas commented on the pull request: https://github.com/apache/flink/pull/1208#issuecomment-146484570 Thanks a lot Fabian for the fantastic review! I addressed most of your comments. The state section needs to be rewritten after

[GitHub] flink pull request: [FLINK-1966][ml]Add support for Predictive Mod...

2015-10-08 Thread chiwanpark
Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/1186#discussion_r41498327 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/regression/MultipleLinearRegression.scala --- @@ -124,6 +121,52 @@ class

[jira] [Commented] (FLINK-2808) Rework / Extend the StatehandleProvider

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948454#comment-14948454 ] ASF GitHub Bot commented on FLINK-2808: --- Github user ktzoumas commented on the pull request:

[GitHub] flink pull request: [FLINK-2808] Rework state abstraction and clea...

2015-10-08 Thread ktzoumas
Github user ktzoumas commented on the pull request: https://github.com/apache/flink/pull/1239#issuecomment-146490272 @senorcarbone I think the cyclic graphs feature will be hard to get into 0.10 --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (FLINK-1966) Add support for predictive model markup language (PMML)

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948453#comment-14948453 ] ASF GitHub Bot commented on FLINK-1966: --- Github user chiwanpark commented on a diff in the pull

[jira] [Commented] (FLINK-1966) Add support for predictive model markup language (PMML)

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948461#comment-14948461 ] ASF GitHub Bot commented on FLINK-1966: --- Github user chiwanpark commented on the pull request:

[jira] [Commented] (FLINK-2808) Rework / Extend the StatehandleProvider

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948515#comment-14948515 ] ASF GitHub Bot commented on FLINK-2808: --- Github user senorcarbone commented on the pull request:

[jira] [Commented] (FLINK-2613) Print usage information for Scala Shell

2015-10-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14948530#comment-14948530 ] ASF GitHub Bot commented on FLINK-2613: --- Github user chiwanpark commented on a diff in the pull

  1   2   3   >