gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [05/77] [abbrv] incubator-gobblin git commit: Updated package names, imports and shell scripts
Date Mon, 31 Jul 2017 07:52:23 GMT
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/scheduler/JobConfigFileMonitorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/scheduler/JobConfigFileMonitorTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/scheduler/JobConfigFileMonitorTest.java
index e1471ac..5d5025e 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/scheduler/JobConfigFileMonitorTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/scheduler/JobConfigFileMonitorTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.scheduler;
+package org.apache.gobblin.scheduler;
 
 import java.io.File;
 import java.io.FileReader;
@@ -42,8 +42,8 @@ import com.google.common.collect.Lists;
 import com.google.common.collect.Sets;
 import com.google.common.util.concurrent.ServiceManager;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.testing.AssertWithBackoff;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.testing.AssertWithBackoff;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/source/extractor/filebased/TextFileBasedSourceTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/source/extractor/filebased/TextFileBasedSourceTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/source/extractor/filebased/TextFileBasedSourceTest.java
index dbf5259..b02832b 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/source/extractor/filebased/TextFileBasedSourceTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/source/extractor/filebased/TextFileBasedSourceTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.source.extractor.filebased;
+package org.apache.gobblin.source.extractor.filebased;
 
 import java.io.File;
 import java.util.Set;
@@ -29,11 +29,11 @@ import com.google.common.base.Charsets;
 import com.google.common.collect.Sets;
 import com.google.common.io.Files;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.embedded.EmbeddedGobblin;
-import gobblin.writer.test.GobblinTestEventBusWriter;
-import gobblin.writer.test.TestingEventBusAsserter;
-import gobblin.writer.test.TestingEventBuses;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.embedded.EmbeddedGobblin;
+import org.apache.gobblin.writer.test.GobblinTestEventBusWriter;
+import org.apache.gobblin.writer.test.TestingEventBusAsserter;
+import org.apache.gobblin.writer.test.TestingEventBuses;
 
 public class TextFileBasedSourceTest {
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/FlowCatalogTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/FlowCatalogTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/FlowCatalogTest.java
index dfac6c7..c42e605 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/FlowCatalogTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/FlowCatalogTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.spec_catalog;
+package org.apache.gobblin.spec_catalog;
 
 import java.io.File;
 import java.net.URI;
@@ -37,14 +37,14 @@ import com.google.gson.Gson;
 import com.google.gson.GsonBuilder;
 import com.typesafe.config.Config;
 
-import gobblin.runtime.api.Spec;
-import gobblin.runtime.api.SpecExecutorInstanceProducer;
-import gobblin.runtime.api.FlowSpec;
-import gobblin.runtime.app.ServiceBasedAppLauncher;
-import gobblin.runtime.spec_catalog.FlowCatalog;
-import gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer;
-import gobblin.util.ConfigUtils;
-import gobblin.util.PathUtils;
+import org.apache.gobblin.runtime.api.Spec;
+import org.apache.gobblin.runtime.api.SpecExecutorInstanceProducer;
+import org.apache.gobblin.runtime.api.FlowSpec;
+import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher;
+import org.apache.gobblin.runtime.spec_catalog.FlowCatalog;
+import org.apache.gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer;
+import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.PathUtils;
 
 
 public class FlowCatalogTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/TopologyCatalogTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/TopologyCatalogTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/TopologyCatalogTest.java
index dd98e85..594c755 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/TopologyCatalogTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/spec_catalog/TopologyCatalogTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.spec_catalog;
+package org.apache.gobblin.spec_catalog;
 
 import java.io.File;
 import java.net.URI;
@@ -36,14 +36,14 @@ import com.google.gson.Gson;
 import com.google.gson.GsonBuilder;
 import com.typesafe.config.Config;
 
-import gobblin.runtime.api.Spec;
-import gobblin.runtime.api.SpecExecutorInstanceProducer;
-import gobblin.runtime.api.TopologySpec;
-import gobblin.runtime.app.ServiceBasedAppLauncher;
-import gobblin.runtime.spec_catalog.TopologyCatalog;
-import gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer;
-import gobblin.util.ConfigUtils;
-import gobblin.util.PathUtils;
+import org.apache.gobblin.runtime.api.Spec;
+import org.apache.gobblin.runtime.api.SpecExecutorInstanceProducer;
+import org.apache.gobblin.runtime.api.TopologySpec;
+import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher;
+import org.apache.gobblin.runtime.spec_catalog.TopologyCatalog;
+import org.apache.gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer;
+import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.PathUtils;
 
 
 public class TopologyCatalogTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/task/CustomTaskTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/task/CustomTaskTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/task/CustomTaskTest.java
index dc24bc4..7056b12 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/task/CustomTaskTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/task/CustomTaskTest.java
@@ -15,17 +15,17 @@
  * limitations under the License.
  */
 
-package gobblin.task;
+package org.apache.gobblin.task;
 
 import com.google.common.collect.HashMultimap;
 import com.google.common.collect.SetMultimap;
 import com.google.common.collect.Sets;
 import com.google.common.eventbus.EventBus;
 import com.google.common.io.Files;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.JobExecutionResult;
-import gobblin.runtime.embedded.EmbeddedGobblin;
-import gobblin.writer.test.TestingEventBuses;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.JobExecutionResult;
+import org.apache.gobblin.runtime.embedded.EmbeddedGobblin;
+import org.apache.gobblin.writer.test.TestingEventBuses;
 import java.io.File;
 import java.util.Set;
 import java.util.UUID;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/task/EventBusPublishingTaskFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/task/EventBusPublishingTaskFactory.java b/gobblin-runtime/src/test/java/org/apache/gobblin/task/EventBusPublishingTaskFactory.java
index bc47446..f4168df 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/task/EventBusPublishingTaskFactory.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/task/EventBusPublishingTaskFactory.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.task;
+package org.apache.gobblin.task;
 
 import java.io.IOException;
 import java.util.Collection;
@@ -32,21 +32,21 @@ import com.google.common.collect.SetMultimap;
 import com.google.common.eventbus.EventBus;
 import com.google.common.eventbus.Subscribe;
 
-import gobblin.configuration.SourceState;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.publisher.DataPublisher;
-import gobblin.publisher.NoopPublisher;
-import gobblin.runtime.JobState;
-import gobblin.runtime.TaskContext;
-import gobblin.runtime.TaskState;
-import gobblin.runtime.task.BaseAbstractTask;
-import gobblin.runtime.task.TaskFactory;
-import gobblin.runtime.task.TaskIFace;
-import gobblin.runtime.task.TaskUtils;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.writer.test.TestingEventBuses;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.publisher.DataPublisher;
+import org.apache.gobblin.publisher.NoopPublisher;
+import org.apache.gobblin.runtime.JobState;
+import org.apache.gobblin.runtime.TaskContext;
+import org.apache.gobblin.runtime.TaskState;
+import org.apache.gobblin.runtime.task.BaseAbstractTask;
+import org.apache.gobblin.runtime.task.TaskFactory;
+import org.apache.gobblin.runtime.task.TaskIFace;
+import org.apache.gobblin.runtime.task.TaskUtils;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.writer.test.TestingEventBuses;
 
 import lombok.Data;
 import lombok.EqualsAndHashCode;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter.java b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter.java
index 4dbe12f..f42f9c1 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.test;
+package org.apache.gobblin.test;
 
 import java.lang.reflect.Type;
 import java.util.Map;
@@ -28,9 +28,9 @@ import com.google.gson.Gson;
 import com.google.gson.JsonElement;
 import com.google.gson.reflect.TypeToken;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.SingleRecordIterable;
-import gobblin.converter.ToAvroConverterBase;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.converter.ToAvroConverterBase;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter2.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter2.java b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter2.java
index 4b2fad0..b28117b 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter2.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestConverter2.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.test;
+package org.apache.gobblin.test;
 
 import java.lang.reflect.Type;
 import java.util.Map;
@@ -28,13 +28,13 @@ import com.google.gson.Gson;
 import com.google.gson.JsonElement;
 import com.google.gson.reflect.TypeToken;
 
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SingleRecordIterable;
-import gobblin.fork.CopyNotSupportedException;
-import gobblin.fork.CopyableGenericRecord;
-import gobblin.fork.CopyableSchema;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SingleRecordIterable;
+import org.apache.gobblin.fork.CopyNotSupportedException;
+import org.apache.gobblin.fork.CopyableGenericRecord;
+import org.apache.gobblin.fork.CopyableSchema;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestDataPublisher.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestDataPublisher.java b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestDataPublisher.java
index 59d33f8..8af01a7 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestDataPublisher.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestDataPublisher.java
@@ -15,15 +15,15 @@
  * limitations under the License.
  */
 
-package gobblin.test;
+package org.apache.gobblin.test;
 
 import java.io.IOException;
 import java.util.Collection;
 
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.publisher.DataPublisher;
-import gobblin.publisher.SingleTaskDataPublisher;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.publisher.DataPublisher;
+import org.apache.gobblin.publisher.SingleTaskDataPublisher;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestExtractor.java b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestExtractor.java
index cb4fb43..8843d67 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestExtractor.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestExtractor.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.test;
+package org.apache.gobblin.test;
 
 import java.io.IOException;
 import java.net.URI;
@@ -32,9 +32,9 @@ import org.apache.hadoop.fs.Path;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.Extractor;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.Extractor;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestSource.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestSource.java b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestSource.java
index 2c36f49..aa1b548 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestSource.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/test/TestSource.java
@@ -15,23 +15,23 @@
  * limitations under the License.
  */
 
-package gobblin.test;
+package org.apache.gobblin.test;
 
 import java.util.List;
 
 import com.google.common.base.Splitter;
 import com.google.common.collect.Lists;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.Source;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.extract.AbstractSource;
-import gobblin.source.workunit.Extract;
-import gobblin.source.workunit.Extract.TableType;
-import gobblin.source.workunit.MultiWorkUnit;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.Source;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.extract.AbstractSource;
+import org.apache.gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.Extract.TableType;
+import org.apache.gobblin.source.workunit.MultiWorkUnit;
+import org.apache.gobblin.source.workunit.WorkUnit;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/util/SchedulerUtilsTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/util/SchedulerUtilsTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/util/SchedulerUtilsTest.java
index b30d898..43696f8 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/util/SchedulerUtilsTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/util/SchedulerUtilsTest.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.util;
+package org.apache.gobblin.util;
 
 import com.google.common.collect.Sets;
 import com.google.common.io.Files;
-import gobblin.util.filesystem.PathAlterationListener;
-import gobblin.util.filesystem.PathAlterationListenerAdaptor;
-import gobblin.util.filesystem.PathAlterationObserverScheduler;
+import org.apache.gobblin.util.filesystem.PathAlterationListener;
+import org.apache.gobblin.util.filesystem.PathAlterationListenerAdaptor;
+import org.apache.gobblin.util.filesystem.PathAlterationObserverScheduler;
 import java.io.File;
 import java.io.FileWriter;
 import java.io.IOException;
@@ -38,7 +38,7 @@ import org.testng.annotations.AfterClass;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/util/TemplateTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/util/TemplateTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/util/TemplateTest.java
index 9087496..a4ab15d 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/util/TemplateTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/util/TemplateTest.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.util;
+package org.apache.gobblin.util;
 
 import java.io.File;
 import java.io.FileWriter;
@@ -35,10 +35,10 @@ import org.testng.annotations.Test;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator;
-import gobblin.runtime.template.HOCONInputStreamJobTemplate;
-import gobblin.runtime.template.ResourceBasedJobTemplate;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.job_catalog.PackagedTemplatesJobCatalogDecorator;
+import org.apache.gobblin.runtime.template.HOCONInputStreamJobTemplate;
+import org.apache.gobblin.runtime.template.ResourceBasedJobTemplate;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConfigurationKeys.java
----------------------------------------------------------------------
diff --git a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConfigurationKeys.java b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConfigurationKeys.java
index ad452d1..e868cd6 100644
--- a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConfigurationKeys.java
+++ b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConfigurationKeys.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.salesforce;
+package org.apache.gobblin.salesforce;
 
 public class SalesforceConfigurationKeys {
   public static final String SOURCE_QUERYBASED_SALESFORCE_IS_SOFT_DELETES_PULL_DISABLED =

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConnector.java
----------------------------------------------------------------------
diff --git a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConnector.java b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConnector.java
index f9cec5b..f95e7f7 100644
--- a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConnector.java
+++ b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConnector.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.salesforce;
+package org.apache.gobblin.salesforce;
 
 import java.util.List;
 
@@ -29,11 +29,11 @@ import org.apache.http.message.BasicNameValuePair;
 
 import com.google.common.collect.Lists;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.password.PasswordManager;
-import gobblin.source.extractor.exception.RestApiConnectionException;
-import gobblin.source.extractor.extract.restapi.RestApiConnector;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.password.PasswordManager;
+import org.apache.gobblin.source.extractor.exception.RestApiConnectionException;
+import org.apache.gobblin.source.extractor.extract.restapi.RestApiConnector;
 import lombok.Getter;
 import lombok.extern.slf4j.Slf4j;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceExtractor.java b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceExtractor.java
index 4584849..4498d72 100644
--- a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceExtractor.java
+++ b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceExtractor.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.salesforce;
+package org.apache.gobblin.salesforce;
 
 import java.io.BufferedReader;
 import java.io.ByteArrayInputStream;
@@ -57,30 +57,30 @@ import com.sforce.async.QueryResultList;
 import com.sforce.soap.partner.PartnerConnection;
 import com.sforce.ws.ConnectorConfig;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.password.PasswordManager;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.exception.HighWatermarkException;
-import gobblin.source.extractor.exception.RecordCountException;
-import gobblin.source.extractor.exception.RestApiClientException;
-import gobblin.source.extractor.exception.RestApiConnectionException;
-import gobblin.source.extractor.exception.SchemaException;
-import gobblin.source.extractor.extract.Command;
-import gobblin.source.extractor.extract.CommandOutput;
-import gobblin.source.jdbc.SqlQueryUtils;
-import gobblin.source.extractor.extract.restapi.RestApiCommand;
-import gobblin.source.extractor.extract.restapi.RestApiCommand.RestApiCommandType;
-import gobblin.source.extractor.extract.restapi.RestApiConnector;
-import gobblin.source.extractor.extract.restapi.RestApiExtractor;
-import gobblin.source.extractor.resultset.RecordSet;
-import gobblin.source.extractor.resultset.RecordSetList;
-import gobblin.source.extractor.schema.Schema;
-import gobblin.source.extractor.utils.InputStreamCSVReader;
-import gobblin.source.extractor.utils.Utils;
-import gobblin.source.extractor.watermark.Predicate;
-import gobblin.source.extractor.watermark.WatermarkType;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.password.PasswordManager;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.exception.HighWatermarkException;
+import org.apache.gobblin.source.extractor.exception.RecordCountException;
+import org.apache.gobblin.source.extractor.exception.RestApiClientException;
+import org.apache.gobblin.source.extractor.exception.RestApiConnectionException;
+import org.apache.gobblin.source.extractor.exception.SchemaException;
+import org.apache.gobblin.source.extractor.extract.Command;
+import org.apache.gobblin.source.extractor.extract.CommandOutput;
+import org.apache.gobblin.source.jdbc.SqlQueryUtils;
+import org.apache.gobblin.source.extractor.extract.restapi.RestApiCommand;
+import org.apache.gobblin.source.extractor.extract.restapi.RestApiCommand.RestApiCommandType;
+import org.apache.gobblin.source.extractor.extract.restapi.RestApiConnector;
+import org.apache.gobblin.source.extractor.extract.restapi.RestApiExtractor;
+import org.apache.gobblin.source.extractor.resultset.RecordSet;
+import org.apache.gobblin.source.extractor.resultset.RecordSetList;
+import org.apache.gobblin.source.extractor.schema.Schema;
+import org.apache.gobblin.source.extractor.utils.InputStreamCSVReader;
+import org.apache.gobblin.source.extractor.utils.Utils;
+import org.apache.gobblin.source.extractor.watermark.Predicate;
+import org.apache.gobblin.source.extractor.watermark.WatermarkType;
+import org.apache.gobblin.source.workunit.WorkUnit;
 import lombok.extern.slf4j.Slf4j;
 
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceSource.java
----------------------------------------------------------------------
diff --git a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceSource.java b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceSource.java
index ac90a33..3b6b729 100644
--- a/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceSource.java
+++ b/gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceSource.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.salesforce;
+package org.apache.gobblin.salesforce;
 
 import java.io.IOException;
 import java.math.RoundingMode;
@@ -43,25 +43,25 @@ import com.google.gson.JsonArray;
 import com.google.gson.JsonElement;
 import com.google.gson.JsonObject;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.extractor.exception.ExtractPrepareException;
-import gobblin.source.extractor.exception.RestApiClientException;
-import gobblin.source.extractor.exception.RestApiConnectionException;
-import gobblin.source.extractor.exception.RestApiProcessingException;
-import gobblin.source.extractor.extract.Command;
-import gobblin.source.extractor.extract.CommandOutput;
-import gobblin.source.extractor.extract.QueryBasedSource;
-import gobblin.source.extractor.extract.restapi.RestApiConnector;
-import gobblin.source.extractor.partition.Partition;
-import gobblin.source.extractor.partition.Partitioner;
-import gobblin.source.extractor.utils.Utils;
-import gobblin.source.extractor.watermark.WatermarkType;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.extractor.exception.ExtractPrepareException;
+import org.apache.gobblin.source.extractor.exception.RestApiClientException;
+import org.apache.gobblin.source.extractor.exception.RestApiConnectionException;
+import org.apache.gobblin.source.extractor.exception.RestApiProcessingException;
+import org.apache.gobblin.source.extractor.extract.Command;
+import org.apache.gobblin.source.extractor.extract.CommandOutput;
+import org.apache.gobblin.source.extractor.extract.QueryBasedSource;
+import org.apache.gobblin.source.extractor.extract.restapi.RestApiConnector;
+import org.apache.gobblin.source.extractor.partition.Partition;
+import org.apache.gobblin.source.extractor.partition.Partitioner;
+import org.apache.gobblin.source.extractor.utils.Utils;
+import org.apache.gobblin.source.extractor.watermark.WatermarkType;
+import org.apache.gobblin.source.workunit.WorkUnit;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-salesforce/src/test/java/org/apache/gobblin/salesforce/SalesforceSourceTest.java
----------------------------------------------------------------------
diff --git a/gobblin-salesforce/src/test/java/org/apache/gobblin/salesforce/SalesforceSourceTest.java b/gobblin-salesforce/src/test/java/org/apache/gobblin/salesforce/SalesforceSourceTest.java
index 68f7f94..958034a 100644
--- a/gobblin-salesforce/src/test/java/org/apache/gobblin/salesforce/SalesforceSourceTest.java
+++ b/gobblin-salesforce/src/test/java/org/apache/gobblin/salesforce/SalesforceSourceTest.java
@@ -1,4 +1,4 @@
-package gobblin.salesforce;
+package org.apache.gobblin.salesforce;
 
 import org.testng.Assert;
 import org.testng.annotations.Test;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/main/java/org/apache/gobblin/service/HelixUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/HelixUtils.java b/gobblin-service/src/main/java/org/apache/gobblin/service/HelixUtils.java
index e144e3d..4f01623 100644
--- a/gobblin-service/src/main/java/org/apache/gobblin/service/HelixUtils.java
+++ b/gobblin-service/src/main/java/org/apache/gobblin/service/HelixUtils.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.service;
+package org.apache.gobblin.service;
 
 import com.google.common.annotations.VisibleForTesting;
 import java.util.UUID;
@@ -28,7 +28,7 @@ import org.apache.helix.model.HelixConfigScope;
 import org.apache.helix.model.Message;
 import org.apache.helix.tools.ClusterSetup;
 
-import gobblin.annotation.Alpha;
+import org.apache.gobblin.annotation.Alpha;
 import org.slf4j.Logger;
 
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceConfigKeys.java
----------------------------------------------------------------------
diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceConfigKeys.java b/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceConfigKeys.java
index 1f9132b..76ed90a 100644
--- a/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceConfigKeys.java
+++ b/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceConfigKeys.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.service;
+package org.apache.gobblin.service;
 
-import gobblin.annotation.Alpha;
-import gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer;
-import gobblin.service.modules.flow.IdentityFlowToJobSpecCompiler;
-import gobblin.service.modules.topology.ConfigBasedTopologySpecFactory;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer;
+import org.apache.gobblin.service.modules.flow.IdentityFlowToJobSpecCompiler;
+import org.apache.gobblin.service.modules.topology.ConfigBasedTopologySpecFactory;
 
 @Alpha
 public class ServiceConfigKeys {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceMetricNames.java
----------------------------------------------------------------------
diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceMetricNames.java b/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceMetricNames.java
index f830ec8..d1fb711 100644
--- a/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceMetricNames.java
+++ b/gobblin-service/src/main/java/org/apache/gobblin/service/ServiceMetricNames.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.service;
+package org.apache.gobblin.service;
 
 public class ServiceMetricNames {
   private static final String GOBBLIN_SERVICE_PREFIX = "gobblin.service.";

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java
----------------------------------------------------------------------
diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java
index d5515f5..6aed51e 100644
--- a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java
+++ b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.service.modules.core;
+package org.apache.gobblin.service.modules.core;
 
-import gobblin.service.FlowId;
-import gobblin.service.Schedule;
+import org.apache.gobblin.service.FlowId;
+import org.apache.gobblin.service.Schedule;
 import java.io.IOException;
 import java.lang.reflect.InvocationTargetException;
 import java.net.URI;
@@ -68,28 +68,28 @@ import com.linkedin.restli.server.resources.BaseResource;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.restli.EmbeddedRestliServer;
-import gobblin.runtime.api.TopologySpec;
-import gobblin.runtime.app.ApplicationException;
-import gobblin.runtime.app.ApplicationLauncher;
-import gobblin.runtime.app.ServiceBasedAppLauncher;
-import gobblin.runtime.api.Spec;
-import gobblin.runtime.api.SpecNotFoundException;
-import gobblin.runtime.spec_catalog.FlowCatalog;
-import gobblin.scheduler.SchedulerService;
-import gobblin.service.FlowConfig;
-import gobblin.service.FlowConfigClient;
-import gobblin.service.FlowConfigsResource;
-import gobblin.service.HelixUtils;
-import gobblin.service.ServiceConfigKeys;
-import gobblin.service.modules.orchestration.Orchestrator;
-import gobblin.service.modules.scheduler.GobblinServiceJobScheduler;
-import gobblin.service.modules.topology.TopologySpecFactory;
-import gobblin.runtime.spec_catalog.TopologyCatalog;
-import gobblin.util.ClassAliasResolver;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.restli.EmbeddedRestliServer;
+import org.apache.gobblin.runtime.api.TopologySpec;
+import org.apache.gobblin.runtime.app.ApplicationException;
+import org.apache.gobblin.runtime.app.ApplicationLauncher;
+import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher;
+import org.apache.gobblin.runtime.api.Spec;
+import org.apache.gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.runtime.spec_catalog.FlowCatalog;
+import org.apache.gobblin.scheduler.SchedulerService;
+import org.apache.gobblin.service.FlowConfig;
+import org.apache.gobblin.service.FlowConfigClient;
+import org.apache.gobblin.service.FlowConfigsResource;
+import org.apache.gobblin.service.HelixUtils;
+import org.apache.gobblin.service.ServiceConfigKeys;
+import org.apache.gobblin.service.modules.orchestration.Orchestrator;
+import org.apache.gobblin.service.modules.scheduler.GobblinServiceJobScheduler;
+import org.apache.gobblin.service.modules.topology.TopologySpecFactory;
+import org.apache.gobblin.runtime.spec_catalog.TopologyCatalog;
+import org.apache.gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.util.ConfigUtils;
 
 
 @Alpha

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/IdentityFlowToJobSpecCompiler.java
----------------------------------------------------------------------
diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/IdentityFlowToJobSpecCompiler.java b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/IdentityFlowToJobSpecCompiler.java
index 7329a74..e8e042e 100644
--- a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/IdentityFlowToJobSpecCompiler.java
+++ b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/IdentityFlowToJobSpecCompiler.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.service.modules.flow;
+package org.apache.gobblin.service.modules.flow;
 
 import java.io.IOException;
 import java.net.URI;
@@ -39,25 +39,25 @@ import com.google.common.collect.Maps;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigValueFactory;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.instrumented.Instrumented;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.Tag;
-import gobblin.runtime.api.FlowSpec;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobTemplate;
-import gobblin.runtime.api.Spec;
-import gobblin.runtime.api.SpecCompiler;
-import gobblin.runtime.api.SpecExecutorInstance;
-import gobblin.runtime.api.SpecExecutorInstanceProducer;
-import gobblin.runtime.api.SpecNotFoundException;
-import gobblin.runtime.api.TopologySpec;
-import gobblin.runtime.job_catalog.FSJobCatalog;
-import gobblin.runtime.job_spec.ResolvedJobSpec;
-import gobblin.service.ServiceConfigKeys;
-import gobblin.service.ServiceMetricNames;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.metrics.Tag;
+import org.apache.gobblin.runtime.api.FlowSpec;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobTemplate;
+import org.apache.gobblin.runtime.api.Spec;
+import org.apache.gobblin.runtime.api.SpecCompiler;
+import org.apache.gobblin.runtime.api.SpecExecutorInstance;
+import org.apache.gobblin.runtime.api.SpecExecutorInstanceProducer;
+import org.apache.gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.runtime.api.TopologySpec;
+import org.apache.gobblin.runtime.job_catalog.FSJobCatalog;
+import org.apache.gobblin.runtime.job_spec.ResolvedJobSpec;
+import org.apache.gobblin.service.ServiceConfigKeys;
+import org.apache.gobblin.service.ServiceMetricNames;
+import org.apache.gobblin.util.ConfigUtils;
 
 
 /***

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/Orchestrator.java
----------------------------------------------------------------------
diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/Orchestrator.java b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/Orchestrator.java
index 1228d1b..7f2493a 100644
--- a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/Orchestrator.java
+++ b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/Orchestrator.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.service.modules.orchestration;
+package org.apache.gobblin.service.modules.orchestration;
 
 import java.lang.reflect.InvocationTargetException;
 import java.net.URI;
@@ -35,24 +35,24 @@ import com.google.common.annotations.VisibleForTesting;
 import com.google.common.base.Optional;
 import com.typesafe.config.Config;
 
-import gobblin.annotation.Alpha;
-import gobblin.instrumented.Instrumented;
-import gobblin.instrumented.Instrumentable;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.Tag;
-
-import gobblin.runtime.api.FlowSpec;
-import gobblin.runtime.api.SpecCompiler;
-import gobblin.runtime.api.SpecExecutorInstanceProducer;
-import gobblin.runtime.api.TopologySpec;
-import gobblin.runtime.api.Spec;
-import gobblin.runtime.api.SpecCatalogListener;
-import gobblin.runtime.spec_catalog.TopologyCatalog;
-import gobblin.service.ServiceConfigKeys;
-import gobblin.service.ServiceMetricNames;
-import gobblin.service.modules.flow.IdentityFlowToJobSpecCompiler;
-import gobblin.util.ClassAliasResolver;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.instrumented.Instrumented;
+import org.apache.gobblin.instrumented.Instrumentable;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.metrics.Tag;
+
+import org.apache.gobblin.runtime.api.FlowSpec;
+import org.apache.gobblin.runtime.api.SpecCompiler;
+import org.apache.gobblin.runtime.api.SpecExecutorInstanceProducer;
+import org.apache.gobblin.runtime.api.TopologySpec;
+import org.apache.gobblin.runtime.api.Spec;
+import org.apache.gobblin.runtime.api.SpecCatalogListener;
+import org.apache.gobblin.runtime.spec_catalog.TopologyCatalog;
+import org.apache.gobblin.service.ServiceConfigKeys;
+import org.apache.gobblin.service.ServiceMetricNames;
+import org.apache.gobblin.service.modules.flow.IdentityFlowToJobSpecCompiler;
+import org.apache.gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.util.ConfigUtils;
 import org.slf4j.LoggerFactory;
 
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java
----------------------------------------------------------------------
diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java
index 34565c6..f6f101b 100644
--- a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java
+++ b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.service.modules.scheduler;
+package org.apache.gobblin.service.modules.scheduler;
 
 import java.net.URI;
 import java.util.Collection;
@@ -40,22 +40,22 @@ import com.google.common.base.Optional;
 import com.google.common.collect.Maps;
 import com.typesafe.config.Config;
 
-import gobblin.annotation.Alpha;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.JobException;
-import gobblin.runtime.api.FlowSpec;
-import gobblin.runtime.api.Spec;
-import gobblin.runtime.api.SpecCatalogListener;
-import gobblin.runtime.listeners.JobListener;
-import gobblin.runtime.spec_catalog.FlowCatalog;
-import gobblin.runtime.spec_catalog.TopologyCatalog;
-import gobblin.scheduler.BaseGobblinJob;
-import gobblin.scheduler.JobScheduler;
-import gobblin.scheduler.SchedulerService;
-import gobblin.service.HelixUtils;
-import gobblin.service.ServiceConfigKeys;
-import gobblin.service.modules.orchestration.Orchestrator;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.JobException;
+import org.apache.gobblin.runtime.api.FlowSpec;
+import org.apache.gobblin.runtime.api.Spec;
+import org.apache.gobblin.runtime.api.SpecCatalogListener;
+import org.apache.gobblin.runtime.listeners.JobListener;
+import org.apache.gobblin.runtime.spec_catalog.FlowCatalog;
+import org.apache.gobblin.runtime.spec_catalog.TopologyCatalog;
+import org.apache.gobblin.scheduler.BaseGobblinJob;
+import org.apache.gobblin.scheduler.JobScheduler;
+import org.apache.gobblin.scheduler.SchedulerService;
+import org.apache.gobblin.service.HelixUtils;
+import org.apache.gobblin.service.ServiceConfigKeys;
+import org.apache.gobblin.service.modules.orchestration.Orchestrator;
+import org.apache.gobblin.util.ConfigUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactory.java b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactory.java
index 42046a5..1a9b8f6 100644
--- a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactory.java
+++ b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactory.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.service.modules.topology;
+package org.apache.gobblin.service.modules.topology;
 
 import java.lang.reflect.InvocationTargetException;
 import java.util.Collection;
@@ -31,12 +31,12 @@ import com.google.common.base.Splitter;
 import com.google.common.collect.Lists;
 import com.typesafe.config.Config;
 
-import gobblin.annotation.Alpha;
-import gobblin.runtime.api.SpecExecutorInstanceProducer;
-import gobblin.runtime.api.TopologySpec;
-import gobblin.service.ServiceConfigKeys;
-import gobblin.util.ClassAliasResolver;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.runtime.api.SpecExecutorInstanceProducer;
+import org.apache.gobblin.runtime.api.TopologySpec;
+import org.apache.gobblin.service.ServiceConfigKeys;
+import org.apache.gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.util.ConfigUtils;
 
 
 @Alpha

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/TopologySpecFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/TopologySpecFactory.java b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/TopologySpecFactory.java
index 0111c3a..f57195b 100644
--- a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/TopologySpecFactory.java
+++ b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/topology/TopologySpecFactory.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.service.modules.topology;
+package org.apache.gobblin.service.modules.topology;
 
 import java.util.Collection;
 
-import gobblin.annotation.Alpha;
-import gobblin.runtime.api.TopologySpec;
+import org.apache.gobblin.annotation.Alpha;
+import org.apache.gobblin.runtime.api.TopologySpec;
 
 
 /***

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java
----------------------------------------------------------------------
diff --git a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java
index 585a935..a468477 100644
--- a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java
+++ b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java
@@ -14,10 +14,10 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.service.modules.core;
+package org.apache.gobblin.service.modules.core;
 
-import gobblin.service.FlowId;
-import gobblin.service.Schedule;
+import org.apache.gobblin.service.FlowId;
+import org.apache.gobblin.service.Schedule;
 import java.io.File;
 import java.util.Map;
 import java.util.Properties;
@@ -41,19 +41,19 @@ import com.google.gson.GsonBuilder;
 import com.linkedin.data.template.StringMap;
 import com.linkedin.restli.client.RestLiResponseException;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.FlowSpec;
-import gobblin.runtime.api.TopologySpec;
-import gobblin.runtime.app.ServiceBasedAppLauncher;
-import gobblin.runtime.spec_catalog.FlowCatalog;
-import gobblin.runtime.spec_catalog.TopologyCatalog;
-import gobblin.service.FlowConfig;
-import gobblin.service.FlowConfigClient;
-import gobblin.service.FlowId;
-import gobblin.service.HelixUtils;
-import gobblin.service.ServiceConfigKeys;
-import gobblin.service.modules.orchestration.Orchestrator;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.FlowSpec;
+import org.apache.gobblin.runtime.api.TopologySpec;
+import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher;
+import org.apache.gobblin.runtime.spec_catalog.FlowCatalog;
+import org.apache.gobblin.runtime.spec_catalog.TopologyCatalog;
+import org.apache.gobblin.service.FlowConfig;
+import org.apache.gobblin.service.FlowConfigClient;
+import org.apache.gobblin.service.FlowId;
+import org.apache.gobblin.service.HelixUtils;
+import org.apache.gobblin.service.ServiceConfigKeys;
+import org.apache.gobblin.service.modules.orchestration.Orchestrator;
+import org.apache.gobblin.util.ConfigUtils;
 
 
 public class GobblinServiceHATest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java
index 3d79606..835588d 100644
--- a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java
+++ b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.service.modules.core;
+package org.apache.gobblin.service.modules.core;
 
-import gobblin.service.FlowId;
-import gobblin.service.Schedule;
+import org.apache.gobblin.service.FlowId;
+import org.apache.gobblin.service.Schedule;
 import java.io.File;
 import java.util.Map;
 import java.util.Properties;
@@ -40,18 +40,18 @@ import com.google.gson.GsonBuilder;
 import com.linkedin.data.template.StringMap;
 import com.linkedin.restli.client.RestLiResponseException;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.FlowSpec;
-import gobblin.runtime.api.TopologySpec;
-import gobblin.runtime.app.ServiceBasedAppLauncher;
-import gobblin.runtime.spec_catalog.FlowCatalog;
-import gobblin.runtime.spec_catalog.TopologyCatalog;
-import gobblin.service.FlowConfig;
-import gobblin.service.FlowConfigClient;
-import gobblin.service.FlowId;
-import gobblin.service.ServiceConfigKeys;
-import gobblin.service.modules.orchestration.Orchestrator;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.FlowSpec;
+import org.apache.gobblin.runtime.api.TopologySpec;
+import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher;
+import org.apache.gobblin.runtime.spec_catalog.FlowCatalog;
+import org.apache.gobblin.runtime.spec_catalog.TopologyCatalog;
+import org.apache.gobblin.service.FlowConfig;
+import org.apache.gobblin.service.FlowConfigClient;
+import org.apache.gobblin.service.FlowId;
+import org.apache.gobblin.service.ServiceConfigKeys;
+import org.apache.gobblin.service.modules.orchestration.Orchestrator;
+import org.apache.gobblin.util.ConfigUtils;
 
 
 public class GobblinServiceManagerTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/IdentityFlowToJobSpecCompilerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/IdentityFlowToJobSpecCompilerTest.java b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/IdentityFlowToJobSpecCompilerTest.java
index d5155df..0b3dc15 100644
--- a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/IdentityFlowToJobSpecCompilerTest.java
+++ b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/IdentityFlowToJobSpecCompilerTest.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.service.modules.core;
+package org.apache.gobblin.service.modules.core;
 
 import java.io.File;
 import java.net.URI;
@@ -35,17 +35,17 @@ import org.testng.annotations.Test;
 
 import com.typesafe.config.Config;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.FlowSpec;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.Spec;
-import gobblin.runtime.api.SpecExecutorInstanceProducer;
-import gobblin.runtime.api.TopologySpec;
-import gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer;
-import gobblin.service.ServiceConfigKeys;
-import gobblin.service.modules.flow.IdentityFlowToJobSpecCompiler;
-import gobblin.util.ConfigUtils;
-import gobblin.util.PathUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.FlowSpec;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.Spec;
+import org.apache.gobblin.runtime.api.SpecExecutorInstanceProducer;
+import org.apache.gobblin.runtime.api.TopologySpec;
+import org.apache.gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer;
+import org.apache.gobblin.service.ServiceConfigKeys;
+import org.apache.gobblin.service.modules.flow.IdentityFlowToJobSpecCompiler;
+import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.PathUtils;
 
 
 public class IdentityFlowToJobSpecCompilerTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/test/java/org/apache/gobblin/service/modules/orchestration/OrchestratorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/orchestration/OrchestratorTest.java b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/orchestration/OrchestratorTest.java
index 8cf4c09..eb9974a 100644
--- a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/orchestration/OrchestratorTest.java
+++ b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/orchestration/OrchestratorTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.service.modules.orchestration;
+package org.apache.gobblin.service.modules.orchestration;
 
 import java.io.File;
 import java.net.URI;
@@ -38,18 +38,18 @@ import com.google.gson.Gson;
 import com.google.gson.GsonBuilder;
 import com.typesafe.config.Config;
 
-import gobblin.runtime.api.FlowSpec;
-import gobblin.runtime.api.Spec;
-import gobblin.runtime.api.SpecCompiler;
-import gobblin.runtime.api.SpecExecutorInstanceProducer;
-import gobblin.runtime.api.TopologySpec;
-import gobblin.runtime.app.ServiceBasedAppLauncher;
-import gobblin.runtime.spec_catalog.FlowCatalog;
-import gobblin.runtime.spec_catalog.TopologyCatalog;
-import gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer;
-import gobblin.service.modules.flow.IdentityFlowToJobSpecCompiler;
-import gobblin.util.ConfigUtils;
-import gobblin.util.PathUtils;
+import org.apache.gobblin.runtime.api.FlowSpec;
+import org.apache.gobblin.runtime.api.Spec;
+import org.apache.gobblin.runtime.api.SpecCompiler;
+import org.apache.gobblin.runtime.api.SpecExecutorInstanceProducer;
+import org.apache.gobblin.runtime.api.TopologySpec;
+import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher;
+import org.apache.gobblin.runtime.spec_catalog.FlowCatalog;
+import org.apache.gobblin.runtime.spec_catalog.TopologyCatalog;
+import org.apache.gobblin.runtime.spec_executorInstance.InMemorySpecExecutorInstanceProducer;
+import org.apache.gobblin.service.modules.flow.IdentityFlowToJobSpecCompiler;
+import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.PathUtils;
 
 
 public class OrchestratorTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-service/src/test/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactoryTest.java
----------------------------------------------------------------------
diff --git a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactoryTest.java b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactoryTest.java
index e019260..c28e97b 100644
--- a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactoryTest.java
+++ b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/topology/ConfigBasedTopologySpecFactoryTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.service.modules.topology;
+package org.apache.gobblin.service.modules.topology;
 
 import java.util.Collection;
 import java.util.Iterator;
@@ -28,10 +28,10 @@ import org.testng.annotations.Test;
 
 import com.typesafe.config.Config;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.TopologySpec;
-import gobblin.service.ServiceConfigKeys;
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.TopologySpec;
+import org.apache.gobblin.service.ServiceConfigKeys;
+import org.apache.gobblin.util.ConfigUtils;
 
 
 public class ConfigBasedTopologySpecFactoryTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/operator/SetupOperator.java
----------------------------------------------------------------------
diff --git a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/operator/SetupOperator.java b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/operator/SetupOperator.java
index 0822beb..b5da141 100644
--- a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/operator/SetupOperator.java
+++ b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/operator/SetupOperator.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.test.execution.operator;
+package org.apache.gobblin.test.execution.operator;
 
 /**
  * An interface for defining the operator , the operator could be a copy of file or converting a file from one format to another. These operators are used for the setup phase of the test

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/validator/ValidationRule.java
----------------------------------------------------------------------
diff --git a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/validator/ValidationRule.java b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/validator/ValidationRule.java
index c0aca77..92cc73c 100644
--- a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/validator/ValidationRule.java
+++ b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/execution/validator/ValidationRule.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.test.execution.validator;
+package org.apache.gobblin.test.execution.validator;
 
 /**
  *  An interface is for defining the validator for the test. The input can be the set of input files and the output will be be output of

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/ConfigStepsGenerator.java
----------------------------------------------------------------------
diff --git a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/ConfigStepsGenerator.java b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/ConfigStepsGenerator.java
index 24f5151..9da7a0d 100644
--- a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/ConfigStepsGenerator.java
+++ b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/ConfigStepsGenerator.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.test.setup.config;
+package org.apache.gobblin.test.setup.config;
 
 import java.util.Collection;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/Step.java
----------------------------------------------------------------------
diff --git a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/Step.java b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/Step.java
index 849f715..66910b1 100644
--- a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/Step.java
+++ b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/Step.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.test.setup.config;
+package org.apache.gobblin.test.setup.config;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/TestHarnessLauncher.java
----------------------------------------------------------------------
diff --git a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/TestHarnessLauncher.java b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/TestHarnessLauncher.java
index 853f5e9..4655178 100644
--- a/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/TestHarnessLauncher.java
+++ b/gobblin-test-harness/src/main/java/org/apache/gobblin/test/setup/config/TestHarnessLauncher.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.test.setup.config;
+package org.apache.gobblin.test.setup.config;
 
 /**
  * An interface for parsing the config data for test harness.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/test/java/org/apache/gobblin/GobblinLocalJobLauncherUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-test-harness/src/test/java/org/apache/gobblin/GobblinLocalJobLauncherUtils.java b/gobblin-test-harness/src/test/java/org/apache/gobblin/GobblinLocalJobLauncherUtils.java
index a05fc34..47b0c9e 100644
--- a/gobblin-test-harness/src/test/java/org/apache/gobblin/GobblinLocalJobLauncherUtils.java
+++ b/gobblin-test-harness/src/test/java/org/apache/gobblin/GobblinLocalJobLauncherUtils.java
@@ -7,9 +7,9 @@ import java.util.UUID;
 
 import org.apache.commons.io.FileUtils;
 
-import gobblin.runtime.app.ApplicationLauncher;
-import gobblin.runtime.app.ServiceBasedAppLauncher;
-import gobblin.runtime.local.LocalJobLauncher;
+import org.apache.gobblin.runtime.app.ApplicationLauncher;
+import org.apache.gobblin.runtime.app.ServiceBasedAppLauncher;
+import org.apache.gobblin.runtime.local.LocalJobLauncher;
 
 
 public class GobblinLocalJobLauncherUtils {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroExtractor.java b/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroExtractor.java
index 95a9ace..f553df9 100644
--- a/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroExtractor.java
+++ b/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroExtractor.java
@@ -16,10 +16,10 @@ import org.apache.avro.mapred.FsInput;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.Path;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.Extractor;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.Extractor;
 
 
 public class TestAvroExtractor implements Extractor<Schema, GenericRecord> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroSource.java
----------------------------------------------------------------------
diff --git a/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroSource.java b/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroSource.java
index dbdb567..8605181 100644
--- a/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroSource.java
+++ b/gobblin-test-harness/src/test/java/org/apache/gobblin/TestAvroSource.java
@@ -7,11 +7,11 @@ import java.util.List;
 import org.apache.avro.Schema;
 import org.apache.avro.generic.GenericRecord;
 
-import gobblin.configuration.SourceState;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.Source;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.Source;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.workunit.WorkUnit;
 
 
 public class TestAvroSource implements Source<Schema, GenericRecord> {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsPublisher.java
----------------------------------------------------------------------
diff --git a/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsPublisher.java b/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsPublisher.java
index ef0ac46..5c1adee 100644
--- a/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsPublisher.java
+++ b/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsPublisher.java
@@ -21,9 +21,9 @@ import java.util.Collection;
 
 import org.testng.Assert;
 
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.publisher.DataPublisher;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.publisher.DataPublisher;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsSource.java
----------------------------------------------------------------------
diff --git a/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsSource.java b/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsSource.java
index 1632b72..1b2d790 100644
--- a/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsSource.java
+++ b/gobblin-test-harness/src/test/java/org/apache/gobblin/TestSkipWorkUnitsSource.java
@@ -22,12 +22,12 @@ import java.util.List;
 
 import org.testng.Assert;
 
-import gobblin.configuration.SourceState;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.Source;
-import gobblin.source.extractor.DummyExtractor;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.Source;
+import org.apache.gobblin.source.extractor.DummyExtractor;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.workunit.WorkUnit;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/test/java/org/apache/gobblin/WriterOutputFormatIntegrationTest.java
----------------------------------------------------------------------
diff --git a/gobblin-test-harness/src/test/java/org/apache/gobblin/WriterOutputFormatIntegrationTest.java b/gobblin-test-harness/src/test/java/org/apache/gobblin/WriterOutputFormatIntegrationTest.java
index 1222cd1..a44074d 100644
--- a/gobblin-test-harness/src/test/java/org/apache/gobblin/WriterOutputFormatIntegrationTest.java
+++ b/gobblin-test-harness/src/test/java/org/apache/gobblin/WriterOutputFormatIntegrationTest.java
@@ -9,8 +9,8 @@ import org.testng.annotations.AfterTest;
 import org.testng.annotations.BeforeTest;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.hive.HiveSerDeWrapper;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.hive.HiveSerDeWrapper;
 
 
 public class WriterOutputFormatIntegrationTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-harness/src/test/java/org/apache/gobblin/test/integration/data/management/CopyIntegrationTest.java
----------------------------------------------------------------------
diff --git a/gobblin-test-harness/src/test/java/org/apache/gobblin/test/integration/data/management/CopyIntegrationTest.java b/gobblin-test-harness/src/test/java/org/apache/gobblin/test/integration/data/management/CopyIntegrationTest.java
index e82845e..e5de71c 100644
--- a/gobblin-test-harness/src/test/java/org/apache/gobblin/test/integration/data/management/CopyIntegrationTest.java
+++ b/gobblin-test-harness/src/test/java/org/apache/gobblin/test/integration/data/management/CopyIntegrationTest.java
@@ -14,11 +14,11 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.test.integration.data.management;
+package org.apache.gobblin.test.integration.data.management;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.JobLauncher;
-import gobblin.runtime.JobLauncherFactory;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.JobLauncher;
+import org.apache.gobblin.runtime.JobLauncherFactory;
 
 import java.io.FileReader;
 import java.util.Properties;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ConstantTimingType.java
----------------------------------------------------------------------
diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ConstantTimingType.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ConstantTimingType.java
index 1dfc64d..606f870 100644
--- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ConstantTimingType.java
+++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ConstantTimingType.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.test;
+package org.apache.gobblin.test;
 
 /**
  * Every call takes a certain amount of time.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ErrorManager.java
----------------------------------------------------------------------
diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ErrorManager.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ErrorManager.java
index 664c91b..e9d69d5 100644
--- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ErrorManager.java
+++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/ErrorManager.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.test;
+package org.apache.gobblin.test;
 
 import java.util.Random;
 import java.util.regex.Pattern;
@@ -24,7 +24,7 @@ import com.typesafe.config.Config;
 
 import lombok.Builder;
 
-import gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.ConfigUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/NthTimingType.java
----------------------------------------------------------------------
diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/NthTimingType.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/NthTimingType.java
index 8dd68b4..97be6e6 100644
--- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/NthTimingType.java
+++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/NthTimingType.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.test;
+package org.apache.gobblin.test;
 
 /**
  * Every nth call has a different latency than the default latency

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TestUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TestUtils.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TestUtils.java
index b550d68..a583198 100644
--- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TestUtils.java
+++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TestUtils.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.test;
+package org.apache.gobblin.test;
 
 import java.io.IOException;
 import java.net.ServerSocket;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingManager.java
----------------------------------------------------------------------
diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingManager.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingManager.java
index 798e11c..4bd7cec 100644
--- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingManager.java
+++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingManager.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.test;
+package org.apache.gobblin.test;
 
 /**
  * A class to manage timing based testing. Supports both sync and async latency decisions.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingResult.java
----------------------------------------------------------------------
diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingResult.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingResult.java
index 0080b4f..fe651b2 100644
--- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingResult.java
+++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingResult.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.test;
+package org.apache.gobblin.test;
 
 /**
  * A class to hold the result of a latency decision in a testing context.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingType.java
----------------------------------------------------------------------
diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingType.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingType.java
index 1192bdb..69253f9 100644
--- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingType.java
+++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/TimingType.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.test;
+package org.apache.gobblin.test;
 
 /**
  * An interface that provides the latency of the next call.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/InsecureShiftCodec.java
----------------------------------------------------------------------
diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/InsecureShiftCodec.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/InsecureShiftCodec.java
index 1cd9ae0..6485ee0 100644
--- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/InsecureShiftCodec.java
+++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/InsecureShiftCodec.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.test.crypto;
+package org.apache.gobblin.test.crypto;
 
 import java.io.FilterInputStream;
 import java.io.FilterOutputStream;
@@ -23,7 +23,7 @@ import java.io.InputStream;
 import java.io.OutputStream;
 import java.util.Map;
 
-import gobblin.codec.StreamCodec;
+import org.apache.gobblin.codec.StreamCodec;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestEncryptionProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestEncryptionProvider.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestEncryptionProvider.java
index 1a937fe..fe813c9 100644
--- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestEncryptionProvider.java
+++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestEncryptionProvider.java
@@ -14,14 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.test.crypto;
+package org.apache.gobblin.test.crypto;
 
 import java.util.Map;
 
-import gobblin.codec.StreamCodec;
-import gobblin.crypto.CredentialStore;
-import gobblin.crypto.CredentialStoreProvider;
-import gobblin.crypto.EncryptionProvider;
+import org.apache.gobblin.codec.StreamCodec;
+import org.apache.gobblin.crypto.CredentialStore;
+import org.apache.gobblin.crypto.CredentialStoreProvider;
+import org.apache.gobblin.crypto.EncryptionProvider;
 
 
 public class TestEncryptionProvider implements CredentialStoreProvider, EncryptionProvider {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestRandomCredentialStore.java
----------------------------------------------------------------------
diff --git a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestRandomCredentialStore.java b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestRandomCredentialStore.java
index 41d9c62..a089053 100644
--- a/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestRandomCredentialStore.java
+++ b/gobblin-test-utils/src/main/java/org/apache/gobblin/test/crypto/TestRandomCredentialStore.java
@@ -14,14 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.test.crypto;
+package org.apache.gobblin.test.crypto;
 
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Random;
 
-import gobblin.crypto.CredentialStore;
+import org.apache.gobblin.crypto.CredentialStore;
 
 
 public class TestRandomCredentialStore implements CredentialStore {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/test/java/org/apache/gobblin/test/ErrorManagerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-test-utils/src/test/java/org/apache/gobblin/test/ErrorManagerTest.java b/gobblin-test-utils/src/test/java/org/apache/gobblin/test/ErrorManagerTest.java
index 8e5d697..5e8a8f8 100644
--- a/gobblin-test-utils/src/test/java/org/apache/gobblin/test/ErrorManagerTest.java
+++ b/gobblin-test-utils/src/test/java/org/apache/gobblin/test/ErrorManagerTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.test;
+package org.apache.gobblin.test;
 
 import java.util.Properties;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-test-utils/src/test/java/org/apache/gobblin/test/RandomCredentialStoreTest.java
----------------------------------------------------------------------
diff --git a/gobblin-test-utils/src/test/java/org/apache/gobblin/test/RandomCredentialStoreTest.java b/gobblin-test-utils/src/test/java/org/apache/gobblin/test/RandomCredentialStoreTest.java
index dc64055..0a6f4ad 100644
--- a/gobblin-test-utils/src/test/java/org/apache/gobblin/test/RandomCredentialStoreTest.java
+++ b/gobblin-test-utils/src/test/java/org/apache/gobblin/test/RandomCredentialStoreTest.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.test;
+package org.apache.gobblin.test;
 
 import java.util.Map;
 
@@ -23,9 +23,9 @@ import org.testng.annotations.Test;
 
 import com.google.common.collect.ImmutableMap;
 
-import gobblin.crypto.CredentialStore;
-import gobblin.test.crypto.TestEncryptionProvider;
-import gobblin.test.crypto.TestRandomCredentialStore;
+import org.apache.gobblin.crypto.CredentialStore;
+import org.apache.gobblin.test.crypto.TestEncryptionProvider;
+import org.apache.gobblin.test.crypto.TestRandomCredentialStore;
 
 
 public class RandomCredentialStoreTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/AcceptHandler.java
----------------------------------------------------------------------
diff --git a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/AcceptHandler.java b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/AcceptHandler.java
index 1ec36d1..9ade2ea 100644
--- a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/AcceptHandler.java
+++ b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/AcceptHandler.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.tunnel;
+package org.apache.gobblin.tunnel;
 
 import java.io.IOException;
 import java.nio.channels.Selector;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Config.java
----------------------------------------------------------------------
diff --git a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Config.java b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Config.java
index 7e84649..03735cb 100644
--- a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Config.java
+++ b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Config.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.tunnel;
+package org.apache.gobblin.tunnel;
 
 class Config {
   public static final int PROXY_CONNECT_TIMEOUT_MS = 5000;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/HandlerState.java
----------------------------------------------------------------------
diff --git a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/HandlerState.java b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/HandlerState.java
index 827af0a..387f249 100644
--- a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/HandlerState.java
+++ b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/HandlerState.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.tunnel;
+package org.apache.gobblin.tunnel;
 
 /**
  * Represents the different states a given handler can be in.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ProxySetupHandler.java
----------------------------------------------------------------------
diff --git a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ProxySetupHandler.java b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ProxySetupHandler.java
index 5e8a462..d983a41 100644
--- a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ProxySetupHandler.java
+++ b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ProxySetupHandler.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.tunnel;
+package org.apache.gobblin.tunnel;
 
 import java.io.IOException;
 import java.net.InetSocketAddress;
@@ -31,7 +31,7 @@ import java.util.concurrent.Callable;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ReadWriteHandler.java
----------------------------------------------------------------------
diff --git a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ReadWriteHandler.java b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ReadWriteHandler.java
index effff6a..a2aab1a 100644
--- a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ReadWriteHandler.java
+++ b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/ReadWriteHandler.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.tunnel;
+package org.apache.gobblin.tunnel;
 
 import java.io.IOException;
 import java.io.OutputStream;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Tunnel.java
----------------------------------------------------------------------
diff --git a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Tunnel.java b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Tunnel.java
index 29ec77f..c1866fd 100644
--- a/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Tunnel.java
+++ b/gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel/Tunnel.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.tunnel;
+package org.apache.gobblin.tunnel;
 
 import java.io.IOException;
 import java.net.InetSocketAddress;
@@ -29,7 +29,7 @@ import java.util.concurrent.Callable;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.util.ExecutorsUtils;
 
 
 /**


Mime
View raw message