gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [03/77] [abbrv] incubator-gobblin git commit: Updated package names, imports and shell scripts
Date Mon, 31 Jul 2017 07:52:21 GMT
http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingExecutorService.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingExecutorService.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingExecutorService.java
index 7337ce0..8026827 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingExecutorService.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingExecutorService.java
@@ -10,7 +10,7 @@
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package gobblin.util.executors;
+package org.apache.gobblin.util.executors;
 
 import com.google.common.util.concurrent.ForwardingListeningExecutorService;
 import com.google.common.util.concurrent.ListenableFuture;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingRunnable.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingRunnable.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingRunnable.java
index 21b919f..a21e668 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingRunnable.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingRunnable.java
@@ -10,7 +10,7 @@
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package gobblin.util.executors;
+package org.apache.gobblin.util.executors;
 
 import org.slf4j.MDC;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingScheduledExecutorService.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingScheduledExecutorService.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingScheduledExecutorService.java
index 7a99fcf..b338b89 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingScheduledExecutorService.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/MDCPropagatingScheduledExecutorService.java
@@ -10,7 +10,7 @@
  * CONDITIONS OF ANY KIND, either express or implied.
  */
 
-package gobblin.util.executors;
+package org.apache.gobblin.util.executors;
 
 import com.google.common.base.Throwables;
 import com.google.common.util.concurrent.AbstractFuture;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingQueue.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingQueue.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingQueue.java
index d896e93..7dc36c4 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingQueue.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingQueue.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.executors;
+package org.apache.gobblin.util.executors;
 
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.ThreadPoolExecutor;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingThreadPoolExecutor.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingThreadPoolExecutor.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingThreadPoolExecutor.java
index a8ab17a..608dd41 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingThreadPoolExecutor.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/executors/ScalingThreadPoolExecutor.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.executors;
+package org.apache.gobblin.util.executors;
 
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.Executors;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ExceptionCatchingPathAlterationListenerDecorator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ExceptionCatchingPathAlterationListenerDecorator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ExceptionCatchingPathAlterationListenerDecorator.java
index b2317d3..4989275 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ExceptionCatchingPathAlterationListenerDecorator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ExceptionCatchingPathAlterationListenerDecorator.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
 
 import org.apache.hadoop.fs.Path;
 
-import gobblin.util.Decorator;
+import org.apache.gobblin.util.Decorator;
 
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileStatusEntry.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileStatusEntry.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileStatusEntry.java
index 88b669a..24d11cf 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileStatusEntry.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileStatusEntry.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
 
 import com.google.common.base.Optional;
 import java.io.FileNotFoundException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemDecorator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemDecorator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemDecorator.java
index c4a146f..d8b07b6 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemDecorator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemDecorator.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
 
 import java.io.IOException;
 import java.net.URI;
@@ -42,9 +42,9 @@ import org.apache.hadoop.security.Credentials;
 import org.apache.hadoop.security.token.Token;
 import org.apache.hadoop.util.Progressable;
 
-import gobblin.util.Decorator;
+import org.apache.gobblin.util.Decorator;
 
-import static gobblin.util.filesystem.InstrumentedFileSystemUtils.*;
+import static org.apache.gobblin.util.filesystem.InstrumentedFileSystemUtils.*;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemFactory.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemFactory.java
index 448ea99..3dac2d6 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemFactory.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemFactory.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
 
 import java.io.IOException;
 import java.net.URI;
@@ -24,14 +24,14 @@ import java.util.ServiceLoader;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;
 
-import gobblin.broker.ResourceInstance;
-import gobblin.broker.iface.ConfigView;
-import gobblin.broker.iface.NotConfiguredException;
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.ScopedConfigView;
-import gobblin.broker.iface.SharedResourceFactory;
-import gobblin.broker.iface.SharedResourceFactoryResponse;
-import gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.broker.ResourceInstance;
+import org.apache.gobblin.broker.iface.ConfigView;
+import org.apache.gobblin.broker.iface.NotConfiguredException;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.ScopedConfigView;
+import org.apache.gobblin.broker.iface.SharedResourceFactory;
+import org.apache.gobblin.broker.iface.SharedResourceFactoryResponse;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
 
 import lombok.extern.slf4j.Slf4j;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemInstrumentation.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemInstrumentation.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemInstrumentation.java
index 41ac1d0..24a4a74 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemInstrumentation.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemInstrumentation.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
 
 import java.io.IOException;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemInstrumentationFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemInstrumentationFactory.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemInstrumentationFactory.java
index fb3ed4d..de2260c 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemInstrumentationFactory.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemInstrumentationFactory.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
 
 import org.apache.hadoop.fs.FileSystem;
 
-import gobblin.broker.iface.ConfigView;
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.broker.iface.ConfigView;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemKey.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemKey.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemKey.java
index ed20557..b3a929f 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemKey.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemKey.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
 
 import java.net.URI;
 import java.net.URISyntaxException;
@@ -25,7 +25,7 @@ import org.apache.hadoop.fs.FileSystem;
 
 import com.google.common.base.Strings;
 
-import gobblin.broker.iface.SharedResourceKey;
+import org.apache.gobblin.broker.iface.SharedResourceKey;
 
 import lombok.Getter;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemLimiterKey.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemLimiterKey.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemLimiterKey.java
index 58fa913..601cbb3 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemLimiterKey.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemLimiterKey.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
 
 import java.net.URI;
 
-import gobblin.util.ClustersNames;
-import gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.util.ClustersNames;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystem.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystem.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystem.java
index ec09ad1..da26b11 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystem.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystem.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
 
 import java.io.IOException;
 import java.net.URI;
@@ -23,9 +23,9 @@ import java.net.URI;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;
 
-import gobblin.broker.SharedResourcesBrokerFactory;
+import org.apache.gobblin.broker.SharedResourcesBrokerFactory;
 
-import static gobblin.util.filesystem.InstrumentedFileSystemUtils.*;
+import static org.apache.gobblin.util.filesystem.InstrumentedFileSystemUtils.*;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystemUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystemUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystemUtils.java
index d73dc47..054012f 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystemUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedFileSystemUtils.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
 
 import java.io.IOException;
 import java.net.URI;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedHDFSFileSystem.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedHDFSFileSystem.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedHDFSFileSystem.java
index 60cb30f..1c6e608 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedHDFSFileSystem.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedHDFSFileSystem.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
 
 import org.apache.hadoop.hdfs.DistributedFileSystem;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedLocalFileSystem.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedLocalFileSystem.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedLocalFileSystem.java
index 48b5138..783558f 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedLocalFileSystem.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedLocalFileSystem.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
 
 import org.apache.hadoop.fs.LocalFileSystem;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedWebHDFSFileSystem.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedWebHDFSFileSystem.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedWebHDFSFileSystem.java
index 47b227f..d5dc46a 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedWebHDFSFileSystem.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/InstrumentedWebHDFSFileSystem.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
 
 import org.apache.hadoop.hdfs.web.WebHdfsFileSystem;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListener.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListener.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListener.java
index 697f518..fa4d940 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListener.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListener.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
 
 import org.apache.commons.io.monitor.FileAlterationListener;
 import org.apache.hadoop.fs.Path;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListenerAdaptor.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListenerAdaptor.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListenerAdaptor.java
index 4bac7ad..cf5891a 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListenerAdaptor.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationListenerAdaptor.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
 
 import org.apache.hadoop.fs.Path;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserver.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserver.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserver.java
index 37a2ec8..1131b87 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserver.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserver.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -32,7 +32,7 @@ import org.apache.hadoop.fs.PathFilter;
 
 import com.google.common.collect.Maps;
 
-import gobblin.util.DecoratorUtils;
+import org.apache.gobblin.util.DecoratorUtils;
 
 import lombok.extern.slf4j.Slf4j;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserverScheduler.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserverScheduler.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserverScheduler.java
index 01f68b2..7321a0a 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserverScheduler.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserverScheduler.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
 
 import java.io.IOException;
 import java.util.List;
@@ -31,7 +31,7 @@ import org.slf4j.LoggerFactory;
 
 import com.google.common.base.Optional;
 
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.util.ExecutorsUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ThrottledFileSystem.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ThrottledFileSystem.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ThrottledFileSystem.java
index b1e4d14..491de82 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ThrottledFileSystem.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/ThrottledFileSystem.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filesystem;
+package org.apache.gobblin.util.filesystem;
 
 import java.io.Closeable;
 import java.io.IOException;
@@ -30,14 +30,14 @@ import org.apache.hadoop.fs.PathFilter;
 import org.apache.hadoop.fs.permission.FsPermission;
 import org.apache.hadoop.util.Progressable;
 
