This is an automated email from the ASF dual-hosted git repository. aljoscha pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit a0d441f8b3ce287c9a380238a1d5dfd7554ac8ee Author: Aljoscha Krettek <aljos...@apache.org> AuthorDate: Fri Dec 6 18:27:34 2019 +0100 [minor] Make RestClient logging less noisy --- .../src/main/java/org/apache/flink/runtime/rest/RestClient.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java index aa79263..aeb3819 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java @@ -149,7 +149,7 @@ public class RestClient implements AutoCloseableAsync { .channel(NioSocketChannel.class) .handler(initializer); - LOG.info("Rest client endpoint started."); + LOG.debug("Rest client endpoint started."); } @Override @@ -162,7 +162,7 @@ public class RestClient implements AutoCloseableAsync { try { shutDownFuture.get(timeout.toMilliseconds(), TimeUnit.MILLISECONDS); - LOG.info("Rest endpoint shutdown complete."); + LOG.debug("Rest endpoint shutdown complete."); } catch (Exception e) { LOG.warn("Rest endpoint shutdown failed.", e); } @@ -170,7 +170,7 @@ public class RestClient implements AutoCloseableAsync { private CompletableFuture<Void> shutdownInternally(Time timeout) { if (isRunning.compareAndSet(true, false)) { - LOG.info("Shutting down rest endpoint."); + LOG.debug("Shutting down rest endpoint."); if (bootstrap != null) { if (bootstrap.group() != null) {