[jira] [Resolved] (FLINK-2561) Sync Gelly Java and Scala APIs

2015-10-07 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2561. -- Resolution: Fixed > Sync Gelly Java and Scala APIs > -- > >

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

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

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

2015-10-07 Thread iampeter
Github user iampeter commented on the pull request: https://github.com/apache/flink/pull/1236#issuecomment-146320512 @aljoscha ok will do --- 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: Combination of Additions to the new Windowing ...

2015-10-07 Thread aljoscha
Github user aljoscha closed the pull request at: https://github.com/apache/flink/pull/1238 --- 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-2731][web-dashboard] Adds access to Job...

2015-10-07 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1233#issuecomment-146319734 @uce, the new web dashboard doesn't work with yarn yet. The files are not shipped with the jar. I'm confused why it isn't being done so. The old frontend's files

[jira] [Commented] (FLINK-2561) Sync Gelly Java and Scala APIs

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

[GitHub] flink pull request: [FLINK-2561] Adds gelly-scala examples

2015-10-07 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1211 --- 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-2749) CliFrontendAddressConfigurationTest fails on GCE

2015-10-07 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14947495#comment-14947495 ] Stephan Ewen commented on FLINK-2749: - We used Flink a lot on GCE, to the CLI seems to work there, so

[jira] [Commented] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set

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

[GitHub] flink pull request: [FLINK-2823][yarn] throw exception on file as ...

2015-10-07 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/1235#issuecomment-146330037 The Hadoop configuration may also be set through resource files in the classpath. IMHO throwing an exception is only acceptable when we're sure no configuration has been

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

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

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

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

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

2015-10-07 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/593#issuecomment-146121012 The build succeeded. How do we proceed? It would be very nice if we finally merge this. --- If your project is set up for it, you can reply to this email and have your

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

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

[GitHub] flink pull request: [FLINK-2591] Add configuration parameter for d...

2015-10-07 Thread willmiao
Github user willmiao commented on the pull request: https://github.com/apache/flink/pull/1121#issuecomment-146371570 @rmetzger : I'm sorry for the late reply, I have been on vacation last three weeks. I failed to find a nice way to "generate a flink-conf.yaml just for the test",

[GitHub] flink pull request: [FLINK-2798] Serve static files for the new we...

2015-10-07 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1222#issuecomment-146400367 I will wait until your pull request is merged to master. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-2798) Prepare new web dashboard for executing in on YARN

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

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

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

[jira] [Commented] (FLINK-2591) Add configuration parameter for default number of yarn containers

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

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

2015-10-07 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/1239 [FLINK-2808] Rework state abstraction and clean up task / operator internals This pull request fixes many related/intermixed issues. It was hard to split this into individual issues.

[jira] [Resolved] (FLINK-2785) Implement Graph's fromCsvReader in Gelly-Scala