-import gobblin.broker.iface.ConfigView;
-import gobblin.broker.iface.NotConfiguredException;
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.util.HadoopUtils;
-import gobblin.util.limiter.Limiter;
-import gobblin.util.limiter.NotEnoughPermitsException;
-import gobblin.util.limiter.broker.SharedLimiterFactory;
+import org.apache.gobblin.broker.iface.ConfigView;
+import org.apache.gobblin.broker.iface.NotConfiguredException;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.util.HadoopUtils;
+import org.apache.gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.NotEnoughPermitsException;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterFactory;
 
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/AndPathFilter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/AndPathFilter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/AndPathFilter.java
index 351e5f7..936453d 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/AndPathFilter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/AndPathFilter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filters;
+package org.apache.gobblin.util.filters;
 
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.fs.PathFilter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/HiddenFilter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/HiddenFilter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/HiddenFilter.java
index 6469442..2f7d075 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/HiddenFilter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/HiddenFilter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filters;
+package org.apache.gobblin.util.filters;
 
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.fs.PathFilter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/RegexPathFilter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/RegexPathFilter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/RegexPathFilter.java
index c634271..619d8d5 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/RegexPathFilter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/RegexPathFilter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filters;
+package org.apache.gobblin.util.filters;
 
 import java.util.regex.Pattern;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/TarGpgPathFilter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/TarGpgPathFilter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/TarGpgPathFilter.java
index 5f881b2..7a6da2e 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/TarGpgPathFilter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/filters/TarGpgPathFilter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.filters;
+package org.apache.gobblin.util.filters;
 
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.fs.PathFilter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/Guid.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/Guid.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/Guid.java
index 0e54356..6a07856 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/Guid.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/Guid.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.guid;
+package org.apache.gobblin.util.guid;
 
 import lombok.EqualsAndHashCode;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/HasGuid.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/HasGuid.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/HasGuid.java
index 3823700..a2f0946 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/HasGuid.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/guid/HasGuid.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.guid;
+package org.apache.gobblin.util.guid;
 
 import java.io.IOException;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/hadoop/TokenUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/hadoop/TokenUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/hadoop/TokenUtils.java
index 33fc107..15d7cd1 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/hadoop/TokenUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/hadoop/TokenUtils.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.hadoop;
+package org.apache.gobblin.util.hadoop;
 
 import java.io.DataOutputStream;
 import java.io.File;
@@ -52,7 +52,7 @@ import com.google.common.base.Optional;
 import com.google.common.base.Preconditions;
 import com.google.common.base.Strings;
 
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/http/HttpLimiterKey.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/http/HttpLimiterKey.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/http/HttpLimiterKey.java
index 850c859..afc20fc 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/http/HttpLimiterKey.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/http/HttpLimiterKey.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.util.http;
+package org.apache.gobblin.util.http;
 
-import gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/AdditionalCloseableInputStream.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/AdditionalCloseableInputStream.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/AdditionalCloseableInputStream.java
index 1adaef3..318a720 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/AdditionalCloseableInputStream.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/AdditionalCloseableInputStream.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
 
 import java.io.Closeable;
 import java.io.IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/BatchedMeterDecorator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/BatchedMeterDecorator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/BatchedMeterDecorator.java
index 9dccf8f..ecaa332 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/BatchedMeterDecorator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/BatchedMeterDecorator.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
 
 import com.codahale.metrics.Meter;
 
-import gobblin.util.Decorator;
+import org.apache.gobblin.util.Decorator;
 
 import javax.annotation.concurrent.NotThreadSafe;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/CloseableHttpConn.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/CloseableHttpConn.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/CloseableHttpConn.java
index cb89d4a..f084ad0 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/CloseableHttpConn.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/CloseableHttpConn.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
 
 import java.io.Closeable;
 import java.io.IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/FilterStreamUnpacker.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/FilterStreamUnpacker.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/FilterStreamUnpacker.java
index afaf6d7..fb7b450 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/FilterStreamUnpacker.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/FilterStreamUnpacker.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
 
 import java.io.FilterInputStream;
 import java.io.FilterOutputStream;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/GsonInterfaceAdapter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/GsonInterfaceAdapter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/GsonInterfaceAdapter.java
index 286709b..5973aa9 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/GsonInterfaceAdapter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/GsonInterfaceAdapter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
 
 import lombok.AllArgsConstructor;
 import lombok.RequiredArgsConstructor;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredInputStream.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredInputStream.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredInputStream.java
