gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [53/77] [abbrv] incubator-gobblin git commit: Change package from gobblin to org.apache.gobblin for fully qualified object initialization
Date Mon, 31 Jul 2017 07:53:11 GMT
Change package from gobblin to org.apache.gobblin for fully qualified object initialization


Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/13adbef8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/13adbef8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/13adbef8

Branch: refs/heads/master
Commit: 13adbef86b5a5c50a4d975018504c9c432ef6695
Parents: fcfad77
Author: Abhishek Tiwari <abhishektiwari.btech@gmail.com>
Authored: Sun Jul 30 19:27:15 2017 -0700
Committer: Abhishek Tiwari <abhishektiwari.btech@gmail.com>
Committed: Sun Jul 30 19:27:15 2017 -0700

----------------------------------------------------------------------
 .../retention/version/finder/DateTimeDatasetVersionFinder.java | 2 +-
 .../version/finder/FileLevelTimestampVersionFinder.java        | 2 +-
 .../version/finder/GlobModTimeDatasetVersionFinder.java        | 2 +-
 .../version/finder/ModDateTimeDatasetVersionFinder.java        | 2 +-
 .../retention/version/finder/UnixTimestampVersionFinder.java   | 2 +-
 .../version/finder/WatermarkDatasetVersionFinder.java          | 2 +-
 .../gen-java/org/apache/gobblin/metrics/FlatGobblinMetric.java | 6 +++---
 .../org/apache/gobblin/metrics/GobblinTrackingEvent.java       | 6 +++---
 .../src/main/gen-java/org/apache/gobblin/metrics/Metric.java   | 6 +++---
 .../main/gen-java/org/apache/gobblin/metrics/MetricReport.java | 6 +++---
 .../runtime/instance/DefaultGobblinInstanceDriverImpl.java     | 2 +-
 .../runtime/instance/StandardGobblinInstanceDriver.java        | 2 +-
 .../runtime/instance/StandardGobblinInstanceLauncher.java      | 2 +-
 .../org/apache/gobblin/runtime/job_catalog/JobCatalogBase.java | 2 +-
 .../gobblin/runtime/job_exec/JobLauncherExecutionDriver.java   | 2 +-
 .../org/apache/gobblin/runtime/kafka/HighLevelConsumer.java    | 2 +-
 .../org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java   | 2 +-
 .../apache/gobblin/runtime/spec_catalog/TopologyCatalog.java   | 2 +-
 18 files changed, 26 insertions(+), 26 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DateTimeDatasetVersionFinder.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DateTimeDatasetVersionFinder.java
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DateTimeDatasetVersionFinder.java
index 8a78d85..19b9b8c 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DateTimeDatasetVersionFinder.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/DateTimeDatasetVersionFinder.java
@@ -52,7 +52,7 @@ public class DateTimeDatasetVersionFinder extends DatasetVersionFinder<Timestamp
 
   public DateTimeDatasetVersionFinder(FileSystem fs, Properties props) {
     super(fs, convertDeprecatedProperties(props));
-    this.realVersionFinder = new gobblin.data.management.version.finder.DateTimeDatasetVersionFinder(fs,
convertDeprecatedProperties(props));
+    this.realVersionFinder = new org.apache.gobblin.data.management.version.finder.DateTimeDatasetVersionFinder(fs,
convertDeprecatedProperties(props));
   }
 
   @Override

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/FileLevelTimestampVersionFinder.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/FileLevelTimestampVersionFinder.java
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/FileLevelTimestampVersionFinder.java
index 2963fdb..6bebe0b 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/FileLevelTimestampVersionFinder.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/FileLevelTimestampVersionFinder.java
@@ -38,7 +38,7 @@ public class FileLevelTimestampVersionFinder implements VersionFinder<Timestampe
   private final gobblin.data.management.version.finder.FileLevelTimestampVersionFinder realVersionFinder;
   public FileLevelTimestampVersionFinder(FileSystem fs, Properties props) {
     this.realVersionFinder =
-        new gobblin.data.management.version.finder.FileLevelTimestampVersionFinder(fs,props);
+        new org.apache.gobblin.data.management.version.finder.FileLevelTimestampVersionFinder(fs,props);
   }
 
   @Override

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/GlobModTimeDatasetVersionFinder.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/GlobModTimeDatasetVersionFinder.java
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/GlobModTimeDatasetVersionFinder.java
index aded4b2..fb3cbf1 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/GlobModTimeDatasetVersionFinder.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/GlobModTimeDatasetVersionFinder.java
@@ -42,7 +42,7 @@ public class GlobModTimeDatasetVersionFinder extends DatasetVersionFinder<Timest
   public GlobModTimeDatasetVersionFinder(FileSystem fs, Path globPattern) {
     super(fs);
     this.realVersionFinder =
-        new gobblin.data.management.version.finder.GlobModTimeDatasetVersionFinder(fs, globPattern);
+        new org.apache.gobblin.data.management.version.finder.GlobModTimeDatasetVersionFinder(fs,
globPattern);
   }
 
   @Override

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/ModDateTimeDatasetVersionFinder.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/ModDateTimeDatasetVersionFinder.java
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/ModDateTimeDatasetVersionFinder.java
index f1e5de8..79622e7 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/ModDateTimeDatasetVersionFinder.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/ModDateTimeDatasetVersionFinder.java
@@ -38,7 +38,7 @@ public class ModDateTimeDatasetVersionFinder implements VersionFinder<Timestampe
   private final gobblin.data.management.version.finder.ModDateTimeDatasetVersionFinder realVersionFinder;
 
   public ModDateTimeDatasetVersionFinder(FileSystem fs, Properties props) {
-    this.realVersionFinder = new gobblin.data.management.version.finder.ModDateTimeDatasetVersionFinder(fs,
props);
+    this.realVersionFinder = new org.apache.gobblin.data.management.version.finder.ModDateTimeDatasetVersionFinder(fs,
props);
   }
 
   @Override

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/UnixTimestampVersionFinder.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/UnixTimestampVersionFinder.java
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/UnixTimestampVersionFinder.java
index bd9ba12..1f66f48 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/UnixTimestampVersionFinder.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/UnixTimestampVersionFinder.java
@@ -38,7 +38,7 @@ public class UnixTimestampVersionFinder extends DatasetVersionFinder<Timestamped
   public UnixTimestampVersionFinder(FileSystem fs, Properties props) {
     super(fs, props);
     this.realVersionFinder =
-        new gobblin.data.management.version.finder.UnixTimestampVersionFinder(fs, convertDeprecatedProperties(props));
+        new org.apache.gobblin.data.management.version.finder.UnixTimestampVersionFinder(fs,
convertDeprecatedProperties(props));
   }
 
   @Override

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/WatermarkDatasetVersionFinder.java
----------------------------------------------------------------------
diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/WatermarkDatasetVersionFinder.java
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/WatermarkDatasetVersionFinder.java
index 80e8c14..44e9d21 100644
--- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/WatermarkDatasetVersionFinder.java
+++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/WatermarkDatasetVersionFinder.java
@@ -43,7 +43,7 @@ public class WatermarkDatasetVersionFinder extends DatasetVersionFinder<StringDa
   public WatermarkDatasetVersionFinder(FileSystem fs, Properties props) {
     super(fs, props);
     this.realVersionFinder =
-        new gobblin.data.management.version.finder.WatermarkDatasetVersionFinder(fs, convertDeprecatedProperties(props));
+        new org.apache.gobblin.data.management.version.finder.WatermarkDatasetVersionFinder(fs,
convertDeprecatedProperties(props));
   }
 
   @Override

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/FlatGobblinMetric.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/FlatGobblinMetric.java
b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/FlatGobblinMetric.java
index d6e8a70..d07312a 100644
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/FlatGobblinMetric.java
+++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/FlatGobblinMetric.java
@@ -140,7 +140,7 @@ public class FlatGobblinMetric extends org.apache.avro.specific.SpecificRecordBa
    * @return A new FlatGobblinMetric RecordBuilder
    */
   public static gobblin.metrics.FlatGobblinMetric.Builder newBuilder() {
-    return new gobblin.metrics.FlatGobblinMetric.Builder();
+    return new org.apache.gobblin.metrics.FlatGobblinMetric.Builder();
   }
 
   /**
@@ -149,7 +149,7 @@ public class FlatGobblinMetric extends org.apache.avro.specific.SpecificRecordBa
    * @return A new FlatGobblinMetric RecordBuilder
    */
   public static gobblin.metrics.FlatGobblinMetric.Builder newBuilder(gobblin.metrics.FlatGobblinMetric.Builder
other) {
-    return new gobblin.metrics.FlatGobblinMetric.Builder(other);
+    return new org.apache.gobblin.metrics.FlatGobblinMetric.Builder(other);
   }
 
   /**
@@ -158,7 +158,7 @@ public class FlatGobblinMetric extends org.apache.avro.specific.SpecificRecordBa
    * @return A new FlatGobblinMetric RecordBuilder
    */
   public static gobblin.metrics.FlatGobblinMetric.Builder newBuilder(gobblin.metrics.FlatGobblinMetric
other) {
-    return new gobblin.metrics.FlatGobblinMetric.Builder(other);
+    return new org.apache.gobblin.metrics.FlatGobblinMetric.Builder(other);
   }
 
   /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/GobblinTrackingEvent.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/GobblinTrackingEvent.java
