flink git commit: [FLINK-9470] Allow querying the key in KeyedProcessFunction

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

flink git commit: [FLINK-9743][client] Use correct zip path separator for nested jars

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

[2/4] flink git commit: [FLINK-9584][connector] Properly close output streams in Bucketing-/RollingSink

[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

[1/4] flink git commit: [FLINK-9754][release] Remove references to scala profiles

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:

[3/4] flink git commit: [FLINK-9768][release] Speed up binary release

[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

[4/4] flink git commit: [FLINK-9743][client] Use correct zip path separator for nested jars

[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

[6/9] flink git commit: [hotfix][rat] Add *.snapshot files to RAT exclusion list

[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

[4/9] flink git commit: [FLINK-9730][refactor] Fix static accesses via instance reference

[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

[2/9] flink git commit: [FLINK-9187][metrics] Add Prometheus PushGateway reporter

[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

[7/9] flink git commit: [FLINK-9754][release] Remove references to scala profiles

[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

[8/9] flink git commit: [FLINK-9768][release] Speed up binary release

[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

[9/9] flink git commit: [FLINK-9584][connector] Properly close output streams in Bucketing-/RollingSink

[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

[3/9] flink git commit: [FLINK-9789][metrics] Ensure uniqueness of watermark metrics

[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

[5/9] flink git commit: [FLINK-9666][refactor] Use short-circuit logic in boolean contexts

[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-

[1/9] flink git commit: [FLINK-9743][client] Use correct zip path separator for nested jars

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

[1/2] flink git commit: [FLINK-5363] Fire timers when window state is currently empty

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,

[2/2] flink git commit: [FLINK-5363] Clarify Trigger behaviour for empty windows

[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

svn commit: r28054 - /dev/flink/1.5.1/

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.

flink git commit: [FLINK-9511] Implement state TTL configuration

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-

flink git commit: [FLINK-9706] Properly wait for termination of JobManagerRunner before restarting jobs

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

flink git commit: [FLINK-9706] Properly wait for termination of JobManagerRunner before restarting jobs

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