buildbot success in on flink-docs-release-0.9

The Buildbot has detected a restored build on builder flink-docs-release-0.9 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-0.9/builds/426 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave3_ubuntu Build Reason: The Ni

buildbot failure in on flink-docs-release-0.10

The Buildbot has detected a new failure on builder flink-docs-release-0.10 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-0.10/builds/311 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave2_ubuntu Build Reason: The Nig

buildbot failure in on flink-docs-release-1.1

The Buildbot has detected a new failure on builder flink-docs-release-1.1 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-1.1/builds/27 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave2_ubuntu Build Reason: The Nightl

[15/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/dev/libs/gelly/graph_api.md -- diff --git a/docs/dev/libs/gelly/graph_api.md b/docs/dev/libs/gelly/graph_api.md new file mode 100644 index 000..465c24f --- /dev/nu

[10/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/dev/windows.md -- diff --git a/docs/dev/windows.md b/docs/dev/windows.md new file mode 100644 index 000..084a2ee --- /dev/null +++ b/docs/dev/windows.md @@ -0,0 +1

[76/89] [abbrv] flink git commit: [FLINK-4384] [rpc] Add "scheduleRunAsync()" to the RpcEndpoint

[FLINK-4384] [rpc] Add "scheduleRunAsync()" to the RpcEndpoint This closes #2360 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/df0bf944 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/df0bf944 Diff: http://git-wip-u

[24/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/concepts/fig/tasks_slots.svg -- diff --git a/docs/concepts/fig/tasks_slots.svg b/docs/concepts/fig/tasks_slots.svg deleted file mode 100644 index 8fa8ac5..000 ---

[27/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/concepts/fig/slot_sharing.svg -- diff --git a/docs/concepts/fig/slot_sharing.svg b/docs/concepts/fig/slot_sharing.svg deleted file mode 100644 index a3be133..000

[61/89] [abbrv] flink git commit: [hotfix] Reduce string concatenations in ExecutionVertex

[hotfix] Reduce string concatenations in ExecutionVertex Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4e45659a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4e45659a Diff: http://git-wip-us.apache.org/repos/asf/fl

[88/89] [abbrv] flink git commit: [FLINK-4355] [cluster management] Add tests for the TaskManager -> ResourceManager registration.

[FLINK-4355] [cluster management] Add tests for the TaskManager -> ResourceManager registration. This closes #2395. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/23048b55 Tree: http://git-wip-us.apache.org/repos/asf/flink/

[86/89] [abbrv] flink git commit: [FLINK-4400] [cluster mngmt] Implement leadership election among JobMasters

[FLINK-4400] [cluster mngmt] Implement leadership election among JobMasters Adapt related components to the changes in HighAvailabilityServices Add comments for getJobMasterElectionService in HighAvailabilityServices This closes #2377. Project: http://git-wip-us.apache.org/repos/asf/flink/repo

[56/89] [abbrv] flink git commit: [FLINK-4253] [config] Clean up renaming of 'recovery.mode'

[FLINK-4253] [config] Clean up renaming of 'recovery.mode' - Renamed config keys and default values to be consistent - Updated default flink-conf.yaml - Cleaned up code occurrences of recovery mode This closes #2342. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-

[79/89] [abbrv] flink git commit: [FLINK-4373] [cluster management] Introduce SlotID, AllocationID, ResourceProfile

[FLINK-4373] [cluster management] Introduce SlotID, AllocationID, ResourceProfile [FLINK-4373] [cluster management] address comments This closes #2370. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/baf4a616 Tree: http://g

[52/89] [abbrv] flink git commit: [FLINK-4454] always display JobManager address using LeaderRetrievalService

[FLINK-4454] always display JobManager address using LeaderRetrievalService This closes #2406 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/72064558 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/72064558 Diff: htt

[36/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/apis/streaming/session-windows.svg -- diff --git a/docs/apis/streaming/session-windows.svg b/docs/apis/streaming/session-windows.svg deleted file mode 100644 index 92

[19/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/dev/batch/iterations.md -- diff --git a/docs/dev/batch/iterations.md b/docs/dev/batch/iterations.md new file mode 100644 index 000..47910d0 --- /dev/null +++ b/doc

[83/89] [abbrv] flink git commit: [FLINK-4355] [cluster management] Implement TaskManager side of registration at ResourceManager.

[FLINK-4355] [cluster management] Implement TaskManager side of registration at ResourceManager. This closes #2353 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7db27883 Tree: http://git-wip-us.apache.org/repos/asf/flink/t

[45/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/apis/batch/libs/ml/distance_metrics.md -- diff --git a/docs/apis/batch/libs/ml/distance_metrics.md b/docs/apis/batch/libs/ml/distance_metrics.md deleted file mode 100

[30/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/concepts/fig/parallel_dataflow.svg -- diff --git a/docs/concepts/fig/parallel_dataflow.svg b/docs/concepts/fig/parallel_dataflow.svg deleted file mode 100644 index 3a

[35/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/apis/streaming/sliding-windows.svg -- diff --git a/docs/apis/streaming/sliding-windows.svg b/docs/apis/streaming/sliding-windows.svg deleted file mode 100644 index 32

[26/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/concepts/fig/state_partitioning.svg -- diff --git a/docs/concepts/fig/state_partitioning.svg b/docs/concepts/fig/state_partitioning.svg deleted file mode 100644 index

[65/89] [abbrv] flink git commit: [FLINK-4457] Make ExecutionGraph independent of actors.

[FLINK-4457] Make ExecutionGraph independent of actors. This introduced types JobStatusListener and ExecutionStatusListener interfaces that replace the ActorRefs and ActorGateway for listeners Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/a

[32/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/concepts/fig/checkpoints.svg -- diff --git a/docs/concepts/fig/checkpoints.svg b/docs/concepts/fig/checkpoints.svg deleted file mode 100644 index c824296..000 ---

[54/89] [abbrv] flink git commit: [FLINK-4253] [config] Rename 'recovery.mode' key to 'high-availability'

[FLINK-4253] [config] Rename 'recovery.mode' key to 'high-availability' Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/01ffe34c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/01ffe34c Diff: http://git-wip-us.apache.o

[39/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/apis/streaming/fig/stream_watermark_out_of_order.svg -- diff --git a/docs/apis/streaming/fig/stream_watermark_out_of_order.svg b/docs/apis/streaming/fig/stream_waterm

[23/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/concepts/index.md -- diff --git a/docs/concepts/index.md b/docs/concepts/index.md new file mode 100644 index 000..a9638451 --- /dev/null +++ b/docs/concepts/index.

[28/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/concepts/fig/program_dataflow.svg -- diff --git a/docs/concepts/fig/program_dataflow.svg b/docs/concepts/fig/program_dataflow.svg deleted file mode 100644 index 7c1ec

[37/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/apis/streaming/libs/cep.md -- diff --git a/docs/apis/streaming/libs/cep.md b/docs/apis/streaming/libs/cep.md deleted file mode 100644 index ef35d32..000 --- a/docs

[41/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/apis/streaming/connectors/kinesis.md -- diff --git a/docs/apis/streaming/connectors/kinesis.md b/docs/apis/streaming/connectors/kinesis.md deleted file mode 100644 in

[20/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/dev/batch/index.md -- diff --git a/docs/dev/batch/index.md b/docs/dev/batch/index.md new file mode 100644 index 000..5cdc36d --- /dev/null +++ b/docs/dev/batch/ind

[55/89] [abbrv] flink git commit: [FLINK-4253] [config] Clean up renaming of 'recovery.mode'

http://git-wip-us.apache.org/repos/asf/flink/blob/58165d69/flink-test-utils-parent/flink-test-utils/src/main/scala/org/apache/flink/test/util/ForkableFlinkMiniCluster.scala -- diff --git a/flink-test-utils-parent/flink-test-utils/

[40/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/apis/streaming/fig/LICENSE.txt -- diff --git a/docs/apis/streaming/fig/LICENSE.txt b/docs/apis/streaming/fig/LICENSE.txt deleted file mode 100644 index 35b8673..0

[22/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/dev/batch/dataset_transformations.md -- diff --git a/docs/dev/batch/dataset_transformations.md b/docs/dev/batch/dataset_transformations.md new file mode 100644 index

[78/89] [abbrv] flink git commit: [FLINK-4392] [rpc] Make RPC Service thread-safe

[FLINK-4392] [rpc] Make RPC Service thread-safe Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0d38da04 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0d38da04 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/

[80/89] [abbrv] flink git commit: [FLINK-4383] [rpc] Eagerly serialize remote rpc invocation messages

[FLINK-4383] [rpc] Eagerly serialize remote rpc invocation messages This PR introduces an eager serialization for remote rpc invocation messages. That way it is possible to check whether the message is serializable and whether it exceeds the maximum allowed akka frame size. If either of these cons

[33/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/apis/table.md -- diff --git a/docs/apis/table.md b/docs/apis/table.md deleted file mode 100644 index 21a7dbe..000 --- a/docs/apis/table.md +++ /dev/null @@ -1,2082

[25/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/concepts/fig/tasks_chains.svg -- diff --git a/docs/concepts/fig/tasks_chains.svg b/docs/concepts/fig/tasks_chains.svg deleted file mode 100644 index 581112a..000

[57/89] [abbrv] flink git commit: [FLINK-4452] [metrics] TaskManager network buffer gauges

[FLINK-4452] [metrics] TaskManager network buffer gauges Adds gauges for the number of total and available TaskManager network memory segments. This closes #2408 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/28743cfb Tree:

[81/89] [abbrv] flink git commit: [FLINK-4403] [rpc] Use relative classloader for proxies, rather than system class loader.

[FLINK-4403] [rpc] Use relative classloader for proxies, rather than system class loader. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4501ca16 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4501ca16 Diff: http://

[58/89] [abbrv] flink git commit: [FLINK-4231] [java] Switch DistinctOperator from GroupReduce to Reduce

[FLINK-4231] [java] Switch DistinctOperator from GroupReduce to Reduce Rewrite the DistinctOperator using Reduce to support both the sort-based combine and the recently added hash-based combine. This is configured by the new method DistinctOperator.setCombineHint(CombineHint). The tests for combi

[87/89] [abbrv] flink git commit: [FLINK-4443] [rpc] Add support for rpc gateway and rpc endpoint inheritance

[FLINK-4443] [rpc] Add support for rpc gateway and rpc endpoint inheritance This commit extends the RpcCompletenessTest such that it can now check for inherited remote procedure calls. All methods defined at the RpcGateway are considered native. This means that they need no RpcEndpoint counterpa

[59/89] [abbrv] flink git commit: [FLINK-4264] [gelly] New GraphMetrics driver

[FLINK-4264] [gelly] New GraphMetrics driver Updates VertexMetrics analytic, adds directed and undirected EdgeMetric analytics, and includes a new GraphMetrics driver. This closes #2295 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/fli

[46/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/apis/batch/libs/gelly/index.md -- diff --git a/docs/apis/batch/libs/gelly/index.md b/docs/apis/batch/libs/gelly/index.md deleted file mode 100644 index 643a318..0

[60/89] [abbrv] flink git commit: [FLINK-4453] [docs] Scala code example in Window documentation shows Java

[FLINK-4453] [docs] Scala code example in Window documentation shows Java This closes #2411 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/42f65e4b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/42f65e4b Diff: http:

[16/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/dev/event_timestamps_watermarks.md -- diff --git a/docs/dev/event_timestamps_watermarks.md b/docs/dev/event_timestamps_watermarks.md new file mode 100644 index 00

[85/89] [abbrv] flink git commit: [FLINK-4382] [rpc] Buffer rpc calls until the RpcEndpoint has been started

[FLINK-4382] [rpc] Buffer rpc calls until the RpcEndpoint has been started This PR allows the AkkaRpcActor to stash messages until the corresponding RcpEndpoint has been started. When receiving a Processing.START message, the AkkaRpcActor unstashes all messages and starts processing rpcs. When re

[51/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

[FLINK-4317, FLIP-3] [docs] Restructure docs - Add redirect layout - Remove Maven artifact name warning - Add info box if stable, but not latest - Add font-awesome 4.6.3 - Add sidenav layout This closes #2387. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.

[34/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/apis/streaming/tumbling-windows.svg -- diff --git a/docs/apis/streaming/tumbling-windows.svg b/docs/apis/streaming/tumbling-windows.svg deleted file mode 100644 index

[84/89] [abbrv] flink git commit: [FLINK-4434] [rpc] Add a testing RPC service.

[FLINK-4434] [rpc] Add a testing RPC service. This closes #2394. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/728f2661 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/728f2661 Diff: http://git-wip-us.apache.org/rep

[12/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/dev/libs/storm_compatibility.md -- diff --git a/docs/dev/libs/storm_compatibility.md b/docs/dev/libs/storm_compatibility.md new file mode 100644 index 000..89d770

[89/89] [abbrv] flink git commit: [hotfix] Remove RecoveryMode from JobMaster

[hotfix] Remove RecoveryMode from JobMaster The recovery mode is not used any more by the latest CheckpointCoordinator. All difference in recovery logic between high-availability and non-high-availability is encapsulated in the HighAvailabilityServices. Project: http://git-wip-us.apache.org/re

[38/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/apis/streaming/index.md -- diff --git a/docs/apis/streaming/index.md b/docs/apis/streaming/index.md deleted file mode 100644 index f6fbbd5..000 --- a/docs/apis/str

[42/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/apis/metrics.md -- diff --git a/docs/apis/metrics.md b/docs/apis/metrics.md deleted file mode 100644 index 1cc7a29..000 --- a/docs/apis/metrics.md +++ /dev/null @@

[17/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/dev/datastream_api.md -- diff --git a/docs/dev/datastream_api.md b/docs/dev/datastream_api.md new file mode 100644 index 000..2dd7842 --- /dev/null +++ b/docs/dev/

[72/89] [abbrv] flink git commit: [FLINK-4346] [rpc] Add new RPC abstraction

[FLINK-4346] [rpc] Add new RPC abstraction Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b273afad Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b273afad Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b273a

[75/89] [abbrv] flink git commit: [FLINK-4362] [rpc] Auto generate rpc gateways via Java proxies

[FLINK-4362] [rpc] Auto generate rpc gateways via Java proxies This PR introduces a generic AkkaRpcActor which receives rpc calls as a RpcInvocation message. The RpcInvocation message is generated by the AkkaInvocationHandler which gets them from automatically generated Java Proxies. Add document

[73/89] [abbrv] flink git commit: [FLINK-4368] [distributed runtime] Eagerly initialize the RPC endpoint members

[FLINK-4368] [distributed runtime] Eagerly initialize the RPC endpoint members This closes #2351 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ddeee3b5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ddeee3b5 Diff:

[04/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/fig/parallel_dataflow.svg -- diff --git a/docs/fig/parallel_dataflow.svg b/docs/fig/parallel_dataflow.svg new file mode 100644 index 000..3a699a9 --- /dev/null +++

[44/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/apis/batch/libs/ml/svm.md -- diff --git a/docs/apis/batch/libs/ml/svm.md b/docs/apis/batch/libs/ml/svm.md deleted file mode 100644 index 6d09482..000 --- a/docs/ap

[47/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/apis/batch/iterations.md -- diff --git a/docs/apis/batch/iterations.md b/docs/apis/batch/iterations.md deleted file mode 100644 index a1bd0e9..000 --- a/docs/apis/

[66/89] [abbrv] flink git commit: [FLINK-3899] [docs] Add examples for incremental window computation.

[FLINK-3899] [docs] Add examples for incremental window computation. This closes #2368 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d16dcd20 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d16dcd20 Diff: http://git

[53/89] [abbrv] flink git commit: [FLINK-4253] [config] Rename 'recovery.mode' key to 'high-availability'

http://git-wip-us.apache.org/repos/asf/flink/blob/01ffe34c/flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionTest.java -- diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/l

[67/89] [abbrv] flink git commit: [FLINK-3823] Fix travis log upload & upload logs to transfer.sh (14 days)

[FLINK-3823] Fix travis log upload & upload logs to transfer.sh (14 days) Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/444315a1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/444315a1 Diff: http://git-wip-us.apache

[82/89] [abbrv] flink git commit: [FLINK-4414] [cluster] Add getAddress method to RpcGateway

[FLINK-4414] [cluster] Add getAddress method to RpcGateway The RpcGateway.getAddress method allows to retrieve the fully qualified address of the associated RpcEndpoint. This closes #2392. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf

[21/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/dev/batch/examples.md -- diff --git a/docs/dev/batch/examples.md b/docs/dev/batch/examples.md new file mode 100644 index 000..63d6c7a --- /dev/null +++ b/docs/dev/

[77/89] [abbrv] flink git commit: [FLINK-4386] [rpc] Add a utility to verify calls happen in the Rpc Endpoint's main thread

[FLINK-4386] [rpc] Add a utility to verify calls happen in the Rpc Endpoint's main thread Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a2f3f317 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a2f3f317 Diff: http://

[71/89] [abbrv] flink git commit: [FLINK-4346] [rpc] Add new RPC abstraction

http://git-wip-us.apache.org/repos/asf/flink/blob/b273afad/flink-runtime/src/main/java/org/apache/flink/runtime/rpc/resourcemanager/ResourceManagerGateway.java -- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/r

[06/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/fig/job_and_execution_graph.svg -- diff --git a/docs/fig/job_and_execution_graph.svg b/docs/fig/job_and_execution_graph.svg new file mode 100644 index 000..2f90ea

[08/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/fig/checkpoints.svg -- diff --git a/docs/fig/checkpoints.svg b/docs/fig/checkpoints.svg new file mode 100644 index 000..c824296 --- /dev/null +++ b/docs/fig/checkp

[68/89] [abbrv] flink git commit: [FLINK-4273] Modify JobClient to attach to running jobs

http://git-wip-us.apache.org/repos/asf/flink/blob/259a3a55/flink-runtime/src/main/scala/org/apache/flink/runtime/testingUtils/TestingJobManagerLike.scala -- diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/testin

[64/89] [abbrv] flink git commit: [hotfix] [tests] Fix mini cluster usage and logging/printing in CustomDistributionITCase

[hotfix] [tests] Fix mini cluster usage and logging/printing in CustomDistributionITCase Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/addad1af Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/addad1af Diff: http://g

[18/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/dev/connectors/kinesis.md -- diff --git a/docs/dev/connectors/kinesis.md b/docs/dev/connectors/kinesis.md new file mode 100644 index 000..ce011b3 --- /dev/null +++

[70/89] [abbrv] flink git commit: [FLINK-3677] FileInputFormat: Allow to specify include/exclude file name patterns

[FLINK-3677] FileInputFormat: Allow to specify include/exclude file name patterns This closes #2109 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/48109104 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/48109104 Di

[49/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/apis/batch/examples.md -- diff --git a/docs/apis/batch/examples.md b/docs/apis/batch/examples.md deleted file mode 100644 index 3523185..000 --- a/docs/apis/batch/

[11/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/dev/table_api.md -- diff --git a/docs/dev/table_api.md b/docs/dev/table_api.md new file mode 100644 index 000..cdd3667 --- /dev/null +++ b/docs/dev/table_api.md @@

[63/89] [abbrv] flink git commit: [FLINK-4417] [checkpoints] Checkpoints are subsumed by CheckpointID not, by timestamp

[FLINK-4417] [checkpoints] Checkpoints are subsumed by CheckpointID not, by timestamp This closes #2407 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4e9d1775 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4e9d177

[50/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/apis/batch/dataset_transformations.md -- diff --git a/docs/apis/batch/dataset_transformations.md b/docs/apis/batch/dataset_transformations.md deleted file mode 100644

[09/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/fig/checkpointing.svg -- diff --git a/docs/fig/checkpointing.svg b/docs/fig/checkpointing.svg new file mode 100644 index 000..a572d8e --- /dev/null +++ b/docs/fig/

[13/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/dev/libs/ml/index.md -- diff --git a/docs/dev/libs/ml/index.md b/docs/dev/libs/ml/index.md new file mode 100644 index 000..d01e18e --- /dev/null +++ b/docs/dev/lib

[31/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/concepts/fig/event_ingestion_processing_time.svg -- diff --git a/docs/concepts/fig/event_ingestion_processing_time.svg b/docs/concepts/fig/event_ingestion_processing_

[29/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/concepts/fig/processes.svg -- diff --git a/docs/concepts/fig/processes.svg b/docs/concepts/fig/processes.svg deleted file mode 100644 index fe83a9d..000 --- a/docs

[43/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/apis/common/index.md -- diff --git a/docs/apis/common/index.md b/docs/apis/common/index.md deleted file mode 100644 index 05d87ce..000 --- a/docs/apis/common/index

[02/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/fig/processes.svg -- diff --git a/docs/fig/processes.svg b/docs/fig/processes.svg new file mode 100644 index 000..fe83a9d --- /dev/null +++ b/docs/fig/processes.sv

[69/89] [abbrv] flink git commit: [FLINK-4273] Modify JobClient to attach to running jobs

[FLINK-4273] Modify JobClient to attach to running jobs These changes are required for FLINK-4272 (introduce a JobClient class for job control). Essentially, we want to be able to re-attach to a running job and monitor it. It shouldn't make any difference whether we just submitted the job or we re

[48/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/apis/batch/index.md -- diff --git a/docs/apis/batch/index.md b/docs/apis/batch/index.md deleted file mode 100644 index ee4cf6c..000 --- a/docs/apis/batch/index.md

[14/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/dev/libs/gelly/iterative_graph_processing.md -- diff --git a/docs/dev/libs/gelly/iterative_graph_processing.md b/docs/dev/libs/gelly/iterative_graph_processing.md new

[74/89] [abbrv] flink git commit: [FLINK-4362] [rpc] Auto generate rpc gateways via Java proxies

http://git-wip-us.apache.org/repos/asf/flink/blob/dc808e76/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceTest.java -- diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpc

[62/89] [abbrv] flink git commit: [FLINK-4437] [checkpoints] Properly lock the triggerCheckpoint() method

[FLINK-4437] [checkpoints] Properly lock the triggerCheckpoint() method This introduces a trigger-lock that makes sure checkpoint trigger attemps to not overtake each other (as may otherwise be the case for periodic checkpoints and manual savepoints). This also fixes the evaluation of the min-d

[05/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/fig/job_status.svg -- diff --git a/docs/fig/job_status.svg b/docs/fig/job_status.svg new file mode 100644 index 000..c259db4 --- /dev/null +++ b/docs/fig/job_statu

[03/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/fig/parallel_streams_watermarks.svg -- diff --git a/docs/fig/parallel_streams_watermarks.svg b/docs/fig/parallel_streams_watermarks.svg new file mode 100644 index 000

[07/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs

http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/fig/event_ingestion_processing_time.svg -- diff --git a/docs/fig/event_ingestion_processing_time.svg b/docs/fig/event_ingestion_processing_time.svg new file mode 1006

[01/89] [abbrv] [partial] flink git commit: [FLINK-4317, FLIP-3] [docs] Restructure docs [Forced Update!]

Repository: flink Updated Branches: refs/heads/flip-6 affa548ca -> 734297615 (forced update) http://git-wip-us.apache.org/repos/asf/flink/blob/844c874b/docs/fig/program_dataflow.svg -- diff --git a/docs/fig/program_dataflow.svg

flink git commit: [FLINK-3677] FileInputFormat: Allow to specify include/exclude file name patterns

Repository: flink Updated Branches: refs/heads/master 259a3a556 -> 481091043 [FLINK-3677] FileInputFormat: Allow to specify include/exclude file name patterns This closes #2109 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/co

[1/2] flink git commit: [FLINK-4273] Modify JobClient to attach to running jobs

Repository: flink Updated Branches: refs/heads/master 444315a12 -> 259a3a556 http://git-wip-us.apache.org/repos/asf/flink/blob/259a3a55/flink-runtime/src/main/scala/org/apache/flink/runtime/testingUtils/TestingJobManagerLike.scala

[2/2] flink git commit: [FLINK-4273] Modify JobClient to attach to running jobs

[FLINK-4273] Modify JobClient to attach to running jobs These changes are required for FLINK-4272 (introduce a JobClient class for job control). Essentially, we want to be able to re-attach to a running job and monitor it. It shouldn't make any difference whether we just submitted the job or we re

flink git commit: [FLINK-3823] Fix travis log upload & upload logs to transfer.sh (14 days)

Repository: flink Updated Branches: refs/heads/master d16dcd205 -> 444315a12 [FLINK-3823] Fix travis log upload & upload logs to transfer.sh (14 days) Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/444315a1 Tree: http://g

flink git commit: [FLINK-3899] [docs] Add examples for incremental window computation.

Repository: flink Updated Branches: refs/heads/release-1.1 016c381cd -> 717fc906d [FLINK-3899] [docs] Add examples for incremental window computation. This closes #2368 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/717f

flink git commit: [FLINK-3899] [docs] Add examples for incremental window computation.

Repository: flink Updated Branches: refs/heads/master addad1af4 -> d16dcd205 [FLINK-3899] [docs] Add examples for incremental window computation. This closes #2368 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d16dcd20

[1/2] flink git commit: [FLINK-4441] Make RocksDB backend return null on empty state + add test for all backends

Repository: flink Updated Branches: refs/heads/release-1.1 b87165deb -> 016c381cd [FLINK-4441] Make RocksDB backend return null on empty state + add test for all backends Closes #2399 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/f

[2/2] flink git commit: [FLINK-4471] Use user code classloader to deserialize state descriptor in RocksDb backend

[FLINK-4471] Use user code classloader to deserialize state descriptor in RocksDb backend Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/016c381c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/016c381c Diff: http://

  1   2   >