[5/7] flink git commit: [FLINK-2050] [ml] Ports existing ML algorithms to new pipeline mechanism

http://git-wip-us.apache.org/repos/asf/flink/blob/1e574750/flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/recommendation/ALS.scala -- diff --git

[2/7] flink git commit: [FLINK-2034] [ml] [docs] Adds FlinkML web documentation (introduction, vision, roadmap)

[FLINK-2034] [ml] [docs] Adds FlinkML web documentation (introduction, vision, roadmap) Also added attribution for some of the Latex in optimization framework. This closes #688. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[4/7] flink git commit: [FLINK-2050] [ml] Ports existing ML algorithms to new pipeline mechanism

http://git-wip-us.apache.org/repos/asf/flink/blob/1e574750/flink-tests/src/test/java/org/apache/flink/test/recordJobTests/TPCHQuery3WithUnionITCase.java -- diff --git

[3/7] flink git commit: [FLINK-2050] [ml] Introduces new pipelining mechanism using implicit classes to wrap the algorithm logic

[FLINK-2050] [ml] Introduces new pipelining mechanism using implicit classes to wrap the algorithm logic This closes #704. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fde0341f Tree:

[1/7] flink git commit: [FLINK-1992] [ml] Adds convergence criterion to Flink's SGD algorithm

Repository: flink Updated Branches: refs/heads/master 35ea6505c - 1e574750d [FLINK-1992] [ml] Adds convergence criterion to Flink's SGD algorithm Added test case for convergence This closes #692. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[6/7] flink git commit: [FLINK-2050] [ml] Ports existing ML algorithms to new pipeline mechanism

http://git-wip-us.apache.org/repos/asf/flink/blob/1e574750/flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/experimental/Transformer.scala -- diff --git

[2/2] flink git commit: [FLINK-1954] [FLINK-1636] [runtime] Improve partition not found error handling

[FLINK-1954] [FLINK-1636] [runtime] Improve partition not found error handling Problem: cancelling of tasks sometimes leads to misleading error messages about not found partitions. This is an artifact of task cancelling. If a task (consumer) consumes data from another remote task (producer), its

[1/2] flink git commit: [FLINK-1954] [FLINK-1636] [runtime] Improve partition not found error handling

Repository: flink Updated Branches: refs/heads/master 1e574750d - 1aad5b759 http://git-wip-us.apache.org/repos/asf/flink/blob/1aad5b75/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerTest.java -- diff

flink git commit: [streaming] Minor bugfix in the BarrierBuffer input finishing logic

Repository: flink Updated Branches: refs/heads/master 1aad5b759 - 36c2026fb [streaming] Minor bugfix in the BarrierBuffer input finishing logic Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/36c2026f Tree: