[06/77] [abbrv] incubator-gobblin git commit: Updated package names, imports and shell scripts

[ab...@apache.org]

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContextTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContextTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContextTest.java
index b0c7d6c..5dee390 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContextTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContextTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import java.io.StringReader;
 import java.util.Properties;
@@ -24,13 +24,13 @@ import org.testng.Assert;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.test.TestSource;
-import gobblin.writer.Destination;
-import gobblin.writer.WriterOutputFormat;
-import gobblin.util.JobLauncherUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.test.TestSource;
+import org.apache.gobblin.writer.Destination;
+import org.apache.gobblin.writer.WriterOutputFormat;
+import org.apache.gobblin.util.JobLauncherUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContinuousTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContinuousTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContinuousTest.java
index 51202a3..fa917fd 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContinuousTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskContinuousTest.java
@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -45,26 +45,26 @@ import com.google.common.collect.Lists;
 
 import lombok.extern.slf4j.Slf4j;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.fork.IdentityForkOperator;
-import gobblin.publisher.TaskPublisher;
-import gobblin.qualitychecker.row.RowLevelPolicyChecker;
-import gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
-import gobblin.qualitychecker.task.TaskLevelPolicyChecker;
-import gobblin.source.extractor.CheckpointableWatermark;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.DefaultCheckpointableWatermark;
-import gobblin.source.extractor.Extractor;
-import gobblin.stream.RecordEnvelope;
-import gobblin.source.extractor.StreamingExtractor;
-import gobblin.source.extractor.extract.LongWatermark;
-import gobblin.source.workunit.Extract;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.util.ExecutorsUtils;
-import gobblin.writer.DataWriter;
-import gobblin.writer.WatermarkAwareWriter;
-import gobblin.writer.WatermarkStorage;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.fork.IdentityForkOperator;
+import org.apache.gobblin.publisher.TaskPublisher;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicyChecker;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyChecker;
+import org.apache.gobblin.source.extractor.CheckpointableWatermark;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.DefaultCheckpointableWatermark;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.source.extractor.StreamingExtractor;
+import org.apache.gobblin.source.extractor.extract.LongWatermark;
+import org.apache.gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.writer.DataWriter;
+import org.apache.gobblin.writer.WatermarkAwareWriter;
+import org.apache.gobblin.writer.WatermarkStorage;
 
 import static org.mockito.Matchers.any;
 import static org.mockito.Matchers.anyInt;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateCollectorServiceTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateCollectorServiceTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateCollectorServiceTest.java
index 83f3a15..a0731eb 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateCollectorServiceTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateCollectorServiceTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import java.io.IOException;
 import java.util.Map;
@@ -33,8 +33,8 @@ import com.google.common.collect.Maps;
 import com.google.common.eventbus.EventBus;
 import com.google.common.eventbus.Subscribe;
 
-import gobblin.metastore.FsStateStore;
-import gobblin.util.JobLauncherUtils;
+import org.apache.gobblin.metastore.FsStateStore;
+import org.apache.gobblin.util.JobLauncherUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateTest.java
index 67e311e..94fd4ea 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskStateTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
@@ -29,9 +29,9 @@ import org.testng.annotations.Test;
 
 import com.google.common.io.Closer;
 
-import gobblin.rest.TaskExecutionInfo;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.rest.TaskExecutionInfo;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskTest.java
index 834e1f94..184943d 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TaskTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import static org.mockito.Matchers.any;
 import static org.mockito.Matchers.anyInt;
@@ -47,22 +47,22 @@ import com.google.common.collect.Lists;
 
 import lombok.extern.slf4j.Slf4j;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.fork.ForkOperator;
-import gobblin.fork.IdentityForkOperator;
-import gobblin.publisher.TaskPublisher;
-import gobblin.qualitychecker.row.RowLevelPolicyCheckResults;
-import gobblin.qualitychecker.row.RowLevelPolicyChecker;
-import gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
-import gobblin.qualitychecker.task.TaskLevelPolicyChecker;
-import gobblin.source.extractor.DataRecordException;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.workunit.Extract;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.writer.DataWriter;
-import gobblin.writer.DataWriterBuilder;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.fork.ForkOperator;
+import org.apache.gobblin.fork.IdentityForkOperator;
+import org.apache.gobblin.publisher.TaskPublisher;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicyCheckResults;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicyChecker;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyChecker;
+import org.apache.gobblin.source.extractor.DataRecordException;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.writer.DataWriter;
+import org.apache.gobblin.writer.DataWriterBuilder;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestRecordStream.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestRecordStream.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestRecordStream.java
index 9181eb3..c2f0cdb 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestRecordStream.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestRecordStream.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -32,28 +32,28 @@ import org.testng.annotations.Test;
 import com.google.common.base.Optional;
 import com.google.common.collect.Lists;
 
-import gobblin.ack.BasicAckableForTesting;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.WorkUnitState;
-import gobblin.converter.Converter;
-import gobblin.converter.DataConversionException;
-import gobblin.converter.SchemaConversionException;
-import gobblin.fork.IdentityForkOperator;
-import gobblin.publisher.TaskPublisher;
-import gobblin.qualitychecker.row.RowLevelPolicyChecker;
-import gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
-import gobblin.qualitychecker.task.TaskLevelPolicyChecker;
-import gobblin.records.ControlMessageHandler;
-import gobblin.records.RecordStreamWithMetadata;
-import gobblin.source.extractor.Extractor;
-import gobblin.source.workunit.Extract;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.stream.ControlMessage;
-import gobblin.stream.FlushControlMessage;
-import gobblin.stream.RecordEnvelope;
-import gobblin.stream.StreamEntity;
-import gobblin.writer.DataWriter;
-import gobblin.writer.DataWriterBuilder;
+import org.apache.gobblin.ack.BasicAckableForTesting;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.WorkUnitState;
+import org.apache.gobblin.converter.Converter;
+import org.apache.gobblin.converter.DataConversionException;
+import org.apache.gobblin.converter.SchemaConversionException;
+import org.apache.gobblin.fork.IdentityForkOperator;
+import org.apache.gobblin.publisher.TaskPublisher;
+import org.apache.gobblin.qualitychecker.row.RowLevelPolicyChecker;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyCheckResults;
+import org.apache.gobblin.qualitychecker.task.TaskLevelPolicyChecker;
+import org.apache.gobblin.records.ControlMessageHandler;
+import org.apache.gobblin.records.RecordStreamWithMetadata;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.workunit.Extract;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.stream.ControlMessage;
+import org.apache.gobblin.stream.FlushControlMessage;
+import org.apache.gobblin.stream.RecordEnvelope;
+import org.apache.gobblin.stream.StreamEntity;
+import org.apache.gobblin.writer.DataWriter;
+import org.apache.gobblin.writer.DataWriterBuilder;
 
 import io.reactivex.Flowable;
 import lombok.AllArgsConstructor;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestWorkUnitStreamSource.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestWorkUnitStreamSource.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestWorkUnitStreamSource.java
index cf66a29..a1fd5ed 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestWorkUnitStreamSource.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/TestWorkUnitStreamSource.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime;
+package org.apache.gobblin.runtime;
 
 import java.util.Iterator;
 import java.util.Set;
@@ -31,17 +31,17 @@ import com.google.common.collect.Sets;
 import com.google.common.eventbus.EventBus;
 import com.google.common.eventbus.Subscribe;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.runtime.api.JobExecutionDriver;
-import gobblin.runtime.api.JobExecutionResult;
-import gobblin.runtime.embedded.EmbeddedGobblin;
-import gobblin.source.WorkUnitStreamSource;
-import gobblin.source.workunit.BasicWorkUnitStream;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.source.workunit.WorkUnitStream;
-import gobblin.task.EventBusPublishingTaskFactory;
-import gobblin.writer.test.TestingEventBuses;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.SourceState;
+import org.apache.gobblin.runtime.api.JobExecutionDriver;
+import org.apache.gobblin.runtime.api.JobExecutionResult;
+import org.apache.gobblin.runtime.embedded.EmbeddedGobblin;
+import org.apache.gobblin.source.WorkUnitStreamSource;
+import org.apache.gobblin.source.workunit.BasicWorkUnitStream;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.source.workunit.WorkUnitStream;
+import org.apache.gobblin.task.EventBusPublishingTaskFactory;
+import org.apache.gobblin.writer.test.TestingEventBuses;
 
 import lombok.extern.slf4j.Slf4j;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobExecutionState.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobExecutionState.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobExecutionState.java
index ce85c9a..99322e0 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobExecutionState.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobExecutionState.java
@@ -14,9 +14,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
 
-import static gobblin.configuration.ConfigurationKeys.JOB_NAME_KEY;
+import static org.apache.gobblin.configuration.ConfigurationKeys.JOB_NAME_KEY;
 import static org.mockito.Matchers.eq;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.verify;
@@ -36,11 +36,11 @@ import com.google.common.base.Predicate;
 import com.typesafe.config.ConfigFactory;
 import com.typesafe.config.ConfigValueFactory;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.JobState.RunningState;
