flink git commit: [FLINK-9665][metrics] Unregister individual metrics in PrometheusReporter

Repository: flink Updated Branches: refs/heads/master a49587a6e -> 75d12f967 [FLINK-9665][metrics] Unregister individual metrics in PrometheusReporter This closes #6239. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-9665][metrics] Unregister individual metrics in PrometheusReporter

Repository: flink Updated Branches: refs/heads/release-1.4 e952408cb -> 7719fddbf [FLINK-9665][metrics] Unregister individual metrics in PrometheusReporter This closes #6239. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-9665][metrics] Unregister individual metrics in PrometheusReporter

Repository: flink Updated Branches: refs/heads/release-1.5 e1fcd458a -> 903a32336 [FLINK-9665][metrics] Unregister individual metrics in PrometheusReporter This closes #6239. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[3/3] flink git commit: [FLINK-9674][tests] Replace hard-coded sleeps in QS E2E test

[FLINK-9674][tests] Replace hard-coded sleeps in QS E2E test This closes #6216. This closes #6025. This closes #5297. This closes #6211. This closes #5899. This closes #5888. This closes #5901. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/3] flink git commit: [hotfix][tests] Simplify jar paths to QS tests

[hotfix][tests] Simplify jar paths to QS tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/02f016e4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/02f016e4 Diff:

[1/3] flink git commit: [hotfix][tests] Reuse existing functions for cleaning logs

Repository: flink Updated Branches: refs/heads/master 75d12f967 -> 41277f6b7 [hotfix][tests] Reuse existing functions for cleaning logs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a9d08a22 Tree:

flink git commit: [FLINK-9578] [sql-client] Allow to define an auto watermark interval in SQL Client

Repository: flink Updated Branches: refs/heads/master 8c15d379d -> 19040a632 [FLINK-9578] [sql-client] Allow to define an auto watermark interval in SQL Client This closes #6160. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-8654][docs] Extend project quickstarts on how to submit jobs

Repository: flink Updated Branches: refs/heads/release-1.4 7719fddbf -> db14fe13e [FLINK-8654][docs] Extend project quickstarts on how to submit jobs This closes #6084. This closes #6047. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-8654][docs] Extend project quickstarts on how to submit jobs

Repository: flink Updated Branches: refs/heads/release-1.5 903a32336 -> e0a4c3591 [FLINK-8654][docs] Extend project quickstarts on how to submit jobs This closes #6084. This closes #6047. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-8654][docs] Extend project quickstarts on how to submit jobs

Repository: flink Updated Branches: refs/heads/master 41277f6b7 -> 8c15d379d [FLINK-8654][docs] Extend project quickstarts on how to submit jobs This closes #6084. This closes #6047. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[04/10] flink git commit: [FLINK-9686] [kinesis] Allow creating AWS credentials by assuming a role

[FLINK-9686] [kinesis] Allow creating AWS credentials by assuming a role Config example: ``` aws.credentials.provider: ASSUME_ROLE aws.credentials.provider.role.arn: aws.credentials.provider.role.sessionName: session-name aws.credentials.provider.role.provider: AUTO ``` [FLINK-9686] [kinesis]

[05/10] flink git commit: [FLINK-9695] Added mesos.resourcemanager.tasks.container.docker.force-pull-image option

[FLINK-9695] Added mesos.resourcemanager.tasks.container.docker.force-pull-image option This closes #6232. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b230bf0e Tree:

[09/10] flink git commit: [FLINK-9708] Clean up LocalBufferPool if NetworkBufferPool#createBufferPool fails

[FLINK-9708] Clean up LocalBufferPool if NetworkBufferPool#createBufferPool fails Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/390e451f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/390e451f Diff:

[03/10] flink git commit: [hotfix][network] checkstyle

[hotfix][network] checkstyle Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/918b16a0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/918b16a0 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/918b16a0 Branch:

[01/10] flink git commit: [hotfix] Let NetworkBufferPoolTest extend TestLogger and make TestIOException static class

Repository: flink Updated Branches: refs/heads/master a25cd3fed -> 382dd0644 [hotfix] Let NetworkBufferPoolTest extend TestLogger and make TestIOException static class Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[10/10] flink git commit: [hotfix][network] always destroy buffer pool in NetworkBufferPoolTest#testRequestMemorySegmentsInterruptable()

[hotfix][network] always destroy buffer pool in NetworkBufferPoolTest#testRequestMemorySegmentsInterruptable() Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/93c7a9b2 Tree:

[08/10] flink git commit: [FLINK-9708][network] fix inconsistency with failed buffer redistribution

[FLINK-9708][network] fix inconsistency with failed buffer redistribution Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/63730b61 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/63730b61 Diff:

[02/10] flink git commit: [FLINK-9636][network] fix inconsistency with interrupted buffer polling

[FLINK-9636][network] fix inconsistency with interrupted buffer polling This closes #6238. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/efc87083 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/efc87083 Diff:

[5/8] flink git commit: [FLINK-9633] Use Savepoint path's file system to create checkpoint output stream

[FLINK-9633] Use Savepoint path's file system to create checkpoint output stream This commit changes Flink such that it uses the savepoint path's file system to generate the output stream instead of the checkpoint path's file system. This closes #6194. Project:

[2/8] flink git commit: [FLINK-9636][network] fix inconsistency with interrupted buffer polling

[FLINK-9636][network] fix inconsistency with interrupted buffer polling This closes #6238. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e58a8e4a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e58a8e4a Diff:

[7/8] flink git commit: [FLINK-9708] Clean up LocalBufferPool if NetworkBufferPool#createBufferPool fails

[FLINK-9708] Clean up LocalBufferPool if NetworkBufferPool#createBufferPool fails Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/90d5b40e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/90d5b40e Diff:

[4/8] flink git commit: [hotfix][network] add a few more checks and tags

[hotfix][network] add a few more checks and tags Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cf4f6f94 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cf4f6f94 Diff:

[3/8] flink git commit: [hotfix][network] checkstyle

[hotfix][network] checkstyle Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c314dd1e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c314dd1e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c314dd1e Branch:

[6/8] flink git commit: [FLINK-9708][network] fix inconsistency with failed buffer redistribution

[FLINK-9708][network] fix inconsistency with failed buffer redistribution Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/07afe1d8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/07afe1d8 Diff:

[1/8] flink git commit: [hotfix] Let NetworkBufferPoolTest extend TestLogger and make TestIOException static class

Repository: flink Updated Branches: refs/heads/release-1.5 797709cb2 -> e4e244991 [hotfix] Let NetworkBufferPoolTest extend TestLogger and make TestIOException static class Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/3] flink git commit: [FLINK-9444] [formats] Add full SQL support for Avro formats

Repository: flink Updated Branches: refs/heads/master 19040a632 -> c34c7e412 http://git-wip-us.apache.org/repos/asf/flink/blob/c34c7e41/flink-formats/flink-avro/src/test/java/org/apache/flink/table/runtime/batch/AvroTypesITCase.java

[3/3] flink git commit: [FLINK-9444] [formats] Add full SQL support for Avro formats

[FLINK-9444] [formats] Add full SQL support for Avro formats This PR adds full support of Apache Avro records for the Table API & SQL. It adds (de)serialization schemas to the row type for both specific and generic records. It converts all Avro types to Flink types and vice versa. It supports

[2/3] flink git commit: [FLINK-9444] [formats] Add full SQL support for Avro formats

http://git-wip-us.apache.org/repos/asf/flink/blob/c34c7e41/flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroRecordInputFormatTest.java -- diff --git

[1/4] flink git commit: [FLINK-9491][state] Generalization of timer queue (decoupled from timers) and second implementation based on RocksDB

Repository: flink Updated Branches: refs/heads/master c34c7e412 -> c6ad421e2 http://git-wip-us.apache.org/repos/asf/flink/blob/c6ad421e/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/InternalTimerHeapTest.java

[3/4] flink git commit: [FLINK-9491][state] Generalization of timer queue (decoupled from timers) and second implementation based on RocksDB

[FLINK-9491][state] Generalization of timer queue (decoupled from timers) and second implementation based on RocksDB This closes #6228. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c6ad421e Tree:

[2/4] flink git commit: [FLINK-9491][state] Generalization of timer queue (decoupled from timers) and second implementation based on RocksDB

http://git-wip-us.apache.org/repos/asf/flink/blob/c6ad421e/flink-runtime/src/test/java/org/apache/flink/runtime/state/heap/OrderedSetCacheTestBase.java -- diff --git

[4/5] flink git commit: [FLINK-9280][rest] Rework JobSubmitHandler to accept jar/artifact files

[FLINK-9280][rest] Rework JobSubmitHandler to accept jar/artifact files This closes #6203. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a25cd3fe Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a25cd3fe Diff:

[1/5] flink git commit: [FLINK-8785][rest] Handle JobSubmissionExceptions

Repository: flink Updated Branches: refs/heads/master c6ad421e2 -> a25cd3fed [FLINK-8785][rest] Handle JobSubmissionExceptions Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/81d13557 Tree:

[3/5] flink git commit: [FLINK-9280][rest] Rework JobSubmitHandler to accept jar/artifact files

http://git-wip-us.apache.org/repos/asf/flink/blob/a25cd3fe/flink-runtime/src/test/java/org/apache/flink/runtime/rest/MultipartUploadResource.java -- diff --git

[5/5] flink git commit: [hotfix][tests] Use utility functions for setting config

[hotfix][tests] Use utility functions for setting config Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/544bfb94 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/544bfb94 Diff:

[2/5] flink git commit: [FLINK-9301][tests] Enable high-parallellism-iterations test

[FLINK-9301][tests] Enable high-parallellism-iterations test This closes #6024. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/885640f7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/885640f7 Diff:

[1/3] flink git commit: [FLINK-8785][rest] Handle JobSubmissionExceptions

Repository: flink Updated Branches: refs/heads/release-1.5 e0a4c3591 -> 797709cb2 [FLINK-8785][rest] Handle JobSubmissionExceptions Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/06b9bf13 Tree:

[3/3] flink git commit: [FLINK-9289][rest] Rework JobSubmitHandler to accept jar files

[FLINK-9289][rest] Rework JobSubmitHandler to accept jar files Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/797709cb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/797709cb Diff:

[2/3] flink git commit: [FLINK-9289][rest] Rework JobSubmitHandler to accept jar files

http://git-wip-us.apache.org/repos/asf/flink/blob/797709cb/flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandlerTest.java -- diff --git