[1/4] flink git commit: [FLINK-1415] [runtime] Akka cleanups

2015-02-05 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 63720634e - 4046819b3 http://git-wip-us.apache.org/repos/asf/flink/blob/4046819b/flink-staging/flink-streaming/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamJoinOperator.scala

[2/2] flink git commit: [FLINK-1481] Fixes flakey JobManagerITCase which relied on non-deterministic behaviour.

2015-02-05 Thread trohrmann
[FLINK-1481] Fixes flakey JobManagerITCase which relied on non-deterministic behaviour. This closes #365. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0ccd1fd5 Tree:

[1/2] flink git commit: [runtime] Enables remote communication for local standalone cluster mode which is required by the JobClient.

2015-02-05 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 140faa945 - 0ccd1fd5b [runtime] Enables remote communication for local standalone cluster mode which is required by the JobClient. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-1491] [runtime] Fixes logging output by setting Akka's stdout logger to log level WARNING.

2015-02-11 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 82cda12ef - 90834ca70 [FLINK-1491] [runtime] Fixes logging output by setting Akka's stdout logger to log level WARNING. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [runtime] Corrects messages sent to the JobManager by the JobManagerInfoServlet

2015-02-11 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 1e9b68164 - bec9c4dae [runtime] Corrects messages sent to the JobManager by the JobManagerInfoServlet Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bec9c4da Tree:

[3/3] flink git commit: [FLINK-1556] [runtime] Corrects faulty JobClient behaviour in case of a submission failure

2015-02-17 Thread trohrmann
[FLINK-1556] [runtime] Corrects faulty JobClient behaviour in case of a submission failure Fixes unhandled FailsIntermediateResultPartitions message. Changes JobResultFailed and JobResultCanceled to send the cause as a throwable instead of a string. Fixes NullPointerException if an execution

[1/3] flink git commit: [FLINK-1549] [yarn] Adds proper exception handling to YarnJobManager

2015-02-17 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master c1e326707 - ac7bf4279 [FLINK-1549] [yarn] Adds proper exception handling to YarnJobManager This closes #397. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/447ce0aa

[2/2] flink git commit: [avro] Cleaning up project structure

2015-02-12 Thread trohrmann
[avro] Cleaning up project structure Updates .gitignore to ignore generated files Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/90ab2bb4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/90ab2bb4 Diff:

[1/2] flink git commit: [FLINK-1531] [runtime] Adds proper EOFException forwarding to KryoSerializer.

2015-02-12 Thread trohrmann
Repository: flink Updated Branches: refs/heads/release-0.8 10f89c73b - 90ab2bb4b [FLINK-1531] [runtime] Adds proper EOFException forwarding to KryoSerializer. Conflicts: flink-java/src/test/java/org/apache/flink/api/java/typeutils/runtime/KryoGenericTypeSerializerTest.java Project:

[2/2] flink git commit: [FLINK-1533] [runtime] Fixes NPE in the scheduler where the allocated shared slots are not properly checked.

2015-02-12 Thread trohrmann
[FLINK-1533] [runtime] Fixes NPE in the scheduler where the allocated shared slots are not properly checked. This closes #388. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bc1432a2 Tree:

flink git commit: [gelly-tests] Fixes DegreesWithExceptionITCase to check expected exceptions

2015-03-16 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 5c8b0ba79 - 36b762e43 [gelly-tests] Fixes DegreesWithExceptionITCase to check expected exceptions Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/36b762e4 Tree:

[3/8] flink git commit: [FLINK-1695] [ml] Initial commit to establish module structure. Adds simple Vector and Matrix types.

2015-03-17 Thread trohrmann
[FLINK-1695] [ml] Initial commit to establish module structure. Adds simple Vector and Matrix types. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cf492be9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cf492be9

[7/8] flink git commit: [FLINK-1697] [ml] Adds web documentation for alternating least squares. Adds web documentation for polynomial base feature mapper.

2015-03-17 Thread trohrmann
[FLINK-1697] [ml] Adds web documentation for alternating least squares. Adds web documentation for polynomial base feature mapper. [ml] Adds comments [ml] Set degree of parallelism of test suites to 2 [ml] Replaces FlatSpec tests with JUnit integration test cases in order to suppress the

[2/8] flink git commit: [FLINK-1696] [ml] Adds batch gradient descent linear regression with l2 norm

2015-03-17 Thread trohrmann
[FLINK-1696] [ml] Adds batch gradient descent linear regression with l2 norm [ml] Adds batch gradient descent linear regression with convergence criterion as relative change in sum of squared residuals [ml] Adds comments to MultipleLinearRegression Project:

[8/8] flink git commit: [ml] Introduces FlinkTools containing persist methods.

2015-03-17 Thread trohrmann
[ml] Introduces FlinkTools containing persist methods. [ml] Changes comments into proper ScalaDoc in MultipleLinearRegression Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/86485434 Tree:

flink git commit: [docs] Adds akka configuration description

2015-03-24 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 8b3cbb525 - de45c06f1 [docs] Adds akka configuration description This closes #527. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/de45c06f Tree:

[3/3] flink git commit: [FLINK-1718] [ml] Unifies existing test cases

2015-04-01 Thread trohrmann
[FLINK-1718] [ml] Unifies existing test cases This closes #539. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d2e2d79f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d2e2d79f Diff:

[1/3] flink git commit: [ml] Adds convenience functions for Breeze matrix/vector conversion

2015-04-01 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master c63580244 - d2e2d79fc [ml] Adds convenience functions for Breeze matrix/vector conversion [ml] Adds breeze to flink-dist LICENSE file [ml] Optimizes sanity checks in vector/matrix accessors [ml] Fixes scala check style error with missing

[2/3] flink git commit: [FLINK-1718] [ml] Adds sparse matrix and sparse vector types

2015-04-01 Thread trohrmann
[FLINK-1718] [ml] Adds sparse matrix and sparse vector types Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9219af7b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9219af7b Diff:

svn commit: r1669535 - in /flink: material.md site/blog/feed.xml site/material.html

2015-03-27 Thread trohrmann
Author: trohrmann Date: Fri Mar 27 09:40:39 2015 New Revision: 1669535 URL: http://svn.apache.org/r1669535 Log: Adds machine learning slides to website Modified: flink/material.md flink/site/blog/feed.xml flink/site/material.html Modified: flink/material.md URL: http

flink git commit: [FLINK-1794] [test-utils] Adds test base for scala tests and adapts existing flink-ml tests

2015-03-31 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master c0b297573 - b8aa49ce7 [FLINK-1794] [test-utils] Adds test base for scala tests and adapts existing flink-ml tests [FLINK-1794] [test-utils] Adds scala docs to FlinkTestBase This closes #540. Project:

flink git commit: [FLINK-1717] [ml] Adds support to directly read libSVM and SVMLight files

2015-04-01 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master cbc8423e2 - 015af177d [FLINK-1717] [ml] Adds support to directly read libSVM and SVMLight files This closes #543. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [scala api] Moves TraversableType behind the CaseClassType in the TypeAnalyzer priority

2015-03-02 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master a201b3011 - 84c11e690 [scala api] Moves TraversableType behind the CaseClassType in the TypeAnalyzer priority Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/84c11e69

flink git commit: [scala-api] Corrects type cast in Scala API's DataSet.collect method and adds test cases for that

2015-03-04 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 7abed950d - 0ae0cba31 [scala-api] Corrects type cast in Scala API's DataSet.collect method and adds test cases for that Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [docs] Fixes jekyll's config to bind to localhost

2015-02-25 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master c032725d3 - 9de47e7c4 [docs] Fixes jekyll's config to bind to localhost Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9de47e7c Tree:

flink git commit: [docs] Fixes Java broadcast variable example

2015-03-23 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master e83d1ec10 - 80dd85900 [docs] Fixes Java broadcast variable example Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/80dd8590 Tree:

flink git commit: [docs] [ml] Fixes wrong ALS example code

2015-04-28 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 64607433d - b0df4f4d9 [docs] [ml] Fixes wrong ALS example code Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b0df4f4d Tree:

flink git commit: [yarn] [python] Adds -Xms start option for yarn, fixes python test case to overwrite files, fixes python docs

2015-04-28 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 844d5e2c4 - 9a18e5790 [yarn] [python] Adds -Xms start option for yarn, fixes python test case to overwrite files, fixes python docs Fixes failing yarn test cases Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/4] flink git commit: [docs] Moves slots_parallelism.svg to correct directory

2015-04-28 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/844d5e2c/docs/setup/config.md -- diff --git a/docs/setup/config.md b/docs/setup/config.md index 2fb3546..afc8631 100644 --- a/docs/setup/config.md +++ b/docs/setup/config.md @@

[4/4] flink git commit: [docs] Moves slots_parallelism.svg to correct directory

2015-04-28 Thread trohrmann
[docs] Moves slots_parallelism.svg to correct directory Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/844d5e2c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/844d5e2c Diff:

flink git commit: [ml] Adds proper log properties file setting for scalatest plugin

2015-05-05 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 912edbca1 - bdd842961 [ml] Adds proper log properties file setting for scalatest plugin Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bdd84296 Tree:

[2/2] flink git commit: [scala] Introduces trait type to TypeAnalyzer which avoids compiler warnings due to misclassification as a pojo type

2015-05-08 Thread trohrmann
[scala] Introduces trait type to TypeAnalyzer which avoids compiler warnings due to misclassification as a pojo type Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f0b45c45 Tree:

[2/2] flink git commit: [FLINK-1933] [ml] Adds distance metrics and documentation to machine learning library

2015-05-07 Thread trohrmann
[FLINK-1933] [ml] Adds distance metrics and documentation to machine learning library [ml] [docs] Add a overview documentation for Distance Metrics [FLINK-1933] [ml] Moves metrics.distances package to org.apache.flink.ml This closes #629. Project:

[1/2] flink git commit: [FLINK-1937] [ml] Fixes sparse vector/matrix creation fromCOO with a single element

2015-05-07 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 689240315 - ddb2b3470 [FLINK-1937] [ml] Fixes sparse vector/matrix creation fromCOO with a single element This closes #636. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [docs] Corrects combineGroup documentation example

2015-04-17 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master ea710204e - 32a04e42d [docs] Corrects combineGroup documentation example Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/32a04e42 Tree:

flink git commit: [dist] Excludes the empty *-tests.jar from being copied to the flink-dist/../examples directory

2015-04-08 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 5dd42c1ab - 4343e448c [dist] Excludes the empty *-tests.jar from being copied to the flink-dist/../examples directory Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/2] flink git commit: [FLINK-1844] [ml] Add MinMaxScaler implementation in the proprocessing package, test for the for the corresponding functionality and documentation.

2015-06-09 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master e0d60ddbd - 97611c245 [FLINK-1844] [ml] Add MinMaxScaler implementation in the proprocessing package, test for the for the corresponding functionality and documentation. This closes #798. Project:

[2/2] flink git commit: [ml] Makes StandardScalers state package private and reduce redundant code. Adjusts flink-ml readme.

2015-06-09 Thread trohrmann
[ml] Makes StandardScalers state package private and reduce redundant code. Adjusts flink-ml readme. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/97611c24 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/97611c24

[1/2] flink git commit: [FLINK-1844] [ml] Add MinMaxScaler implementation in the proprocessing package, test for the for the corresponding functionality and documentation.

2015-06-09 Thread trohrmann
Repository: flink Updated Branches: refs/heads/release-0.9 ee7c41738 - 80cf2c544 [FLINK-1844] [ml] Add MinMaxScaler implementation in the proprocessing package, test for the for the corresponding functionality and documentation. This closes #798. Project:

[2/2] flink git commit: [ml] Makes StandardScalers state package private and reduce redundant code. Adjusts flink-ml readme.

2015-06-09 Thread trohrmann
[ml] Makes StandardScalers state package private and reduce redundant code. Adjusts flink-ml readme. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/80cf2c54 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/80cf2c54

flink git commit: [FLINK-2194] [type extractor] Excludes Writable type from WritableTypeInformation to be treated as an interface

2015-06-10 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 1481647d5 - d81f4cf92 [FLINK-2194] [type extractor] Excludes Writable type from WritableTypeInformation to be treated as an interface This closes #814. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-2278] [ml] Fixes wrong Breeze sparse vector to Flink sparse vector conversion