index c7d8d08..33d7cac 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredInputStream.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredInputStream.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
 
 import java.io.FilterInputStream;
 import java.io.IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredOutputStream.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredOutputStream.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredOutputStream.java
index badcfc5..6144ebf 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredOutputStream.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredOutputStream.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
 
 import java.io.FilterOutputStream;
 import java.io.IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredStream.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredStream.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredStream.java
index 9282ec4..71bd6f7 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredStream.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/MeteredStream.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
 
 import com.codahale.metrics.Meter;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/SeekableFSInputStream.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/SeekableFSInputStream.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/SeekableFSInputStream.java
index 24e7b25..6d07da1 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/SeekableFSInputStream.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/SeekableFSInputStream.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
 
 import java.io.IOException;
 import java.io.InputStream;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamCopier.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamCopier.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamCopier.java
index 4c4d77d..48917bb 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamCopier.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamCopier.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
 
 import java.io.Closeable;
 import java.io.IOException;
@@ -28,7 +28,7 @@ import java.nio.channels.WritableByteChannel;
 
 import com.codahale.metrics.Meter;
 
-import gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.Limiter;
 
 import javax.annotation.concurrent.NotThreadSafe;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamCopierSharedLimiterKey.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamCopierSharedLimiterKey.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamCopierSharedLimiterKey.java
index 7a305d5..e7cbc00 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamCopierSharedLimiterKey.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamCopierSharedLimiterKey.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
 
 import java.net.URI;
 
@@ -23,8 +23,8 @@ import org.apache.hadoop.fs.LocalFileSystem;
 
 import com.google.common.base.Joiner;
 
-import gobblin.util.ClustersNames;
-import gobblin.util.limiter.broker.SharedLimiterKey;
+import org.apache.gobblin.util.ClustersNames;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterKey;
 
 import lombok.Getter;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamThrottler.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamThrottler.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamThrottler.java
index 7995069..86f3a96 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamThrottler.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamThrottler.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
 
 import java.io.InputStream;
 import java.net.URI;
@@ -23,19 +23,19 @@ import java.net.URI;
 import com.google.common.base.Optional;
 import com.google.common.base.Preconditions;
 
-import gobblin.broker.EmptyKey;
-import gobblin.broker.ResourceInstance;
-import gobblin.broker.iface.ConfigView;
-import gobblin.broker.iface.NotConfiguredException;
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.ScopedConfigView;
-import gobblin.broker.iface.SharedResourceFactory;
-import gobblin.broker.iface.SharedResourceFactoryResponse;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.util.limiter.Limiter;
-import gobblin.util.limiter.MultiLimiter;
-import gobblin.util.limiter.NoopLimiter;
-import gobblin.util.limiter.broker.SharedLimiterFactory;
+import org.apache.gobblin.broker.EmptyKey;
+import org.apache.gobblin.broker.ResourceInstance;
+import org.apache.gobblin.broker.iface.ConfigView;
+import org.apache.gobblin.broker.iface.NotConfiguredException;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.ScopedConfigView;
+import org.apache.gobblin.broker.iface.SharedResourceFactory;
+import org.apache.gobblin.broker.iface.SharedResourceFactoryResponse;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.MultiLimiter;
+import org.apache.gobblin.util.limiter.NoopLimiter;
+import org.apache.gobblin.util.limiter.broker.SharedLimiterFactory;
 
 import lombok.AllArgsConstructor;
 import lombok.Builder;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamUtils.java
index 8e7b3db..428b209 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/StreamUtils.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -43,7 +43,7 @@ import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.fs.PositionedReadable;
 import org.apache.hadoop.fs.Seekable;
 
-import gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.ConfigurationKeys;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/io/ThrottledInputStream.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/ThrottledInputStream.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/ThrottledInputStream.java
index 7c86e01..fd2edb0 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/io/ThrottledInputStream.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/io/ThrottledInputStream.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package gobblin.util.io;
+package org.apache.gobblin.util.io;
 
 import java.io.Closeable;
 import java.io.FilterInputStream;
 import java.io.IOException;
 import java.io.InputStream;
 
-import gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.Limiter;
 
 import javax.annotation.concurrent.NotThreadSafe;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/iterators/InterruptibleIterator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/iterators/InterruptibleIterator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/iterators/InterruptibleIterator.java
index 8695d55..b1054f8 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/iterators/InterruptibleIterator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/iterators/InterruptibleIterator.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.iterators;
+package org.apache.gobblin.util.iterators;
 
 import java.util.Iterator;
 import java.util.NoSuchElementException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceBuilder.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceBuilder.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceBuilder.java
