Change internal references to org.apache.gobblin packages
Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/bbf2aee0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/bbf2aee0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/bbf2aee0 Branch: refs/heads/master Commit: bbf2aee0c24d106eb6108efffcaf2458616db705 Parents: fbdcc8a Author: Abhishek Tiwari <[email protected]> Authored: Sun Jul 30 18:41:41 2017 -0700 Committer: Abhishek Tiwari <[email protected]> Committed: Sun Jul 30 18:41:41 2017 -0700 ---------------------------------------------------------------------- .../gobblin/configuration/ConfigurationKeys.java | 4 ++-- .../resources/GobblinAWSClusterLauncherTest.conf | 2 +- .../cluster/GobblinClusterConfigurationKeys.java | 6 +++--- .../gobblin/compaction/mapreduce/MRCompactor.java | 2 +- .../mapreduce/avro/AvroKeyDedupReducer.java | 2 +- .../mapreduce/avro/ConfBasedDeltaFieldProvider.java | 2 +- .../FieldAttributeBasedDeltaFieldsProvider.java | 4 ++-- .../qualitychecker/RowCountTaskLevelPolicyTest.java | 12 ++++++------ .../qualitychecker/RowLevelQualityCheckerTest.java | 4 ++-- .../qualitychecker/TaskLevelQualityCheckerTest.java | 4 ++-- .../copy/publisher/CopyDataPublisher.java | 2 +- .../retention/ConfigurableCleanableDatasetTest.java | 16 ++++++++-------- gobblin-docs/adaptors/Hive-Avro-To-ORC-Converter.md | 4 ++-- gobblin-example/src/main/resources/csvToAvro.conf | 6 +++--- .../java/org/apache/gobblin/hive/HiveRegister.java | 2 +- .../hive/metastore/HiveMetaStoreBasedRegister.java | 2 +- .../src/test/resources/performance-testng.xml | 2 +- .../gobblin/kafka/writer/Kafka08DataWriterTest.java | 2 +- .../source/extractor/extract/kafka/KafkaSource.java | 2 +- .../idl/gobblin.rest.jobExecutions.restspec.json | 2 +- .../gobblin.rest.jobExecutions.snapshot.json | 2 +- .../gobblin/rest/JobExecutionInfoResource.java | 2 +- .../idl/gobblin.service.flowconfigs.restspec.json | 2 +- .../idl/gobblin.service.flowstatuses.restspec.json | 4 ++-- .../org/apache/gobblin/service/FlowConfig.pdsc | 2 +- .../org/apache/gobblin/service/Schedule.pdsc | 2 +- .../gobblin.service.flowconfigs.snapshot.json | 6 +++--- .../gobblin.service.flowstatuses.snapshot.json | 4 ++-- .../apache/gobblin/service/FlowConfigsResource.java | 2 +- .../apache/gobblin/service/FlowStatusResource.java | 2 +- .../gobblin.restli.throttling.permits.restspec.json | 2 +- .../gobblin.restli.throttling.permits.snapshot.json | 2 +- .../restli/throttling/LimiterServerResource.java | 2 +- .../gobblin/restli/throttling/PoliciesResource.java | 2 +- .../throttling/ThrottlingGuiceServletConfig.java | 2 +- .../1/ConfigBasedPolicyTest/resource2/main.conf | 2 +- gobblin-runtime/build.gradle | 2 +- .../gobblin/runtime/local/LocalJobLauncherTest.java | 10 +++++----- .../runtime/mapreduce/MRJobLauncherTest.java | 12 ++++++------ .../brokerTest/SimpleHelloWorldJob.jobconf | 2 +- .../service/modules/core/GobblinServiceHATest.java | 2 +- .../modules/core/GobblinServiceManagerTest.java | 2 +- .../gobblin/SkipWorkUnitsIntegrationTest.java | 2 +- .../java/org/apache/gobblin/util/HadoopUtils.java | 2 +- .../util/limiter/broker/SharedLimiterFactory.java | 2 +- ligradle/findbugs/findbugsExclude.xml | 6 +++--- 46 files changed, 82 insertions(+), 82 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java ---------------------------------------------------------------------- diff --git a/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java b/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java index 0d8dcf5..79e9b98 100644 --- a/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java +++ b/gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java @@ -397,7 +397,7 @@ public class ConfigurationKeys { /** * Metadata configuration properties used internally */ - public static final String DATA_PUBLISH_WRITER_METADATA_MERGER_NAME_DEFAULT = "gobblin.metadata.types.GlobalMetadataJsonMerger"; + public static final String DATA_PUBLISH_WRITER_METADATA_MERGER_NAME_DEFAULT = "org.apache.gobblin.metadata.types.GlobalMetadataJsonMerger"; public static final String DATA_PUBLISHER_METADATA_OUTPUT_DIR = DATA_PUBLISHER_PREFIX + ".metadata.output.dir"; //Metadata String in the configuration file public static final String DATA_PUBLISHER_METADATA_STR = DATA_PUBLISHER_PREFIX + ".metadata.string"; @@ -410,7 +410,7 @@ public class ConfigurationKeys { public static final String DATA_PUBLISHER_TYPE = DATA_PUBLISHER_PREFIX + ".type"; public static final String JOB_DATA_PUBLISHER_TYPE = DATA_PUBLISHER_PREFIX + ".job.type"; public static final String TASK_DATA_PUBLISHER_TYPE = DATA_PUBLISHER_PREFIX + ".task.type"; - public static final String DEFAULT_DATA_PUBLISHER_TYPE = "gobblin.publisher.BaseDataPublisher"; + public static final String DEFAULT_DATA_PUBLISHER_TYPE = "org.apache.gobblin.publisher.BaseDataPublisher"; public static final String DATA_PUBLISHER_FILE_SYSTEM_URI = DATA_PUBLISHER_PREFIX + ".fs.uri"; public static final String DATA_PUBLISHER_FINAL_DIR = DATA_PUBLISHER_PREFIX + ".final.dir"; public static final String DATA_PUBLISHER_APPEND_EXTRACT_TO_FINAL_DIR = DATA_PUBLISHER_PREFIX + ".appendExtractToFinalDir"; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-aws/src/test/resources/GobblinAWSClusterLauncherTest.conf ---------------------------------------------------------------------- diff --git a/gobblin-aws/src/test/resources/GobblinAWSClusterLauncherTest.conf b/gobblin-aws/src/test/resources/GobblinAWSClusterLauncherTest.conf index 12eabc6..4e2024d 100644 --- a/gobblin-aws/src/test/resources/GobblinAWSClusterLauncherTest.conf +++ b/gobblin-aws/src/test/resources/GobblinAWSClusterLauncherTest.conf @@ -67,7 +67,7 @@ gobblin.aws.nfs.parent.dir="/home/ec2-user" gobblin.aws.nfs.root.dir=${gobblin.aws.nfs.parent.dir}"/"${gobblin.aws.cluster.name} gobblin.cluster.helix.cluster.name=${gobblin.aws.cluster.name} gobblin.cluster.job.conf.path=${gobblin.aws.nfs.root.dir}"/job-conf" -gobblin.cluster.job.configuration.manager="gobblin.aws.AWSJobConfigurationManager" +gobblin.cluster.job.configuration.manager="org.apache.gobblin.aws.AWSJobConfigurationManager" gobblin.aws.email.notification.on.shutdown=false ## AWS Configuration http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterConfigurationKeys.java ---------------------------------------------------------------------- diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterConfigurationKeys.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterConfigurationKeys.java index 9c3f6c8..e8dfb1d 100644 --- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterConfigurationKeys.java +++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterConfigurationKeys.java @@ -70,12 +70,12 @@ public class GobblinClusterConfigurationKeys { public static final String JOB_SPEC_REFRESH_INTERVAL = GOBBLIN_CLUSTER_PREFIX + "job.spec.refresh.interval"; public static final String SPEC_EXECUTOR_INSTANCE_CONSUMER_CLASS_KEY = GOBBLIN_CLUSTER_PREFIX + "specConsumer.class"; public static final String DEFAULT_SPEC_EXECUTOR_INSTANCE_CONSUMER_CLASS = - "gobblin.service.SimpleKafkaSpecExecutorInstanceConsumer"; + "org.apache.gobblin.service.SimpleKafkaSpecExecutorInstanceConsumer"; public static final String DEFAULT_STREAMING_SPEC_EXECUTOR_INSTANCE_CONSUMER_CLASS = - "gobblin.service.StreamingKafkaSpecExecutorInstanceConsumer"; + "org.apache.gobblin.service.StreamingKafkaSpecExecutorInstanceConsumer"; public static final String JOB_CATALOG_KEY = GOBBLIN_CLUSTER_PREFIX + "job.catalog"; public static final String DEFAULT_JOB_CATALOG = - "gobblin.runtime.job_catalog.NonObservingFSJobCatalog"; + "org.apache.gobblin.runtime.job_catalog.NonObservingFSJobCatalog"; public static final String STOP_TIMEOUT_SECONDS = GOBBLIN_CLUSTER_PREFIX + "stopTimeoutSeconds"; public static final long DEFAULT_STOP_TIMEOUT_SECONDS = 60; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java index e52b5e5..2b57782 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java @@ -131,7 +131,7 @@ public class MRCompactor implements Compactor { public static final String COMPACTION_JOB_RUNNER_CLASS = COMPACTION_PREFIX + "job.runner.class"; public static final String DEFAULT_COMPACTION_JOB_RUNNER_CLASS = - "gobblin.compaction.mapreduce.avro.MRCompactorAvroKeyDedupJobRunner"; + "org.apache.gobblin.compaction.mapreduce.avro.MRCompactorAvroKeyDedupJobRunner"; public static final String COMPACTION_TIMEZONE = COMPACTION_PREFIX + "timezone"; public static final String DEFAULT_COMPACTION_TIMEZONE = ConfigurationKeys.PST_TIMEZONE_NAME; public static final String COMPACTION_FILE_SYSTEM_URI = COMPACTION_PREFIX + "file.system.uri"; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/AvroKeyDedupReducer.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/AvroKeyDedupReducer.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/AvroKeyDedupReducer.java index ecb0dc5..130e544 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/AvroKeyDedupReducer.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/AvroKeyDedupReducer.java @@ -49,7 +49,7 @@ public class AvroKeyDedupReducer extends Reducer<AvroKey<GenericRecord>, AvroVal } public static final String DELTA_SCHEMA_PROVIDER = - "gobblin.compaction." + AvroKeyDedupReducer.class.getSimpleName() + ".deltaFieldsProvider"; + "org.apache.gobblin.compaction." + AvroKeyDedupReducer.class.getSimpleName() + ".deltaFieldsProvider"; private AvroKey<GenericRecord> outKey; private Optional<AvroValueDeltaSchemaComparator> deltaComparatorOptional; private AvroDeltaFieldNameProvider deltaFieldNamesProvider; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/ConfBasedDeltaFieldProvider.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/ConfBasedDeltaFieldProvider.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/ConfBasedDeltaFieldProvider.java index cef3d0e..d8a1f8b 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/ConfBasedDeltaFieldProvider.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/ConfBasedDeltaFieldProvider.java @@ -33,7 +33,7 @@ import com.google.common.base.Splitter; @Test(groups = {"gobblin.compaction"}) public class ConfBasedDeltaFieldProvider implements AvroDeltaFieldNameProvider { public static final String DELTA_FIELDS_KEY = - "gobblin.compaction." + ConfBasedDeltaFieldProvider.class.getSimpleName() + ".deltaFields"; + "org.apache.gobblin.compaction." + ConfBasedDeltaFieldProvider.class.getSimpleName() + ".deltaFields"; private final List<String> deltaFields; public ConfBasedDeltaFieldProvider(Configuration conf) { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/FieldAttributeBasedDeltaFieldsProvider.java ---------------------------------------------------------------------- diff --git a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/FieldAttributeBasedDeltaFieldsProvider.java b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/FieldAttributeBasedDeltaFieldsProvider.java index 2596ebf..8e508e5 100644 --- a/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/FieldAttributeBasedDeltaFieldsProvider.java +++ b/gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/FieldAttributeBasedDeltaFieldsProvider.java @@ -46,9 +46,9 @@ import lombok.extern.slf4j.Slf4j; @Slf4j public class FieldAttributeBasedDeltaFieldsProvider implements AvroDeltaFieldNameProvider { public static final String ATTRIBUTE_FIELD = - "gobblin.compaction." + FieldAttributeBasedDeltaFieldsProvider.class.getSimpleName() + ".deltaAttributeField"; + "org.apache.gobblin.compaction." + FieldAttributeBasedDeltaFieldsProvider.class.getSimpleName() + ".deltaAttributeField"; public static final String DELTA_PROP_NAME = - "gobblin.compaction." + FieldAttributeBasedDeltaFieldsProvider.class.getSimpleName() + ".deltaPropName"; + "org.apache.gobblin.compaction." + FieldAttributeBasedDeltaFieldsProvider.class.getSimpleName() + ".deltaPropName"; public static final String DEFAULT_DELTA_PROP_NAME = "delta"; private final String attributeField; private final String deltaPropName; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java index e8edba6..43736fa 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowCountTaskLevelPolicyTest.java @@ -40,7 +40,7 @@ public class RowCountTaskLevelPolicyTest { public void testRowCountPolicyPassed() throws Exception { State state = new State(); - state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "gobblin.policies.count.RowCountPolicy"); + state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "org.apache.gobblin.policies.count.RowCountPolicy"); state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE, "FAIL"); state.setProp(ConfigurationKeys.EXTRACTOR_ROWS_EXPECTED, EXTRACTOR_ROWS_READ); state.setProp(ConfigurationKeys.WRITER_ROWS_WRITTEN, WRITER_ROWS_WRITTEN); @@ -55,7 +55,7 @@ public class RowCountTaskLevelPolicyTest { public void testRowCountPolicyFailed() throws Exception { State state = new State(); - state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "gobblin.policies.count.RowCountPolicy"); + state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "org.apache.gobblin.policies.count.RowCountPolicy"); state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE, "FAIL"); state.setProp(ConfigurationKeys.EXTRACTOR_ROWS_EXPECTED, EXTRACTOR_ROWS_READ); state.setProp(ConfigurationKeys.WRITER_ROWS_WRITTEN, -1); @@ -70,7 +70,7 @@ public class RowCountTaskLevelPolicyTest { public void testRowCountRangePolicyPassedExact() throws Exception { State state = new State(); - state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "gobblin.policies.count.RowCountRangePolicy"); + state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "org.apache.gobblin.policies.count.RowCountRangePolicy"); state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE, "FAIL"); state.setProp(ConfigurationKeys.EXTRACTOR_ROWS_EXPECTED, EXTRACTOR_ROWS_READ); state.setProp(ConfigurationKeys.WRITER_ROWS_WRITTEN, WRITER_ROWS_WRITTEN); @@ -86,7 +86,7 @@ public class RowCountTaskLevelPolicyTest { public void testRowCountRangePolicyPassedRange() throws Exception { State state = new State(); - state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "gobblin.policies.count.RowCountRangePolicy"); + state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "org.apache.gobblin.policies.count.RowCountRangePolicy"); state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE, "FAIL"); state.setProp(ConfigurationKeys.EXTRACTOR_ROWS_EXPECTED, EXTRACTOR_ROWS_READ); state.setProp(ConfigurationKeys.WRITER_ROWS_WRITTEN, (long) 0.03 * EXTRACTOR_ROWS_READ + EXTRACTOR_ROWS_READ); @@ -102,7 +102,7 @@ public class RowCountTaskLevelPolicyTest { public void testRowCountRangePolicyFailed() throws Exception { State state = new State(); - state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "gobblin.policies.count.RowCountRangePolicy"); + state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "org.apache.gobblin.policies.count.RowCountRangePolicy"); state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE, "FAIL"); state.setProp(ConfigurationKeys.EXTRACTOR_ROWS_EXPECTED, EXTRACTOR_ROWS_READ); state.setProp(ConfigurationKeys.WRITER_ROWS_WRITTEN, -1); @@ -119,7 +119,7 @@ public class RowCountTaskLevelPolicyTest { throws Exception { State state = new State(); state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, - "gobblin.policies.count.RowCountPolicy,gobblin.policies.count.RowCountRangePolicy"); + "org.apache.gobblin.policies.count.RowCountPolicy,org.apache.gobblin.policies.count.RowCountRangePolicy"); state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE, "FAIL,FAIL"); state.setProp(ConfigurationKeys.EXTRACTOR_ROWS_EXPECTED, EXTRACTOR_ROWS_READ); state.setProp(ConfigurationKeys.WRITER_ROWS_WRITTEN, WRITER_ROWS_WRITTEN); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java index 1ce5868..808cfef 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/RowLevelQualityCheckerTest.java @@ -43,7 +43,7 @@ public class RowLevelQualityCheckerTest { public void testRowLevelPolicy() throws Exception { State state = new State(); - state.setProp(ConfigurationKeys.ROW_LEVEL_POLICY_LIST, "gobblin.qualitychecker.TestRowLevelPolicy"); + state.setProp(ConfigurationKeys.ROW_LEVEL_POLICY_LIST, "org.apache.gobblin.qualitychecker.TestRowLevelPolicy"); state.setProp(ConfigurationKeys.ROW_LEVEL_POLICY_LIST_TYPE, "FAIL"); RowLevelPolicyChecker checker = @@ -61,7 +61,7 @@ public class RowLevelQualityCheckerTest { public void testWriteToErrFile() throws Exception { State state = new State(); - state.setProp(ConfigurationKeys.ROW_LEVEL_POLICY_LIST, "gobblin.qualitychecker.TestRowLevelPolicyFail"); + state.setProp(ConfigurationKeys.ROW_LEVEL_POLICY_LIST, "org.apache.gobblin.qualitychecker.TestRowLevelPolicyFail"); state.setProp(ConfigurationKeys.ROW_LEVEL_POLICY_LIST_TYPE, "ERR_FILE"); state.setProp(ConfigurationKeys.ROW_LEVEL_ERR_FILE, TestConstants.TEST_ERR_FILE); state.setProp(ConfigurationKeys.WRITER_FILE_SYSTEM_URI, TestConstants.TEST_FS_URI); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java index 8bd8edf..c366faa 100644 --- a/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java +++ b/gobblin-core/src/test/java/org/apache/gobblin/qualitychecker/TaskLevelQualityCheckerTest.java @@ -37,7 +37,7 @@ public class TaskLevelQualityCheckerTest { public void testPolicyChecker() throws Exception { State state = new State(); - state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "gobblin.qualitychecker.TestTaskLevelPolicy"); + state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, "org.apache.gobblin.qualitychecker.TestTaskLevelPolicy"); state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE, "FAIL"); TaskLevelPolicyCheckResults results = getPolicyResults(state); @@ -51,7 +51,7 @@ public class TaskLevelQualityCheckerTest { throws Exception { State state = new State(); state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST, - "gobblin.qualitychecker.TestTaskLevelPolicy,gobblin.qualitychecker.TestTaskLevelPolicy"); + "org.apache.gobblin.qualitychecker.TestTaskLevelPolicy,org.apache.gobblin.qualitychecker.TestTaskLevelPolicy"); state.setProp(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE, "FAIL,FAIL"); TaskLevelPolicyCheckResults results = getPolicyResults(state); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java index 3b22a89..b961faa 100644 --- a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java +++ b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java @@ -103,7 +103,7 @@ public class CopyDataPublisher extends DataPublisher implements UnpublishedHandl MetricContext metricContext = Instrumented.getMetricContext(state, CopyDataPublisher.class, GobblinMetrics.getCustomTagsFromState(state)); - this.eventSubmitter = new EventSubmitter.Builder(metricContext, "gobblin.copy.CopyDataPublisher").build(); + this.eventSubmitter = new EventSubmitter.Builder(metricContext, "org.apache.gobblin.copy.CopyDataPublisher").build(); this.recoveryHelper = new RecoveryHelper(this.fs, state); this.recoveryHelper.purgeOldPersistedFile(); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/ConfigurableCleanableDatasetTest.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/ConfigurableCleanableDatasetTest.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/ConfigurableCleanableDatasetTest.java index 1a4311d..35ddd77 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/ConfigurableCleanableDatasetTest.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/ConfigurableCleanableDatasetTest.java @@ -48,9 +48,9 @@ public class ConfigurableCleanableDatasetTest { Config conf = ConfigFactory.parseMap(ImmutableMap.<String, String> of("gobblin.retention.version.finder.class", - "gobblin.data.management.version.finder.WatermarkDatasetVersionFinder", + "org.apache.gobblin.data.management.version.finder.WatermarkDatasetVersionFinder", "gobblin.retention.retention.policy.class", - "gobblin.data.management.retention.policy.NewestKRetentionPolicy", + "org.apache.gobblin.data.management.retention.policy.NewestKRetentionPolicy", "gobblin.retention.newestK.versions.retained", "2")); ConfigurableCleanableDataset<FileSystemDatasetVersion> dataset = @@ -67,9 +67,9 @@ public class ConfigurableCleanableDatasetTest { Config conf = ConfigFactory.parseMap(ImmutableMap.<String, String> of("gobblin.retention.version.finder.class", - "gobblin.data.management.version.finder.WatermarkDatasetVersionFinder", + "org.apache.gobblin.data.management.version.finder.WatermarkDatasetVersionFinder", "gobblin.retention.selection.policy.class", - "gobblin.data.management.policy.NewestKSelectionPolicy", + "org.apache.gobblin.data.management.policy.NewestKSelectionPolicy", "gobblin.retention.selection.newestK.versionsSelected", "2")); ConfigurableCleanableDataset<FileSystemDatasetVersion> dataset = @@ -86,8 +86,8 @@ public class ConfigurableCleanableDatasetTest { Map<String, String> partitionConf = ImmutableMap.<String, String> of("version.finder.class", - "gobblin.data.management.version.finder.WatermarkDatasetVersionFinder", "selection.policy.class", - "gobblin.data.management.policy.NewestKSelectionPolicy", "selection.newestK.versionsSelected", "2"); + "org.apache.gobblin.data.management.version.finder.WatermarkDatasetVersionFinder", "selection.policy.class", + "org.apache.gobblin.data.management.policy.NewestKSelectionPolicy", "selection.newestK.versionsSelected", "2"); Config conf = ConfigFactory.parseMap(ImmutableMap.<String, List<Map<String, String>>> of("gobblin.retention.dataset.partitions", ImmutableList.of(partitionConf, partitionConf))); @@ -108,9 +108,9 @@ public class ConfigurableCleanableDatasetTest { Config conf = ConfigFactory.parseMap(ImmutableMap.<String, String> of("gobblin.retention.version.finder.class", - "gobblin.data.management.version.finder.WatermarkDatasetVersionFinder", + "org.apache.gobblin.data.management.version.finder.WatermarkDatasetVersionFinder", "gobblin.retention.selection.policy.class", - "gobblin.data.management.policy.NewestKSelectionPolicy", + "org.apache.gobblin.data.management.policy.NewestKSelectionPolicy", "gobblin.retention.selection.newestK.versionsSelected", "2", "gobblin.retention.dataset.is.blacklisted", "true")); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-docs/adaptors/Hive-Avro-To-ORC-Converter.md ---------------------------------------------------------------------- diff --git a/gobblin-docs/adaptors/Hive-Avro-To-ORC-Converter.md b/gobblin-docs/adaptors/Hive-Avro-To-ORC-Converter.md index c88f1f6..117d506 100644 --- a/gobblin-docs/adaptors/Hive-Avro-To-ORC-Converter.md +++ b/gobblin-docs/adaptors/Hive-Avro-To-ORC-Converter.md @@ -257,9 +257,9 @@ SLA event is published every time an Avro partition/table is converted to ORC. E "workunitCreateTime": "1470227446703" ## Gobblin metrics metadata - "class": "gobblin.data.management.conversion.hive.publisher.HiveConvertPublisher", + "class": "org.apache.gobblin.data.management.conversion.hive.publisher.HiveConvertPublisher", "metricContextID": "20bfb2a2-0592-4f53-9259-c8ee125f90a8", - "metricContextName": "gobblin.data.management.conversion.hive.publisher.HiveConvertPublisher.781426901", + "metricContextName": "org.apache.gobblin.data.management.conversion.hive.publisher.HiveConvertPublisher.781426901", } } ``` http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-example/src/main/resources/csvToAvro.conf ---------------------------------------------------------------------- diff --git a/gobblin-example/src/main/resources/csvToAvro.conf b/gobblin-example/src/main/resources/csvToAvro.conf index 8a60486..e318588 100644 --- a/gobblin-example/src/main/resources/csvToAvro.conf +++ b/gobblin-example/src/main/resources/csvToAvro.conf @@ -1,8 +1,8 @@ source.filebased.data.directory=/tmp/csvSource -source.class=gobblin.source.extractor.filebased.TextFileBasedSource -converter.classes="gobblin.converter.StringSchemaInjector,gobblin.converter.csv.CsvToJsonConverter,gobblin.converter.avro.JsonIntermediateToAvroConverter" -writer.builder.class=gobblin.writer.AvroDataWriterBuilder +source.class=org.apache.gobblin.source.extractor.filebased.TextFileBasedSource +converter.classes="org.apache.gobblin.converter.StringSchemaInjector,org.apache.gobblin.converter.csv.CsvToJsonConverter,org.apache.gobblin.converter.avro.JsonIntermediateToAvroConverter" +writer.builder.class=org.apache.gobblin.writer.AvroDataWriterBuilder extract.table.name=CsvToAvro extract.namespace=gobblin.example http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegister.java ---------------------------------------------------------------------- diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegister.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegister.java index 66cce96..82d205b 100644 --- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegister.java +++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegister.java @@ -61,7 +61,7 @@ import lombok.extern.slf4j.Slf4j; public abstract class HiveRegister implements Closeable { public static final String HIVE_REGISTER_TYPE = "hive.register.type"; - public static final String DEFAULT_HIVE_REGISTER_TYPE = "gobblin.hive.metastore.HiveMetaStoreBasedRegister"; + public static final String DEFAULT_HIVE_REGISTER_TYPE = "org.apache.gobblin.hive.metastore.HiveMetaStoreBasedRegister"; public static final String HIVE_TABLE_COMPARATOR_TYPE = "hive.table.comparator.type"; public static final String DEFAULT_HIVE_TABLE_COMPARATOR_TYPE = HiveTableComparator.class.getName(); public static final String HIVE_PARTITION_COMPARATOR_TYPE = "hive.partition.comparator.type"; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java ---------------------------------------------------------------------- diff --git a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java index 49c08a7..2d074d9 100644 --- a/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java +++ b/gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java @@ -142,7 +142,7 @@ public class HiveMetaStoreBasedRegister extends HiveRegister { this.metricContext = GobblinMetricsRegistry.getInstance().getMetricContext(state, HiveMetaStoreBasedRegister.class, GobblinMetrics.getCustomTagsFromState(state)); - this.eventSubmitter = new EventSubmitter.Builder(this.metricContext, "gobblin.hive.HiveMetaStoreBasedRegister").build(); + this.eventSubmitter = new EventSubmitter.Builder(this.metricContext, "org.apache.gobblin.hive.HiveMetaStoreBasedRegister").build(); } @Override http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-metrics-libs/gobblin-metrics-base/src/test/resources/performance-testng.xml ---------------------------------------------------------------------- diff --git a/gobblin-metrics-libs/gobblin-metrics-base/src/test/resources/performance-testng.xml b/gobblin-metrics-libs/gobblin-metrics-base/src/test/resources/performance-testng.xml index 0a95a7c..442f5c0 100644 --- a/gobblin-metrics-libs/gobblin-metrics-base/src/test/resources/performance-testng.xml +++ b/gobblin-metrics-libs/gobblin-metrics-base/src/test/resources/performance-testng.xml @@ -23,7 +23,7 @@ </run> </groups> <packages> - <package name="gobblin.metrics.*" /> + <package name="org.apache.gobblin.metrics.*" /> </packages> </test> </suite> http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterTest.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterTest.java b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterTest.java index 900e0be..c7ac96f 100644 --- a/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterTest.java +++ b/gobblin-modules/gobblin-kafka-08/src/test/java/org/apache/gobblin/kafka/writer/Kafka08DataWriterTest.java @@ -137,7 +137,7 @@ public class Kafka08DataWriterTest { props.setProperty(KafkaWriterConfigurationKeys.KAFKA_TOPIC, topic); props.setProperty(KafkaWriterConfigurationKeys.KAFKA_PRODUCER_CONFIG_PREFIX + "bootstrap.servers", "localhost:" + _kafkaTestHelper.getKafkaServerPort()); props.setProperty(KafkaWriterConfigurationKeys.KAFKA_PRODUCER_CONFIG_PREFIX + "value.serializer", - "gobblin.kafka.serialize.LiAvroSerializer"); + "org.apache.gobblin.kafka.serialize.LiAvroSerializer"); // set up mock schema registry http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java ---------------------------------------------------------------------- diff --git a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java index 42c594d..ec4bed5 100644 --- a/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java +++ b/gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java @@ -108,7 +108,7 @@ public abstract class KafkaSource<S, D> extends EventBasedSource<S, D> { public static final String GOBBLIN_KAFKA_EXTRACT_ALLOW_TABLE_TYPE_NAMESPACE_CUSTOMIZATION = "gobblin.kafka.extract.allowTableTypeAndNamspaceCustomization"; public static final String DEFAULT_GOBBLIN_KAFKA_CONSUMER_CLIENT_FACTORY_CLASS = - "gobblin.kafka.client.Kafka08ConsumerClient$Factory"; + "org.apache.gobblin.kafka.client.Kafka08ConsumerClient$Factory"; public static final String GOBBLIN_KAFKA_SHOULD_ENABLE_DATASET_STATESTORE = "gobblin.kafka.shouldEnableDatasetStateStore"; public static final boolean DEFAULT_GOBBLIN_KAFKA_SHOULD_ENABLE_DATASET_STATESTORE = false; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json ---------------------------------------------------------------------- diff --git a/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json b/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json index 4be751e..40e5004 100644 --- a/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json +++ b/gobblin-rest-service/gobblin-rest-api/src/main/idl/gobblin.rest.jobExecutions.restspec.json @@ -7,7 +7,7 @@ "collection" : { "identifier" : { "name" : "jobExecutionsId", - "type" : "gobblin.rest.JobExecutionQuery", + "type" : "org.apache.gobblin.rest.JobExecutionQuery", "params" : "com.linkedin.restli.common.EmptyRecord" }, "supports" : [ "batch_get", "get" ], http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json ---------------------------------------------------------------------- diff --git a/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json b/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json index fe626e4..50b37b5 100644 --- a/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json +++ b/gobblin-rest-service/gobblin-rest-api/src/main/snapshot/gobblin.rest.jobExecutions.snapshot.json @@ -333,7 +333,7 @@ "collection" : { "identifier" : { "name" : "jobExecutionsId", - "type" : "gobblin.rest.JobExecutionQuery", + "type" : "org.apache.gobblin.rest.JobExecutionQuery", "params" : "com.linkedin.restli.common.EmptyRecord" }, "supports" : [ "batch_get", "get" ], http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoResource.java ---------------------------------------------------------------------- diff --git a/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoResource.java b/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoResource.java index bcaa164..99f4374 100644 --- a/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoResource.java +++ b/gobblin-rest-service/gobblin-rest-server/src/main/java/org/apache/gobblin/rest/JobExecutionInfoResource.java @@ -41,7 +41,7 @@ import org.apache.gobblin.metastore.JobHistoryStore; * * @author Yinan Li */ -@RestLiCollection(name = "jobExecutions", namespace = "gobblin.rest") +@RestLiCollection(name = "jobExecutions", namespace = "org.apache.gobblin.rest") public class JobExecutionInfoResource extends ComplexKeyResourceTemplate<JobExecutionQuery, EmptyRecord, JobExecutionQueryResult> { private static final Logger LOGGER = LoggerFactory.getLogger(JobExecutionInfoResource.class); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json index 8191d60..3f06bbe 100644 --- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json +++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowconfigs.restspec.json @@ -7,7 +7,7 @@ "collection" : { "identifier" : { "name" : "id", - "type" : "gobblin.service.FlowId", + "type" : "org.apache.gobblin.service.FlowId", "params" : "com.linkedin.restli.common.EmptyRecord" }, "supports" : [ "create", "delete", "get", "update" ], http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json index 97f7da1..a8e4d1c 100644 --- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json +++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/idl/gobblin.service.flowstatuses.restspec.json @@ -7,7 +7,7 @@ "collection" : { "identifier" : { "name" : "id", - "type" : "gobblin.service.FlowStatusId", + "type" : "org.apache.gobblin.service.FlowStatusId", "params" : "com.linkedin.restli.common.EmptyRecord" }, "supports" : [ "get" ], @@ -19,7 +19,7 @@ "name" : "latestFlowStatus", "parameters" : [ { "name" : "flowId", - "type" : "gobblin.service.FlowId" + "type" : "org.apache.gobblin.service.FlowId" } ] } ], "entity" : { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowConfig.pdsc ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowConfig.pdsc b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowConfig.pdsc index b77c204..0bba724 100644 --- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowConfig.pdsc +++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/FlowConfig.pdsc @@ -20,7 +20,7 @@ "type" : "string", "doc" : "Comma separated list of URIs for templates used in the flow. The template location is defined by the multiproduct that packages the template.", "validate": { - "gobblin.service.validator.TemplateUriValidator": {} + "org.apache.gobblin.service.validator.TemplateUriValidator": {} } }, { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/Schedule.pdsc ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/Schedule.pdsc b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/Schedule.pdsc index 030a10f..8ca592f 100644 --- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/Schedule.pdsc +++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/pegasus/org/apache/gobblin/service/Schedule.pdsc @@ -9,7 +9,7 @@ "type" : "string", "doc" : "Schedule for flow in cron format", "validate": { - "gobblin.service.validator.CronValidator": {} + "org.apache.gobblin.service.validator.CronValidator": {} } }, { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json index 9bbdfe8..5871f21 100644 --- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json +++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowconfigs.snapshot.json @@ -35,7 +35,7 @@ "type" : "string", "doc" : "Schedule for flow in cron format", "validate" : { - "gobblin.service.validator.CronValidator" : { } + "org.apache.gobblin.service.validator.CronValidator" : { } } }, { "name" : "runImmediately", @@ -62,7 +62,7 @@ "type" : "string", "doc" : "Comma separated list of URIs for templates used in the flow. The template location is defined by the multiproduct that packages the template.", "validate" : { - "gobblin.service.validator.TemplateUriValidator" : { } + "org.apache.gobblin.service.validator.TemplateUriValidator" : { } } }, { "name" : "properties", @@ -91,7 +91,7 @@ "collection" : { "identifier" : { "name" : "id", - "type" : "gobblin.service.FlowId", + "type" : "org.apache.gobblin.service.FlowId", "params" : "com.linkedin.restli.common.EmptyRecord" }, "supports" : [ "create", "delete", "get", "update" ], http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json index 4ed7fd6..cd2943d 100644 --- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json +++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-api/src/main/snapshot/gobblin.service.flowstatuses.snapshot.json @@ -204,7 +204,7 @@ "collection" : { "identifier" : { "name" : "id", - "type" : "gobblin.service.FlowStatusId", + "type" : "org.apache.gobblin.service.FlowStatusId", "params" : "com.linkedin.restli.common.EmptyRecord" }, "supports" : [ "get" ], @@ -216,7 +216,7 @@ "name" : "latestFlowStatus", "parameters" : [ { "name" : "flowId", - "type" : "gobblin.service.FlowId" + "type" : "org.apache.gobblin.service.FlowId" } ] } ], "entity" : { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigsResource.java ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigsResource.java b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigsResource.java index bb47050..3159d49 100644 --- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigsResource.java +++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigsResource.java @@ -49,7 +49,7 @@ import org.apache.gobblin.runtime.spec_catalog.FlowCatalog; /** * Resource for handling flow configuration requests */ -@RestLiCollection(name = "flowconfigs", namespace = "gobblin.service", keyName = "id") +@RestLiCollection(name = "flowconfigs", namespace = "org.apache.gobblin.service", keyName = "id") public class FlowConfigsResource extends ComplexKeyResourceTemplate<FlowId, EmptyRecord, FlowConfig> { private static final Logger LOG = LoggerFactory.getLogger(FlowConfigsResource.class); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java index d8192d4..a8ba987 100644 --- a/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java +++ b/gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java @@ -42,7 +42,7 @@ import org.apache.gobblin.service.monitoring.FlowStatusGenerator; /** * Resource for handling flow status requests */ -@RestLiCollection(name = "flowstatuses", namespace = "gobblin.service", keyName = "id") +@RestLiCollection(name = "flowstatuses", namespace = "org.apache.gobblin.service", keyName = "id") public class FlowStatusResource extends ComplexKeyResourceTemplate<FlowStatusId, EmptyRecord, FlowStatus> { private static final Logger LOG = LoggerFactory.getLogger(FlowStatusResource.class); public static final String FLOW_STATUS_GENERATOR_INJECT_NAME = "FlowStatusGenerator"; http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json index 799ecb7..4cb7820 100644 --- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json +++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/idl/gobblin.restli.throttling.permits.restspec.json @@ -7,7 +7,7 @@ "collection" : { "identifier" : { "name" : "permitsId", - "type" : "gobblin.restli.throttling.PermitRequest", + "type" : "org.apache.gobblin.restli.throttling.PermitRequest", "params" : "com.linkedin.restli.common.EmptyRecord" }, "supports" : [ "get" ], http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json index 65947c0..c534de20e8 100644 --- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json +++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-api/src/main/snapshot/gobblin.restli.throttling.permits.snapshot.json @@ -60,7 +60,7 @@ "collection" : { "identifier" : { "name" : "permitsId", - "type" : "gobblin.restli.throttling.PermitRequest", + "type" : "org.apache.gobblin.restli.throttling.PermitRequest", "params" : "com.linkedin.restli.common.EmptyRecord" }, "supports" : [ "get" ], http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LimiterServerResource.java ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LimiterServerResource.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LimiterServerResource.java index 94b303f..0f06967 100644 --- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LimiterServerResource.java +++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LimiterServerResource.java @@ -58,7 +58,7 @@ import lombok.extern.slf4j.Slf4j; */ @Alpha @Slf4j -@RestLiCollection(name = "permits", namespace = "gobblin.restli.throttling") +@RestLiCollection(name = "permits", namespace = "org.apache.gobblin.restli.throttling") public class LimiterServerResource extends ComplexKeyResourceAsyncTemplate<PermitRequest, EmptyRecord, PermitAllocation> { public static final long TIMEOUT_MILLIS = 7000; // resli client times out after 10 seconds http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/PoliciesResource.java ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/PoliciesResource.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/PoliciesResource.java index 9242717..8311d4d 100644 --- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/PoliciesResource.java +++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/PoliciesResource.java @@ -43,7 +43,7 @@ import static org.apache.gobblin.restli.throttling.LimiterServerResource.*; /** * A Rest.li endpoint for getting the {@link ThrottlingPolicy} associated with a resource id. */ -@RestLiCollection(name = "policies", namespace = "gobblin.restli.throttling") +@RestLiCollection(name = "policies", namespace = "org.apache.gobblin.restli.throttling") public class PoliciesResource extends CollectionResourceTemplate<String, Policy> { @Inject http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingGuiceServletConfig.java ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingGuiceServletConfig.java b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingGuiceServletConfig.java index b2f18ff..91d3b17 100644 --- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingGuiceServletConfig.java +++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingGuiceServletConfig.java @@ -124,7 +124,7 @@ public class ThrottlingGuiceServletConfig extends GuiceServletContextListener im try { RestLiConfig restLiConfig = new RestLiConfig(); - restLiConfig.setResourcePackageNames("gobblin.restli.throttling"); + restLiConfig.setResourcePackageNames("org.apache.gobblin.restli.throttling"); bind(RestLiConfig.class).toInstance(restLiConfig); bind(SharedResourcesBroker.class).annotatedWith(Names.named(LimiterServerResource.BROKER_INJECT_NAME)).toInstance(topLevelBroker); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/test/resources/configStore/_CONFIG_STORE/1/ConfigBasedPolicyTest/resource2/main.conf ---------------------------------------------------------------------- diff --git a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/test/resources/configStore/_CONFIG_STORE/1/ConfigBasedPolicyTest/resource2/main.conf b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/test/resources/configStore/_CONFIG_STORE/1/ConfigBasedPolicyTest/resource2/main.conf index 41e5a83..212b56b 100644 --- a/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/test/resources/configStore/_CONFIG_STORE/1/ConfigBasedPolicyTest/resource2/main.conf +++ b/gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/test/resources/configStore/_CONFIG_STORE/1/ConfigBasedPolicyTest/resource2/main.conf @@ -1,2 +1,2 @@ -globalThrottling.policy = "gobblin.restli.throttling.CountBasedPolicy$Factory" +globalThrottling.policy = "org.apache.gobblin.restli.throttling.CountBasedPolicy$Factory" globalThrottling.count = 50 http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-runtime/build.gradle ---------------------------------------------------------------------- diff --git a/gobblin-runtime/build.gradle b/gobblin-runtime/build.gradle index ec99635..422d6f3 100644 --- a/gobblin-runtime/build.gradle +++ b/gobblin-runtime/build.gradle @@ -172,7 +172,7 @@ ext.classification="library" task pullFileConverter(type: JavaExec) { dependsOn jar doFirst { - main = "gobblin.runtime.template.PullFileToConfigConverter" + main = "org.apache.gobblin.runtime.template.PullFileToConfigConverter" def pullFilesRootPath = "pullFilesRootPath" def pullFilesToConvertGlob = "pullFilesToConvertGlob" http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java index f620561..8b0c481 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/local/LocalJobLauncherTest.java @@ -120,18 +120,18 @@ public class LocalJobLauncherTest { Properties jobProps = loadJobProps(); jobProps.setProperty(ConfigurationKeys.JOB_NAME_KEY, jobProps.getProperty(ConfigurationKeys.JOB_NAME_KEY) + "-testLaunchJobWithFork"); - jobProps.setProperty(ConfigurationKeys.CONVERTER_CLASSES_KEY, "gobblin.test.TestConverter2"); + jobProps.setProperty(ConfigurationKeys.CONVERTER_CLASSES_KEY, "org.apache.gobblin.test.TestConverter2"); jobProps.setProperty(ConfigurationKeys.FORK_BRANCHES_KEY, "2"); jobProps.setProperty(ConfigurationKeys.ROW_LEVEL_POLICY_LIST + ".0", - "gobblin.policies.schema.SchemaRowCheckPolicy"); + "org.apache.gobblin.policies.schema.SchemaRowCheckPolicy"); jobProps.setProperty(ConfigurationKeys.ROW_LEVEL_POLICY_LIST + ".1", - "gobblin.policies.schema.SchemaRowCheckPolicy"); + "org.apache.gobblin.policies.schema.SchemaRowCheckPolicy"); jobProps.setProperty(ConfigurationKeys.ROW_LEVEL_POLICY_LIST_TYPE + ".0", "OPTIONAL"); jobProps.setProperty(ConfigurationKeys.ROW_LEVEL_POLICY_LIST_TYPE + ".1", "OPTIONAL"); jobProps.setProperty(ConfigurationKeys.TASK_LEVEL_POLICY_LIST + ".0", - "gobblin.policies.count.RowCountPolicy,gobblin.policies.schema.SchemaCompatibilityPolicy"); + "org.apache.gobblin.policies.count.RowCountPolicy,org.apache.gobblin.policies.schema.SchemaCompatibilityPolicy"); jobProps.setProperty(ConfigurationKeys.TASK_LEVEL_POLICY_LIST + ".1", - "gobblin.policies.count.RowCountPolicy,gobblin.policies.schema.SchemaCompatibilityPolicy"); + "org.apache.gobblin.policies.count.RowCountPolicy,org.apache.gobblin.policies.schema.SchemaCompatibilityPolicy"); jobProps.setProperty(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE + ".0", "OPTIONAL,OPTIONAL"); jobProps.setProperty(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE + ".1", "OPTIONAL,OPTIONAL"); jobProps.setProperty(ConfigurationKeys.WRITER_OUTPUT_FORMAT_KEY + ".0", WriterOutputFormat.AVRO.name()); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java index e9f6c62..cd7af9d 100644 --- a/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java +++ b/gobblin-runtime/src/test/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncherTest.java @@ -161,18 +161,18 @@ public class MRJobLauncherTest extends BMNGRunner { Properties jobProps = loadJobProps(); jobProps.setProperty(ConfigurationKeys.JOB_NAME_KEY, jobProps.getProperty(ConfigurationKeys.JOB_NAME_KEY) + "-testLaunchJobWithFork"); - jobProps.setProperty(ConfigurationKeys.CONVERTER_CLASSES_KEY, "gobblin.test.TestConverter2"); + jobProps.setProperty(ConfigurationKeys.CONVERTER_CLASSES_KEY, "org.apache.gobblin.test.TestConverter2"); jobProps.setProperty(ConfigurationKeys.FORK_BRANCHES_KEY, "2"); jobProps.setProperty(ConfigurationKeys.ROW_LEVEL_POLICY_LIST + ".0", - "gobblin.policies.schema.SchemaRowCheckPolicy"); + "org.apache.gobblin.policies.schema.SchemaRowCheckPolicy"); jobProps.setProperty(ConfigurationKeys.ROW_LEVEL_POLICY_LIST + ".1", - "gobblin.policies.schema.SchemaRowCheckPolicy"); + "org.apache.gobblin.policies.schema.SchemaRowCheckPolicy"); jobProps.setProperty(ConfigurationKeys.ROW_LEVEL_POLICY_LIST_TYPE + ".0", "OPTIONAL"); jobProps.setProperty(ConfigurationKeys.ROW_LEVEL_POLICY_LIST_TYPE + ".1", "OPTIONAL"); jobProps.setProperty(ConfigurationKeys.TASK_LEVEL_POLICY_LIST + ".0", - "gobblin.policies.count.RowCountPolicy,gobblin.policies.schema.SchemaCompatibilityPolicy"); + "org.apache.gobblin.policies.count.RowCountPolicy,org.apache.gobblin.policies.schema.SchemaCompatibilityPolicy"); jobProps.setProperty(ConfigurationKeys.TASK_LEVEL_POLICY_LIST + ".1", - "gobblin.policies.count.RowCountPolicy,gobblin.policies.schema.SchemaCompatibilityPolicy"); + "org.apache.gobblin.policies.count.RowCountPolicy,org.apache.gobblin.policies.schema.SchemaCompatibilityPolicy"); jobProps.setProperty(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE + ".0", "OPTIONAL,OPTIONAL"); jobProps.setProperty(ConfigurationKeys.TASK_LEVEL_POLICY_LIST_TYPE + ".1", "OPTIONAL,OPTIONAL"); jobProps.setProperty(ConfigurationKeys.WRITER_OUTPUT_FORMAT_KEY + ".0", WriterOutputFormat.AVRO.name()); @@ -205,7 +205,7 @@ public class MRJobLauncherTest extends BMNGRunner { * {@link MRJobLauncher#countersToMetrics(GobblinMetrics)} method is called. */ @Test - @BMRule(name = "testJobCleanupOnError", targetClass = "gobblin.runtime.mapreduce.MRJobLauncher", + @BMRule(name = "testJobCleanupOnError", targetClass = "org.apache.gobblin.runtime.mapreduce.MRJobLauncher", targetMethod = "countersToMetrics(GobblinMetrics)", targetLocation = "AT ENTRY", condition = "true", action = "throw new IOException(\"Exception for testJobCleanupOnError\")") public void testJobCleanupOnError() throws IOException { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-runtime/src/test/resources/brokerTest/SimpleHelloWorldJob.jobconf ---------------------------------------------------------------------- diff --git a/gobblin-runtime/src/test/resources/brokerTest/SimpleHelloWorldJob.jobconf b/gobblin-runtime/src/test/resources/brokerTest/SimpleHelloWorldJob.jobconf index 4edc7d6..373d5ff 100644 --- a/gobblin-runtime/src/test/resources/brokerTest/SimpleHelloWorldJob.jobconf +++ b/gobblin-runtime/src/test/resources/brokerTest/SimpleHelloWorldJob.jobconf @@ -28,7 +28,7 @@ job.description=The "Hello World" Gobblin job # Source, Converters, Writer, Publisher source.class=gobblin.util.test.HelloWorldSource -converter.classes="gobblin.runtime.JobBrokerInjectionTest$JobBrokerConverter" +converter.classes="org.apache.gobblin.runtime.JobBrokerInjectionTest$JobBrokerConverter" writer.builder.class="org.apache.gobblin.writer.test.GobblinTestEventBusWriter$Builder" writer.GobblinTestEventBusWriter.eventBusId=${gobblin.workDir} data.publisher.type=gobblin.publisher.NoopPublisher http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java ---------------------------------------------------------------------- diff --git a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java index a468477..01d0285 100644 --- a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java +++ b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceHATest.java @@ -140,7 +140,7 @@ public class GobblinServiceHATest { commonServiceCoreProperties.put(ServiceConfigKeys.TOPOLOGY_FACTORY_PREFIX + TEST_GOBBLIN_EXECUTOR_NAME + ".uri", "gobblinExecutor"); commonServiceCoreProperties.put(ServiceConfigKeys.TOPOLOGY_FACTORY_PREFIX + TEST_GOBBLIN_EXECUTOR_NAME + ".specExecutorInstanceProducer", - "gobblin.service.InMemorySpecExecutorInstanceProducer"); + "org.apache.gobblin.service.InMemorySpecExecutorInstanceProducer"); commonServiceCoreProperties.put(ServiceConfigKeys.TOPOLOGY_FACTORY_PREFIX + TEST_GOBBLIN_EXECUTOR_NAME + ".specExecInstance.capabilities", TEST_SOURCE_NAME + ":" + TEST_SINK_NAME); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java ---------------------------------------------------------------------- diff --git a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java index 835588d..6378339 100644 --- a/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java +++ b/gobblin-service/src/test/java/org/apache/gobblin/service/modules/core/GobblinServiceManagerTest.java @@ -104,7 +104,7 @@ public class GobblinServiceManagerTest { serviceCoreProperties.put(ServiceConfigKeys.TOPOLOGY_FACTORY_PREFIX + TEST_GOBBLIN_EXECUTOR_NAME + ".uri", "gobblinExecutor"); serviceCoreProperties.put(ServiceConfigKeys.TOPOLOGY_FACTORY_PREFIX + TEST_GOBBLIN_EXECUTOR_NAME + ".specExecutorInstanceProducer", - "gobblin.service.InMemorySpecExecutorInstanceProducer"); + "org.apache.gobblin.service.InMemorySpecExecutorInstanceProducer"); serviceCoreProperties.put(ServiceConfigKeys.TOPOLOGY_FACTORY_PREFIX + TEST_GOBBLIN_EXECUTOR_NAME + ".specExecInstance.capabilities", TEST_SOURCE_NAME + ":" + TEST_SINK_NAME); http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-test-harness/src/test/java/org/apache/gobblin/SkipWorkUnitsIntegrationTest.java ---------------------------------------------------------------------- diff --git a/gobblin-test-harness/src/test/java/org/apache/gobblin/SkipWorkUnitsIntegrationTest.java b/gobblin-test-harness/src/test/java/org/apache/gobblin/SkipWorkUnitsIntegrationTest.java index 84ebc81..ce4f61d 100644 --- a/gobblin-test-harness/src/test/java/org/apache/gobblin/SkipWorkUnitsIntegrationTest.java +++ b/gobblin-test-harness/src/test/java/org/apache/gobblin/SkipWorkUnitsIntegrationTest.java @@ -47,7 +47,7 @@ public class SkipWorkUnitsIntegrationTest { throws Exception { Properties jobProperties = GobblinLocalJobLauncherUtils.getJobProperties("runtime_test/skip_workunits_test.properties"); - jobProperties.setProperty("data.publisher.type", "gobblin.TestSkipWorkUnitsPublisher"); + jobProperties.setProperty("data.publisher.type", "org.apache.gobblin.TestSkipWorkUnitsPublisher"); GobblinLocalJobLauncherUtils.invokeLocalJobLauncher(jobProperties); } http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/gobblin-utility/src/main/java/org/apache/gobblin/util/HadoopUtils.java ---------------------------------------------------------------------- diff --git a/gobblin-utility/src/main/java/org/apache/gobblin/util/HadoopUtils.java b/gobblin-utility/src/main/java/org/apache/gobblin/util/HadoopUtils.java index 1b9b45f..b1bd6cc 100644 --- a/gobblin-utility/src/main/java/org/apache/gobblin/util/HadoopUtils.java +++ b/gobblin-utility/src/main/java/org/apache/gobblin/util/HadoopUtils.java @@ -111,7 +111,7 @@ public class HadoopUtils { } // Add a new custom filesystem mapping - conf.set("fs.sftp.impl", "gobblin.source.extractor.extract.sftp.SftpLightWeightFileSystem"); + conf.set("fs.sftp.impl", "org.apache.gobblin.source.extractor.extract.sftp.SftpLightWeightFileSystem"); conf.set("fs.sftp.impl.disable.cache", "true"); return conf; } http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/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 7d2a364..8a029c1 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 @@ -99,7 +99,7 @@ public class SharedLimiterFactory<S extends ScopeType<S>> implements SharedResou if (!configView.getScope().isLocal() && !globalLimiterPolicy.equals(SharedLimiterKey.GlobalLimiterPolicy.LOCAL_ONLY)) { try { - Class<?> klazz = Class.forName("gobblin.util.limiter.RestliLimiterFactory"); + Class<?> klazz = Class.forName("org.apache.gobblin.util.limiter.RestliLimiterFactory"); return new ResourceCoordinate<>((SharedResourceFactory<Limiter, SharedLimiterKey, S>) klazz.newInstance(), configView.getKey(), (S) configView.getScope()); } catch (ReflectiveOperationException roe) { http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/bbf2aee0/ligradle/findbugs/findbugsExclude.xml ---------------------------------------------------------------------- diff --git a/ligradle/findbugs/findbugsExclude.xml b/ligradle/findbugs/findbugsExclude.xml index 8a75879..7032a51 100644 --- a/ligradle/findbugs/findbugsExclude.xml +++ b/ligradle/findbugs/findbugsExclude.xml @@ -37,16 +37,16 @@ </Match> <!-- Ignore gobblin.audit.values.auditor as the package is still a WIP --> <Match> - <Package name="~gobblin\.audit\.values\.auditor.*" /> + <Package name="~org\.apache\.gobblin\.audit\.values\.auditor.*" /> </Match> <!-- Ignored until https://github.com/linkedin/gobblin/issues/969 has been resolved --> <Match> - <Class name="~gobblin\.metastore\.database\.DatabaseJobHistoryStoreV.*" /> + <Class name="~org\.apache\.gobblin\.metastore\.database\.DatabaseJobHistoryStoreV.*" /> <Bug pattern="SQL_PREPARED_STATEMENT_GENERATED_FROM_NONCONSTANT_STRING" /> </Match> <!-- Ignored until https://github.com/linkedin/gobblin/issues/976 has been resolved --> <Match> - <Class name="gobblin.source.jdbc.JdbcExtractor" /> + <Class name="org.apache.gobblin.source.jdbc.JdbcExtractor" /> <Bug pattern="OBL_UNSATISFIED_OBLIGATION,ODR_OPEN_DATABASE_RESOURCE" /> </Match> </FindBugsFilter>