2015-06-26 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 7a7a29403 - bc3684e69 [FLINK-2278] [ml] Fixes wrong Breeze sparse vector to Flink sparse vector conversion Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bc3684e6

[2/2] flink git commit: [FLINK-2214] [ml] Fixes prediction join operation and empirical risk join operation of ALS by giving join hint

2015-06-26 Thread trohrmann
[FLINK-2214] [ml] Fixes prediction join operation and empirical risk join operation of ALS by giving join hint This closes #844. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/38ee125e Tree:

flink git commit: [FLINK-2072] [ml] Adds quickstart guide

2015-06-11 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 7f3108d37 - 63b8c3647 [FLINK-2072] [ml] Adds quickstart guide This closes #792. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/63b8c364 Tree:

flink git commit: [FLINK-2225] [scheduler] Excludes static code paths from co-location constraint to avoid scheduling problems

2015-06-16 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master d38154129 - 5374ba97c [FLINK-2225] [scheduler] Excludes static code paths from co-location constraint to avoid scheduling problems This closes #843. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [legal] Updates LICENSE/NOTICE file of source and binary distribution

2015-06-16 Thread trohrmann
[legal] Updates LICENSE/NOTICE file of source and binary distribution This closes #830. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6a9782af Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6a9782af Diff:

[1/2] flink git commit: [FLINK-2225] [scheduler] Excludes static code paths from co-location constraint to avoid scheduling problems

2015-06-16 Thread trohrmann
Repository: flink Updated Branches: refs/heads/release-0.9 0a8142a99 - 6a9782afe [FLINK-2225] [scheduler] Excludes static code paths from co-location constraint to avoid scheduling problems This closes #843. Conflicts:

flink git commit: [2104] [ml] Hotfix for wrong class name after renaming

2015-05-29 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 3e860e7fd - d1d2ccc63 [2104] [ml] Hotfix for wrong class name after renaming Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d1d2ccc6 Tree:

flink git commit: [FLINK-2073] [ml] [docs] Adds contribution guide. Adds links to FlinkML main site.

2015-05-27 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 63edeca85 - c77947e94 [FLINK-2073] [ml] [docs] Adds contribution guide. Adds links to FlinkML main site. Adds html titles. Adds explicit operation section to all operators. This closes #727. Project:

flink git commit: [ml] [docs] Fixes broken back links

2015-05-27 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 96bbdbd70 - c81256bd2 [ml] [docs] Fixes broken back links Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c81256bd Tree:

flink git commit: [FLINK-2047] [ml] Renaming CoCoA to SVM

2015-05-28 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 41181603d - 995f8f969 [FLINK-2047] [ml] Renaming CoCoA to SVM This closes #733. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/995f8f96 Tree:

flink git commit: [ml] [docs] Replaces remaining CoCoA names by SVM

2015-05-28 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 995f8f969 - d951f1120 [ml] [docs] Replaces remaining CoCoA names by SVM Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d951f112 Tree:

flink git commit: [FLINK-2104] [ml] Fixes problem with type inference for fallback implicits where Nothing is not correctly treated (see SI-1570)

2015-05-28 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master d951f1120 - 3e860e7fd [FLINK-2104] [ml] Fixes problem with type inference for fallback implicits where Nothing is not correctly treated (see SI-1570) This closes #741. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-2102] [ml] Add predict function for labeled data for SVM and MLR.

2015-06-02 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 7571959a1 - d163a817f [FLINK-2102] [ml] Add predict function for labeled data for SVM and MLR. These functions return for each example in the input DataSet[LabeledVector] a pair (truth, prediction) Added documentation for new predict

[2/2] flink git commit: [ml] Replaces RichMapFunctions with mapWithBcVariable in FlinkML

2015-06-02 Thread trohrmann
[ml] Replaces RichMapFunctions with mapWithBcVariable in FlinkML Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/950b79c5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/950b79c5 Diff:

[1/2] flink git commit: [ml] Adds syntactic sugar for map with single broadcast element. Rewrites the optimization framework to to consolidate the loss function.

2015-06-02 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master d163a817f - 950b79c59 [ml] Adds syntactic sugar for map with single broadcast element. Rewrites the optimization framework to to consolidate the loss function. Adds closure cleaner to convenience functions on RichDataSet Removing