index 168671d..83cafff 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceBuilder.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceBuilder.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package gobblin.util.jdbc;
+package org.apache.gobblin.util.jdbc;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.configuration.State;
 
 import java.util.Properties;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceModule.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceModule.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceModule.java
index bd3fb61..84852f8 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceModule.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceModule.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.jdbc;
+package org.apache.gobblin.util.jdbc;
 
 import java.util.Properties;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceProvider.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceProvider.java
index 686fe91..1d67136 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceProvider.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceProvider.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.jdbc;
+package org.apache.gobblin.util.jdbc;
 
 import java.util.Properties;
 
@@ -27,7 +27,7 @@ import com.google.inject.Inject;
 import com.google.inject.Provider;
 import com.google.inject.name.Named;
 
-import gobblin.password.PasswordManager;
+import org.apache.gobblin.password.PasswordManager;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/json/JsonUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/json/JsonUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/json/JsonUtils.java
index 62739e0..d575ce6 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/json/JsonUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/json/JsonUtils.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.util.json;
+package org.apache.gobblin.util.json;
 
 import org.codehaus.jackson.JsonFactory;
 import org.codehaus.jackson.map.ObjectMapper;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/BaseLimiterType.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/BaseLimiterType.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/BaseLimiterType.java
index ad2a4af..1a4905d 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/BaseLimiterType.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/BaseLimiterType.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
 
 /**
  * An enumeration of types of {@link Limiter}s supported out-of-the-box.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/CountBasedLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/CountBasedLimiter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/CountBasedLimiter.java
index 8d56da4..081bb17 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/CountBasedLimiter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/CountBasedLimiter.java
@@ -15,14 +15,14 @@
  * limitations under the License.
  */
 
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
 
 import java.io.Closeable;
 
 import com.google.common.annotations.VisibleForTesting;
 import com.typesafe.config.Config;
 
-import gobblin.annotation.Alias;
+import org.apache.gobblin.annotation.Alias;
 
 import lombok.AccessLevel;
 import lombok.Getter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/DefaultLimiterFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/DefaultLimiterFactory.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/DefaultLimiterFactory.java
index c374097..c9aa104 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/DefaultLimiterFactory.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/DefaultLimiterFactory.java
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
 
 import java.util.concurrent.TimeUnit;
 
 import com.google.common.base.Preconditions;
 
-import gobblin.configuration.State;
+import org.apache.gobblin.configuration.State;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/Limiter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/Limiter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/Limiter.java
index 4e805b7..44b2ff9 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/Limiter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/Limiter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
 
 import java.io.Closeable;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/LimiterFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/LimiterFactory.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/LimiterFactory.java
index eef4800..b17381b 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/LimiterFactory.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/LimiterFactory.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
 
 import com.typesafe.config.Config;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/MultiLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/MultiLimiter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/MultiLimiter.java
index f00f723..5c88ca6 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/MultiLimiter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/MultiLimiter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
 
 import java.io.Closeable;
 import java.io.IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NonRefillableLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NonRefillableLimiter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NonRefillableLimiter.java
index 3975599..5567fee 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NonRefillableLimiter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NonRefillableLimiter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
 
 import java.io.Closeable;
 import java.io.IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NoopLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NoopLimiter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NoopLimiter.java
index 258d4c0..4eed19b 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NoopLimiter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NoopLimiter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
 
 import java.io.Closeable;
 import java.io.IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NotEnoughPermitsException.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NotEnoughPermitsException.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NotEnoughPermitsException.java
index 6e9d84e..6bedd87 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NotEnoughPermitsException.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/NotEnoughPermitsException.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
 
 import java.io.IOException;
 
-import gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.Limiter;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/PoolBasedLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/PoolBasedLimiter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/PoolBasedLimiter.java
index 5ae7243..6813114 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/PoolBasedLimiter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/PoolBasedLimiter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
 
 import java.io.Closeable;
 import java.io.IOException;
@@ -24,7 +24,7 @@ import java.util.concurrent.Semaphore;
 import com.google.common.primitives.Ints;
 import com.typesafe.config.Config;
 
-import gobblin.annotation.Alias;
+import org.apache.gobblin.annotation.Alias;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/RateBasedLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/RateBasedLimiter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/RateBasedLimiter.java
index a18384c..05f3bc5 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/RateBasedLimiter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/RateBasedLimiter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
 
 import java.io.Closeable;
 import java.util.concurrent.TimeUnit;
