[3/6] flink git commit: [FLINK-8065][QS] Improve error message when client already shut down.

2017-11-17 Thread kkloudas
[FLINK-8065][QS] Improve error message when client already shut down. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6314e486 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6314e486 Diff:

[5/6] flink git commit: [FLINK-8059][QS] QS client throws FlinkJobNotFoundException for queries with unknown jobIds.

2017-11-17 Thread kkloudas
[FLINK-8059][QS] QS client throws FlinkJobNotFoundException for queries with unknown jobIds. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1a68d752 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1a68d752 Diff:

[1/6] flink git commit: [FLINK-8063][QS] QS client does not retry when an UnknownKvStateLocation is thrown.

2017-11-17 Thread kkloudas
Repository: flink Updated Branches: refs/heads/release-1.4 42e24413b -> 3753ae251 [FLINK-8063][QS] QS client does not retry when an UnknownKvStateLocation is thrown. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[6/6] flink git commit: [FLINK-8057][QS] Change error message in KvStateRegistry.registerKvState().

2017-11-17 Thread kkloudas
[FLINK-8057][QS] Change error message in KvStateRegistry.registerKvState(). Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3753ae25 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3753ae25 Diff:

[4/6] flink git commit: [FLINK-8055][QS] Deduplicate logging messages about QS start.

2017-11-17 Thread kkloudas
[FLINK-8055][QS] Deduplicate logging messages about QS start. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/12b0c58f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/12b0c58f Diff:

[2/6] flink git commit: [FLINK-8062][QS] Make getKvState() with namespace private.

2017-11-17 Thread kkloudas
[FLINK-8062][QS] Make getKvState() with namespace private. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/96b350ad Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/96b350ad Diff:

flink git commit: [FLINK-8063][QS] QS client does not retry when an UnknownKvStateLocation is thrown.

2017-11-17 Thread kkloudas
Repository: flink Updated Branches: refs/heads/master 81dc260dc -> a0838de79 [FLINK-8063][QS] QS client does not retry when an UnknownKvStateLocation is thrown. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a0838de7

[5/5] flink git commit: [FLINK-8057][QS] Change error message in KvStateRegistry.registerKvState()

2017-11-17 Thread kkloudas
[FLINK-8057][QS] Change error message in KvStateRegistry.registerKvState() Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a4d86975 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a4d86975 Diff:

[1/5] flink git commit: [FLINK-8062][QS] Make getKvState() with namespace private.

2017-11-17 Thread kkloudas
Repository: flink Updated Branches: refs/heads/master a0838de79 -> a4d869759 [FLINK-8062][QS] Make getKvState() with namespace private. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ff7e3cf6 Tree:

[2/5] flink git commit: [FLINK-8055][QS] Deduplicate logging messages about QS start.

2017-11-17 Thread kkloudas
[FLINK-8055][QS] Deduplicate logging messages about QS start. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5e059e96 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5e059e96 Diff:

flink git commit: [FLINK-8061][QS] Remove trailing * in QSClient javadocs.

2017-11-17 Thread kkloudas
Repository: flink Updated Branches: refs/heads/master a4d869759 -> 3edbb7bce [FLINK-8061][QS] Remove trailing * in QSClient javadocs. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3edbb7bc Tree:

flink git commit: [FLINK-8061][QS] Remove trailing * in QSClient javadocs.

2017-11-17 Thread kkloudas
Repository: flink Updated Branches: refs/heads/release-1.4 3753ae251 -> e784f3a18 [FLINK-8061][QS] Remove trailing * in QSClient javadocs. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e784f3a1 Tree:

[2/2] flink git commit: [FLINK-7265] [core] Introduce FileSystemKind to differentiate between FileSystem and ObjectStore

2017-11-17 Thread aljoscha
[FLINK-7265] [core] Introduce FileSystemKind to differentiate between FileSystem and ObjectStore Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f29f8057 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f29f8057 Diff:

[1/2] flink git commit: [FLINK-7266] [core] Prevent attempt for parent directory deletion for object stores

2017-11-17 Thread aljoscha
Repository: flink Updated Branches: refs/heads/master 3edbb7bce -> b00f1b326 [FLINK-7266] [core] Prevent attempt for parent directory deletion for object stores This closes #4397 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/2] flink git commit: [FLINK-7266] [core] Prevent attempt for parent directory deletion for object stores

2017-11-17 Thread aljoscha
Repository: flink Updated Branches: refs/heads/release-1.4 e784f3a18 -> 666b1b2e6 [FLINK-7266] [core] Prevent attempt for parent directory deletion for object stores This closes #4397 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [FLINK-7265] [core] Introduce FileSystemKind to differentiate between FileSystem and ObjectStore

2017-11-17 Thread aljoscha
[FLINK-7265] [core] Introduce FileSystemKind to differentiate between FileSystem and ObjectStore Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a0dbe182 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a0dbe182 Diff: