Repository: flink
Updated Branches:
refs/heads/master 53e665765 -> cde504eb4
[FLINK-9470] Allow querying the key in KeyedProcessFunction
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cde504eb
Tree: http://git-wip-us.apac
Repository: flink
Updated Branches:
refs/heads/release-1.4 5380ad3a3 -> 1a852ecfe
[FLINK-9743][client] Use correct zip path separator for nested jars
This closes #6263.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1a85
[FLINK-9584][connector] Properly close output streams in Bucketing-/RollingSink
This closes #6164.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d3b644a0
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d3b644a0
Diff
Repository: flink
Updated Branches:
refs/heads/release-1.5 62839e88e -> 8c18a9217
[FLINK-9754][release] Remove references to scala profiles
This closes #6286.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8c18a921
Tree:
[FLINK-9768][release] Speed up binary release
This closes #6285.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bbdb9877
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bbdb9877
Diff: http://git-wip-us.apache.org/rep
[FLINK-9743][client] Use correct zip path separator for nested jars
This closes #6263.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/434bf57c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/434bf57c
Diff: http://git
[hotfix][rat] Add *.snapshot files to RAT exclusion list
This closes #6295.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0cb1fe2f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0cb1fe2f
Diff: http://git-wip-us.apa
[FLINK-9730][refactor] Fix static accesses via instance reference
This closes #6247.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cad6e4d3
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cad6e4d3
Diff: http://git-w
[FLINK-9187][metrics] Add Prometheus PushGateway reporter
This closes #6184.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5ee5dbf3
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5ee5dbf3
Diff: http://git-wip-us.ap
[FLINK-9754][release] Remove references to scala profiles
This closes #6286.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c3b013b9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c3b013b9
Diff: http://git-wip-us.ap
[FLINK-9768][release] Speed up binary release
This closes #6285.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/04d00098
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/04d00098
Diff: http://git-wip-us.apache.org/rep
[FLINK-9584][connector] Properly close output streams in Bucketing-/RollingSink
This closes #6164.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/04a7cd4d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/04a7cd4d
Diff
[FLINK-9789][metrics] Ensure uniqueness of watermark metrics
This closes #6292.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/60df251a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/60df251a
Diff: http://git-wip-us
[FLINK-9666][refactor] Use short-circuit logic in boolean contexts
This closes #6230.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5dbb6dda
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5dbb6dda
Diff: http://git-
Repository: flink
Updated Branches:
refs/heads/master cde504eb4 -> c3b013b9d
[FLINK-9743][client] Use correct zip path separator for nested jars
This closes #6263.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2fbe562d
Repository: flink
Updated Branches:
refs/heads/master c3b013b9d -> 5c43d2b8a
[FLINK-5363] Fire timers when window state is currently empty
Before, a window Trigger would not be invoked if the window is empty at
the time of the timer firing. Now the Trigger is always invoked.
As a side effect,
[FLINK-5363] Clarify Trigger behaviour for empty windows
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5c43d2b8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5c43d2b8
Diff: http://git-wip-us.apache.org/repos/asf/fl
Author: chesnay
Date: Wed Jul 11 14:42:05 2018
New Revision: 28054
Log:
Update release-1.5.1-rc3 files to include streaming examples
Modified:
dev/flink/1.5.1/flink-1.5.1-bin-hadoop24-scala_2.11.tgz
dev/flink/1.5.1/flink-1.5.1-bin-hadoop24-scala_2.11.tgz.asc
dev/flink/1.5.1/flink-1.5.
Repository: flink
Updated Branches:
refs/heads/master 5c43d2b8a -> dc7d81c9c
[FLINK-9511] Implement state TTL configuration
This closes #6277.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dc7d81c9
Tree: http://git-wip-
Repository: flink
Updated Branches:
refs/heads/master dc7d81c9c -> 3c4e59a7f
[FLINK-9706] Properly wait for termination of JobManagerRunner before
restarting jobs
In order to avoid race conditions between resource clean up, we now wait for
the proper
termination of a previously running JobMa
Repository: flink
Updated Branches:
refs/heads/release-1.5 8c18a9217 -> ddf550aa8
[FLINK-9706] Properly wait for termination of JobManagerRunner before
restarting jobs
In order to avoid race conditions between resource clean up, we now wait for
the proper
termination of a previously running
21 matches
Mail list logo