@@ -24,7 +24,7 @@ import com.google.common.primitives.Ints;
 import com.google.common.util.concurrent.RateLimiter;
 import com.typesafe.config.Config;
 
-import gobblin.annotation.Alias;
+import org.apache.gobblin.annotation.Alias;
 
 import lombok.Getter;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/TimeBasedLimiter.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/TimeBasedLimiter.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/TimeBasedLimiter.java
index b7904df..8523528 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/TimeBasedLimiter.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/TimeBasedLimiter.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.limiter;
+package org.apache.gobblin.util.limiter;
 
 import java.io.Closeable;
 import java.util.concurrent.ScheduledThreadPoolExecutor;
@@ -27,8 +27,8 @@ import org.slf4j.LoggerFactory;
 import com.google.common.base.Optional;
 import com.typesafe.config.Config;
 
-import gobblin.annotation.Alias;
-import gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.annotation.Alias;
+import org.apache.gobblin.util.ExecutorsUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactory.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactory.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactory.java
index 0ae45a6..7d2a364 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactory.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactory.java
@@ -15,28 +15,28 @@
  * limitations under the License.
  */
 
-package gobblin.util.limiter.broker;
+package org.apache.gobblin.util.limiter.broker;
 
 import java.util.Collection;
 
 import com.typesafe.config.Config;
 
-import gobblin.broker.ResourceInstance;
-import gobblin.broker.iface.ConfigView;
-import gobblin.broker.iface.NoSuchScopeException;
-import gobblin.broker.iface.NotConfiguredException;
-import gobblin.broker.iface.ScopeType;
-import gobblin.broker.iface.ScopedConfigView;
-import gobblin.broker.iface.SharedResourceFactory;
-import gobblin.broker.iface.SharedResourcesBroker;
-import gobblin.broker.iface.SharedResourceFactoryResponse;
-import gobblin.broker.ResourceCoordinate;
-import gobblin.util.ClassAliasResolver;
-import gobblin.util.ConfigUtils;
-import gobblin.util.limiter.Limiter;
-import gobblin.util.limiter.LimiterFactory;
-import gobblin.util.limiter.MultiLimiter;
-import gobblin.util.limiter.NoopLimiter;
+import org.apache.gobblin.broker.ResourceInstance;
+import org.apache.gobblin.broker.iface.ConfigView;
+import org.apache.gobblin.broker.iface.NoSuchScopeException;
+import org.apache.gobblin.broker.iface.NotConfiguredException;
+import org.apache.gobblin.broker.iface.ScopeType;
+import org.apache.gobblin.broker.iface.ScopedConfigView;
+import org.apache.gobblin.broker.iface.SharedResourceFactory;
+import org.apache.gobblin.broker.iface.SharedResourcesBroker;
+import org.apache.gobblin.broker.iface.SharedResourceFactoryResponse;
+import org.apache.gobblin.broker.ResourceCoordinate;
+import org.apache.gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.util.ConfigUtils;
+import org.apache.gobblin.util.limiter.Limiter;
+import org.apache.gobblin.util.limiter.LimiterFactory;
+import org.apache.gobblin.util.limiter.MultiLimiter;
+import org.apache.gobblin.util.limiter.NoopLimiter;
 
 import lombok.extern.slf4j.Slf4j;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterKey.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterKey.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterKey.java
index 0d89e01..04e9a6a 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterKey.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterKey.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package gobblin.util.limiter.broker;
+package org.apache.gobblin.util.limiter.broker;
 
-import gobblin.broker.iface.SharedResourceKey;
+import org.apache.gobblin.broker.iface.SharedResourceKey;
 
 import lombok.EqualsAndHashCode;
 import lombok.Getter;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/Log4jConfigurationHelper.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/Log4jConfigurationHelper.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/Log4jConfigurationHelper.java
index 76c660e..e1559fd 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/Log4jConfigurationHelper.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/Log4jConfigurationHelper.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.logs;
+package org.apache.gobblin.util.logs;
 
 import java.io.FileInputStream;
 import java.io.IOException;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/LogCopier.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/LogCopier.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/LogCopier.java
index 96795ad..9e4b957 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/LogCopier.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/logs/LogCopier.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.logs;
+package org.apache.gobblin.util.logs;
 
 import java.io.BufferedReader;
 import java.io.BufferedWriter;
@@ -51,13 +51,13 @@ import com.google.common.io.Closer;
 import com.google.common.io.Files;
 import com.google.common.util.concurrent.AbstractScheduledService;
 
