flink git commit: [FLINK-7853] [table] Reject table function outer joins with predicates in Table API.

2017-10-18 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-1.3 b896b4b65 -> c112e2363 [FLINK-7853] [table] Reject table function outer joins with predicates in Table API. This closes #4842. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-7853] [table] Reject table function outer joins with predicates in Table API.

2017-10-18 Thread fhueske
Repository: flink Updated Branches: refs/heads/master eaa5a4668 -> c81a6db44 [FLINK-7853] [table] Reject table function outer joins with predicates in Table API. This closes #4842. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [FLINK-7368][metrics] Backport synchronization fix for MetricStore

2017-10-18 Thread chesnay
Repository: flink Updated Branches: refs/heads/release-1.3 80c23de70 -> b896b4b65 [FLINK-7368][metrics] Backport synchronization fix for MetricStore This closes #4841. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[4/4] flink git commit: [FLINK-7813] [metrics] Replace MetricRegistryThreadFactory

2017-10-18 Thread chesnay
[FLINK-7813] [metrics] Replace MetricRegistryThreadFactory This closes #4803. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e14f2dbd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e14f2dbd Diff:

[3/4] flink git commit: [hotfix] Fix typo in CassandraSink

2017-10-18 Thread chesnay
[hotfix] Fix typo in CassandraSink Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2b7d6d5b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2b7d6d5b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2b7d6d5b

[2/4] flink git commit: [FLINK-7703] Port JobExceptionsHandler to new REST endpoint

2017-10-18 Thread chesnay
[FLINK-7703] Port JobExceptionsHandler to new REST endpoint This closes #4834. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cb528a11 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cb528a11 Diff:

[1/4] flink git commit: [FLINK-6314] [cassandra] Support user-defined Mapper options

2017-10-18 Thread chesnay
Repository: flink Updated Branches: refs/heads/master 7d026aa72 -> eaa5a4668 [FLINK-6314] [cassandra] Support user-defined Mapper options This closes #4831. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/eaa5a466 Tree:

flink git commit: [FLINK-7757] [checkpointing] Introduce resource guard for RocksDBKeyedStateBackend to reduce locking and avoid blocking behavior.

2017-10-18 Thread srichter
Repository: flink Updated Branches: refs/heads/master abc3e1c88 -> 7d026aa72 [FLINK-7757] [checkpointing] Introduce resource guard for RocksDBKeyedStateBackend to reduce locking and avoid blocking behavior. This closes #4764. Project: http://git-wip-us.apache.org/repos/asf/flink/repo

[1/2] flink git commit: [FLINK-7826][QS] Add support for all types of state to the QS Client.

2017-10-18 Thread kkloudas
Repository: flink Updated Branches: refs/heads/master 717a7dc81 -> abc3e1c88 http://git-wip-us.apache.org/repos/asf/flink/blob/abc3e1c8/flink-queryable-state/flink-queryable-state-java/src/test/java/org/apache/flink/queryablestate/state/ImmutableValueStateTest.java

[2/2] flink git commit: [FLINK-7826][QS] Add support for all types of state to the QS Client.

2017-10-18 Thread kkloudas
[FLINK-7826][QS] Add support for all types of state to the QS Client. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/abc3e1c8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/abc3e1c8 Diff:

[2/2] flink git commit: [FLINK-7788][QS] Allow specification of port range for queryable state proxy.

2017-10-18 Thread kkloudas
[FLINK-7788][QS] Allow specification of port range for queryable state proxy. The queryable state client proxy can now take a port range as argument so that if multiple proxies run on one machine, they can all start without problems. Project: http://git-wip-us.apache.org/repos/asf/flink/repo

[1/2] flink git commit: [FLINK-5920][QS] Allow specification of port range for queryable state server.

2017-10-18 Thread kkloudas
Repository: flink Updated Branches: refs/heads/master 9772e03d7 -> 717a7dc81 [FLINK-5920][QS] Allow specification of port range for queryable state server. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/717a7dc8 Tree: