[GitHub] flink pull request: Stale Synchronous Parallel Iterations

2016-01-19 Thread nltran
Github user nltran commented on the pull request: https://github.com/apache/flink/pull/967#issuecomment-172786594 An ecosystem of 3rd party libraries for Flink makes sense to me. That would be a good place for experimental features (à la Google Labs back in its time) that are

[GitHub] flink pull request: Stale Synchronous Parallel Iterations

2016-01-05 Thread nltran
Github user nltran commented on the pull request: https://github.com/apache/flink/pull/967#issuecomment-168965380 Hello guys, Do you have any plans or updates on this one? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[GitHub] flink pull request: Stale Synchronous Parallel Iterations

2015-08-31 Thread nltran
Github user nltran commented on a diff in the pull request: https://github.com/apache/flink/pull/967#discussion_r38295439 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/iterative/event/EventWithAggregatorsTest.java --- @@ -123,6 +169,31 @@ private

[GitHub] flink pull request: Stale Synchronous Parallel Iterations

2015-08-20 Thread nltran
Github user nltran commented on the pull request: https://github.com/apache/flink/pull/967#issuecomment-132935694 @StephanEwen Both interfaces for the parameter and the parameter server are quite similar. The things I see are the following: - The parameter server code is

[GitHub] flink pull request: Stale Synchronous Parallel Iterations

2015-08-13 Thread nltran
Github user nltran commented on the pull request: https://github.com/apache/flink/pull/967#issuecomment-130734997 The code now passes all the checks :smiley: I have addressed the previous comments you made previously. @StephanEwen , @fhueske could you give it a another review

[GitHub] flink pull request: Stale Synchronous Parallel Iterations

2015-08-05 Thread nltran
Github user nltran commented on a diff in the pull request: https://github.com/apache/flink/pull/967#discussion_r36280226 --- Diff: flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate/JobGraphGenerator.java --- @@ -920,15 +928,33 @@ private JobVertex

[GitHub] flink pull request: Stale Synchronous Parallel Iterations

2015-08-03 Thread nltran
Github user nltran commented on the pull request: https://github.com/apache/flink/pull/967#issuecomment-127257276 Thank you for your feedback! I think this is a fine way to go. I will then provide the parameter server related code in a different module and include an example

[GitHub] flink pull request: Stale Synchronous Parallel Iterations

2015-08-03 Thread nltran
Github user nltran commented on the pull request: https://github.com/apache/flink/pull/967#issuecomment-127220430 >The code includes Apache Ignite as a parameter server. Is it possible to make this independent of Ignite? I know that SSP is usually used in parameter server ML setti

[GitHub] flink pull request: Stale Synchronous Parallel Iterations

2015-07-31 Thread nltran
GitHub user nltran opened a pull request: https://github.com/apache/flink/pull/967 Stale Synchronous Parallel Iterations Here is a pull request containing our development on [Stale Synchronous Parallel (SSP)](http://reports-archive.adm.cs.cmu.edu/anon/ml2013/CMU-ML-13-103.pdf

[GitHub] flink pull request: IntelliJ Setup Guide

2015-03-12 Thread nltran
GitHub user nltran opened a pull request: https://github.com/apache/flink/pull/480 IntelliJ Setup Guide Following my interactions with fhueske on the IRC channel, I summarized the steps to correctly setup IntelliJ with flink core. You can merge this pull request into a Git