Repository: flink Updated Branches: refs/heads/master 75b8398b5 -> f270deca3
[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/f270deca Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f270deca Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f270deca Branch: refs/heads/master Commit: f270deca3a1f64124b9c1aad4e925535be0b01be Parents: a4442f8 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:13:11 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/f270deca/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);
