use a newer api in guava (apache#4034)

Author: arjun4084346

gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java

@@ -55,6 +55,7 @@
 import com.google.common.util.concurrent.FutureCallback;
 import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.ListenableFuture;
+import com.google.common.util.concurrent.MoreExecutors;
 
 import org.apache.gobblin.compaction.Compactor;
 import org.apache.gobblin.compaction.dataset.Dataset;
@@ -723,7 +724,7 @@ public void onFailure(Throwable t) {
           addCallback(datasetsToBeVerified, future2);
         }
       }
-    });
+    }, MoreExecutors.directExecutor());
   }
 
   /**

gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleaner.java

@@ -40,6 +40,7 @@
 import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.ListenableFuture;
 import com.google.common.util.concurrent.ListeningExecutorService;
+import com.google.common.util.concurrent.MoreExecutors;
 import com.typesafe.config.Config;
 
 import org.apache.gobblin.configuration.ConfigurationKeys;
@@ -170,7 +171,7 @@ public void onSuccess(Void arg0) {
           LOG.info("Successfully cleaned: " + dataset.datasetURN());
           Instrumented.markMeter(DatasetCleaner.this.datasetsCleanSuccessMeter);
         }
-      });
+      }, MoreExecutors.directExecutor());
     }
   }
 

gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java

@@ -32,6 +32,7 @@
 import com.google.common.util.concurrent.FutureCallback;
 import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.ListenableFuture;
+import com.google.common.util.concurrent.MoreExecutors;
 
 import javax.annotation.Nullable;
 import lombok.extern.slf4j.Slf4j;
@@ -109,7 +110,7 @@ public void onFailure(Throwable t) {
               .of(ComplianceEvents.FAILURE_CONTEXT_METADATA_KEY, ExceptionUtils.getFullStackTrace(t),
                   ComplianceEvents.DATASET_URN_METADATA_KEY, dataset.datasetURN()));
         }
-      });
+      }, MoreExecutors.directExecutor());
     }
   }
 

gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/ComplianceRetentionJob.java

@@ -38,6 +38,7 @@
 import com.google.common.util.concurrent.FutureCallback;
 import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.ListenableFuture;
+import com.google.common.util.concurrent.MoreExecutors;
 
 import edu.umd.cs.findbugs.annotations.SuppressWarnings;
 import javax.annotation.Nullable;
@@ -156,7 +157,7 @@ public void onFailure(Throwable t) {
               .of(ComplianceEvents.FAILURE_CONTEXT_METADATA_KEY, ExceptionUtils.getFullStackTrace(t),
                   ComplianceEvents.DATASET_URN_METADATA_KEY, dataset.datasetURN()));
         }
-      });
+      }, MoreExecutors.directExecutor());
     }
   }
 

gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/validation/ComplianceValidationJob.java

@@ -32,6 +32,7 @@
 import com.google.common.util.concurrent.FutureCallback;
 import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.ListenableFuture;
+import com.google.common.util.concurrent.MoreExecutors;
 
 import javax.annotation.Nullable;
 import lombok.extern.slf4j.Slf4j;
@@ -106,7 +107,7 @@ public void onFailure(Throwable t) {
               .of(ComplianceEvents.FAILURE_CONTEXT_METADATA_KEY, ExceptionUtils.getFullStackTrace(t),
                   ComplianceEvents.DATASET_URN_METADATA_KEY, dataset.datasetURN()));
         }
-      });
+      }, MoreExecutors.directExecutor());
     }
   }
 

gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ServiceBasedAppLauncher.java

@@ -33,6 +33,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import com.google.common.util.concurrent.MoreExecutors;
 import com.google.common.util.concurrent.Service;
 import com.google.common.util.concurrent.ServiceManager;
 
@@ -157,7 +158,7 @@ public void failure(Service service) {
           LOG.error("Could not shutdown services gracefully. This may cause the application to hang.");
         }
       }
-    });
+    }, MoreExecutors.directExecutor());
 
     Runtime.getRuntime().addShutdownHook(new Thread() {
       @Override

gobblin-runtime/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java

@@ -59,6 +59,7 @@
 import com.google.common.escape.Escaper;
 import com.google.common.util.concurrent.FutureCallback;
 import com.google.common.util.concurrent.Futures;
+import com.google.common.util.concurrent.MoreExecutors;
 import com.linkedin.data.template.DataTemplate;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
@@ -513,7 +514,7 @@ private void stopGobblinInstanceDriver() {
           log.error("Failed to shutdown Gobblin instance driver.");
         }
       }
-    });
+    }, MoreExecutors.directExecutor());
 
     return listener.getJobDriver();
   }