b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/GobblinTrackingEvent.java
index 59c956c..a6dbaed 100644
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/GobblinTrackingEvent.java
+++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/GobblinTrackingEvent.java
@@ -140,7 +140,7 @@ public class GobblinTrackingEvent extends org.apache.avro.specific.SpecificRecor
    * @return A new GobblinTrackingEvent RecordBuilder
    */
   public static gobblin.metrics.GobblinTrackingEvent.Builder newBuilder() {
-    return new gobblin.metrics.GobblinTrackingEvent.Builder();
+    return new org.apache.gobblin.metrics.GobblinTrackingEvent.Builder();
   }
 
   /**
@@ -149,7 +149,7 @@ public class GobblinTrackingEvent extends org.apache.avro.specific.SpecificRecor
    * @return A new GobblinTrackingEvent RecordBuilder
    */
   public static gobblin.metrics.GobblinTrackingEvent.Builder newBuilder(gobblin.metrics.GobblinTrackingEvent.Builder
other) {
-    return new gobblin.metrics.GobblinTrackingEvent.Builder(other);
+    return new org.apache.gobblin.metrics.GobblinTrackingEvent.Builder(other);
   }
 
   /**
@@ -158,7 +158,7 @@ public class GobblinTrackingEvent extends org.apache.avro.specific.SpecificRecor
    * @return A new GobblinTrackingEvent RecordBuilder
    */
   public static gobblin.metrics.GobblinTrackingEvent.Builder newBuilder(gobblin.metrics.GobblinTrackingEvent
other) {
-    return new gobblin.metrics.GobblinTrackingEvent.Builder(other);
+    return new org.apache.gobblin.metrics.GobblinTrackingEvent.Builder(other);
   }
 
   /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/Metric.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/Metric.java