-import gobblin.configuration.ConfigurationKeys;
-import gobblin.util.concurrent.ScheduledTask;
-import gobblin.util.concurrent.TaskScheduler;
-import gobblin.util.concurrent.TaskSchedulerFactory;
-import gobblin.util.DatasetFilterUtils;
-import gobblin.util.FileListUtils;
-import gobblin.util.HadoopUtils;
+import org.apache.gobblin.configuration.ConfigurationKeys;
+import org.apache.gobblin.util.concurrent.ScheduledTask;
+import org.apache.gobblin.util.concurrent.TaskScheduler;
+import org.apache.gobblin.util.concurrent.TaskSchedulerFactory;
+import org.apache.gobblin.util.DatasetFilterUtils;
+import org.apache.gobblin.util.FileListUtils;
+import org.apache.gobblin.util.HadoopUtils;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/CompactionRecordCountProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/CompactionRecordCountProvider.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/CompactionRecordCountProvider.java
index 6950b61..f1b86ee 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/CompactionRecordCountProvider.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/CompactionRecordCountProvider.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.recordcount;
+package org.apache.gobblin.util.recordcount;
 
 import java.util.Random;
 import java.util.regex.Pattern;
@@ -24,7 +24,7 @@ import org.apache.hadoop.fs.Path;
 
 import com.google.common.base.Preconditions;
 
-import gobblin.util.RecordCountProvider;
+import org.apache.gobblin.util.RecordCountProvider;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/IngestionRecordCountProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/IngestionRecordCountProvider.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/IngestionRecordCountProvider.java
index 6ca3300..35f0664 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/IngestionRecordCountProvider.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/IngestionRecordCountProvider.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.recordcount;
+package org.apache.gobblin.util.recordcount;
 
 import java.util.regex.Pattern;
 
@@ -25,7 +25,7 @@ import org.apache.hadoop.fs.Path;
 import com.google.common.base.Preconditions;
 import com.google.common.io.Files;
 
-import gobblin.util.RecordCountProvider;
+import org.apache.gobblin.util.RecordCountProvider;
 
 
 /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/LateFileRecordCountProvider.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/LateFileRecordCountProvider.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/LateFileRecordCountProvider.java
index a90b55e..6a12ff5 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/LateFileRecordCountProvider.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/recordcount/LateFileRecordCountProvider.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.recordcount;
+package org.apache.gobblin.util.recordcount;
 
 import java.io.IOException;
 import java.util.Random;
@@ -25,7 +25,7 @@ import org.apache.commons.io.FilenameUtils;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
 
-import gobblin.util.RecordCountProvider;
+import org.apache.gobblin.util.RecordCountProvider;
 import lombok.AllArgsConstructor;
 
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/reflection/GobblinConstructorUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/reflection/GobblinConstructorUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/reflection/GobblinConstructorUtils.java
index 1569b46..13791b2 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/reflection/GobblinConstructorUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/reflection/GobblinConstructorUtils.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package gobblin.util.reflection;
+package org.apache.gobblin.util.reflection;
 
 import java.lang.reflect.InvocationTargetException;
 import java.util.Arrays;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/AllocatedRequestsIterator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/AllocatedRequestsIterator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/AllocatedRequestsIterator.java
index 23e0bd3..f68c52e 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/AllocatedRequestsIterator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/AllocatedRequestsIterator.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 import java.util.Iterator;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/AllocatedRequestsIteratorBase.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/AllocatedRequestsIteratorBase.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/AllocatedRequestsIteratorBase.java
index 2c7c307..a0e31d1 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/AllocatedRequestsIteratorBase.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/AllocatedRequestsIteratorBase.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 import java.util.Iterator;
 import java.util.Random;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/BruteForceAllocator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/BruteForceAllocator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/BruteForceAllocator.java
index 8e87aaf..3df01b2 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/BruteForceAllocator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/BruteForceAllocator.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 import java.util.Iterator;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ConcurrentBoundedPriorityIterable.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ConcurrentBoundedPriorityIterable.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ConcurrentBoundedPriorityIterable.java
index 306042c..c1a4505 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ConcurrentBoundedPriorityIterable.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ConcurrentBoundedPriorityIterable.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 import java.util.Comparator;
 import java.util.Iterator;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/GreedyAllocator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/GreedyAllocator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/GreedyAllocator.java
