GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/4176
[FLINK-6916][blob] add API to allow job-related BLOBs to be stored
This PR is the fourth in a series for FLIP-19, based upon #4174. It allows
(CONTENT_ADDRESSABLE) BLOBs to not only be stored job-independently but also
based on a jobId which will become the future default for JARs,
`TaskDeploymentDescriptor` data, and `DistributedCache` data.
Please note that we will rework/reorganise the whole BLOB store APIs
completely in a future request. This PR focusses on the added functionality.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/NicoK/flink flink-6916-3-jobid
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/4176.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #4176
----
commit ce719ee39fbbca7b7828c17d9792fc87d37450c7
Author: Nico Kruber <n...@data-artisans.com>
Date: 2017-01-06T17:42:58Z
[FLINK-6008][docs] update some config options to the new, non-deprecated
ones
commit 9efa8808e46adc1253f52a6a8cec6d3b4d29fee3
Author: Nico Kruber <n...@data-artisans.com>
Date: 2016-12-20T15:49:57Z
[FLINK-6008][docs] minor improvements in the BlobService docs
commit ca3d533b0affa645ec93d40de378dadc829bbfe5
Author: Nico Kruber <n...@data-artisans.com>
Date: 2016-12-20T17:27:13Z
[FLINK-6008] refactor BlobCache#getURL() for cleaner code
commit 0eededeb36dd833835753def7f4bb27c9d5fb67e
Author: Nico Kruber <n...@data-artisans.com>
Date: 2017-03-09T17:14:02Z
[FLINK-6008] use Preconditions.checkArgument in BlobClient
commit 6249041a9db2b39ddf54e79a1aed5e7706e739c7
Author: Nico Kruber <n...@data-artisans.com>
Date: 2016-12-21T15:23:29Z
[FLINK-6008] do not fail the BlobServer if delete fails
also extend the delete tests and remove one code duplication
commit e681239a538547f752d65358db1ebd2ba312b33c
Author: Nico Kruber <n...@data-artisans.com>
Date: 2017-03-17T15:21:40Z
[FLINK-6008] fix concurrent job directory creation
also add according unit tests
commit 20beae2dbc91859e2ec724b35b20536dcd11fe90
Author: Nico Kruber <n...@data-artisans.com>
Date: 2017-04-18T14:37:37Z
[FLINK-6008] some comments about BlobLibraryCacheManager cleanup
commit 8a33517fe6eb2fa932ab17cb0d82a3fa8d7b8d0b
Author: Nico Kruber <n...@data-artisans.com>
Date: 2017-04-19T13:39:03Z
[hotfix] minor typos
commit 23889866ac21494fc4af90905ab1518cbe897118
Author: Nico Kruber <n...@data-artisans.com>
Date: 2017-04-19T14:10:16Z
[FLINK-6008] further cleanup tests for BlobLibraryCacheManager
commit 01b1a245528c264a6061ed3a48b24c5a207369f6
Author: Nico Kruber <n...@data-artisans.com>
Date: 2017-06-14T16:01:47Z
[FLINK-6008] do not guard a delete() call with a check for existence
commit cb249759b79d88eda37a8bb149040be3052059ac
Author: Nico Kruber <n...@data-artisans.com>
Date: 2017-06-16T08:51:04Z
[FLINK-6916][blob] remove (unused) NAME_ADDRESSABLE mode
commit 7d3333c9cdb5bcf19a5e6b3190ce564201f1cc24
Author: Nico Kruber <n...@data-artisans.com>
Date: 2017-06-21T15:05:57Z
[FLINK-6916][blob] remove further unused code due to the NAME_ADDRESSABLE
removal
commit 00242371fed84a658ce88765204c450cc7819cf3
Author: Nico Kruber <n...@data-artisans.com>
Date: 2017-06-22T15:31:17Z
[FLINK-6916] remove code duplication in BlobClientSslTest
This lets BlobClientSslTest extend BlobClientTest as most of its
implementation
came from there and was simply copied.
commit 2a251e5cef0b757333d0dc1ff37f78fa0ea6eba7
Author: Nico Kruber <n...@data-artisans.com>
Date: 2017-06-21T12:45:31Z
[FLINK-6916] remove LibraryCacheManager#getFile()
This was only used in tests where it is avoidable but if used anywhere
else, it
may have caused cleanup issues.
commit 12d76e96247fc34a498260d323c67cbd07f3f905
Author: Nico Kruber <n...@data-artisans.com>
Date: 2017-06-21T14:14:15Z
[FLINK-6916][blob] refactor getURL() to the more generic getFile()
The fact that we always returned URL objects is a relic of the BlobServer's
only
use for URLClassLoader. Since we'd like to extend its use, returning File
objects instead is more generic.
commit 3126c3c5e0c146e16d415fe75ccbfaf1770a3bea
Author: Nico Kruber <n...@data-artisans.com>
Date: 2017-06-23T09:40:34Z
[FLINK-6916][blob] verify some of the buffers returned by GET
commit 4992ad7bb093444356d4258f2abe0731e1c18825
Author: Nico Kruber <n...@data-artisans.com>
Date: 2017-06-23T10:04:10Z
[FLINK-6916][blob] use TemporaryFolder for local BLOB dir in unit tests
This replaces the use of some temporary directory where it is not guaranteed
that it will be deleted after the test.
commit d87d742b9a19efc1a26d2dda0c724d286ba9904d
Author: Nico Kruber <n...@data-artisans.com>
Date: 2017-06-21T16:04:43Z
[FLINK-6916][blob] add API to allow job-related BLOBs to be stored
commit 053f4ba218e10038ddb4fa8790bb171144f70a72
Author: Nico Kruber <n...@data-artisans.com>
Date: 2017-06-23T17:17:07Z
[FLINK-6916][blob] refactor the new API for job-related BLOBs
For a cleaner API, instead of having a nullable jobId parameter, use two
methods:
one for job-related BLOBs, another for job-unrelated ones.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
