This is an automated email from the ASF dual-hosted git repository.
arjun4084346 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git
The following commit(s) were added to refs/heads/master by this push:
new d58bbc0a12 use a newer api in guava (#4034)
d58bbc0a12 is described below
commit d58bbc0a12689e83696360f86235925743d1be3a
Author: Arjun Singh Bora <[email protected]>
AuthorDate: Thu Aug 22 15:50:16 2024 -0700
use a newer api in guava (#4034)
---
.../main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java | 3 ++-
.../org/apache/gobblin/data/management/retention/DatasetCleaner.java | 3 ++-
.../org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java | 3 ++-
.../apache/gobblin/compliance/retention/ComplianceRetentionJob.java | 3 ++-
.../apache/gobblin/compliance/validation/ComplianceValidationJob.java | 3 ++-
.../java/org/apache/gobblin/runtime/app/ServiceBasedAppLauncher.java | 3 ++-
.../main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java | 3 ++-
7 files changed, 14 insertions(+), 7 deletions(-)
diff --git
a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java
b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java
index 850a1eb04e..f6666ca493 100644
---
a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java
+++
b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java
@@ -55,6 +55,7 @@ import com.google.common.io.Closer;
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 class MRCompactor implements Compactor {
addCallback(datasetsToBeVerified, future2);
}
}
- });
+ }, MoreExecutors.directExecutor());
}
/**
diff --git
a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleaner.java
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleaner.java
index eb3f367cc7..fc6940ade9 100644
---
a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleaner.java
+++
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleaner.java
@@ -40,6 +40,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.ListeningExecutorService;
+import com.google.common.util.concurrent.MoreExecutors;
import com.typesafe.config.Config;
import org.apache.gobblin.configuration.ConfigurationKeys;
@@ -170,7 +171,7 @@ public class DatasetCleaner implements Instrumentable,
Closeable {
LOG.info("Successfully cleaned: " + dataset.datasetURN());
Instrumented.markMeter(DatasetCleaner.this.datasetsCleanSuccessMeter);
}
- });
+ }, MoreExecutors.directExecutor());
}
}
diff --git
a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java
b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java
index 7280c420d7..9b1009dcec 100644
---
a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java
+++
b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java
@@ -32,6 +32,7 @@ import com.google.common.collect.ImmutableMap;
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 class ComplianceRestoreJob extends ComplianceJob {
.of(ComplianceEvents.FAILURE_CONTEXT_METADATA_KEY,
ExceptionUtils.getFullStackTrace(t),
ComplianceEvents.DATASET_URN_METADATA_KEY,
dataset.datasetURN()));
}
- });
+ }, MoreExecutors.directExecutor());
}
}
diff --git
a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/ComplianceRetentionJob.java
b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/ComplianceRetentionJob.java
index 0cf5c2aad7..5543850914 100644
---
a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/ComplianceRetentionJob.java
+++
b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/ComplianceRetentionJob.java
@@ -38,6 +38,7 @@ import com.google.common.collect.ImmutableMap;
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 class ComplianceRetentionJob extends ComplianceJob {
.of(ComplianceEvents.FAILURE_CONTEXT_METADATA_KEY,
ExceptionUtils.getFullStackTrace(t),
ComplianceEvents.DATASET_URN_METADATA_KEY,
dataset.datasetURN()));
}
- });
+ }, MoreExecutors.directExecutor());
}
}
diff --git
a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/validation/ComplianceValidationJob.java
b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/validation/ComplianceValidationJob.java
index 7df4fca966..3bda8db947 100644
---
a/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/validation/ComplianceValidationJob.java
+++
b/gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/validation/ComplianceValidationJob.java
@@ -32,6 +32,7 @@ import com.google.common.collect.ImmutableMap;
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 class ComplianceValidationJob extends ComplianceJob {
.of(ComplianceEvents.FAILURE_CONTEXT_METADATA_KEY,
ExceptionUtils.getFullStackTrace(t),
ComplianceEvents.DATASET_URN_METADATA_KEY,
dataset.datasetURN()));
}
- });
+ }, MoreExecutors.directExecutor());
}
}
diff --git
a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ServiceBasedAppLauncher.java
b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ServiceBasedAppLauncher.java
index b31c00657f..9e5e7ce94d 100644
---
a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ServiceBasedAppLauncher.java
+++
b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ServiceBasedAppLauncher.java
@@ -33,6 +33,7 @@ import org.apache.commons.lang3.reflect.ConstructorUtils;
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 class ServiceBasedAppLauncher implements
ApplicationLauncher {
LOG.error("Could not shutdown services gracefully. This may cause
the application to hang.");
}
}
- });
+ }, MoreExecutors.directExecutor());
Runtime.getRuntime().addShutdownHook(new Thread() {
@Override
diff --git
a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java
b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java
index ce99dbfc72..e0544b4fce 100644
---
a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java
+++
b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java
@@ -59,6 +59,7 @@ import com.google.common.collect.Maps;
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 @@ public class EmbeddedGobblin {
log.error("Failed to shutdown Gobblin instance driver.");
}
}
- });
+ }, MoreExecutors.directExecutor());
return listener.getJobDriver();
}
