flink git commit: [FLINK-1229][docs] Updated web client documentation - WebClient assembler class flag is '-c' (not 'assembler') - doc-building script is named 'build_docs.sh' (not '_build_docs.sh')

2015-06-04 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master f4195ac02 -> da8aa1089 [FLINK-1229][docs] Updated web client documentation - WebClient assembler class flag is '-c' (not 'assembler') - doc-building script is named 'build_docs.sh' (not '_build_docs.sh') Project: http://git-wip-us.apache

[3/3] flink git commit: [FLINK-2098] Improvements on checkpoint-aligned sources

2015-06-04 Thread aljoscha
[FLINK-2098] Improvements on checkpoint-aligned sources Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f4195ac0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f4195ac0 Diff: http://git-wip-us.apache.org/repos/asf/fli

[1/3] flink git commit: [FLINK-2098] Ensure checkpoints and element emission are in order

2015-06-04 Thread aljoscha
Repository: flink Updated Branches: refs/heads/master 39010dce4 -> f4195ac02 http://git-wip-us.apache.org/repos/asf/flink/blob/6685b0ba/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/complex/ComplexIntegrationTest.java ---

[2/3] flink git commit: [FLINK-2098] Ensure checkpoints and element emission are in order

2015-06-04 Thread aljoscha
[FLINK-2098] Ensure checkpoints and element emission are in order Before, it could happen that a streaming source would keep emitting elements while a checkpoint is being performed. This can lead to inconsistencies in the checkpoints with other operators. This also adds a test that checks whether

[1/2] flink git commit: [streaming] [scala] ITCases for streaming scala examples

2015-06-04 Thread mbalassi
Repository: flink Updated Branches: refs/heads/master 8e49e7b5b -> 39010dce4 [streaming] [scala] ITCases for streaming scala examples Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/23a36461 Tree: http://git-wip-us.apache.

[2/2] flink git commit: [streaming] Removed StockPrices example

2015-06-04 Thread mbalassi
[streaming] Removed StockPrices example The purpose of this was to serve as an example for a blogpost. Moved it to another branch and removed it from the master. Closes #777 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/39

[1/2] flink git commit: [streaming] Minor cleanups on data stream.

2015-06-04 Thread sewen
Repository: flink Updated Branches: refs/heads/master 86692e55f -> 8e49e7b5b [streaming] Minor cleanups on data stream. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8e49e7b5 Tree: http://git-wip-us.apache.org/repos/asf/

[2/2] flink git commit: [hbase] Add a stream data sink for HBase

2015-06-04 Thread sewen
[hbase] Add a stream data sink for HBase This closes #706 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b5e55918 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b5e55918 Diff: http://git-wip-us.apache.org/repos/asf/

flink git commit: [scala-shell] [docs] Fixes wrong scala shell command in online documentation

2015-06-04 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 463300ec5 -> 86692e55f [scala-shell] [docs] Fixes wrong scala shell command in online documentation Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/86692e55 Tree: http:

flink git commit: [FLINK-1993] [ml] Replaces custom SGD logic with optimization framework's SGD in MultipleLinearRegression

2015-06-04 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 1559701f4 -> 463300ec5 [FLINK-1993] [ml] Replaces custom SGD logic with optimization framework's SGD in MultipleLinearRegression Fixes PipelineITSuite because of change MLR loss function This closes #760. Project: http://git-wip-us.apac

[1/2] flink-web git commit: Extend coding guidelines with a rule enforcing documentation updates

2015-06-04 Thread rmetzger
Repository: flink-web Updated Branches: refs/heads/asf-site 01ee1809e -> 86f2da148 http://git-wip-us.apache.org/repos/asf/flink-web/blob/86f2da14/content/news/2015/02/09/streaming-example.html -- diff --git a/content/news/2015/

[2/2] flink-web git commit: Extend coding guidelines with a rule enforcing documentation updates

