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"