b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/Metric.java
index 1160507..fd5618d 100644
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/Metric.java
+++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/Metric.java
@@ -94,7 +94,7 @@ public class Metric extends org.apache.avro.specific.SpecificRecordBase
implemen
    * @return A new Metric RecordBuilder
    */
   public static gobblin.metrics.Metric.Builder newBuilder() {
-    return new gobblin.metrics.Metric.Builder();
+    return new org.apache.gobblin.metrics.Metric.Builder();
   }
 
   /**
@@ -103,7 +103,7 @@ public class Metric extends org.apache.avro.specific.SpecificRecordBase
implemen
    * @return A new Metric RecordBuilder
    */
   public static gobblin.metrics.Metric.Builder newBuilder(gobblin.metrics.Metric.Builder
other) {
-    return new gobblin.metrics.Metric.Builder(other);
+    return new org.apache.gobblin.metrics.Metric.Builder(other);
   }
 
   /**
@@ -112,7 +112,7 @@ public class Metric extends org.apache.avro.specific.SpecificRecordBase
implemen
    * @return A new Metric RecordBuilder
    */
   public static gobblin.metrics.Metric.Builder newBuilder(gobblin.metrics.Metric other) {
-    return new gobblin.metrics.Metric.Builder(other);
+    return new org.apache.gobblin.metrics.Metric.Builder(other);
   }
 
   /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/MetricReport.java
