Repository: flink Updated Branches: refs/heads/release-1.4 a044d9d6c -> 59f9ded8f
[FLINK-8652] [QS] Reduce log level in getKvState to DEBUG. This closes #5489. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/59f9ded8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/59f9ded8 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/59f9ded8 Branch: refs/heads/release-1.4 Commit: 59f9ded8fd36d17b339f46a7a95286ff703719ef Parents: a044d9d Author: Fabian Hueske <fhue...@apache.org> Authored: Wed Feb 14 15:43:16 2018 +0100 Committer: Fabian Hueske <fhue...@apache.org> Committed: Wed Feb 14 20:15:17 2018 +0100 ---------------------------------------------------------------------- .../apache/flink/queryablestate/client/QueryableStateClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/59f9ded8/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java ---------------------------------------------------------------------- diff --git a/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java b/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java index f1c69ed..2a6baf0 100644 --- a/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java +++ b/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java @@ -268,7 +268,7 @@ public class QueryableStateClient { final String queryableStateName, final int keyHashCode, final byte[] serializedKeyAndNamespace) { - LOG.info("Sending State Request to {}.", remoteAddress); + LOG.debug("Sending State Request to {}.", remoteAddress); try { KvStateRequest request = new KvStateRequest(jobId, queryableStateName, keyHashCode, serializedKeyAndNamespace); return client.sendRequest(remoteAddress, request);