flink git commit: [ml] Fixes implicit issue with BreezeVectorConverter

2015-06-02 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 950b79c59 - 90c0142ef [ml] Fixes implicit issue with BreezeVectorConverter Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/90c0142e Tree:

[2/2] flink git commit: [FLINK-2297] [ml] Adds threshold setting for SVM binary predictions.

2015-07-02 Thread trohrmann
[FLINK-2297] [ml] Adds threshold setting for SVM binary predictions. Added Threshold option for SVM, to determine which predictions are positive/negative. Added parameter to determine output of prediction function. Determines whether we output raw distances to the boundary or binary class

[1/2] flink git commit: [FLINK-2272] [ml] Removed roadmap and vision from docs, added link to them in the wiki.

2015-07-02 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master a137321ac - eb23f8074 [FLINK-2272] [ml] Removed roadmap and vision from docs, added link to them in the wiki. This closes #864. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

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

2015-05-22 Thread trohrmann
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)

2015-05-22 Thread trohrmann
[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

2015-05-22 Thread trohrmann
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

2015-05-22 Thread trohrmann
[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

2015-05-22 Thread trohrmann
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

2015-05-22 Thread trohrmann
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

flink git commit: [FLINK-2056] [ml] [docs] Addes docs for ML pipelines

2015-05-26 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 44c247bda - 48e2cb5e8 [FLINK-2056] [ml] [docs] Addes docs for ML pipelines This closes #714. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/48e2cb5e Tree:

flink git commit: [FLINK-2053] [ml] Adds automatic type registration of flink-ml types. Adds de-duplication of registered types at ExecutionConfig. Fixes bug in Breeze SparseVector to Flink SparseVect

2015-05-26 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master a1d2df614 - ae446388b [FLINK-2053] [ml] Adds automatic type registration of flink-ml types. Adds de-duplication of registered types at ExecutionConfig. Fixes bug in Breeze SparseVector to Flink SparseVector conversion. This closes #723.

flink git commit: [FLINK-2083] [ml] [docs] Improves FlinkML documentation

2015-05-26 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master f78339faa - b015a32f6 [FLINK-2083] [ml] [docs] Improves FlinkML documentation Added tables for parameter values Adds links to optimization parameter values in the description This closes #715. Project:

flink git commit: [tests] Replaces Scala mixins for the Job/TaskManager with classes which extend the respective classes. Adds proper logger registration for sub-classes of FlinkUntypedActor.

2015-08-19 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 8602b7af0 - baaa3daca [tests] Replaces Scala mixins for the Job/TaskManager with classes which extend the respective classes. Adds proper logger registration for sub-classes of FlinkUntypedActor. Project:

flink git commit: [FLINK-1901] [core] Create sample operator for Dataset.

2015-08-21 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 58421b848 - c9cfb17cb [FLINK-1901] [core] Create sample operator for Dataset. [FLINK-1901] [core] enable sample with fixed size on the whole dataset. [FLINK-1901] [core] add more comments for RandomSamplerTest. [FLINK-1901] [core]

flink git commit: [docs] Fixes broken link in FlinkML docs

2015-08-04 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master bb5e61d24 - 77b747158 [docs] Fixes broken link in FlinkML docs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/77b74715 Tree:

flink git commit: [FLINK-2409] [webserver] Replaces ActorRefs with ActorGateways in the web server to automatically decorate messages with a leader session ID.

2015-08-03 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 416ff589e - fab61a195 [FLINK-2409] [webserver] Replaces ActorRefs with ActorGateways in the web server to automatically decorate messages with a leader session ID. Refactored MiniCluster to also store a reference to the web server to stop

flink git commit: [travis tools] Adds $HOME/bin/artifacts to $PATH of watchdog script

2015-08-11 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master b19e5e3bb - 4ce9475cd [travis tools] Adds $HOME/bin/artifacts to $PATH of watchdog script Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4ce9475c Tree:

[3/6] flink git commit: [FLINK-2332] [runtime] Adds leader session IDs and registration session IDs to JobManager and TaskManager messages.

2015-07-23 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/4542/flink-runtime/src/test/java/org/apache/flink/runtime/instance/InstanceManagerTest.java -- diff --git

[5/6] flink git commit: [FLINK-2332] [runtime] Adds leader session IDs and registration session IDs to JobManager and TaskManager messages.

2015-07-23 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/4542/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/RuntimeEnvironment.java -- diff --git

[1/6] flink git commit: [FLINK-2332] [runtime] Adds leader session IDs and registration session IDs to JobManager and TaskManager messages.

2015-07-23 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master fa78be6df - 45428 http://git-wip-us.apache.org/repos/asf/flink/blob/4542/flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterActor.scala -- diff --git

[4/6] flink git commit: [FLINK-2332] [runtime] Adds leader session IDs and registration session IDs to JobManager and TaskManager messages.

2015-07-23 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/4542/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala -- diff --git

[2/6] flink git commit: [FLINK-2332] [runtime] Adds leader session IDs and registration session IDs to JobManager and TaskManager messages.

2015-07-23 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/4542/flink-runtime/src/test/scala/org/apache/flink/runtime/jobmanager/JobManagerITCase.scala -- diff --git

flink git commit: [docs] Fixes broken links on the setup_quickstart.html site

2015-07-23 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 0c538915b - 4473db64c [docs] Fixes broken links on the setup_quickstart.html site Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4473db64 Tree:

flink git commit: [docs] Fix typos in streaming documentation

2015-11-06 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master f33f33206 -> 90b7a9eb9 [docs] Fix typos in streaming documentation Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/90b7a9eb Tree:

[45/47] flink git commit: [FLINK-2354] [runtime] Replace old StateHandleProvider by StateStorageHelper in ZooKeeperStateHandleStore

2015-10-20 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/a6890b28/flink-runtime-web/src/main/resources/web/fonts/fontawesome-webfont.eot -- diff --git a/flink-runtime-web/src/main/resources/web/fonts/fontawesome-webfont.eot

[47/47] flink git commit: [FLINK-2354] [runtime] Replace old StateHandleProvider by StateStorageHelper in ZooKeeperStateHandleStore

2015-10-20 Thread trohrmann
[FLINK-2354] [runtime] Replace old StateHandleProvider by StateStorageHelper in ZooKeeperStateHandleStore The old StateHandleProvider used in ZooKeeperStateHandleStore had to be replaced because the state backend implementation has changed. Since the new state backend could not be used

[26/47] flink git commit: [FLINK-2804] [runtime] Add blocking job submission support for HA

2015-10-20 Thread trohrmann
[FLINK-2804] [runtime] Add blocking job submission support for HA The JobClientActor is now repsonsible for receiving the JobStatus updates from a newly elected leader. It uses the LeaderRetrievalService to be notified about new leaders. The actor can only be used to submit a single job to the

[29/47] flink git commit: [FLINK-2354] [runtime] Replace old StateHandleProvider by StateStorageHelper in ZooKeeperStateHandleStore

2015-10-20 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/a6890b28/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/util/TwoInputStreamOperatorTestHarness.java -- diff --git

[41/47] flink git commit: [FLINK-2354] [runtime] Replace old StateHandleProvider by StateStorageHelper in ZooKeeperStateHandleStore

2015-10-20 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/a6890b28/flink-runtime-web/src/main/resources/web/js/index.js.orig -- diff --git a/flink-runtime-web/src/main/resources/web/js/index.js.orig

[25/47] flink git commit: [FLINK-2793] [runtime-web] Redirect to leader in non-standalone mode

2015-10-20 Thread trohrmann
[FLINK-2793] [runtime-web] Redirect to leader in non-standalone mode Squashes: 5a88d5e [tests] Add HttpTestClient for testing HTTP responses 656d6d6 Split WebMonitor and LeaderRetrievalService start up a7e8da8 Move generated /web files to src/main/resources Add comment to webMonitorPort

[36/47] flink git commit: [FLINK-2354] [runtime] Replace old StateHandleProvider by StateStorageHelper in ZooKeeperStateHandleStore

2015-10-20 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/a6890b28/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.ttf -- diff --git a/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.ttf

[17/47] flink git commit: [FLINK-2793] [runtime-web] Redirect to leader in non-standalone mode

2015-10-20 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/77fc0cc4/flink-runtime-web/src/main/resources/web/partials/jobmanager/config.html -- diff --git a/flink-runtime-web/src/main/resources/web/partials/jobmanager/config.html

[20/47] flink git commit: [FLINK-2793] [runtime-web] Redirect to leader in non-standalone mode

2015-10-20 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/77fc0cc4/flink-runtime-web/src/main/resources/web/js/index.js -- diff --git a/flink-runtime-web/src/main/resources/web/js/index.js

[39/47] flink git commit: [FLINK-2354] [runtime] Replace old StateHandleProvider by StateStorageHelper in ZooKeeperStateHandleStore

2015-10-20 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/a6890b28/flink-runtime-web/src/main/resources/web/partials/jobmanager/config.html -- diff --git a/flink-runtime-web/src/main/resources/web/partials/jobmanager/config.html

[12/47] flink git commit: [FLINK-2793] [runtime-web] Redirect to leader in non-standalone mode

2015-10-20 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/77fc0cc4/flink-runtime-web/web-dashboard/web/js/vendor.js -- diff --git a/flink-runtime-web/web-dashboard/web/js/vendor.js b/flink-runtime-web/web-dashboard/web/js/vendor.js

[02/47] flink git commit: [FLINK-2354] [runtime] Add job graph and checkpoint recovery

2015-10-20 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/73c73e92/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StateCheckpoinedITCase.java -- diff --git

[16/47] flink git commit: [FLINK-2793] [runtime-web] Redirect to leader in non-standalone mode

2015-10-20 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/77fc0cc4/flink-runtime-web/web-dashboard/web/css/vendor.css -- diff --git a/flink-runtime-web/web-dashboard/web/css/vendor.css b/flink-runtime-web/web-dashboard/web/css/vendor.css

[10/47] flink git commit: [FLINK-2354] [runtime] Remove state changing futures in JobManager

2015-10-20 Thread trohrmann
[FLINK-2354] [runtime] Remove state changing futures in JobManager Internal actor states must only be modified within the actor thread. This avoids all the well-known issues coming with concurrency. Fix RemoveCachedJob by introducing RemoveJob Fix JobManagerITCase Add removeJob which maintains

[14/47] flink git commit: [FLINK-2793] [runtime-web] Redirect to leader in non-standalone mode

2015-10-20 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/77fc0cc4/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.ttf -- diff --git a/flink-runtime-web/web-dashboard/web/fonts/fontawesome-webfont.ttf

[31/47] flink git commit: [FLINK-2354] [runtime] Replace old StateHandleProvider by StateStorageHelper in ZooKeeperStateHandleStore

2015-10-20 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/a6890b28/flink-runtime/src/test/java/org/apache/flink/runtime/state/FileStateBackendTest.java -- diff --git

[03/47] flink git commit: [FLINK-2354] [runtime] Add job graph and checkpoint recovery

2015-10-20 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/73c73e92/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskCancelTest.java -- diff --git

[33/47] flink git commit: [FLINK-2354] [runtime] Replace old StateHandleProvider by StateStorageHelper in ZooKeeperStateHandleStore

2015-10-20 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/a6890b28/flink-runtime-web/web-dashboard/web/partials/jobmanager/config.html -- diff --git a/flink-runtime-web/web-dashboard/web/partials/jobmanager/config.html

[09/47] flink git commit: [FLINK-2805] [blobmanager] Write JARs to file state backend for recovery

2015-10-20 Thread trohrmann
[FLINK-2805] [blobmanager] Write JARs to file state backend for recovery Move StateBackend enum to top level and org.apache.flink.runtime.state Abstract blob store in blob server for recovery This closes #1227. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[34/47] flink git commit: [FLINK-2354] [runtime] Replace old StateHandleProvider by StateStorageHelper in ZooKeeperStateHandleStore

2015-10-20 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/a6890b28/flink-runtime-web/web-dashboard/web/js/vendor.js -- diff --git a/flink-runtime-web/web-dashboard/web/js/vendor.js b/flink-runtime-web/web-dashboard/web/js/vendor.js new

  1   2   3   4   5   6   7   8   9   10   >