flink git commit: [FLINK-2955] [Documentation] Add operators description in Table API page.

Repository: flink Updated Branches: refs/heads/master 3cf78aa81 -> 8325bc6a6 [FLINK-2955] [Documentation] Add operators description in Table API page. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8325bc6a Tree:

[2/2] flink git commit: [hotfix] [streaming] Fix instantiation of state backends from state backend factory.

[hotfix] [streaming] Fix instantiation of state backends from state backend factory. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3c5f363d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3c5f363d Diff:

[5/5] flink git commit: [doc] Fix JavaDoc of ElasticsearchSink

[doc] Fix JavaDoc of ElasticsearchSink This closes #1367. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/821bcf5b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/821bcf5b Diff:

[3/5] flink git commit: [FLINK-3013] [gelly] Incorrect package declaration in GellyScalaAPICompletenessTest.scala

http://git-wip-us.apache.org/repos/asf/flink/blob/3a300e63/flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/test/TestGraphUtils.java -- diff --git

[2/5] flink git commit: [FLINK-3013] [gelly] Incorrect package declaration in GellyScalaAPICompletenessTest.scala

http://git-wip-us.apache.org/repos/asf/flink/blob/3a300e63/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java -- diff --git a/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java

[4/5] flink git commit: [FLINK-3013] [gelly] Incorrect package declaration in GellyScalaAPICompletenessTest.scala

[FLINK-3013] [gelly] Incorrect package declaration in GellyScalaAPICompletenessTest.scala This closes #1356. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3a300e63 Tree:

[1/2] flink git commit: [FLINK-3040] [docs] Add docs for State Backends

Repository: flink Updated Branches: refs/heads/master 8325bc6a6 -> 8b086eb91 [FLINK-3040] [docs] Add docs for State Backends Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8b086eb9 Tree:

[1/2] flink git commit: [FLINK-3040] [docs] Add docs for State Backends

Repository: flink Updated Branches: refs/heads/release-0.10 a7e799b9f -> db456a761 [FLINK-3040] [docs] Add docs for State Backends Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/db456a76 Tree:

[2/2] flink git commit: [hotfix] [streaming] Fix instantiation of state backends from state backend factory.

[hotfix] [streaming] Fix instantiation of state backends from state backend factory. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ef709093 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ef709093 Diff:

[1/5] flink git commit: [FLINK-3036] [gelly] Fix Graph.fromCsvReader method in Gelly's Scala API

Repository: flink Updated Branches: refs/heads/release-0.10 db456a761 -> 821bcf5b6 [FLINK-3036] [gelly] Fix Graph.fromCsvReader method in Gelly's Scala API The Graph.fromCsvReader in Gelly's Scala API returns a wrongly typed Graph instance because the implementation contains code paths with

flink git commit: [hotfix] [docs] Fix errors in streaming docs for fold()

Repository: flink Updated Branches: refs/heads/master 38cf0c610 -> 2f013a204 [hotfix] [docs] Fix errors in streaming docs for fold() Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2f013a20 Tree:

flink git commit: [docs] Add note about Znode root config for HA setups

Repository: flink Updated Branches: refs/heads/master 891a1b966 -> 40cb4e0d7 [docs] Add note about Znode root config for HA setups Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/40cb4e0d Tree:

flink git commit: FLINK-3041: Twitter Streaming Description section of Streaming Programming guide refers to an incorrect example 'TwitterLocal'

Repository: flink Updated Branches: refs/heads/master c1dd9604d -> dc61c7a95 FLINK-3041: Twitter Streaming Description section of Streaming Programming guide refers to an incorrect example 'TwitterLocal' This closes #1379. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [hotfix] Fix concurrent processing-time Trigger in WindowOperator

Repository: flink Updated Branches: refs/heads/master 8b086eb91 -> 891a1b966 [hotfix] Fix concurrent processing-time Trigger in WindowOperator This fixes a problem that would occur if a Trigger registers a new processing-time trigger in the onProcessingTime method. The problem is that

[1/3] flink git commit: FLINK-3022: Broken link 'Working With State' in Fault Tolerance Section of Stream Programming Guide

Repository: flink Updated Branches: refs/heads/release-0.10 0e80b0540 -> be27a188f FLINK-3022: Broken link 'Working With State' in Fault Tolerance Section of Stream Programming Guide Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [docs] remove snapshot information from front page

Repository: flink Updated Branches: refs/heads/release-0.10 be27a188f -> e977d8274 [docs] remove snapshot information from front page Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e977d827 Tree:

flink git commit: [FLINK-1945][py] Python Tests less verbose

Repository: flink Updated Branches: refs/heads/test_1945_pytest [created] c1dd9604d [FLINK-1945][py] Python Tests less verbose This closes #1376 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c1dd9604 Tree:

[3/3] flink git commit: FLINK-3041: Twitter Streaming Description section of Streaming Programming guide refers to an incorrect example 'TwitterLocal'

FLINK-3041: Twitter Streaming Description section of Streaming Programming guide refers to an incorrect example 'TwitterLocal' This closes #1379. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/be27a188 Tree:

[2/3] flink git commit: [FLINK-3017] [Docu] Fix broken 'Slots' link on Streaming Guide.

[FLINK-3017] [Docu] Fix broken 'Slots' link on Streaming Guide. This closes #1357 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5495d93f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5495d93f Diff:

[2/2] flink git commit: [FLINK-3048] [tests] Increase stability of DataSinkTaskTest

[FLINK-3048] [tests] Increase stability of DataSinkTaskTest Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/93622001 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/93622001 Diff:

Git Push Summary

Repository: flink Updated Tags: refs/tags/flink_0.10.1_prev [created] cf00d94ea refs/tags/flink_0.10.1_prev2 [created] 14573f380 refs/tags/release-0.10.0 [created] ab2cca489 refs/tags/rg_fix_0.10 [created] 63b9b3c14 refs/tags/rg_fix_0.9.2 [created] babe19ce1

Git Push Summary

Repository: flink Updated Tags: refs/tags/flink_0.10.1_prev2 [deleted] 14573f380

Git Push Summary

Repository: flink Updated Tags: refs/tags/flink_0.10.1_prev [deleted] cf00d94ea

[2/2] flink git commit: [FLINK-3005] [core] Bump commons-collections version to fix object deserialization remote command execution vulnerability

[FLINK-3005] [core] Bump commons-collections version to fix object deserialization remote command execution vulnerability This closes #1381 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7441799e Tree:

flink git commit: [FLINK-3032] Fix jackson-core dependency conflict with Hadoop 2.7.1.

Repository: flink Updated Branches: refs/heads/master 93622001e -> d8ab8bcfe [FLINK-3032] Fix jackson-core dependency conflict with Hadoop 2.7.1. This commit is also changing how we build the "flink-shaded-hadoop" artifact. In the past, we were including all Hadoop dependencies into a fat

flink git commit: [FLINK-3002] Add Either type, EitherTypeInfo, and EitherSerializer to the Java API

Repository: flink Updated Branches: refs/heads/master 6888c9cf9 -> 6b253d9f8 [FLINK-3002] Add Either type, EitherTypeInfo, and EitherSerializer to the Java API This closes #1371 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

Git Push Summary

Repository: flink Updated Tags: refs/tags/rg_fix_0.9.2 [deleted] babe19ce1

[1/2] flink git commit: [FLINK-3043] [docs] Fix description of Kafka Consumer and Producer.

Repository: flink Updated Branches: refs/heads/master 6b253d9f8 -> 864357bac [FLINK-3043] [docs] Fix description of Kafka Consumer and Producer. This also adds to the deprecated classes pointers forward to the designated classes. This closes #1380 Project:

[2/2] flink git commit: [FLINK-3005] [core] Bump commons-collections version to fix object deserialization remote command execution vulnerability

[FLINK-3005] [core] Bump commons-collections version to fix object deserialization remote command execution vulnerability This closes #1381 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/20612063 Tree:

[1/2] flink git commit: [FLINK-3043] [docs] Fix description of Kafka Consumer and Producer.

Repository: flink Updated Branches: refs/heads/release-0.10 e977d8274 -> 9defe0cb2 [FLINK-3043] [docs] Fix description of Kafka Consumer and Producer. This also adds to the deprecated classes pointers forward to the designated classes. This closes #1380 Project:

flink git commit: [travis] correct target path of uploaded snapshot artifact

Repository: flink Updated Branches: refs/heads/master 8cfc232ef -> 6888c9cf9 [travis] correct target path of uploaded snapshot artifact Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6888c9cf Tree:

flink git commit: [FLINK-1945][py] Python Tests less verbose

Repository: flink Updated Branches: refs/heads/master 40cb4e0d7 -> c1dd9604d [FLINK-1945][py] Python Tests less verbose This closes #1376 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c1dd9604 Tree:

[5/5] flink git commit: [FLINK-3028] [runtime-web] Show cancel button for restarting jobs

[FLINK-3028] [runtime-web] Show cancel button for restarting jobs This closes #1369 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c64fe3e3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c64fe3e3 Diff:

[4/5] flink git commit: [FLINK-3011] [runtime, tests] Translate ExecutionGraphRestartTest to Java

[FLINK-3011] [runtime, tests] Translate ExecutionGraphRestartTest to Java Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ceabbd07 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ceabbd07 Diff:

[7/8] flink git commit: [FLINK-3028] [runtime-web] Show cancel button for restarting jobs

http://git-wip-us.apache.org/repos/asf/flink/blob/7f3d08ff/flink-runtime-web/web-dashboard/web/js/index.js -- diff --git a/flink-runtime-web/web-dashboard/web/js/index.js b/flink-runtime-web/web-dashboard/web/js/index.js index

[2/8] flink git commit: [FLINK-3011] [runtime] Fix cancel during restart

[FLINK-3011] [runtime] Fix cancel during restart Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bf065a38 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bf065a38 Diff:

[6/8] flink git commit: [FLINK-3028] [runtime-web] Show cancel button for restarting jobs

http://git-wip-us.apache.org/repos/asf/flink/blob/7f3d08ff/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 index

[3/8] flink git commit: [FLINK-3011] [runtime] Disallow ExecutionGraph state transition from FAILED to RESTARTING

[FLINK-3011] [runtime] Disallow ExecutionGraph state transition from FAILED to RESTARTING Removes the possibility to go from FAILED state back to RESTARTING. This was only used in a test case. It was a breaking the terminal state semantics of the FAILED state. Project:

[5/8] flink git commit: [FLINK-3028] [runtime-web] Show cancel button for restarting jobs

http://git-wip-us.apache.org/repos/asf/flink/blob/7f3d08ff/flink-runtime-web/web-dashboard/web/partials/jobs/job.html -- diff --git a/flink-runtime-web/web-dashboard/web/partials/jobs/job.html

[8/8] flink git commit: [FLINK-3028] [runtime-web] Show cancel button for restarting jobs

[FLINK-3028] [runtime-web] Show cancel button for restarting jobs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7f3d08ff Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7f3d08ff Diff: