Reduce some overly verbose log lines to debug

Author: Sushisource

temporal-sdk/src/main/java/io/temporal/internal/worker/AsyncPoller.java

@@ -305,7 +305,7 @@ public void run() {
           if (shouldTerminate()) {
             pollerBalancer.removePoller(asyncTaskPoller.getLabel());
             abort = true;
-            log.info(
+            log.debug(
                 "Poll loop is terminated: {} - {}",
                 AsyncPoller.this.getClass().getSimpleName(),
                 asyncTaskPoller.getLabel());

temporal-sdk/src/main/java/io/temporal/internal/worker/BasePoller.java

@@ -52,7 +52,7 @@ public boolean isTerminated() {
 
   @Override
   public CompletableFuture<Void> shutdown(ShutdownManager shutdownManager, boolean interruptTasks) {
-    log.info("shutdown: {}", this);
+    log.debug("shutdown: {}", this);
     WorkerLifecycleState lifecycleState = getLifecycleState();
     switch (lifecycleState) {
       case NOT_STARTED:

temporal-sdk/src/main/java/io/temporal/internal/worker/MultiThreadedPoller.java

@@ -193,7 +193,7 @@ public void run() {
           // Resubmit itself back to pollExecutor
           pollExecutor.execute(this);
         } else {
-          log.info(
+          log.debug(
               "poll loop is terminated: {}",
               MultiThreadedPoller.this.pollTask.getClass().getSimpleName());
         }

temporal-sdk/src/main/java/io/temporal/worker/WorkerFactory.java

@@ -391,7 +391,7 @@ public WorkflowClient getWorkflowClient() {
    * Invocation has no additional effect if already shut down.
    */
   public synchronized void shutdown() {
-    log.info("shutdown: {}", this);
+    log.debug("shutdown: {}", this);
     shutdownInternal(false);
   }
 
@@ -497,7 +497,7 @@ private void doShutdown(boolean interruptUserTasks) {
    * occurs.
    */
   public void awaitTermination(long timeout, TimeUnit unit) {
-    log.info("awaitTermination begin: {}", this);
+    log.debug("awaitTermination begin: {}", this);
     long timeoutMillis = unit.toMillis(timeout);
     for (Worker worker : workers.values()) {
       long t = timeoutMillis; // closure needs immutable value
@@ -510,7 +510,7 @@ public void awaitTermination(long timeout, TimeUnit unit) {
       ShutdownManager.runAndGetRemainingTimeoutMs(
           t, () -> workerCommandWorker.awaitTermination(t, TimeUnit.MILLISECONDS));
     }
-    log.info("awaitTermination done: {}", this);
+    log.debug("awaitTermination done: {}", this);
   }
 
   // TODO we should hide an actual implementation of WorkerFactory under WorkerFactory interface and

temporal-serviceclient/src/main/java/io/temporal/serviceclient/CloudServiceStubsImpl.java

@@ -39,7 +39,7 @@ final class CloudServiceStubsImpl implements CloudServiceStubs {
                 .setInternalErrorDifferentiation(true)
                 .build());
 
-    log.info("Created CloudServiceStubs for channel: {}", channelManager.getRawChannel());
+    log.debug("Created CloudServiceStubs for channel: {}", channelManager.getRawChannel());
 
     this.blockingStub = CloudServiceGrpc.newBlockingStub(channelManager.getInterceptedChannel());
     this.futureStub = CloudServiceGrpc.newFutureStub(channelManager.getInterceptedChannel());

temporal-serviceclient/src/main/java/io/temporal/serviceclient/OperatorServiceStubsImpl.java

@@ -32,7 +32,7 @@ final class OperatorServiceStubsImpl implements OperatorServiceStubs {
     this.channelManager =
         new ChannelManager(options, Collections.singletonList(deadlineInterceptor));
 
-    log.info("Created OperatorServiceStubs for channel: {}", channelManager.getRawChannel());
+    log.debug("Created OperatorServiceStubs for channel: {}", channelManager.getRawChannel());
 
     this.blockingStub = OperatorServiceGrpc.newBlockingStub(channelManager.getInterceptedChannel());
     this.futureStub = OperatorServiceGrpc.newFutureStub(channelManager.getInterceptedChannel());

temporal-serviceclient/src/main/java/io/temporal/serviceclient/WorkflowServiceStubsImpl.java

@@ -63,7 +63,7 @@ final class WorkflowServiceStubsImpl implements WorkflowServiceStubs {
     this.channelManager =
         new ChannelManager(this.options, Collections.singletonList(deadlineInterceptor));
 
-    log.info(
+    log.debug(
         String.format(
             "Created WorkflowServiceStubs for channel: %s", channelManager.getRawChannel()));
 

temporal-test-server/src/main/java/io/temporal/serviceclient/TestServiceStubsImpl.java

@@ -32,7 +32,7 @@ public class TestServiceStubsImpl implements TestServiceStubs {
     this.channelManager =
         new ChannelManager(options, Collections.singletonList(deadlineInterceptor));
 
-    log.info("Created TestServiceStubs for channel: {}", channelManager.getRawChannel());
+    log.debug("Created TestServiceStubs for channel: {}", channelManager.getRawChannel());
 
     this.blockingStub = TestServiceGrpc.newBlockingStub(channelManager.getInterceptedChannel());
     this.futureStub = TestServiceGrpc.newFutureStub(channelManager.getInterceptedChannel());