-import gobblin.runtime.std.JobExecutionUpdatable;
-import gobblin.testing.AssertWithBackoff;
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.JobState.RunningState;
+import org.apache.gobblin.runtime.std.JobExecutionUpdatable;
+import org.apache.gobblin.testing.AssertWithBackoff;
+import org.apache.gobblin.util.ExecutorsUtils;
 
 /**
  * Unit tests for {@link JobExecutionState}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobSpec.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobSpec.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobSpec.java
index ca8987f..2f0f2d9 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobSpec.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/api/TestJobSpec.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.api;
+package org.apache.gobblin.runtime.api;
 
 import java.net.URI;
 import java.net.URISyntaxException;
@@ -29,7 +29,7 @@ import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 import com.typesafe.config.ConfigValueFactory;
 
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
 
 /**
  * Unit tests for {@link JobSpec}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/CommitSequenceTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/CommitSequenceTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/CommitSequenceTest.java
index fc88e81..213f1e4 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/CommitSequenceTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/CommitSequenceTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.commit;
+package org.apache.gobblin.runtime.commit;
 
 import java.io.IOException;
 
@@ -27,11 +27,11 @@ import org.testng.annotations.AfterClass;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;
 
-import gobblin.commit.CommitSequence;
-import gobblin.commit.FsRenameCommitStep;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
-import gobblin.runtime.JobState.DatasetState;
+import org.apache.gobblin.commit.CommitSequence;
+import org.apache.gobblin.commit.FsRenameCommitStep;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.runtime.JobState.DatasetState;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/FsCommitSequenceStoreTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/FsCommitSequenceStoreTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/FsCommitSequenceStoreTest.java
index 2f03373..cd036a2 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/FsCommitSequenceStoreTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/commit/FsCommitSequenceStoreTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.commit;
+package org.apache.gobblin.runtime.commit;
 
 import java.io.IOException;
 
@@ -31,14 +31,14 @@ import org.testng.annotations.Test;
 import com.google.common.base.Optional;
 import com.google.gson.Gson;
 
-import gobblin.commit.CommitSequence;
-import gobblin.commit.CommitStep;
-import gobblin.commit.FsRenameCommitStep;
-import gobblin.configuration.State;
-import gobblin.runtime.JobState.DatasetState;
-import gobblin.runtime.commit.DatasetStateCommitStep;
-import gobblin.runtime.commit.FsCommitSequenceStore;
-import gobblin.util.io.GsonInterfaceAdapter;
+import org.apache.gobblin.commit.CommitSequence;
+import org.apache.gobblin.commit.CommitStep;
+import org.apache.gobblin.commit.FsRenameCommitStep;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.runtime.JobState.DatasetState;
+import org.apache.gobblin.runtime.commit.DatasetStateCommitStep;
+import org.apache.gobblin.runtime.commit.FsCommitSequenceStore;
+import org.apache.gobblin.util.io.GsonInterfaceAdapter;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinTest.java
index dfe45ec..42581a9 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.embedded;
+package org.apache.gobblin.runtime.embedded;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -23,12 +23,12 @@ import java.util.List;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.JobExecutionResult;
-import gobblin.runtime.template.ResourceBasedJobTemplate;
-import gobblin.util.test.HelloWorldSource;
-import gobblin.writer.test.GobblinTestEventBusWriter;
-import gobblin.writer.test.TestingEventBusAsserter;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.JobExecutionResult;
+import org.apache.gobblin.runtime.template.ResourceBasedJobTemplate;
+import org.apache.gobblin.util.test.HelloWorldSource;
+import org.apache.gobblin.writer.test.GobblinTestEventBusWriter;
+import org.apache.gobblin.writer.test.TestingEventBusAsserter;
 
 
 public class EmbeddedGobblinTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestDefaultGobblinInstanceDriverImpl.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestDefaultGobblinInstanceDriverImpl.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestDefaultGobblinInstanceDriverImpl.java
index 5f04640..de40176 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestDefaultGobblinInstanceDriverImpl.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestDefaultGobblinInstanceDriverImpl.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.instance;
+package org.apache.gobblin.runtime.instance;
 
 import java.util.Collections;
 import java.util.concurrent.TimeUnit;
@@ -30,18 +30,18 @@ import com.google.common.base.Predicate;
 import com.google.common.util.concurrent.Service.State;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.metrics.MetricContext;
-import gobblin.broker.SharedResourcesBrokerFactory;
-import gobblin.broker.gobblin_scopes.GobblinScopeTypes;
-import gobblin.runtime.api.Configurable;
-import gobblin.runtime.api.GobblinInstancePluginFactory;
-import gobblin.runtime.api.JobExecutionLauncher;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecScheduler;
-import gobblin.runtime.job_catalog.InMemoryJobCatalog;
-import gobblin.runtime.std.DefaultConfigurableImpl;
-import gobblin.runtime.std.DefaultJobSpecScheduleImpl;
-import gobblin.testing.AssertWithBackoff;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.broker.SharedResourcesBrokerFactory;
+import org.apache.gobblin.broker.gobblin_scopes.GobblinScopeTypes;
+import org.apache.gobblin.runtime.api.Configurable;
+import org.apache.gobblin.runtime.api.GobblinInstancePluginFactory;
+import org.apache.gobblin.runtime.api.JobExecutionLauncher;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecScheduler;
+import org.apache.gobblin.runtime.job_catalog.InMemoryJobCatalog;
+import org.apache.gobblin.runtime.std.DefaultConfigurableImpl;
+import org.apache.gobblin.runtime.std.DefaultJobSpecScheduleImpl;
+import org.apache.gobblin.testing.AssertWithBackoff;
 
 /**
  * Unit tests for {@link DefaultGobblinInstanceDriverImpl}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceDriver.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceDriver.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceDriver.java
index 303f1e4..8ad9093 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceDriver.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceDriver.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.instance;
+package org.apache.gobblin.runtime.instance;
 
 import java.util.HashSet;
 import java.util.List;
@@ -28,13 +28,13 @@ import com.google.common.util.concurrent.AbstractIdleService;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.annotation.Alias;
-import gobblin.runtime.api.GobblinInstanceDriver;
-import gobblin.runtime.api.GobblinInstanceEnvironment;
-import gobblin.runtime.api.GobblinInstancePlugin;
-import gobblin.runtime.api.GobblinInstancePluginFactory;
-import gobblin.runtime.plugins.email.EmailNotificationPlugin;
-import gobblin.runtime.std.DefaultConfigurableImpl;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.runtime.api.GobblinInstanceDriver;
+import org.apache.gobblin.runtime.api.GobblinInstanceEnvironment;
+import org.apache.gobblin.runtime.api.GobblinInstancePlugin;
+import org.apache.gobblin.runtime.api.GobblinInstancePluginFactory;
+import org.apache.gobblin.runtime.plugins.email.EmailNotificationPlugin;
+import org.apache.gobblin.runtime.std.DefaultConfigurableImpl;
 
 import avro.shaded.com.google.common.collect.ImmutableMap;
 import lombok.AllArgsConstructor;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceLauncher.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceLauncher.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceLauncher.java
index fab5de0..9b97fe9 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceLauncher.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/TestStandardGobblinInstanceLauncher.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.instance;
+package org.apache.gobblin.runtime.instance;
 
 import java.net.URI;
 import java.util.ArrayList;
@@ -30,21 +30,21 @@ import com.google.common.base.Function;
 import com.google.common.collect.ImmutableMap;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.runtime.api.GobblinInstanceDriver;
-import gobblin.runtime.api.JobExecutionDriver;
-import gobblin.runtime.api.JobExecutionLauncher;
-import gobblin.runtime.api.JobExecutionResult;
-import gobblin.runtime.api.JobLifecycleListener;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.instance.DefaultGobblinInstanceDriverImpl.JobSpecRunnable;
-import gobblin.runtime.job_spec.ResolvedJobSpec;
-import gobblin.runtime.std.DefaultJobLifecycleListenerImpl;
-import gobblin.runtime.std.FilteredJobLifecycleListener;
-import gobblin.runtime.std.JobSpecFilter;
-import gobblin.testing.AssertWithBackoff;
-import gobblin.util.test.HelloWorldSource;
-import gobblin.writer.test.GobblinTestEventBusWriter;
-import gobblin.writer.test.TestingEventBusAsserter;
+import org.apache.gobblin.runtime.api.GobblinInstanceDriver;
+import org.apache.gobblin.runtime.api.JobExecutionDriver;
+import org.apache.gobblin.runtime.api.JobExecutionLauncher;
+import org.apache.gobblin.runtime.api.JobExecutionResult;
+import org.apache.gobblin.runtime.api.JobLifecycleListener;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.instance.DefaultGobblinInstanceDriverImpl.JobSpecRunnable;
+import org.apache.gobblin.runtime.job_spec.ResolvedJobSpec;
+import org.apache.gobblin.runtime.std.DefaultJobLifecycleListenerImpl;
+import org.apache.gobblin.runtime.std.FilteredJobLifecycleListener;
+import org.apache.gobblin.runtime.std.JobSpecFilter;
+import org.apache.gobblin.testing.AssertWithBackoff;
+import org.apache.gobblin.util.test.HelloWorldSource;
+import org.apache.gobblin.writer.test.GobblinTestEventBusWriter;
+import org.apache.gobblin.writer.test.TestingEventBusAsserter;
 
 /**
  * Unit tests for {@link StandardGobblinInstanceLauncher}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/hadoop/TestHadoopConfigLoader.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/hadoop/TestHadoopConfigLoader.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/hadoop/TestHadoopConfigLoader.java
index fb1829f..ca245eb 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/hadoop/TestHadoopConfigLoader.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/instance/hadoop/TestHadoopConfigLoader.java
@@ -9,7 +9,7 @@
  * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
  * CONDITIONS OF ANY KIND, either express or implied.
  */
-package gobblin.runtime.instance.hadoop;
+package org.apache.gobblin.runtime.instance.hadoop;
 
 import org.apache.hadoop.conf.Configuration;
 import org.testng.Assert;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/FSJobCatalogHelperTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/FSJobCatalogHelperTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/FSJobCatalogHelperTest.java
