flink git commit: [FLINK-1811] Allow passing custom buffer sizes and timeouts to PersistentKafkaSource

2015-04-01 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 015af177d -> 79a92a647 [FLINK-1811] Allow passing custom buffer sizes and timeouts to PersistentKafkaSource This closes #558 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/

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: http://git-wip-us.apache.org/repos/asf/flink/commit/015a

flink git commit: [tools] Add --abbrev-ref to get the right branch name of HEAD

2015-04-01 Thread hsaputra
Repository: flink Updated Branches: refs/heads/master 5691f2626 -> cbc8423e2 [tools] Add --abbrev-ref to get the right branch name of HEAD Add --abbrev-ref to get the right branch name of HEAD rather than checksum to return back to original branch. Without it will make merge tool to go to un

flink git commit: [streaming] Streaming program cancellation bugfix

2015-04-01 Thread gyfora
Repository: flink Updated Branches: refs/heads/master 500b0 -> 5691f2626 [streaming] Streaming program cancellation bugfix Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5691f262 Tree: http://git-wip-us.apache.org/rep

flink git commit: [travis] Fix YARN container log upload to s3 on Travis

2015-04-01 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master d2e2d79fc -> 500b0 [travis] Fix YARN container log upload to s3 on Travis Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/500b Tree: http://git-wip-us.apache.or

[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: http://git-wip-us.apache.org/repos/as

[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: http://git-wip-us.apache.org/repo

[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

[1/2] flink git commit: [FLINK-1662] [streaming] Triggering on fake element bugfix

2015-04-01 Thread gyfora
Repository: flink Updated Branches: refs/heads/master d8c74d209 -> c63580244 [FLINK-1662] [streaming] Triggering on fake element bugfix Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1a3ae03b Tree: http://git-wip-us.apach

[2/2] flink git commit: [FLINK-1797] Add jumping pre-reducer for Count and Time windows

2015-04-01 Thread gyfora
[FLINK-1797] Add jumping pre-reducer for Count and Time windows Closes #549 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c6358024 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c6358024 Diff: http://git-wip-us.apa