2015-06-04 Thread rmetzger
Extend coding guidelines with a rule enforcing documentation updates Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/86f2da14 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/86f2da14 Diff: http://git-wip-us

[2/4] flink git commit: [core] Remove extra li HTML tags in TypeInformation JavaDoc class header.

2015-06-04 Thread sewen
[core] Remove extra li HTML tags in TypeInformation JavaDoc class header. Rhis closes #766 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8e793f94 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8e793f94 Diff: http:/

[4/4] flink git commit: [FLINK-2126] [scala shell] All tests now dont check for "Job execution switched to status FINISHED.", which sometimes did not show up. Fixed typo in add numbers test

2015-06-04 Thread sewen
[FLINK-2126] [scala shell] All tests now dont check for "Job execution switched to status FINISHED.", which sometimes did not show up. Fixed typo in add numbers test This closes #768 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/

[3/4] flink git commit: [docs/javadoc][hotfix] Corrected Join hint and misleadling pointer to Spargel

2015-06-04 Thread sewen
[docs/javadoc][hotfix] Corrected Join hint and misleadling pointer to Spargel This closes #763 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7411343a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7411343a Diff: ht

[1/4] flink git commit: [FLINK-2076] [runtime] Fix memory leakage in MutableHashTable

2015-06-04 Thread sewen
Repository: flink Updated Branches: refs/heads/master 0081fb2ef -> 1559701f4 [FLINK-2076] [runtime] Fix memory leakage in MutableHashTable This closes #751 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1559701f Tree: ht

flink git commit: [FLINK-2135] Fix faulty cast to GroupReduceFunction

2015-06-04 Thread rmetzger
Repository: flink Updated Branches: refs/heads/master 0dea359b3 -> 0081fb2ef [FLINK-2135] Fix faulty cast to GroupReduceFunction This closes #769 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0081fb2e Tree: http://git-w

flink git commit: [FLINK-2134] Close Netty channel via CloseRequest msg

2015-06-04 Thread uce
Repository: flink Updated Branches: refs/heads/master 11643c0cc -> 0dea359b3 [FLINK-2134] Close Netty channel via CloseRequest msg This closes #773. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0dea359b Tree: http://gi

[4/4] flink-web git commit: [blog] Updated streaming blogpost to link to stable code

2015-06-04 Thread mbalassi
[blog] Updated streaming blogpost to link to stable code Project: http://git-wip-us.apache.org/repos/asf/flink-web/repo Commit: http://git-wip-us.apache.org/repos/asf/flink-web/commit/01ee1809 Tree: http://git-wip-us.apache.org/repos/asf/flink-web/tree/01ee1809 Diff: http://git-wip-us.apache.org/

[2/4] flink-web git commit: [blog] Updated streaming blogpost to link to stable code

2015-06-04 Thread mbalassi
http://git-wip-us.apache.org/repos/asf/flink-web/blob/01ee1809/content/blog/page3/index.html -- diff --git a/content/blog/page3/index.html b/content/blog/page3/index.html index b96f0c9..350033e 100644 --- a/content/blog/page3/index

[1/4] flink-web git commit: [blog] Updated streaming blogpost to link to stable code

2015-06-04 Thread mbalassi
Repository: flink-web Updated Branches: refs/heads/asf-site e57f039b8 -> 01ee1809e http://git-wip-us.apache.org/repos/asf/flink-web/blob/01ee1809/content/news/2015/05/11/Juggling-with-Bits-and-Bytes.html -- diff --git a/content

[3/4] flink-web git commit: [blog] Updated streaming blogpost to link to stable code

2015-06-04 Thread mbalassi
http://git-wip-us.apache.org/repos/asf/flink-web/blob/01ee1809/content/blog/feed.xml -- diff --git a/content/blog/feed.xml b/content/blog/feed.xml index 627f2fd..5efaf14 100644 --- a/content/blog/feed.xml +++ b/content/blog/feed.xm