2015-10-07 Thread Vasia Kalavri (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vasia Kalavri resolved FLINK-2785. -- Resolution: Done Fix Version/s: 0.10 > Implement Graph's fromCsvReader in Gelly-Scala >

[GitHub] flink pull request: [FLINK-2823][yarn] throw exception on file as ...

2015-10-07 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1235#issuecomment-146303645 I don't think that we can merge this change. We can not assume that file:/// is an invalid path. Also, I don't think there is a good way to check whether the hadoop

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

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

[jira] [Commented] (FLINK-2785) Implement Graph's fromCsvReader in Gelly-Scala

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

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

2015-10-07 Thread chiwanpark
Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/1220#discussion_r41378136 --- Diff: flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/nn/KNN.scala --- @@ -0,0 +1,298 @@ +/* + * Licensed to the Apache Software

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

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

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

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

[jira] [Commented] (FLINK-2790) Add high availability support for Yarn

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

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

2015-10-07 Thread Sachin Goel (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14946726#comment-14946726 ] Sachin Goel commented on FLINK-2730: Great. I will open a PR. > Add CPU/Network utilization graphs to

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

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

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

2015-10-07 Thread danielblazevski
Github user danielblazevski commented on the pull request: https://github.com/apache/flink/pull/1220#issuecomment-146175924 @chiwanpark, I could see if I can do a conversion from ListBuffer to Vector so that at least the constructor for the QuadTree is a Vector, which I agree is

[GitHub] flink pull request: Parameter Server: Distributed Key-Value store,...

2015-10-07 Thread sachingoel0101
Github user sachingoel0101 closed the pull request at: https://github.com/apache/flink/pull/1003 --- 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

[jira] [Commented] (FLINK-2790) Add high availability support for Yarn

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

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

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

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

2015-10-07 Thread mxm
Github user mxm commented on a diff in the pull request: https://github.com/apache/flink/pull/593#discussion_r41376580 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/BlobLibraryCacheManager.java --- @@ -124,7 +129,13 @@ public void

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

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

[GitHub] flink pull request: [FLINK-2785] [gelly] implements fromCsvReader ...

2015-10-07 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1205#issuecomment-146158372 Thanks for the fast update! Good to merge. I added a comment about the parameter order that could be addressed if you agree. --- If your project is set up for it,

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

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

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

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

[GitHub] flink pull request: Parameter Server: Distributed Key-Value store,...

2015-10-07 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1003#issuecomment-146178033 Sure. However, any further work will depend on finalizing the interface in #967 which has been idle for quite some time. --- If your project is set up for it,

[jira] [Closed] (FLINK-2801) Rework Storm Compatibility Tests

2015-10-07 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax closed FLINK-2801. -- Resolution: Duplicate > Rework Storm Compatibility Tests > > >

[jira] [Commented] (FLINK-2790) Add high availability support for Yarn

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

[jira] [Commented] (FLINK-2790) Add high availability support for Yarn

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

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

2015-10-07 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14946619#comment-14946619 ] Stephan Ewen commented on FLINK-2730: - This looks really nice, great work! Hope that we can check

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

2015-10-07 Thread mxm
Github user mxm commented on the pull request: https://github.com/apache/flink/pull/593#issuecomment-146159521 I went through the pull request again and it looks good. +1 for merging --- If your project is set up for it, you can reply to this email and have your reply appear

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

2015-10-07 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/593#discussion_r41379357 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/BlobLibraryCacheManager.java --- @@ -124,7 +129,13 @@ public void

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

2015-10-07 Thread sachingoel0101
GitHub user sachingoel0101 opened a pull request: https://github.com/apache/flink/pull/1236 [FLINK-2730][web-dashboard] Adds cpu and memory usage graphs. Screenshots: ![screenshot

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

2015-10-07 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1213#issuecomment-146150504 The code looks good. :-) I like the changes around the testing classes and the changes to the retrieval utils (that one I've looked into in more detail). I didn't check the

[jira] [Commented] (FLINK-2790) Add high availability support for Yarn

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

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

2015-10-07 Thread chiwanpark
Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/1220#discussion_r41378859 --- 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-2823) YARN client should report a proper exception if Hadoop Env variables are not set

2015-10-07 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14946602#comment-14946602 ] Maximilian Michels commented on FLINK-2823: --- We have had users struggling with this issue a

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

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

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

2015-10-07 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1213#issuecomment-146136443 I found the issue. My code did not properly reflected the methods `setKeepContainersAcrossApplicationAttempts` and `setAttemptFailuresValidityInterval`. With the

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

2015-10-07 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1213#issuecomment-146136479 Good catch @rmetzger :-) --- 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

[jira] [Commented] (FLINK-2066) Make delay between execution retries configurable

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

[jira] [Commented] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set

2015-10-07 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14946630#comment-14946630 ] Maximilian Michels commented on FLINK-2823: --- I think MapR FS comes with its own file system

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

2015-10-07 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1213#discussion_r41374461 --- Diff: flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingJobManagerLike.scala --- @@ -0,0 +1,367 @@ +/* + * Licensed to the

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

2015-10-07 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-2804: Assignee: Till Rohrmann (was: Ufuk Celebi) > Support blocking job submission with Job

[jira] [Commented] (FLINK-2790) Add high availability support for Yarn

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

[jira] [Commented] (FLINK-2790) Add high availability support for Yarn

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

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

2015-10-07 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1213#discussion_r41374493 --- Diff: flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingJobManagerLike.scala --- @@ -0,0 +1,367 @@ +/* + * Licensed to the

[GitHub] flink pull request: [FLINK-2798] Serve static files for the new we...

2015-10-07 Thread uce
Github user uce commented on the pull request: https://github.com/apache/flink/pull/1222#issuecomment-146151414 Note: We have to check the startup logic of my changes in the YARN case as well (either in this PR or the other one). --- If your project is set up for it, you can reply

[jira] [Commented] (FLINK-2798) Prepare new web dashboard for executing in on YARN

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

[GitHub] flink pull request: [FLINK-2767] [scala shell] Add Scala 2.11 supp...

2015-10-07 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1197#issuecomment-146151202 Thanks for the update @chiwanpark! LGTM, will merge it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[GitHub] flink pull request: [FLINK-2823][yarn] throw exception on file as ...

2015-10-07 Thread mxm
GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/1235 [FLINK-2823][yarn] throw exception on file as default file system Without a distributed file system, Flink cannot distribute its files correctly. Thus, we can throw an exception in case we discover

[jira] [Commented] (FLINK-2767) Add support Scala 2.11 to Scala shell

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

[jira] [Commented] (FLINK-2785) Implement Graph's fromCsvReader in Gelly-Scala

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

[GitHub] flink pull request: [FLINK-2785] [gelly] implements fromCsvReader ...

2015-10-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1205#discussion_r41377804 --- Diff: flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala --- @@ -126,6 +126,131 @@ object Graph {

[jira] [Commented] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set

2015-10-07 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14946615#comment-14946615 ] Stephan Ewen commented on FLINK-2823: - +1 for an exception Logging is good, but experience shows many

[jira] [Commented] (FLINK-2790) Add high availability support for Yarn

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

[jira] [Assigned] (FLINK-2747) TypeExtractor does not correctly analyze Scala Immutables (AnyVal)

2015-10-07 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-2747: --- Assignee: Aljoscha Krettek > TypeExtractor does not correctly analyze Scala

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

2015-10-07 Thread danielblazevski
Github user danielblazevski commented on the pull request: https://github.com/apache/flink/pull/1220#issuecomment-146175315 @chiwanpark, in lines 203-207 + val useQuadTree = resultParameters.get(useQuadTreeParam).getOrElse( +

[jira] [Created] (FLINK-2828) Add interfaces for Table API input formats

2015-10-07 Thread Timo Walther (JIRA)
Timo Walther created FLINK-2828: --- Summary: Add interfaces for Table API input formats Key: FLINK-2828 URL: https://issues.apache.org/jira/browse/FLINK-2828 Project: Flink Issue Type: New

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

2015-10-07 Thread aljoscha
Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/1236#issuecomment-146191633 Wow, the screenshots look super nice. :smile: Someone with knowledge about the new web fronted should probably review the code, though. --- If your project

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

2015-10-07 Thread tillrohrmann
Github user tillrohrmann commented on the pull request: https://github.com/apache/flink/pull/1236#issuecomment-146193617 Really cool graphs Sachin :-) Looking forward monitoring my Flink jobs with these graphs. On Wed, Oct 7, 2015 at 3:10 PM, Aljoscha Krettek

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

2015-10-07 Thread sachingoel0101
Github user sachingoel0101 commented on the pull request: https://github.com/apache/flink/pull/1236#issuecomment-146193727 Thanks. :) Although there's not much to review here. :') It's mostly a rearrangement of existing content, with a major addition in `taskmanager.ctrl.coffee`

[jira] [Commented] (FLINK-2561) Sync Gelly Java and Scala APIs

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

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

2015-10-07 Thread chiwanpark
Github user chiwanpark commented on the pull request: https://github.com/apache/flink/pull/1220#issuecomment-146202529 It sounds weird for me. If the user sets `useQuadTree` to false, the algorithm should not use quadtree. Otherwise if the user sets `useQuadTree` to true, the

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

2015-10-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1233#discussion_r41393269 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebRuntimeMonitor.java --- @@ -276,4 +294,18 @@ public int getServerPort() {

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

2015-10-07 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/1233#discussion_r41393573 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/files/StaticFileServerHandler.java --- @@ -123,9 +124,18 @@ public void

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

2015-10-07 Thread uce
Github user uce commented on a diff in the pull request: https://github.com/apache/flink/pull/1233#discussion_r41393603 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebRuntimeMonitor.java --- @@ -276,4 +294,18 @@ public int getServerPort() {

[jira] [Commented] (FLINK-2066) Make delay between execution retries configurable

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

[GitHub] flink pull request: [FLINK-2066][core] Add delay between execution...

2015-10-07 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1223 --- 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] [Closed] (FLINK-2767) Add support Scala 2.11 to Scala shell

2015-10-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-2767. Resolution: Fixed Fix Version/s: 0.10 Implemented via

[jira] [Commented] (FLINK-2561) Sync Gelly Java and Scala APIs

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

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

2015-10-07 Thread ktzoumas
Github user ktzoumas commented on the pull request: https://github.com/apache/flink/pull/1208#issuecomment-146203981 Once https://github.com/apache/flink/pull/1238 is merged, this is ready to be merged as well (the docs track the changes in that PR) --- If your project is set up for

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

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

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

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

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

2015-10-07 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1213#discussion_r41387700 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnClientBase.java --- @@ -0,0 +1,867 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-2790) Add high availability support for Yarn

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

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

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

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

2015-10-07 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1213#discussion_r41387623 --- Diff: flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingJobManagerLike.scala --- @@ -0,0 +1,367 @@ +/* + * Licensed

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

2015-10-07 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1213#discussion_r41387670 --- Diff: flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingTaskManagerLike.scala --- @@ -0,0 +1,222 @@ +/* + *

[jira] [Commented] (FLINK-2790) Add high availability support for Yarn

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

[jira] [Commented] (FLINK-2561) Sync Gelly Java and Scala APIs

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

[GitHub] flink pull request: [FLINK-2561] Adds gelly-scala examples

2015-10-07 Thread fhueske
Github user fhueske commented on the pull request: https://github.com/apache/flink/pull/1211#issuecomment-146200483 The examples look good. But the indention of the Scala code is quite different from the remaining Flink Scala code. Is the remaining Gelly Scala code formatted in

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

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

[jira] [Commented] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set

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

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

2015-10-07 Thread twalthr
Github user twalthr commented on the pull request: https://github.com/apache/flink/pull/593#issuecomment-146192177 Do we need another committers +1? It touches very sensitive parts... --- If your project is set up for it, you can reply to this email and have your reply appear on

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

2015-10-07 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/1213#discussion_r41387583 --- Diff: flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingJobManagerLike.scala --- @@ -0,0 +1,367 @@ +/* + * Licensed

  1   2   3   >