index 0404275..c50daec 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/FSJobCatalogHelperTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/FSJobCatalogHelperTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.job_catalog;
+package org.apache.gobblin.runtime.job_catalog;
 
 import java.io.File;
 import java.io.FileWriter;
@@ -44,16 +44,16 @@ import com.google.common.io.Files;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.job_catalog.FSJobCatalog;
-import gobblin.runtime.job_catalog.ImmutableFSJobCatalog;
-import gobblin.util.ConfigUtils;
-import gobblin.util.PullFileLoader;
-import gobblin.util.filesystem.PathAlterationObserverScheduler;
-import gobblin.util.filesystem.PathAlterationListener;
-import gobblin.util.filesystem.PathAlterationListenerAdaptor;
-import gobblin.util.filesystem.PathAlterationObserver;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.job_catalog.FSJobCatalog;
+import org.apache.gobblin.runtime.job_catalog.ImmutableFSJobCatalog;
+import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.PullFileLoader;
+import org.apache.gobblin.util.filesystem.PathAlterationObserverScheduler;
+import org.apache.gobblin.util.filesystem.PathAlterationListener;
+import org.apache.gobblin.util.filesystem.PathAlterationListenerAdaptor;
+import org.apache.gobblin.util.filesystem.PathAlterationObserver;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/PackagedTemplatesJobCatalogDecoratorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/PackagedTemplatesJobCatalogDecoratorTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/PackagedTemplatesJobCatalogDecoratorTest.java
index 1324096..bf448cb 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/PackagedTemplatesJobCatalogDecoratorTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/PackagedTemplatesJobCatalogDecoratorTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.job_catalog;
+package org.apache.gobblin.runtime.job_catalog;
 
 import java.net.URI;
 import java.util.Collection;
@@ -26,10 +26,10 @@ import org.testng.annotations.Test;
 
 import com.typesafe.config.Config;
 
-import gobblin.runtime.api.JobCatalogWithTemplates;
-import gobblin.runtime.api.JobTemplate;
-import gobblin.runtime.api.SpecNotFoundException;
-import gobblin.runtime.template.ResourceBasedJobTemplate;
+import org.apache.gobblin.runtime.api.JobCatalogWithTemplates;
+import org.apache.gobblin.runtime.api.JobTemplate;
+import org.apache.gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.runtime.template.ResourceBasedJobTemplate;
 
 
 public class PackagedTemplatesJobCatalogDecoratorTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestFSJobCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestFSJobCatalog.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestFSJobCatalog.java
index caab700..149d56a 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestFSJobCatalog.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestFSJobCatalog.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.job_catalog;
+package org.apache.gobblin.runtime.job_catalog;
 
-import gobblin.config.ConfigBuilder;
-import gobblin.runtime.job_spec.ResolvedJobSpec;
+import org.apache.gobblin.config.ConfigBuilder;
+import org.apache.gobblin.runtime.job_spec.ResolvedJobSpec;
 import java.io.File;
 import java.io.PrintWriter;
 import java.net.URI;
@@ -33,11 +33,11 @@ import org.mockito.invocation.InvocationOnMock;
 import org.mockito.stubbing.Answer;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.JobCatalogListener;
-import gobblin.runtime.api.JobSpec;
-import gobblin.util.ConfigUtils;
-import gobblin.util.filesystem.PathAlterationObserver;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.JobCatalogListener;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.filesystem.PathAlterationObserver;
 
 import org.testng.Assert;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestImmutableFSJobCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestImmutableFSJobCatalog.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestImmutableFSJobCatalog.java
index 72efd7a..d58cd46 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestImmutableFSJobCatalog.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestImmutableFSJobCatalog.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.job_catalog;
+package org.apache.gobblin.runtime.job_catalog;
 
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;
@@ -28,7 +28,7 @@ import com.google.common.collect.ImmutableMap;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
 
 /**
  * Unit tests for {@link ImmutableFSJobCatalog}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestInMemoryJobCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestInMemoryJobCatalog.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestInMemoryJobCatalog.java
index 29f6ef7..5920f78 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestInMemoryJobCatalog.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestInMemoryJobCatalog.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.job_catalog;
+package org.apache.gobblin.runtime.job_catalog;
 
 import java.net.URI;
 import java.util.concurrent.TimeUnit;
@@ -29,12 +29,12 @@ import org.testng.annotations.Test;
 import com.google.common.base.Optional;
 import com.google.common.base.Predicates;
 
-import gobblin.instrumented.GobblinMetricsKeys;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.test.MetricsAssert;
-import gobblin.runtime.api.JobCatalog;
-import gobblin.runtime.api.JobCatalogListener;
-import gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.instrumented.GobblinMetricsKeys;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.metrics.test.MetricsAssert;
+import org.apache.gobblin.runtime.api.JobCatalog;
+import org.apache.gobblin.runtime.api.JobCatalogListener;
+import org.apache.gobblin.runtime.api.JobSpec;
 
 
 /** Unit tests for {@link InMemoryJobCatalog} */

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestJobCatalogListenersList.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestJobCatalogListenersList.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestJobCatalogListenersList.java
index 91ef22a..8bbfdd2 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestJobCatalogListenersList.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestJobCatalogListenersList.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.job_catalog;
+package org.apache.gobblin.runtime.job_catalog;
 
 import org.mockito.Mockito;
 import org.testng.annotations.Test;
 