----------------------------------------------------------------------
diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/MetricReport.java
b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/MetricReport.java
index 6cbf097..22bf9b9 100644
--- a/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/MetricReport.java
+++ b/gobblin-metrics-libs/gobblin-metrics-base/src/main/gen-java/org/apache/gobblin/metrics/MetricReport.java
@@ -117,7 +117,7 @@ public class MetricReport extends org.apache.avro.specific.SpecificRecordBase
im
    * @return A new MetricReport RecordBuilder
    */
   public static gobblin.metrics.MetricReport.Builder newBuilder() {
-    return new gobblin.metrics.MetricReport.Builder();
+    return new org.apache.gobblin.metrics.MetricReport.Builder();
   }
 
   /**
@@ -126,7 +126,7 @@ public class MetricReport extends org.apache.avro.specific.SpecificRecordBase
im
    * @return A new MetricReport RecordBuilder
    */
   public static gobblin.metrics.MetricReport.Builder newBuilder(gobblin.metrics.MetricReport.Builder
other) {
-    return new gobblin.metrics.MetricReport.Builder(other);
+    return new org.apache.gobblin.metrics.MetricReport.Builder(other);
   }
 
   /**
@@ -135,7 +135,7 @@ public class MetricReport extends org.apache.avro.specific.SpecificRecordBase
im
    * @return A new MetricReport RecordBuilder
    */
   public static gobblin.metrics.MetricReport.Builder newBuilder(gobblin.metrics.MetricReport
other) {
-    return new gobblin.metrics.MetricReport.Builder(other);
+    return new org.apache.gobblin.metrics.MetricReport.Builder(other);
   }
 
   /**

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/DefaultGobblinInstanceDriverImpl.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/DefaultGobblinInstanceDriverImpl.java
b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/DefaultGobblinInstanceDriverImpl.java
index d508e16..939f251 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/DefaultGobblinInstanceDriverImpl.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/DefaultGobblinInstanceDriverImpl.java
@@ -105,7 +105,7 @@ public class DefaultGobblinInstanceDriverImpl extends AbstractIdleService
   }
 
   private MetricContext constructMetricContext(Configurable sysConfig, Logger log) {
-    gobblin.configuration.State tmpState = new gobblin.configuration.State(sysConfig.getConfigAsProperties());
+    gobblin.configuration.State tmpState = new org.apache.gobblin.configuration.State(sysConfig.getConfigAsProperties());
     return GobblinMetrics.isEnabled(sysConfig.getConfig()) ?
           Instrumented.getMetricContext(tmpState, getClass())
           : null;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceDriver.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceDriver.java
b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceDriver.java
index dc9df98..1daffaf 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceDriver.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceDriver.java
@@ -349,7 +349,7 @@ public class StandardGobblinInstanceDriver extends DefaultGobblinInstanceDriverI
 
     public MetricContext getDefaultMetricContext() {
       gobblin.configuration.State fakeState =
-          new gobblin.configuration.State(getSysConfig().getConfigAsProperties());
+          new org.apache.gobblin.configuration.State(getSysConfig().getConfigAsProperties());
       List<Tag<?>> tags = new ArrayList<>();
       tags.add(new Tag<>(StandardMetrics.INSTANCE_NAME_TAG, getInstanceName()));
       MetricContext res = Instrumented.getMetricContext(fakeState,

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceLauncher.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceLauncher.java
b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceLauncher.java
index 69889dd..a4efcdd 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceLauncher.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceLauncher.java
@@ -224,7 +224,7 @@ public class StandardGobblinInstanceLauncher extends AbstractIdleService
 
     private MetricContext getDefaultMetricContext() {
       gobblin.configuration.State fakeState =
-          new gobblin.configuration.State(getSysConfig().getConfigAsProperties());
+          new org.apache.gobblin.configuration.State(getSysConfig().getConfigAsProperties());
       return Instrumented.getMetricContext(fakeState, StandardGobblinInstanceLauncher.class);
     }
 

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogBase.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogBase.java
b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogBase.java
index 8abf914..545edad 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogBase.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogBase.java
@@ -66,7 +66,7 @@ public abstract class JobCatalogBase extends AbstractIdleService implements
JobC
     this.listeners = new JobCatalogListenersList(log);
     if (instrumentationEnabled) {
       MetricContext realParentCtx =
-          parentMetricContext.or(Instrumented.getMetricContext(new gobblin.configuration.State(),
getClass()));
+          parentMetricContext.or(Instrumented.getMetricContext(new org.apache.gobblin.configuration.State(),
getClass()));
       this.metricContext = realParentCtx.childBuilder(JobCatalog.class.getSimpleName()).build();
       this.metrics = new StandardMetrics(this);
     }

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/JobLauncherExecutionDriver.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/JobLauncherExecutionDriver.java
b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/JobLauncherExecutionDriver.java
index 864abf4..c126ab2 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/JobLauncherExecutionDriver.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/JobLauncherExecutionDriver.java
@@ -435,7 +435,7 @@ public class JobLauncherExecutionDriver extends FutureTask<JobExecutionResult>
i
             .childBuilder(JobExecutionLauncher.class.getSimpleName()).build();
       }
       gobblin.configuration.State fakeState =
-          new gobblin.configuration.State(getSysConfig().getConfigAsProperties());
+          new org.apache.gobblin.configuration.State(getSysConfig().getConfigAsProperties());
       List<Tag<?>> tags = new ArrayList<>();
       MetricContext res = Instrumented.getMetricContext(fakeState, Launcher.class, tags);
       return res;

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java
b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java
index a619582..da2ac81 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java
@@ -98,7 +98,7 @@ public abstract class HighLevelConsumer<K, V> extends AbstractIdleService
{
    */
   @VisibleForTesting
   protected void buildMetricsContextAndMetrics() {
-    this.metricContext = Instrumented.getMetricContext(new gobblin.configuration.State(ConfigUtils.configToProperties(config)),
+    this.metricContext = Instrumented.getMetricContext(new org.apache.gobblin.configuration.State(ConfigUtils.configToProperties(config)),
         this.getClass(), getTagsForMetrics());
     createMetrics();
   }

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java
b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java
index 8abfc42..c0ad68a 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java
@@ -85,7 +85,7 @@ public class FlowCatalog extends AbstractIdleService implements SpecCatalog,
Mut
     this.listeners = new SpecCatalogListenersList(log);
     if (instrumentationEnabled) {
       MetricContext realParentCtx =
-          parentMetricContext.or(Instrumented.getMetricContext(new gobblin.configuration.State(),
getClass()));
+          parentMetricContext.or(Instrumented.getMetricContext(new org.apache.gobblin.configuration.State(),
getClass()));
       this.metricContext = realParentCtx.childBuilder(FlowCatalog.class.getSimpleName()).build();
       this.metrics = new StandardMetrics(this);
     }

http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/13adbef8/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java
----------------------------------------------------------------------
diff --git a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java
b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java
index 057ef7c..e3bb988 100644
--- a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java
+++ b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java
@@ -86,7 +86,7 @@ public class TopologyCatalog extends AbstractIdleService implements SpecCatalog,
     this.listeners = new SpecCatalogListenersList(log);
     if (instrumentationEnabled) {
       MetricContext realParentCtx =
-          parentMetricContext.or(Instrumented.getMetricContext(new gobblin.configuration.State(),
getClass()));
+          parentMetricContext.or(Instrumented.getMetricContext(new org.apache.gobblin.configuration.State(),
getClass()));
       this.metricContext = realParentCtx.childBuilder(TopologyCatalog.class.getSimpleName()).build();
       this.metrics = new SpecCatalog.StandardMetrics(this);
     }


Mime
View raw message