This is an automated email from the ASF dual-hosted git repository.

wlo 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 69f3f9c33 [GOBBLIN-1780] Refactor/rename YarnServiceIT to 
YarnServiceTest (#3637)
69f3f9c33 is described below

commit 69f3f9c33c9679d723c447fbe626db8f1b7afa9e
Author: Andy Jiang <[email protected]>
AuthorDate: Tue Feb 7 14:54:26 2023 -0800

    [GOBBLIN-1780] Refactor/rename YarnServiceIT to YarnServiceTest (#3637)
    
    * Refactor YarnServiceIT to YarnServiceTest
    
    * Refactor additional files
---
 .../gobblin/yarn/{YarnServiceTest.java => YarnServiceIT.java}  | 10 +++++-----
 .../org/apache/gobblin/yarn/YarnServiceTestWithExpiration.java | 10 +++++-----
 .../resources/{YarnServiceTest.conf => YarnServiceIT.conf}     |  6 +++---
 3 files changed, 13 insertions(+), 13 deletions(-)

diff --git 
a/gobblin-yarn/src/test/java/org/apache/gobblin/yarn/YarnServiceTest.java 
b/gobblin-yarn/src/test/java/org/apache/gobblin/yarn/YarnServiceIT.java
similarity index 98%
rename from 
gobblin-yarn/src/test/java/org/apache/gobblin/yarn/YarnServiceTest.java
rename to gobblin-yarn/src/test/java/org/apache/gobblin/yarn/YarnServiceIT.java
index e143a4b35..2f4443053 100644
--- a/gobblin-yarn/src/test/java/org/apache/gobblin/yarn/YarnServiceTest.java
+++ b/gobblin-yarn/src/test/java/org/apache/gobblin/yarn/YarnServiceIT.java
@@ -78,8 +78,8 @@ import org.apache.gobblin.testing.AssertWithBackoff;
  * Tests for {@link YarnService}.
  */
 @Test(groups = {"gobblin.yarn", "disabledOnCI"}, singleThreaded=true)
-public class YarnServiceTest {
-  final Logger LOG = LoggerFactory.getLogger(YarnServiceTest.class);
+public class YarnServiceIT {
+  final Logger LOG = LoggerFactory.getLogger(YarnServiceIT.class);
 
   private YarnClient yarnClient;
   private MiniYARNCluster yarnCluster;
@@ -88,7 +88,7 @@ public class YarnServiceTest {
   private YarnConfiguration clusterConf;
   private ApplicationId applicationId;
   private ApplicationAttemptId applicationAttemptId;
-  private final EventBus eventBus = new EventBus("YarnServiceTest");
+  private final EventBus eventBus = new EventBus("YarnServiceIT");
 
   private final Closer closer = Closer.create();
 
@@ -134,8 +134,8 @@ public class YarnServiceTest {
     this.yarnClient.init(this.clusterConf);
     this.yarnClient.start();
 
-    URL url = YarnServiceTest.class.getClassLoader()
-        .getResource(YarnServiceTest.class.getSimpleName() + ".conf");
+    URL url = YarnServiceIT.class.getClassLoader()
+        .getResource(YarnServiceIT.class.getSimpleName() + ".conf");
     Assert.assertNotNull(url, "Could not find resource " + url);
 
     this.config = ConfigFactory.parseURL(url).resolve();
diff --git 
a/gobblin-yarn/src/test/java/org/apache/gobblin/yarn/YarnServiceTestWithExpiration.java
 
b/gobblin-yarn/src/test/java/org/apache/gobblin/yarn/YarnServiceTestWithExpiration.java
index 1041cc31b..f043d1471 100644
--- 
a/gobblin-yarn/src/test/java/org/apache/gobblin/yarn/YarnServiceTestWithExpiration.java
+++ 
b/gobblin-yarn/src/test/java/org/apache/gobblin/yarn/YarnServiceTestWithExpiration.java
@@ -66,7 +66,7 @@ import org.apache.gobblin.testing.AssertWithBackoff;
  */
 @Test(groups = {"gobblin.yarn", "disabledOnCI"})
 public class YarnServiceTestWithExpiration {
-  final Logger LOG = LoggerFactory.getLogger(YarnServiceTest.class);
+  final Logger LOG = LoggerFactory.getLogger(YarnServiceIT.class);
 
   private YarnClient yarnClient;
   private MiniYARNCluster yarnCluster;
@@ -75,7 +75,7 @@ public class YarnServiceTestWithExpiration {
   private YarnConfiguration clusterConf;
   private ApplicationId applicationId;
   private ApplicationAttemptId applicationAttemptId;
-  private final EventBus eventBus = new EventBus("YarnServiceTest");
+  private final EventBus eventBus = new EventBus("YarnServiceIT");
 
   private final Closer closer = Closer.create();
 
@@ -122,8 +122,8 @@ public class YarnServiceTestWithExpiration {
     this.yarnClient.init(this.clusterConf);
     this.yarnClient.start();
 
-    URL url = YarnServiceTest.class.getClassLoader()
-        .getResource(YarnServiceTest.class.getSimpleName() + ".conf");
+    URL url = YarnServiceIT.class.getClassLoader()
+        .getResource(YarnServiceIT.class.getSimpleName() + ".conf");
     Assert.assertNotNull(url, "Could not find resource " + url);
 
     this.config = ConfigFactory.parseURL(url).resolve();
@@ -215,7 +215,7 @@ public class YarnServiceTestWithExpiration {
 
   }
 
-  private static class TestExpiredYarnService extends 
YarnServiceTest.TestYarnService {
+  private static class TestExpiredYarnService extends 
YarnServiceIT.TestYarnService {
     public HashSet<ContainerId> startErrorContainers = new HashSet<>();
     public HashSet<ContainerStatus> completedContainers = new HashSet<>();
     public TestExpiredYarnService(Config config, String applicationName, 
String applicationId, YarnConfiguration yarnConfiguration,
diff --git a/gobblin-yarn/src/test/resources/YarnServiceTest.conf 
b/gobblin-yarn/src/test/resources/YarnServiceIT.conf
similarity index 94%
rename from gobblin-yarn/src/test/resources/YarnServiceTest.conf
rename to gobblin-yarn/src/test/resources/YarnServiceIT.conf
index 73ecf85cd..83ac38698 100644
--- a/gobblin-yarn/src/test/resources/YarnServiceTest.conf
+++ b/gobblin-yarn/src/test/resources/YarnServiceIT.conf
@@ -16,10 +16,10 @@
 #
 
 # Yarn/Helix configuration properties
-gobblin.cluster.helix.cluster.name=YarnServiceTest
+gobblin.cluster.helix.cluster.name=YarnServiceIT
 gobblin.cluster.helixInstanceTags=GobblinKafkaStreaming
-gobblin.yarn.app.name=YarnServiceTest
-gobblin.yarn.work.dir=YarnServiceTest
+gobblin.yarn.app.name=YarnServiceIT
+gobblin.yarn.work.dir=YarnServiceIT
 
 gobblin.yarn.lib.jars.dir="build/gobblin-yarn/libs"
 gobblin.yarn.conf.dir="gobblin-yarn/src/test/resources"

Reply via email to