-import gobblin.runtime.api.JobCatalogListener;
-import gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobCatalogListener;
+import org.apache.gobblin.runtime.api.JobSpec;
 
 /** Unit tests for {@link JobCatalogListenersList} */
 public class TestJobCatalogListenersList {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestMutableCachingJobCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestMutableCachingJobCatalog.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestMutableCachingJobCatalog.java
index dabf4b2..294fece 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestMutableCachingJobCatalog.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestMutableCachingJobCatalog.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.job_catalog;
+package org.apache.gobblin.runtime.job_catalog;
 
 import java.net.URI;
 import java.util.concurrent.TimeUnit;
@@ -27,9 +27,9 @@ import org.testng.annotations.Test;
 
 import com.google.common.base.Optional;
 
-import gobblin.runtime.api.JobCatalogListener;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecNotFoundException;
+import org.apache.gobblin.runtime.api.JobCatalogListener;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecNotFoundException;
 
 /** Unit tests for {@link CachingJobCatalog} and {@link MutableCachingJobCatalog} */
 public class TestMutableCachingJobCatalog {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestNonObservingFSJobCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestNonObservingFSJobCatalog.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestNonObservingFSJobCatalog.java
index 855cf1b..3346766 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestNonObservingFSJobCatalog.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_catalog/TestNonObservingFSJobCatalog.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.job_catalog;
+package org.apache.gobblin.runtime.job_catalog;
 
 import java.io.File;
 import java.io.PrintWriter;
@@ -32,13 +32,13 @@ import org.mockito.stubbing.Answer;
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.config.ConfigBuilder;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.JobCatalogListener;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.job_spec.ResolvedJobSpec;
-import gobblin.util.ConfigUtils;
-import gobblin.util.filesystem.PathAlterationObserver;
+import org.apache.gobblin.config.ConfigBuilder;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.JobCatalogListener;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.job_spec.ResolvedJobSpec;
+import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.filesystem.PathAlterationObserver;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_exec/TestJobLauncherExecutionDriver.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_exec/TestJobLauncherExecutionDriver.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_exec/TestJobLauncherExecutionDriver.java
index 02081bb..4aa5084 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_exec/TestJobLauncherExecutionDriver.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_exec/TestJobLauncherExecutionDriver.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.job_exec;
+package org.apache.gobblin.runtime.job_exec;
 
 import java.io.File;
 import java.io.IOException;
@@ -30,13 +30,13 @@ import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 import com.typesafe.config.ConfigValueFactory;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.JobLauncherFactory;
-import gobblin.runtime.api.JobExecution;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.local.LocalJobLauncher;
-import gobblin.runtime.mapreduce.MRJobLauncher;
-import gobblin.util.test.TestingSource;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.JobLauncherFactory;
+import org.apache.gobblin.runtime.api.JobExecution;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.local.LocalJobLauncher;
+import org.apache.gobblin.runtime.mapreduce.MRJobLauncher;
+import org.apache.gobblin.util.test.TestingSource;
 
 /**
  * Unit tests for {@link JobLauncherExecutionDriver}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaAvroJobMonitorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaAvroJobMonitorTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaAvroJobMonitorTest.java
index 1f38a07..416e237 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaAvroJobMonitorTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaAvroJobMonitorTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.job_monitor;
+package org.apache.gobblin.runtime.job_monitor;
 
 import java.net.URI;
 import java.util.Collection;
@@ -29,17 +29,17 @@ import com.google.common.base.Optional;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 
-import gobblin.metrics.GobblinTrackingEvent;
-import gobblin.metrics.Metric;
-import gobblin.metrics.MetricReport;
-import gobblin.metrics.reporter.util.AvroBinarySerializer;
-import gobblin.metrics.reporter.util.AvroSerializer;
-import gobblin.metrics.reporter.util.FixedSchemaVersionWriter;
-import gobblin.metrics.reporter.util.NoopSchemaVersionWriter;
-import gobblin.metrics.reporter.util.SchemaVersionWriter;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.kafka.HighLevelConsumerTest;
-import gobblin.util.Either;
+import org.apache.gobblin.metrics.GobblinTrackingEvent;
+import org.apache.gobblin.metrics.Metric;
+import org.apache.gobblin.metrics.MetricReport;
+import org.apache.gobblin.metrics.reporter.util.AvroBinarySerializer;
+import org.apache.gobblin.metrics.reporter.util.AvroSerializer;
+import org.apache.gobblin.metrics.reporter.util.FixedSchemaVersionWriter;
+import org.apache.gobblin.metrics.reporter.util.NoopSchemaVersionWriter;
+import org.apache.gobblin.metrics.reporter.util.SchemaVersionWriter;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.kafka.HighLevelConsumerTest;
+import org.apache.gobblin.util.Either;
 
 
 public class KafkaAvroJobMonitorTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitorTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitorTest.java
index c517acc..1dd90b1 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitorTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitorTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.job_monitor;
+package org.apache.gobblin.runtime.job_monitor;
 
 import java.net.URI;
 
@@ -24,7 +24,7 @@ import org.testng.annotations.Test;
 
 import com.google.common.base.Optional;
 
-import gobblin.runtime.kafka.HighLevelConsumerTest;
+import org.apache.gobblin.runtime.kafka.HighLevelConsumerTest;
 
 
 public class KafkaJobMonitorTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockKafkaStream.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockKafkaStream.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockKafkaStream.java
index 5644795..7787519 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockKafkaStream.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockKafkaStream.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.job_monitor;
+package org.apache.gobblin.runtime.job_monitor;
 
 import java.util.List;
 import java.util.concurrent.BlockingQueue;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockedKafkaJobMonitor.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockedKafkaJobMonitor.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockedKafkaJobMonitor.java
index c127c83..7d3ef37 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockedKafkaJobMonitor.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/MockedKafkaJobMonitor.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.job_monitor;
+package org.apache.gobblin.runtime.job_monitor;
 
 import java.io.IOException;
 import java.net.URI;
@@ -38,10 +38,10 @@ import com.google.common.collect.Maps;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.MutableJobCatalog;
-import gobblin.testing.AssertWithBackoff;
-import gobblin.util.Either;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.MutableJobCatalog;
+import org.apache.gobblin.testing.AssertWithBackoff;
+import org.apache.gobblin.util.Either;
 
 import kafka.consumer.KafkaStream;
 import kafka.javaapi.consumer.ConsumerConnector;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/SLAEventKafkaJobMonitorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/SLAEventKafkaJobMonitorTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/SLAEventKafkaJobMonitorTest.java
index f4dc696..5c278c9 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/SLAEventKafkaJobMonitorTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/job_monitor/SLAEventKafkaJobMonitorTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.job_monitor;
+package org.apache.gobblin.runtime.job_monitor;
 
 import java.net.URI;
 import java.util.Collection;
@@ -32,13 +32,13 @@ import com.google.common.collect.Maps;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.metrics.GobblinTrackingEvent;
-import gobblin.metrics.event.sla.SlaEventKeys;
-import gobblin.metrics.reporter.util.FixedSchemaVersionWriter;
-import gobblin.metrics.reporter.util.NoopSchemaVersionWriter;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.kafka.HighLevelConsumerTest;
-import gobblin.util.Either;
+import org.apache.gobblin.metrics.GobblinTrackingEvent;
+import org.apache.gobblin.metrics.event.sla.SlaEventKeys;
+import org.apache.gobblin.metrics.reporter.util.FixedSchemaVersionWriter;
+import org.apache.gobblin.metrics.reporter.util.NoopSchemaVersionWriter;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.kafka.HighLevelConsumerTest;
+import org.apache.gobblin.util.Either;
 
 
 public class SLAEventKafkaJobMonitorTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/HighLevelConsumerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/HighLevelConsumerTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/HighLevelConsumerTest.java
index 8cbdb68..6e8d7a2 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/HighLevelConsumerTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/HighLevelConsumerTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.kafka;
+package org.apache.gobblin.runtime.kafka;
 
 import java.util.Properties;
 import java.util.concurrent.TimeoutException;
@@ -27,7 +27,7 @@ import com.google.common.base.Optional;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.runtime.job_monitor.MockKafkaStream;
+import org.apache.gobblin.runtime.job_monitor.MockKafkaStream;
 
 
 public class HighLevelConsumerTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/MockedHighLevelConsumer.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/MockedHighLevelConsumer.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/MockedHighLevelConsumer.java
index d675cfc..5035afa 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/MockedHighLevelConsumer.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/kafka/MockedHighLevelConsumer.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.kafka;
+package org.apache.gobblin.runtime.kafka;
 
 import java.util.List;
 
@@ -26,8 +26,8 @@ import com.google.common.base.Predicate;
 import com.google.common.collect.Lists;
 import com.typesafe.config.Config;
 
-import gobblin.runtime.job_monitor.MockKafkaStream;
-import gobblin.testing.AssertWithBackoff;
+import org.apache.gobblin.runtime.job_monitor.MockKafkaStream;
+import org.apache.gobblin.testing.AssertWithBackoff;
 
 import javax.annotation.Nullable;
 import kafka.consumer.ConsumerConfig;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java
index d446923..f620561 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.local;
+package org.apache.gobblin.runtime.local;
 
 import java.io.FileReader;
 import java.io.IOException;
@@ -25,18 +25,18 @@ import org.testng.annotations.AfterClass;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.metastore.FsStateStore;
-import gobblin.metastore.StateStore;
-
-import gobblin.metastore.testing.ITestMetastoreDatabase;
-import gobblin.metastore.testing.TestMetastoreDatabaseFactory;
-import gobblin.runtime.JobLauncherTestHelper;
-import gobblin.runtime.JobState;
-import gobblin.util.limiter.BaseLimiterType;
-import gobblin.util.limiter.DefaultLimiterFactory;
-import gobblin.writer.Destination;
-import gobblin.writer.WriterOutputFormat;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.metastore.FsStateStore;
+import org.apache.gobblin.metastore.StateStore;
+
+import org.apache.gobblin.metastore.testing.ITestMetastoreDatabase;
+import org.apache.gobblin.metastore.testing.TestMetastoreDatabaseFactory;
+import org.apache.gobblin.runtime.JobLauncherTestHelper;
+import org.apache.gobblin.runtime.JobState;
+import org.apache.gobblin.util.limiter.BaseLimiterType;
+import org.apache.gobblin.util.limiter.DefaultLimiterFactory;
+import org.apache.gobblin.writer.Destination;
+import org.apache.gobblin.writer.WriterOutputFormat;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactoryManagerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactoryManagerTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactoryManagerTest.java
index bcc9502..c536202 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactoryManagerTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactoryManagerTest.java
@@ -1,7 +1,7 @@
 /**
  *
  */
-package gobblin.runtime.locks;
+package org.apache.gobblin.runtime.locks;
 
 import java.io.File;
 
@@ -17,7 +17,7 @@ import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 import com.typesafe.config.ConfigValueFactory;
 
-import gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpec;
 
 /**
  *  Unit tests for {@link FileBasedJobLockFactoryManager}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockTest.java
index 4f7a2c3..d6f1378 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/FileBasedJobLockTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.locks;
+package org.apache.gobblin.runtime.locks;
 
 import java.io.IOException;
 import java.util.Properties;
@@ -28,7 +28,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/runtime/locks/JobLockTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/JobLockTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/JobLockTest.java
index 9a905c9..8d03010 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/JobLockTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/JobLockTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.locks;
+package org.apache.gobblin.runtime.locks;
 
 import java.io.IOException;
 import java.util.concurrent.CountDownLatch;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/LegacyJobLockFactoryManagerTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/LegacyJobLockFactoryManagerTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/LegacyJobLockFactoryManagerTest.java
index f313376..6dbc17f 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/LegacyJobLockFactoryManagerTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/LegacyJobLockFactoryManagerTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.locks;
+package org.apache.gobblin.runtime.locks;
 
 import java.io.IOException;
 import java.util.Properties;
@@ -28,7 +28,7 @@ import org.testng.annotations.Test;
 
 import com.google.common.io.Closer;
 
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
 
 
 @Test(groups = {"gobblin.runtime"})

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/ZookeeperBasedJobLockTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/ZookeeperBasedJobLockTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/ZookeeperBasedJobLockTest.java
index 6e7718c..1fe94c9 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/ZookeeperBasedJobLockTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/locks/ZookeeperBasedJobLockTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.locks;
+package org.apache.gobblin.runtime.locks;
 
 import java.io.IOException;
 import java.util.Properties;
@@ -25,7 +25,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;
 
 /**
  * Unit test for {@link ZookeeperBasedJobLock}.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitterTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitterTest.java
index ada7480..c182dce 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitterTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinOutputCommitterTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.mapreduce;
+package org.apache.gobblin.runtime.mapreduce;
 
 import java.io.IOException;
 import java.util.Arrays;
@@ -35,10 +35,10 @@ import org.testng.annotations.Test;
 import com.google.common.collect.Lists;
 import com.google.common.io.Closer;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.source.workunit.MultiWorkUnit;
-import gobblin.source.workunit.WorkUnit;
-import gobblin.util.ForkOperatorUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.source.workunit.MultiWorkUnit;
+import org.apache.gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.util.ForkOperatorUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormatTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormatTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormatTest.java
index 85a98b2..102c8a0 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormatTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormatTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.mapreduce;
+package org.apache.gobblin.runtime.mapreduce;
 
 import java.io.ByteArrayInputStream;
 import java.io.DataInputStream;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java
index e5127d6..e9f6c62 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.mapreduce;
+package org.apache.gobblin.runtime.mapreduce;
 
 import java.io.File;
 import java.io.IOException;
@@ -32,18 +32,18 @@ import org.testng.annotations.AfterClass;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.metastore.FsStateStore;
-import gobblin.metastore.StateStore;
-import gobblin.metastore.testing.ITestMetastoreDatabase;
-import gobblin.metastore.testing.TestMetastoreDatabaseFactory;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.runtime.JobLauncherTestHelper;
-import gobblin.runtime.JobState;
-import gobblin.util.limiter.BaseLimiterType;
-import gobblin.util.limiter.DefaultLimiterFactory;
-import gobblin.writer.Destination;
-import gobblin.writer.WriterOutputFormat;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.metastore.FsStateStore;
+import org.apache.gobblin.metastore.StateStore;
+import org.apache.gobblin.metastore.testing.ITestMetastoreDatabase;
+import org.apache.gobblin.metastore.testing.TestMetastoreDatabaseFactory;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.runtime.JobLauncherTestHelper;
+import org.apache.gobblin.runtime.JobState;
+import org.apache.gobblin.util.limiter.BaseLimiterType;
+import org.apache.gobblin.util.limiter.DefaultLimiterFactory;
+import org.apache.gobblin.writer.Destination;
+import org.apache.gobblin.writer.WriterOutputFormat;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRTaskFactoryTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRTaskFactoryTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRTaskFactoryTest.java
index 7774056..a1e91f1 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRTaskFactoryTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRTaskFactoryTest.java
@@ -15,22 +15,22 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.mapreduce;
+package org.apache.gobblin.runtime.mapreduce;
 
 import com.google.common.base.Charsets;
 import com.google.common.base.Splitter;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import com.google.common.io.Files;
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.WorkUnitState;
-import gobblin.runtime.api.JobExecutionResult;
-import gobblin.runtime.embedded.EmbeddedGobblin;
-import gobblin.runtime.task.TaskUtils;
-import gobblin.source.Source;
-import gobblin.source.extractor.Extractor;
-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.runtime.api.JobExecutionResult;
+import org.apache.gobblin.runtime.embedded.EmbeddedGobblin;
+import org.apache.gobblin.runtime.task.TaskUtils;
+import org.apache.gobblin.source.Source;
+import org.apache.gobblin.source.extractor.Extractor;
+import org.apache.gobblin.source.workunit.WorkUnit;
 import java.io.File;
 import java.io.IOException;
 import java.util.List;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestImmediateJobSpecScheduler.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestImmediateJobSpecScheduler.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestImmediateJobSpecScheduler.java
index eaefc62..cc1720d 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestImmediateJobSpecScheduler.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestImmediateJobSpecScheduler.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.scheduler;
+package org.apache.gobblin.runtime.scheduler;
 
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.verify;
@@ -30,9 +30,9 @@ import org.testng.annotations.Test;
 
 import com.google.common.base.Optional;
 
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecSchedule;
-import gobblin.runtime.api.JobSpecSchedulerListener;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecSchedule;
+import org.apache.gobblin.runtime.api.JobSpecSchedulerListener;
 
 /**
  * Unit tests for {@link ImmediateJobSpecScheduler}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestQuartzJobSpecScheduler.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestQuartzJobSpecScheduler.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestQuartzJobSpecScheduler.java
index 8eb5cdf..b51d362 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestQuartzJobSpecScheduler.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/scheduler/TestQuartzJobSpecScheduler.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.scheduler;
+package org.apache.gobblin.runtime.scheduler;
 
 import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.TimeUnit;
@@ -28,10 +28,10 @@ import com.google.common.collect.ImmutableMap;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.JobSpec;
-import gobblin.runtime.api.JobSpecSchedule;
-import gobblin.runtime.scheduler.QuartzJobSpecScheduler.QuartzJobSchedule;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpecSchedule;
+import org.apache.gobblin.runtime.scheduler.QuartzJobSpecScheduler.QuartzJobSchedule;
 
 /**
  * Unit tests for {@link QuartzJobSpecScheduler}.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestDefaultConfigurableImpl.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestDefaultConfigurableImpl.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestDefaultConfigurableImpl.java
index 0d7fd71..ae47536 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestDefaultConfigurableImpl.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestDefaultConfigurableImpl.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.std;
+package org.apache.gobblin.runtime.std;
 
 import java.util.Properties;
 
@@ -26,7 +26,7 @@ import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 import com.typesafe.config.ConfigValueFactory;
 
-import gobblin.runtime.std.DefaultConfigurableImpl;
+import org.apache.gobblin.runtime.std.DefaultConfigurableImpl;
 
 /**
  * Unit tests for {@link DefaultConfigurableImpl}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestFilteredJobLifecycleListener.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestFilteredJobLifecycleListener.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestFilteredJobLifecycleListener.java
index 865df22..467d835 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestFilteredJobLifecycleListener.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestFilteredJobLifecycleListener.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.std;
+package org.apache.gobblin.runtime.std;
 
 import static org.mockito.Matchers.eq;
 import static org.mockito.Mockito.mock;
@@ -28,12 +28,12 @@ import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 import com.typesafe.config.ConfigValueFactory;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.JobState.RunningState;
-import gobblin.runtime.api.JobExecutionState;
-import gobblin.runtime.api.JobExecutionStateListener;
-import gobblin.runtime.api.JobLifecycleListener;
-import gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.JobState.RunningState;
+import org.apache.gobblin.runtime.api.JobExecutionState;
+import org.apache.gobblin.runtime.api.JobExecutionStateListener;
+import org.apache.gobblin.runtime.api.JobLifecycleListener;
+import org.apache.gobblin.runtime.api.JobSpec;
 
 /**
  * Unit tests for {@link FilteredJobLifecycleListener}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobExecutionStateListeners.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobExecutionStateListeners.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobExecutionStateListeners.java
index 826fe6b..e746cfd 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobExecutionStateListeners.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobExecutionStateListeners.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.std;
+package org.apache.gobblin.runtime.std;
 
 import org.mockito.Mockito;
 import org.slf4j.Logger;
@@ -25,11 +25,11 @@ import com.google.common.base.Optional;
 import com.typesafe.config.ConfigFactory;
 import com.typesafe.config.ConfigValueFactory;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.JobState.RunningState;
-import gobblin.runtime.api.JobExecutionState;
-import gobblin.runtime.api.JobExecutionStateListener;
-import gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.JobState.RunningState;
+import org.apache.gobblin.runtime.api.JobExecutionState;
+import org.apache.gobblin.runtime.api.JobExecutionStateListener;
+import org.apache.gobblin.runtime.api.JobSpec;
 
 /**
  * Unit tests for {@link JobExecutionStateListeners}.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobLifecycleListenersList.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobLifecycleListenersList.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobLifecycleListenersList.java
index bd6dfac..24ed6c4 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobLifecycleListenersList.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobLifecycleListenersList.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.std;
+package org.apache.gobblin.runtime.std;
 
 import static org.mockito.Matchers.eq;
 import static org.mockito.Mockito.mock;
@@ -25,11 +25,11 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.testng.annotations.Test;
 
-import gobblin.runtime.api.JobCatalogListenersContainer;
-import gobblin.runtime.api.JobExecutionDriver;
-import gobblin.runtime.api.JobExecutionState;
-import gobblin.runtime.api.JobLifecycleListener;
-import gobblin.runtime.api.JobSpecSchedulerListenersContainer;
+import org.apache.gobblin.runtime.api.JobCatalogListenersContainer;
+import org.apache.gobblin.runtime.api.JobExecutionDriver;
+import org.apache.gobblin.runtime.api.JobExecutionState;
+import org.apache.gobblin.runtime.api.JobLifecycleListener;
+import org.apache.gobblin.runtime.api.JobSpecSchedulerListenersContainer;
 
 /**
  * Unit tests for {@link JobLifecycleListenersList}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobSpecFilter.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobSpecFilter.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobSpecFilter.java
index 6b3cb69..54f28b2 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobSpecFilter.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/std/TestJobSpecFilter.java
@@ -14,12 +14,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.std;
+package org.apache.gobblin.runtime.std;
 
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.runtime.api.JobSpec;
+import org.apache.gobblin.runtime.api.JobSpec;
 
 /**
  * Unit tests for {@link JobSpecFilter}

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/InheritingJobTemplateTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/InheritingJobTemplateTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/InheritingJobTemplateTest.java
index 4a12c5f..ab76f18 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/InheritingJobTemplateTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/InheritingJobTemplateTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.template;
+package org.apache.gobblin.runtime.template;
 
 import java.net.URI;
 import java.net.URISyntaxException;
@@ -36,9 +36,9 @@ import com.typesafe.config.Config;
 import com.typesafe.config.ConfigException;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.runtime.api.JobCatalogWithTemplates;
-import gobblin.runtime.api.JobTemplate;
-import gobblin.runtime.api.SpecNotFoundException;
+import org.apache.gobblin.runtime.api.JobCatalogWithTemplates;
+import org.apache.gobblin.runtime.api.JobTemplate;
+import org.apache.gobblin.runtime.api.SpecNotFoundException;
 
 import lombok.AllArgsConstructor;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplateTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplateTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplateTest.java
index 9429d69..7864658 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplateTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/ResourceBasedJobTemplateTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.template;
+package org.apache.gobblin.runtime.template;
 
 import java.util.Collection;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/StaticJobTemplateTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/StaticJobTemplateTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/StaticJobTemplateTest.java
index 50206c3..ce42f8e 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/StaticJobTemplateTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/template/StaticJobTemplateTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.template;
+package org.apache.gobblin.runtime.template;
 
 import java.net.URI;
 import java.util.Collection;
@@ -31,8 +31,8 @@ import com.google.common.collect.Maps;
 import com.typesafe.config.Config;
 import com.typesafe.config.ConfigFactory;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.runtime.api.JobCatalogWithTemplates;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.runtime.api.JobCatalogWithTemplates;
 
 
 public class StaticJobTemplateTest {

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobMetricsTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobMetricsTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobMetricsTest.java
index 0c3b329..8a21d58 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobMetricsTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobMetricsTest.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.util;
+package org.apache.gobblin.runtime.util;
 
 import java.util.List;
 import java.util.Map;
@@ -27,13 +27,13 @@ import org.testng.annotations.Test;
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.Iterables;
 
-import gobblin.configuration.State;
-import gobblin.metrics.GobblinMetrics;
-import gobblin.metrics.GobblinMetricsRegistry;
-import gobblin.metrics.MetricContext;
-import gobblin.metrics.Tag;
-import gobblin.metrics.event.JobEvent;
-import gobblin.runtime.JobState;
+import org.apache.gobblin.configuration.State;
+import org.apache.gobblin.metrics.GobblinMetrics;
+import org.apache.gobblin.metrics.GobblinMetricsRegistry;
+import org.apache.gobblin.metrics.MetricContext;
+import org.apache.gobblin.metrics.Tag;
+import org.apache.gobblin.metrics.event.JobEvent;
+import org.apache.gobblin.runtime.JobState;
 
 
 @Test(groups = { "gobblin.runtime" })

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobStateToJsonConverterTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobStateToJsonConverterTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobStateToJsonConverterTest.java
index 07ce7c4..a195ff4 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobStateToJsonConverterTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/JobStateToJsonConverterTest.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.runtime.util;
+package org.apache.gobblin.runtime.util;
 
 import com.google.gson.JsonElement;
 import com.google.gson.JsonObject;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIteratorTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIteratorTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIteratorTest.java
index 4f933ab..1d2fd82 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIteratorTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/MultiWorkUnitUnpackingIteratorTest.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.util;
+package org.apache.gobblin.runtime.util;
 
 import com.google.common.base.Function;
 import com.google.common.collect.Iterators;
 import com.google.common.collect.Lists;
-import gobblin.source.workunit.MultiWorkUnit;
-import gobblin.source.workunit.WorkUnit;
+import org.apache.gobblin.source.workunit.MultiWorkUnit;
+import org.apache.gobblin.source.workunit.WorkUnit;
 import java.util.List;
 import javax.annotation.Nullable;
 import org.testng.Assert;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/TaskMetricsTest.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/TaskMetricsTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/TaskMetricsTest.java
index 1b0c6fc..6ea2997 100644
--- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/TaskMetricsTest.java
+++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/util/TaskMetricsTest.java
@@ -15,20 +15,20 @@
  * limitations under the License.
  */
 
-package gobblin.runtime.util;
+package org.apache.gobblin.runtime.util;
 
 import java.util.ArrayList;
 
 import org.testng.Assert;
 import org.testng.annotations.Test;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.SourceState;
-import gobblin.configuration.State;
-import gobblin.configuration.WorkUnitState;
-import gobblin.runtime.JobState;
-import gobblin.runtime.TaskState;
-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.runtime.JobState;
+import org.apache.gobblin.runtime.TaskState;
+import org.apache.gobblin.source.workunit.WorkUnit;
 
 
 @Test(groups = {"gobblin.runtime"})