Repository: incubator-gobblin Updated Branches: refs/heads/master 9b68773e0 -> 5457af88d
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnAppLauncher.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnAppLauncher.java b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnAppLauncher.java index a5f119d..514386c 100644 --- a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnAppLauncher.java +++ b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnAppLauncher.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.yarn; +package org.apache.gobblin.yarn; import java.io.File; import java.io.IOException; @@ -86,21 +86,21 @@ import com.google.common.util.concurrent.ServiceManager; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.cluster.GobblinClusterConfigurationKeys; -import gobblin.cluster.GobblinClusterUtils; -import gobblin.cluster.GobblinHelixConstants; -import gobblin.cluster.HelixUtils; -import gobblin.configuration.ConfigurationKeys; -import gobblin.rest.JobExecutionInfoServer; -import gobblin.runtime.app.ServiceBasedAppLauncher; -import gobblin.util.ConfigUtils; -import gobblin.util.EmailUtils; -import gobblin.util.ExecutorsUtils; -import gobblin.util.io.StreamUtils; -import gobblin.util.JvmUtils; -import gobblin.util.logs.LogCopier; -import gobblin.yarn.event.ApplicationReportArrivalEvent; -import gobblin.yarn.event.GetApplicationReportFailureEvent; +import org.apache.gobblin.cluster.GobblinClusterConfigurationKeys; +import org.apache.gobblin.cluster.GobblinClusterUtils; +import org.apache.gobblin.cluster.GobblinHelixConstants; +import org.apache.gobblin.cluster.HelixUtils; +import org.apache.gobblin.configuration.ConfigurationKeys; +import org.apache.gobblin.rest.JobExecutionInfoServer; +import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.EmailUtils; +import org.apache.gobblin.util.ExecutorsUtils; +import org.apache.gobblin.util.io.StreamUtils; +import org.apache.gobblin.util.JvmUtils; +import org.apache.gobblin.util.logs.LogCopier; +import org.apache.gobblin.yarn.event.ApplicationReportArrivalEvent; +import org.apache.gobblin.yarn.event.GetApplicationReportFailureEvent; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnConfigurationKeys.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnConfigurationKeys.java b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnConfigurationKeys.java index 904c472..e0b8e31 100644 --- a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnConfigurationKeys.java +++ b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnConfigurationKeys.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.yarn; +package org.apache.gobblin.yarn; /** * A central place for configuration related constants of Gobblin on Yarn. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnEventConstants.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnEventConstants.java b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnEventConstants.java index d148753..907d8c2 100644 --- a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnEventConstants.java +++ b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnEventConstants.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.yarn; +package org.apache.gobblin.yarn; /** * YARN specific event constants to be used with an {@link gobblin.metrics.event.EventSubmitter}. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnLogSource.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnLogSource.java b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnLogSource.java index bb8359a..7163804 100644 --- a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnLogSource.java +++ b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnLogSource.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.yarn; +package org.apache.gobblin.yarn; import java.io.IOException; @@ -28,7 +28,7 @@ import org.apache.hadoop.yarn.api.records.ContainerId; import com.google.common.collect.ImmutableSet; -import gobblin.util.logs.LogCopier; +import org.apache.gobblin.util.logs.LogCopier; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnMetricTagNames.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnMetricTagNames.java b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnMetricTagNames.java index 7e29c48..2269a37 100644 --- a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnMetricTagNames.java +++ b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnMetricTagNames.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.yarn; +package org.apache.gobblin.yarn; /** * A central place for constants of {@link gobblin.metrics.MetricContext} tag names for Gobblin on Yarn. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnTaskRunner.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnTaskRunner.java b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnTaskRunner.java index 110adb3..60dd4d3 100644 --- a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnTaskRunner.java +++ b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnTaskRunner.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.yarn; +package org.apache.gobblin.yarn; import java.util.ArrayList; import java.util.Collections; @@ -47,11 +47,11 @@ import com.google.common.util.concurrent.Service; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; -import gobblin.cluster.GobblinTaskRunner; -import gobblin.cluster.GobblinClusterConfigurationKeys; -import gobblin.util.JvmUtils; -import gobblin.util.logs.Log4jConfigurationHelper; -import gobblin.yarn.event.DelegationTokenUpdatedEvent; +import org.apache.gobblin.cluster.GobblinTaskRunner; +import org.apache.gobblin.cluster.GobblinClusterConfigurationKeys; +import org.apache.gobblin.util.JvmUtils; +import org.apache.gobblin.util.logs.Log4jConfigurationHelper; +import org.apache.gobblin.yarn.event.DelegationTokenUpdatedEvent; public class GobblinYarnTaskRunner extends GobblinTaskRunner { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/HelixMessageSubTypes.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/HelixMessageSubTypes.java b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/HelixMessageSubTypes.java index b818f35..65f2622 100644 --- a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/HelixMessageSubTypes.java +++ b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/HelixMessageSubTypes.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.yarn; +package org.apache.gobblin.yarn; /** * An enumeration of Helix message sub types. http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnAppSecurityManager.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnAppSecurityManager.java b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnAppSecurityManager.java index 63a65cb..26b2fff 100644 --- a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnAppSecurityManager.java +++ b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnAppSecurityManager.java @@ -15,9 +15,9 @@ * limitations under the License. */ -package gobblin.yarn; +package org.apache.gobblin.yarn; -import gobblin.cluster.GobblinHelixMessagingService; +import org.apache.gobblin.cluster.GobblinHelixMessagingService; import java.io.File; import java.io.IOException; import java.util.UUID; @@ -51,7 +51,7 @@ import com.google.common.util.concurrent.AbstractIdleService; import com.typesafe.config.Config; -import gobblin.util.ExecutorsUtils; +import org.apache.gobblin.util.ExecutorsUtils; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnContainerSecurityManager.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnContainerSecurityManager.java b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnContainerSecurityManager.java index ee9f51a..12f8d74 100644 --- a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnContainerSecurityManager.java +++ b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnContainerSecurityManager.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.yarn; +package org.apache.gobblin.yarn; import java.io.IOException; import java.util.Collection; @@ -36,7 +36,7 @@ import com.google.common.eventbus.EventBus; import com.google.common.eventbus.Subscribe; import com.google.common.util.concurrent.AbstractIdleService; -import gobblin.yarn.event.DelegationTokenUpdatedEvent; +import org.apache.gobblin.yarn.event.DelegationTokenUpdatedEvent; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnHelixUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnHelixUtils.java b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnHelixUtils.java index fe46083..c88d7fe 100644 --- a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnHelixUtils.java +++ b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnHelixUtils.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.yarn; +package org.apache.gobblin.yarn; import java.io.File; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnService.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnService.java b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnService.java index 4c76fe6..d4043f1 100644 --- a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnService.java +++ b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnService.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.yarn; +package org.apache.gobblin.yarn; import java.io.File; import java.io.IOException; @@ -79,21 +79,21 @@ import com.google.common.util.concurrent.AbstractIdleService; import com.typesafe.config.Config; -import gobblin.configuration.ConfigurationKeys; - -import gobblin.cluster.GobblinClusterConfigurationKeys; -import gobblin.cluster.GobblinClusterMetricTagNames; -import gobblin.cluster.GobblinClusterUtils; -import gobblin.cluster.HelixUtils; -import gobblin.metrics.GobblinMetrics; -import gobblin.metrics.Tag; -import gobblin.metrics.event.EventSubmitter; -import gobblin.util.ConfigUtils; -import gobblin.util.ExecutorsUtils; -import gobblin.util.JvmUtils; -import gobblin.cluster.event.ClusterManagerShutdownRequest; -import gobblin.yarn.event.ContainerShutdownRequest; -import gobblin.yarn.event.NewContainerRequest; +import org.apache.gobblin.configuration.ConfigurationKeys; + +import org.apache.gobblin.cluster.GobblinClusterConfigurationKeys; +import org.apache.gobblin.cluster.GobblinClusterMetricTagNames; +import org.apache.gobblin.cluster.GobblinClusterUtils; +import org.apache.gobblin.cluster.HelixUtils; +import org.apache.gobblin.metrics.GobblinMetrics; +import org.apache.gobblin.metrics.Tag; +import org.apache.gobblin.metrics.event.EventSubmitter; +import org.apache.gobblin.util.ConfigUtils; +import org.apache.gobblin.util.ExecutorsUtils; +import org.apache.gobblin.util.JvmUtils; +import org.apache.gobblin.cluster.event.ClusterManagerShutdownRequest; +import org.apache.gobblin.yarn.event.ContainerShutdownRequest; +import org.apache.gobblin.yarn.event.NewContainerRequest; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/ApplicationReportArrivalEvent.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/ApplicationReportArrivalEvent.java b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/ApplicationReportArrivalEvent.java index 5ca14a4..ca87993 100644 --- a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/ApplicationReportArrivalEvent.java +++ b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/ApplicationReportArrivalEvent.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.yarn.event; +package org.apache.gobblin.yarn.event; import org.apache.hadoop.yarn.api.records.ApplicationReport; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/ContainerShutdownRequest.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/ContainerShutdownRequest.java b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/ContainerShutdownRequest.java index c9c93cb..832107a 100644 --- a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/ContainerShutdownRequest.java +++ b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/ContainerShutdownRequest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.yarn.event; +package org.apache.gobblin.yarn.event; import java.util.Collection; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/DelegationTokenUpdatedEvent.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/DelegationTokenUpdatedEvent.java b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/DelegationTokenUpdatedEvent.java index 79c4624..6f6d782 100644 --- a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/DelegationTokenUpdatedEvent.java +++ b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/DelegationTokenUpdatedEvent.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.yarn.event; +package org.apache.gobblin.yarn.event; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/GetApplicationReportFailureEvent.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/GetApplicationReportFailureEvent.java b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/GetApplicationReportFailureEvent.java index 2b2ba77..0527ff8 100644 --- a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/GetApplicationReportFailureEvent.java +++ b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/GetApplicationReportFailureEvent.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.yarn.event; +package org.apache.gobblin.yarn.event; import org.apache.hadoop.yarn.api.records.ApplicationReport; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/NewContainerRequest.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/NewContainerRequest.java b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/NewContainerRequest.java index 545e628..7ee4b32 100644 --- a/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/NewContainerRequest.java +++ b/gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/NewContainerRequest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.yarn.event; +package org.apache.gobblin.yarn.event; import org.apache.hadoop.yarn.api.records.Container; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/test/java/org/apache/gobblin/yarn/GobblinYarnAppLauncherTest.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/test/java/org/apache/gobblin/yarn/GobblinYarnAppLauncherTest.java b/gobblin-yarn/src/test/java/org/apache/gobblin/yarn/GobblinYarnAppLauncherTest.java index 7a8e1f1..153e9bd 100644 --- a/gobblin-yarn/src/test/java/org/apache/gobblin/yarn/GobblinYarnAppLauncherTest.java +++ b/gobblin-yarn/src/test/java/org/apache/gobblin/yarn/GobblinYarnAppLauncherTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.yarn; +package org.apache.gobblin.yarn; import com.google.common.base.Predicate; import java.io.File; @@ -51,13 +51,13 @@ import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.cluster.GobblinClusterConfigurationKeys; -import gobblin.cluster.GobblinHelixConstants; -import gobblin.cluster.HelixMessageTestBase; -import gobblin.cluster.HelixUtils; -import gobblin.cluster.TestHelper; -import gobblin.cluster.TestShutdownMessageHandlerFactory; -import gobblin.testing.AssertWithBackoff; +import org.apache.gobblin.cluster.GobblinClusterConfigurationKeys; +import org.apache.gobblin.cluster.GobblinHelixConstants; +import org.apache.gobblin.cluster.HelixMessageTestBase; +import org.apache.gobblin.cluster.HelixUtils; +import org.apache.gobblin.cluster.TestHelper; +import org.apache.gobblin.cluster.TestShutdownMessageHandlerFactory; +import org.apache.gobblin.testing.AssertWithBackoff; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-yarn/src/test/java/org/apache/gobblin/yarn/YarnSecurityManagerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-yarn/src/test/java/org/apache/gobblin/yarn/YarnSecurityManagerTest.java b/gobblin-yarn/src/test/java/org/apache/gobblin/yarn/YarnSecurityManagerTest.java index dbf3c85..a6e6e55 100644 --- a/gobblin-yarn/src/test/java/org/apache/gobblin/yarn/YarnSecurityManagerTest.java +++ b/gobblin-yarn/src/test/java/org/apache/gobblin/yarn/YarnSecurityManagerTest.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package gobblin.yarn; +package org.apache.gobblin.yarn; import java.io.IOException; import java.net.URL; @@ -49,10 +49,10 @@ import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigValueFactory; -import gobblin.cluster.GobblinClusterConfigurationKeys; -import gobblin.cluster.HelixUtils; -import gobblin.cluster.TestHelper; -import gobblin.testing.AssertWithBackoff; +import org.apache.gobblin.cluster.GobblinClusterConfigurationKeys; +import org.apache.gobblin.cluster.HelixUtils; +import org.apache.gobblin.cluster.TestHelper; +import org.apache.gobblin.testing.AssertWithBackoff; /** http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gradle/scripts/defaultBuildProperties.gradle ---------------------------------------------------------------------- diff --git a/gradle/scripts/defaultBuildProperties.gradle b/gradle/scripts/defaultBuildProperties.gradle index 2d7bd9a..7f25b22 100644 --- a/gradle/scripts/defaultBuildProperties.gradle +++ b/gradle/scripts/defaultBuildProperties.gradle @@ -15,8 +15,8 @@ * limitations under the License. */ -import gobblin.gradle.BuildProperties -import gobblin.gradle.BuildProperty +import org.apache.gobblin.gradle.BuildProperties +import org.apache.gobblin.gradle.BuildProperty def BuildProperties BUILD_PROPERTIES = new BuildProperties(project) .register(new BuildProperty("artifactRepository", "https://oss.sonatype.org/service/local/staging/deploy/maven2/";, "Maven repository to publish artifacts"))