index 74e66c4..76cc600 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/GreedyAllocator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/GreedyAllocator.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 import java.util.Iterator;
 import java.util.concurrent.Callable;
@@ -23,7 +23,7 @@ import java.util.concurrent.Callable;
 import com.google.common.base.Function;
 import com.google.common.collect.Iterators;
 
-import gobblin.util.iterators.InterruptibleIterator;
+import org.apache.gobblin.util.iterators.InterruptibleIterator;
 
 import javax.annotation.Nullable;
 import lombok.extern.slf4j.Slf4j;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalAllocator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalAllocator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalAllocator.java
index 3301a2b..9b24e28 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalAllocator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalAllocator.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 import java.util.Collections;
 import java.util.Comparator;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalPrioritizer.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalPrioritizer.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalPrioritizer.java
index 093b381..9703bb0 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalPrioritizer.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalPrioritizer.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 import java.util.Comparator;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PreOrderAllocator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PreOrderAllocator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PreOrderAllocator.java
index 27fcb0e..f136bc3 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PreOrderAllocator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PreOrderAllocator.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 import java.io.IOException;
 import java.util.Iterator;
@@ -24,7 +24,7 @@ import java.util.concurrent.Callable;
 
 import com.google.common.collect.Lists;
 
-import gobblin.util.iterators.InterruptibleIterator;
+import org.apache.gobblin.util.iterators.InterruptibleIterator;
 
 import lombok.extern.slf4j.Slf4j;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityIterableBasedRequestAllocator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityIterableBasedRequestAllocator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityIterableBasedRequestAllocator.java
index a3db8a3..876a4eb 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityIterableBasedRequestAllocator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityIterableBasedRequestAllocator.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 import java.util.Iterator;
 import java.util.List;
@@ -28,9 +28,9 @@ import com.google.common.base.Function;
 import com.google.common.base.Optional;
 import com.google.common.collect.Iterators;
 
-import gobblin.util.Either;
-import gobblin.util.ExecutorsUtils;
-import gobblin.util.executors.IteratorExecutor;
+import org.apache.gobblin.util.Either;
+import org.apache.gobblin.util.ExecutorsUtils;
+import org.apache.gobblin.util.executors.IteratorExecutor;
 
 import lombok.AccessLevel;
 import lombok.AllArgsConstructor;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityMultiIterator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityMultiIterator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityMultiIterator.java
index 71c09cd..e535245 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityMultiIterator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityMultiIterator.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 import java.util.Collection;
 import java.util.Comparator;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PushDownRequestor.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PushDownRequestor.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PushDownRequestor.java
index 27e2ddf..33df64e 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PushDownRequestor.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PushDownRequestor.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 import java.io.IOException;
 import java.util.Comparator;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Request.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Request.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Request.java
index cb7f85f..67dc931 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Request.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Request.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 /**
  * Represents an expensive request in the request allocation problem. See {@link RequestAllocator}.

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocator.java
index b244007..f9bfe48 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocator.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 import java.util.Comparator;
 import java.util.Iterator;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorConfig.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorConfig.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorConfig.java
index de09fad..b33070b 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorConfig.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorConfig.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 import java.io.Serializable;
 import java.util.Comparator;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorUtils.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorUtils.java
index d1dc81c..d5fdf43 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorUtils.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/RequestAllocatorUtils.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 import com.typesafe.config.Config;
 
-import gobblin.util.ClassAliasResolver;
+import org.apache.gobblin.util.ClassAliasResolver;
 
 import lombok.extern.slf4j.Slf4j;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Requestor.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Requestor.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Requestor.java
index 88e0f71..b276ce9 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Requestor.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/Requestor.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 import java.io.IOException;
 import java.util.Iterator;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceEstimator.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceEstimator.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceEstimator.java
index 0da3817..ec59ef2 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceEstimator.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceEstimator.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 import com.typesafe.config.Config;
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourcePool.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourcePool.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourcePool.java
index e849229..01ce129 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourcePool.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourcePool.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 import java.util.Arrays;
 import java.util.List;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/2c22b8a9/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceRequirement.java
----------------------------------------------------------------------
diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceRequirement.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceRequirement.java
index d0fb925..463dd8c 100644
--- a/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceRequirement.java
+++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ResourceRequirement.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package gobblin.util.request_allocation;
+package org.apache.gobblin.util.request_allocation;
 
 import lombok.AccessLevel;
 import lombok.AllArgsConstructor;


Mime
View raw message