flink git commit: [streaming] Discretizer reuse bugfixes

Repository: flink Updated Branches: refs/heads/master 4b53e66c4 - ff750e61a [streaming] Discretizer reuse bugfixes Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ff750e61 Tree:

[01/10] flink git commit: [FLINK-1953] [runtime] Integrate new snapshot checkpoint coordinator with jobgraph and execution graph

Repository: flink Updated Branches: refs/heads/master ff750e61a - e79ff4ebf http://git-wip-us.apache.org/repos/asf/flink/blob/9b7f8aa1/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/RuntimeEnvironment.java --

[02/10] flink git commit: [FLINK-1953] [runtime] Integrate new snapshot checkpoint coordinator with jobgraph and execution graph

[FLINK-1953] [runtime] Integrate new snapshot checkpoint coordinator with jobgraph and execution graph This closes #651 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9b7f8aa1 Tree:

[05/10] flink git commit: [streaming] Integrate new checkpointed interface with StreamTask, StreamOperator, and PersistentKafkaSource

[streaming] Integrate new checkpointed interface with StreamTask, StreamOperator, and PersistentKafkaSource Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3b2ee23b Tree:

[07/10] flink git commit: [FLINK-1935] Reimplement PersistentKafkaSource using high level Kafka API

http://git-wip-us.apache.org/repos/asf/flink/blob/54e95761/flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/kafka/api/simple/iterator/KafkaSinglePartitionIterator.java --

[08/10] flink git commit: [FLINK-1935] Reimplement PersistentKafkaSource using high level Kafka API

[FLINK-1935] Reimplement PersistentKafkaSource using high level Kafka API Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/54e95761 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/54e95761 Diff:

[04/10] flink git commit: [FLINK-1973] [jobmanager] Task execution state messages are logged on INFO level, rather than on DEBUG level

[FLINK-1973] [jobmanager] Task execution state messages are logged on INFO level, rather than on DEBUG level Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ededb6b7 Tree:

[10/10] flink git commit: [tests] Add test that checkes canceling against a failed TaskManager process

[tests] Add test that checkes canceling against a failed TaskManager process Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4bd35259 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4bd35259 Diff:

buildbot exception in ASF Buildbot on flink-docs-release-0.8.0

The Buildbot has detected a build exception on builder flink-docs-release-0.8.0 while building ASF Buildbot. Full details are available at: http://ci.apache.org/builders/flink-docs-release-0.8.0/builds/70 Buildbot URL: http://ci.apache.org/ Buildslave for this Build: orcus_ubuntu Build

[2/3] flink-web git commit: Added blog post about how Flink operates on binary data

http://git-wip-us.apache.org/repos/asf/flink-web/blob/7a9b4873/content/blog/index.html -- diff --git a/content/blog/index.html b/content/blog/index.html index 107d6da..2d39bde 100644 --- a/content/blog/index.html +++

[2/2] flink git commit: [FLINK-1959] [runtime] Support accumulators in chained functions after a non-UDF operation

[FLINK-1959] [runtime] Support accumulators in chained functions after a non-UDF operation Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/73493335 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/73493335 Diff:

[1/2] flink git commit: [tests] Consolidate miscellaneous tests into one IntegrationTestCase to reuse minicluster and speed up tests

Repository: flink Updated Branches: refs/heads/master e79ff4ebf - 73493335f [tests] Consolidate miscellaneous tests into one IntegrationTestCase to reuse minicluster and speed up tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/7] flink git commit: [FLINK-1987][docs] Fixed broken links

[FLINK-1987][docs] Fixed broken links This closes #662 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cafb8769 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cafb8769 Diff:

[4/7] flink git commit: [FLINK-2001] [ml] Fix DistanceMetric serialization error

[FLINK-2001] [ml] Fix DistanceMetric serialization error This closes #668 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/40683718 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/40683718 Diff:

[6/7] flink git commit: [FLINK-785] ChainedAllReduce

[FLINK-785] ChainedAllReduce Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a3a7350d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a3a7350d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a3a7350d Branch:

[5/7] flink git commit: [FLINK-1928] [hbase] Added HBase write example

[FLINK-1928] [hbase] Added HBase write example Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3be621cf Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3be621cf Diff:

[7/7] flink git commit: [FLINK-1928] [hbase] Fix license header for HBase tests

[FLINK-1928] [hbase] Fix license header for HBase tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a771cfb6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a771cfb6 Diff:

[1/7] flink git commit: [FLINK-785] Fixed ObjectReuseITCase

Repository: flink Updated Branches: refs/heads/master 318a14d85 - 57615aaa1 [FLINK-785] Fixed ObjectReuseITCase This closes #370 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/57615aaa Tree:

flink git commit: [QA] display max 100 lines of compiler warnings

Repository: flink Updated Branches: refs/heads/master 57615aaa1 - 4b53e66c4 [QA] display max 100 lines of compiler warnings hide warning if output file does not exist Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: