gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [38/77] [abbrv] incubator-gobblin git commit: Updated package names, imports and shell scripts
Date Mon, 31 Jul 2017 07:52:56 GMT
Updated package names, imports and shell scripts


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

Branch: refs/heads/master
Commit: 2c22b8a92eb1eefed43c7345bd271e6385c7b8a5
Parents: 976b3d9
Author: Abhishek Tiwari <abhishektiwari.btech@gmail.com>
Authored: Sun Jul 30 17:02:16 2017 -0700
Committer: Abhishek Tiwari <abhishektiwari.btech@gmail.com>
Committed: Sun Jul 30 17:02:16 2017 -0700

----------------------------------------------------------------------
 bin/gobblin-admin.sh                            |  2 +-
 bin/gobblin-compaction.sh                       |  4 +-
 bin/gobblin-standalone.sh                       |  2 +-
 .../gobblin/gradle/BuildProperties.groovy       | 10 +--
 .../apache/gobblin/gradle/BuildProperty.groovy  |  2 +-
 .../apache/gobblin/admin/AdminWebServer.java    |  4 +-
 .../admin/DefaultAdminWebServerFactory.java     |  6 +-
 .../org/apache/gobblin/cli/AdminClient.java     |  6 +-
 .../main/java/org/apache/gobblin/cli/Cli.java   |  2 +-
 .../org/apache/gobblin/cli/CliTablePrinter.java |  2 +-
 .../java/org/apache/gobblin/cli/Command.java    |  2 +-
 .../java/org/apache/gobblin/cli/JobCommand.java |  6 +-
 .../apache/gobblin/cli/JobInfoPrintUtils.java   |  8 +-
 .../gobblin/admin/AdminWebServerTest.java       |  4 +-
 .../java/org/apache/gobblin/Constructs.java     | 16 ++--
 .../java/org/apache/gobblin/ack/Ackable.java    |  2 +-
 .../gobblin/ack/BasicAckableForTesting.java     |  2 +-
 .../apache/gobblin/ack/HierarchicalAckable.java |  2 +-
 .../org/apache/gobblin/annotation/Alias.java    |  4 +-
 .../org/apache/gobblin/annotation/Alpha.java    |  2 +-
 .../org/apache/gobblin/annotation/Beta.java     |  2 +-
 .../org/apache/gobblin/annotation/Stable.java   |  2 +-
 .../apache/gobblin/broker/BrokerConstants.java  |  2 +-
 .../gobblin/broker/ResourceCoordinate.java      | 10 +--
 .../apache/gobblin/broker/ResourceEntry.java    |  4 +-
 .../org/apache/gobblin/broker/SimpleScope.java  |  6 +-
 .../apache/gobblin/broker/SimpleScopeType.java  |  6 +-
 .../gobblin_scopes/GobblinScopeInstance.java    |  4 +-
 .../gobblin_scopes/GobblinScopeTypes.java       |  6 +-
 .../broker/gobblin_scopes/JobScopeInstance.java |  2 +-
 .../gobblin_scopes/TaskScopeInstance.java       |  2 +-
 .../apache/gobblin/broker/iface/ConfigView.java |  2 +-
 .../broker/iface/NoSuchScopeException.java      |  2 +-
 .../broker/iface/NotConfiguredException.java    |  2 +-
 .../gobblin/broker/iface/ScopeInstance.java     |  2 +-
 .../apache/gobblin/broker/iface/ScopeType.java  |  2 +-
 .../gobblin/broker/iface/ScopedConfigView.java  |  2 +-
 .../broker/iface/SharedResourceFactory.java     |  2 +-
 .../iface/SharedResourceFactoryResponse.java    |  2 +-
 .../gobblin/broker/iface/SharedResourceKey.java |  2 +-
 .../broker/iface/SharedResourcesBroker.java     |  2 +-
 .../broker/iface/SubscopedBrokerBuilder.java    |  4 +-
 .../org/apache/gobblin/codec/StreamCodec.java   |  4 +-
 .../apache/gobblin/commit/CommitSequence.java   |  4 +-
 .../gobblin/commit/CommitSequenceStore.java     |  4 +-
 .../org/apache/gobblin/commit/CommitStep.java   |  4 +-
 .../apache/gobblin/commit/CommitStepBase.java   |  6 +-
 .../gobblin/commit/DeliverySemantics.java       |  6 +-
 .../gobblin/compat/hadoop/TextSerializer.java   |  2 +-
 .../gobblin/compat/hadoop/WritableShim.java     |  2 +-
 .../configuration/ConfigurationKeys.java        |  2 +-
 .../configuration/ImmutableWorkUnitState.java   |  4 +-
 .../gobblin/configuration/SourceState.java      |  6 +-
 .../org/apache/gobblin/configuration/State.java |  6 +-
 .../gobblin/configuration/StateUtils.java       |  2 +-
 .../gobblin/configuration/WorkUnitState.java    | 16 ++--
 .../org/apache/gobblin/converter/Converter.java | 26 +++---
 .../converter/DataConversionException.java      |  2 +-
 .../converter/SchemaConversionException.java    |  4 +-
 .../initializer/ConverterInitializer.java       |  4 +-
 .../initializer/NoopConverterInitializer.java   |  6 +-
 .../apache/gobblin/crypto/CredentialStore.java  |  2 +-
 .../gobblin/crypto/CredentialStoreProvider.java |  2 +-
 .../gobblin/crypto/EncryptionProvider.java      |  4 +-
 .../org/apache/gobblin/dataset/Dataset.java     |  2 +-
 .../apache/gobblin/dataset/DatasetsFinder.java  |  2 +-
 .../gobblin/dataset/FileSystemDataset.java      |  2 +-
 .../gobblin/dataset/IterableDatasetFinder.java  |  2 +-
 .../dataset/IterableDatasetFinderImpl.java      |  2 +-
 .../org/apache/gobblin/fork/CopyHelper.java     |  2 +-
 .../gobblin/fork/CopyNotSupportedException.java |  2 +-
 .../java/org/apache/gobblin/fork/Copyable.java  |  2 +-
 .../org/apache/gobblin/fork/ForkOperator.java   |  4 +-
 .../java/org/apache/gobblin/fork/Forker.java    | 14 +--
 .../apache/gobblin/initializer/Initializer.java |  2 +-
 .../gobblin/initializer/NoopInitializer.java    |  2 +-
 .../apache/gobblin/metadata/MetadataMerger.java |  4 +-
 .../gobblin/password/PasswordManager.java       |  6 +-
 .../apache/gobblin/publisher/DataPublisher.java |  8 +-
 .../publisher/SingleTaskDataPublisher.java      |  6 +-
 .../gobblin/publisher/UnpublishedHandling.java  |  4 +-
 .../qualitychecker/row/RowLevelPolicy.java      |  8 +-
 .../qualitychecker/task/TaskLevelPolicy.java    |  6 +-
 .../FieldDoesNotExistException.java             |  2 +-
 .../recordaccess/IncorrectTypeException.java    |  2 +-
 .../gobblin/recordaccess/RecordAccessor.java    |  4 +-
 .../recordaccess/RecordAccessorException.java   |  2 +-
 .../recordaccess/RecordAccessorProvider.java    |  2 +-
 .../gobblin/records/ControlMessageHandler.java  |  4 +-
 .../records/FlushControlMessageHandler.java     |  6 +-
 .../gobblin/records/RecordStreamConsumer.java   |  2 +-
 .../gobblin/records/RecordStreamProcessor.java  |  4 +-
 .../records/RecordStreamWithMetadata.java       |  6 +-
 .../runtime/BasicTestControlMessage.java        |  6 +-
 .../runtime/api/AdminWebServerFactory.java      |  4 +-
 .../org/apache/gobblin/runtime/api/Spec.java    |  2 +-
 .../runtime/api/SpecExecutorInstance.java       |  4 +-
 .../api/SpecExecutorInstanceConsumer.java       |  2 +-
 .../api/SpecExecutorInstanceProducer.java       |  4 +-
 .../java/org/apache/gobblin/source/Source.java  | 10 +--
 .../gobblin/source/WorkUnitStreamSource.java    |  6 +-
 .../extractor/CheckpointableWatermark.java      |  4 +-
 .../source/extractor/ComparableWatermark.java   |  2 +-
 .../source/extractor/DataRecordException.java   |  2 +-
 .../gobblin/source/extractor/Extractor.java     |  8 +-
 .../source/extractor/StreamingExtractor.java    |  6 +-
 .../gobblin/source/extractor/Watermark.java     |  2 +-
 .../source/extractor/WatermarkInterval.java     |  2 +-
 .../extractor/WatermarkSerializerHelper.java    |  2 +-
 .../source/workunit/BasicWorkUnitStream.java    |  2 +-
 .../apache/gobblin/source/workunit/Extract.java | 10 +--
 .../gobblin/source/workunit/ExtractFactory.java |  4 +-
 .../source/workunit/ImmutableExtract.java       |  6 +-
 .../source/workunit/ImmutableWorkUnit.java      |  4 +-
 .../MissingExtractAttributeException.java       |  2 +-
 .../gobblin/source/workunit/MultiWorkUnit.java  |  2 +-
 .../gobblin/source/workunit/WorkUnit.java       | 14 +--
 .../source/workunit/WorkUnitBinPacker.java      |  2 +-
 .../gobblin/source/workunit/WorkUnitStream.java |  2 +-
 .../source/workunit/WorkUnitWeighter.java       |  2 +-
 .../apache/gobblin/stream/ControlMessage.java   |  2 +-
 .../gobblin/stream/FlushControlMessage.java     |  2 +-
 .../apache/gobblin/stream/RecordEnvelope.java   | 10 +--
 .../org/apache/gobblin/stream/StreamEntity.java |  6 +-
 .../gobblin/testing/AssertWithBackoff.java      |  2 +-
 .../apache/gobblin/util/ClassAliasResolver.java |  4 +-
 .../apache/gobblin/util/CompletedFuture.java    |  2 +-
 .../java/org/apache/gobblin/util/Decorator.java |  2 +-
 .../org/apache/gobblin/util/DecoratorUtils.java |  2 +-
 .../org/apache/gobblin/util/FinalState.java     |  4 +-
 .../gobblin/util/RecordCountProvider.java       |  2 +-
 .../org/apache/gobblin/writer/DataWriter.java   |  8 +-
 .../gobblin/writer/DataWriterBuilder.java       | 10 +--
 .../org/apache/gobblin/writer/Destination.java  |  4 +-
 .../gobblin/writer/FluentDataWriterBuilder.java |  2 +-
 .../apache/gobblin/writer/FsWriterMetrics.java  |  2 +-
 .../gobblin/writer/PartitionIdentifier.java     |  2 +-
 .../apache/gobblin/writer/WatermarkStorage.java |  6 +-
 .../gobblin/writer/WriterOutputFormat.java      |  2 +-
 .../apache/gobblin/writer/WriterWrapper.java    |  2 +-
 .../initializer/NoopWriterInitializer.java      |  6 +-
 .../writer/initializer/WriterInitializer.java   |  4 +-
 .../java/com/linkedin/gobblin/TestAlias.java    |  2 +-
 .../gobblin/ack/HierarchicalAckableTest.java    |  2 +-
 .../gobblin_scopes/GobblinScopesTest.java       |  2 +-
 .../gobblin/compat/TextSerializerTest.java      |  4 +-
 .../apache/gobblin/configuration/StateTest.java |  2 +-
 .../apache/gobblin/converter/ConverterTest.java | 14 +--
 .../org/apache/gobblin/fork/CopyHelperTest.java |  2 +-
 .../org/apache/gobblin/fork/ForkerTest.java     | 14 +--
 .../gobblin/password/PasswordManagerTest.java   |  6 +-
 .../gobblin/source/extractor/TestWatermark.java |  2 +-
 .../gobblin/source/extractor/WatermarkTest.java |  6 +-
 .../source/workunit/ExtractFactoryTest.java     |  2 +-
 .../gobblin/stream/RecordEnvelopeTest.java      | 14 +--
 .../apache/gobblin/stream/StreamEntityTest.java |  4 +-
 .../gobblin/testing/AssertWithBackoffTest.java  |  2 +-
 .../gobblin/util/ClassAliasResolverTest.java    |  4 +-
 .../gobblin/writer/FsWriterMetricsTest.java     |  2 +-
 .../values/auditor/ValueAuditGenerator.java     | 14 +--
 .../auditor/ValueAuditRuntimeMetadata.java      |  2 +-
 .../column/AbstractColumnProjectionPolicy.java  |  4 +-
 .../policy/column/ColumnProjectionPolicy.java   |  2 +-
 .../DefaultColumnProjectionPolicyFactory.java   |  6 +-
 .../ProjectAllColumnProjectionPolicy.java       |  6 +-
 .../policy/row/AbstractRowSelectionPolicy.java  |  8 +-
 .../row/DefaultRowSelectionPolicyFactory.java   | 10 +--
 .../values/policy/row/RowSelectionPolicy.java   |  2 +-
 .../policy/row/SelectAllRowSelectionPolicy.java |  8 +-
 .../gobblin/audit/values/sink/AuditSink.java    |  2 +-
 .../values/sink/DefaultAuditSinkFactory.java    |  6 +-
 .../gobblin/audit/values/sink/FsAuditSink.java  | 12 +--
 .../gobblin/audit/values/FsAuditSinkTest.java   |  6 +-
 .../apache/gobblin/audit/values/MockSink.java   |  8 +-
 .../audit/values/ValueAuditGeneratorTest.java   | 10 +--
 .../values/ValueAuditRuntimeMetadataTest.java   |  6 +-
 .../gobblin/aws/AWSClusterSecurityManager.java  |  8 +-
 .../gobblin/aws/AWSJobConfigurationManager.java | 20 ++---
 .../org/apache/gobblin/aws/AWSSdkClient.java    |  4 +-
 .../apache/gobblin/aws/AWSShutdownHandler.java  |  4 +-
 .../gobblin/aws/CloudInitScriptBuilder.java     | 10 +--
 .../gobblin/aws/GobblinAWSClusterLauncher.java  | 26 +++---
 .../gobblin/aws/GobblinAWSClusterManager.java   | 16 ++--
 .../aws/GobblinAWSConfigurationKeys.java        |  4 +-
 .../gobblin/aws/GobblinAWSTaskRunner.java       | 18 ++--
 .../org/apache/gobblin/aws/GobblinAWSUtils.java |  4 +-
 .../apache/gobblin/aws/Log4jConfigHelper.java   |  4 +-
 .../aws/AWSJobConfigurationManagerTest.java     |  6 +-
 .../gobblin/aws/CloudInitScriptBuilderTest.java |  2 +-
 .../aws/GobblinAWSClusterLauncherTest.java      | 18 ++--
 .../cluster/ClusterEventMetadataGenerator.java  | 16 ++--
 .../gobblin/cluster/ContainerMetrics.java       | 10 +--
 .../GobblinClusterConfigurationKeys.java        |  4 +-
 .../gobblin/cluster/GobblinClusterManager.java  | 28 +++---
 .../cluster/GobblinClusterMetricTagNames.java   |  4 +-
 .../gobblin/cluster/GobblinClusterUtils.java    |  4 +-
 .../gobblin/cluster/GobblinHelixConstants.java  |  2 +-
 .../apache/gobblin/cluster/GobblinHelixJob.java | 18 ++--
 .../cluster/GobblinHelixJobLauncher.java        | 46 +++++-----
 .../cluster/GobblinHelixJobScheduler.java       | 26 +++---
 .../cluster/GobblinHelixMessagingService.java   |  2 +-
 .../gobblin/cluster/GobblinHelixTask.java       | 42 ++++-----
 .../gobblin/cluster/GobblinHelixTaskDriver.java |  2 +-
 .../cluster/GobblinHelixTaskFactory.java        | 10 +--
 .../cluster/GobblinHelixTaskStateTracker.java   | 10 +--
 .../gobblin/cluster/GobblinTaskRunner.java      | 22 ++---
 .../gobblin/cluster/GobblinTaskStateModel.java  |  6 +-
 .../cluster/GobblinTaskStateModelFactory.java   |  6 +-
 .../gobblin/cluster/HelixMessageSubTypes.java   |  4 +-
 .../org/apache/gobblin/cluster/HelixUtils.java  |  4 +-
 .../cluster/JobConfigurationManager.java        | 16 ++--
 .../gobblin/cluster/NoopReplyHandler.java       |  2 +-
 .../ScheduledJobConfigurationManager.java       | 18 ++--
 .../StreamingJobConfigurationManager.java       | 22 ++---
 .../event/ClusterManagerShutdownRequest.java    |  4 +-
 .../event/DeleteJobConfigArrivalEvent.java      |  4 +-
 .../cluster/event/NewJobConfigArrivalEvent.java |  4 +-
 .../event/UpdateJobConfigArrivalEvent.java      |  4 +-
 .../ClusterEventMetadataGeneratorTest.java      | 14 +--
 .../gobblin/cluster/GobblinClusterKillTest.java |  4 +-
 .../cluster/GobblinClusterManagerTest.java      |  6 +-
 .../cluster/GobblinHelixJobLauncherTest.java    | 20 ++---
 .../gobblin/cluster/GobblinHelixTaskTest.java   | 28 +++---
 .../gobblin/cluster/GobblinTaskRunnerTest.java  |  4 +-
 .../gobblin/cluster/HelixMessageTestBase.java   |  2 +-
 .../apache/gobblin/cluster/HelixUtilsTest.java  |  4 +-
 .../cluster/JobConfigurationManagerTest.java    |  6 +-
 .../org/apache/gobblin/cluster/TestHelper.java  |  6 +-
 .../TestShutdownMessageHandlerFactory.java      |  2 +-
 .../apache/gobblin/compaction/CliOptions.java   |  4 +-
 .../apache/gobblin/compaction/Compactor.java    |  2 +-
 .../compaction/CompactorCreationException.java  |  2 +-
 .../gobblin/compaction/CompactorFactory.java    |  8 +-
 .../compaction/ReflectionCompactorFactory.java  |  6 +-
 .../action/CompactionCompleteAction.java        |  6 +-
 .../CompactionCompleteFileOperationAction.java  | 30 +++----
 .../CompactionHiveRegistrationAction.java       | 24 +++---
 .../action/CompactionMarkDirectoryAction.java   | 16 ++--
 .../compaction/audit/AuditCountClient.java      |  2 +-
 .../audit/AuditCountClientFactory.java          |  4 +-
 .../audit/KafkaAuditCountHttpClient.java        |  4 +-
 .../audit/KafkaAuditCountHttpClientFactory.java |  6 +-
 .../audit/PinotAuditCountHttpClient.java        |  4 +-
 .../audit/PinotAuditCountHttpClientFactory.java |  6 +-
 .../RecompactionCombineCondition.java           | 14 +--
 .../conditions/RecompactionCondition.java       |  4 +-
 .../RecompactionConditionBasedOnDuration.java   | 10 +--
 .../RecompactionConditionBasedOnFileCount.java  | 10 +--
 .../RecompactionConditionBasedOnRatio.java      | 12 +--
 .../RecompactionConditionFactory.java           |  4 +-
 .../gobblin/compaction/dataset/Dataset.java     |  8 +-
 .../compaction/dataset/DatasetHelper.java       | 18 ++--
 .../compaction/dataset/DatasetsFinder.java      | 12 +--
 .../dataset/SimpleDatasetsFinder.java           |  6 +-
 .../dataset/TimeBasedSubDirDatasetsFinder.java  |  8 +-
 .../event/CompactionSlaEventHelper.java         | 18 ++--
 .../gobblin/compaction/event/DedupeStatus.java  |  2 +-
 .../compaction/hive/AvroExternalTable.java      |  4 +-
 .../compaction/hive/CompactionRunner.java       |  6 +-
 .../apache/gobblin/compaction/hive/HdfsIO.java  |  2 +-
 .../gobblin/compaction/hive/HdfsReader.java     |  2 +-
 .../gobblin/compaction/hive/HdfsWriter.java     |  4 +-
 .../gobblin/compaction/hive/HiveAttribute.java  |  2 +-
 .../compaction/hive/HiveManagedTable.java       |  4 +-
 .../gobblin/compaction/hive/HiveTable.java      |  4 +-
 .../compaction/hive/SerialCompactor.java        |  6 +-
 .../HiveRegistrationCompactorListener.java      | 16 ++--
 .../CompactionLauncherWriter.java               | 12 +--
 .../CompactionLauncherWriterBuilder.java        |  6 +-
 .../HiveMetadataForCompactionExtractor.java     | 14 +--
 ...veMetadataForCompactionExtractorFactory.java |  8 +-
 .../hivebasedconstructs/MRCompactionEntity.java |  2 +-
 .../listeners/CompactorCompletionListener.java  |  4 +-
 .../CompactorCompletionListenerFactory.java     |  4 +-
 .../compaction/listeners/CompactorListener.java |  8 +-
 .../CompactorListenerCreationException.java     |  2 +-
 .../listeners/CompactorListenerFactory.java     |  4 +-
 .../ReflectionCompactorListenerFactory.java     |  4 +-
 .../listeners/SerialCompactorListener.java      |  4 +-
 .../SimpleCompactorCompletionListener.java      | 10 +--
 .../CompactionAvroJobConfigurator.java          | 22 ++---
 .../mapreduce/MRCompactionRunner.java           | 22 ++---
 .../compaction/mapreduce/MRCompactionTask.java  | 20 ++---
 .../mapreduce/MRCompactionTaskFactory.java      |  8 +-
 .../compaction/mapreduce/MRCompactor.java       | 62 +++++++-------
 .../mapreduce/MRCompactorJobPropCreator.java    | 12 +--
 .../mapreduce/MRCompactorJobRunner.java         | 28 +++---
 .../avro/AvroDeltaFieldNameProvider.java        |  2 +-
 .../avro/AvroKeyCombineFileRecordReader.java    |  4 +-
 .../avro/AvroKeyCompactorOutputCommitter.java   |  4 +-
 .../avro/AvroKeyCompactorOutputFormat.java      |  2 +-
 .../mapreduce/avro/AvroKeyDedupReducer.java     |  4 +-
 .../mapreduce/avro/AvroKeyMapper.java           |  2 +-
 .../AvroKeyRecursiveCombineFileInputFormat.java |  6 +-
 .../avro/ConfBasedDeltaFieldProvider.java       |  2 +-
 .../FieldAttributeBasedDeltaFieldsProvider.java |  2 +-
 .../avro/MRCompactorAvroKeyDedupJobRunner.java  |  8 +-
 .../compaction/parser/CompactionPathParser.java |  8 +-
 .../compaction/source/CompactionFailedTask.java | 16 ++--
 .../compaction/source/CompactionSource.java     | 80 ++++++++---------
 .../compaction/suite/CompactionAvroSuite.java   | 24 +++---
 .../suite/CompactionAvroSuiteFactory.java       |  6 +-
 .../compaction/suite/CompactionSuite.java       | 16 ++--
 .../suite/CompactionSuiteFactory.java           |  4 +-
 .../compaction/suite/CompactionSuiteUtils.java  |  8 +-
 .../verify/CompactionAuditCountVerifier.java    | 16 ++--
 .../verify/CompactionThresholdVerifier.java     | 12 +--
 .../verify/CompactionTimeRangeVerifier.java     | 12 +--
 .../compaction/verify/CompactionVerifier.java   |  4 +-
 .../verify/DataCompletenessVerifier.java        | 12 +--
 .../verify/InputRecordCountHelper.java          | 16 ++--
 .../mapreduce/MRCompactionTaskTest.java         | 28 +++---
 ...obRunnerFilenameRecordCountProviderTest.java |  8 +-
 .../mapreduce/RenameSourceDirectoryTest.java    |  4 +-
 .../mapreduce/avro/AvroKeyDedupReducerTest.java |  2 +-
 .../avro/ConfBasedDeltaFieldProviderTest.java   |  2 +-
 ...ldAttributeBasedDeltaFieldsProviderTest.java |  2 +-
 .../MRCompactorAvroKeyDedupJobRunnerTest.java   | 12 +--
 .../conditions/RecompactionConditionTest.java   | 20 ++---
 .../suite/TestCompactionSuiteFactories.java     |  6 +-
 .../compaction/suite/TestCompactionSuites.java  |  8 +-
 .../verify/PinotAuditCountVerifierTest.java     | 12 +--
 .../dedup-schema/dedup-schema-with-pkey.avsc    |  2 +-
 .../dedup-schema/dedup-schema-without-pkey.avsc |  2 +-
 .../gobblin/config/client/ConfigClient.java     | 30 +++----
 .../gobblin/config/client/ConfigClientCLI.java  | 14 +--
 .../config/client/ConfigClientCache.java        |  4 +-
 .../config/client/ConfigClientUtils.java        | 12 +--
 .../client/ConfigStoreFactoryRegister.java      |  4 +-
 .../gobblin/config/client/package-info.java     |  2 +-
 .../gobblin/config/client/TestConfigClient.java | 12 +--
 .../config/client/TestConfigClientUtils.java    |  8 +-
 ...onfigStoreFactoryDoesNotExistsException.java |  2 +-
 .../client/api/VersionStabilityPolicy.java      |  6 +-
 .../impl/CircularDependencyException.java       |  2 +-
 .../common/impl/ConfigStoreBackedTopology.java  | 12 +--
 .../impl/ConfigStoreBackedValueInspector.java   | 10 +--
 .../impl/ConfigStoreTopologyInspector.java      |  4 +-
 .../common/impl/ConfigStoreValueInspector.java  |  4 +-
 .../config/common/impl/ImportTraverser.java     |  2 +-
 .../config/common/impl/InMemoryTopology.java    |  4 +-
 .../common/impl/InMemoryValueInspector.java     |  6 +-
 .../impl/SingleLinkedListConfigKeyPath.java     |  4 +-
 .../gobblin/config/store/api/ConfigKeyPath.java |  4 +-
 .../gobblin/config/store/api/ConfigStore.java   |  4 +-
 .../store/api/ConfigStoreCreationException.java |  4 +-
 .../config/store/api/ConfigStoreFactory.java    |  4 +-
 .../store/api/ConfigStoreWithBatchFetches.java  |  4 +-
 .../store/api/ConfigStoreWithImportedBy.java    |  4 +-
 .../ConfigStoreWithImportedByRecursively.java   |  4 +-
 .../store/api/ConfigStoreWithResolution.java    |  4 +-
 .../api/ConfigStoreWithStableVersioning.java    |  6 +-
 .../store/api/VersionDoesNotExistException.java |  4 +-
 .../gobblin/config/store/api/package-info.java  |  2 +-
 .../store/deploy/ClasspathConfigSource.java     |  2 +-
 .../config/store/deploy/ConfigStream.java       |  2 +-
 .../gobblin/config/store/deploy/Deployable.java |  4 +-
 .../store/deploy/DeployableConfigSource.java    |  4 +-
 .../config/store/deploy/DeploymentConfig.java   |  2 +-
 .../config/store/deploy/FsDeploymentConfig.java |  2 +-
 .../config/store/deploy/StoreDeployer.java      |  6 +-
 .../DefaultCapableLocalConfigStoreFactory.java  |  2 +-
 .../hdfs/SimpleHDFSConfigStoreFactory.java      |  8 +-
 .../store/hdfs/SimpleHDFSStoreMetadata.java     |  8 +-
 .../hdfs/SimpleHadoopFilesystemConfigStore.java | 28 +++---
 ...impleHadoopFilesystemConfigStoreFactory.java |  8 +-
 .../hdfs/SimpleLocalHDFSConfigStoreFactory.java |  2 +-
 .../apache/gobblin/config/TestEnvironment.java  |  6 +-
 .../config/common/impl/ImportTraverserTest.java |  2 +-
 .../common/impl/TestCircularDependency.java     |  6 +-
 .../impl/TestConfigStoreValueInspector.java     |  8 +-
 .../common/impl/TestInMemoryTopology.java       |  6 +-
 .../impl/TestSingleLinkedListConfigKeyPath.java |  4 +-
 .../store/hdfs/SimpleHDFSStoreMetadataTest.java |  4 +-
 .../store/hdfs/SimpleHdfsConfigStoreTest.java   | 16 ++--
 .../SimpleHdfsConfigureStoreFactoryTest.java    |  4 +-
 .../FineGrainedWatermarkTrackerBenchmark.java   |  8 +-
 .../java/org/apache/gobblin/async/Callback.java |  2 +-
 .../compression/CompressionConfigParser.java    |  8 +-
 .../gobblin/compression/CompressionFactory.java |  8 +-
 .../gobblin/converter/AsyncConverter1to1.java   | 16 ++--
 .../converter/AvroToAvroConverterBase.java      |  4 +-
 .../gobblin/converter/IdentityConverter.java    |  4 +-
 .../gobblin/converter/SamplingConverter.java    |  6 +-
 .../gobblin/converter/SingleRecordIterable.java |  2 +-
 .../gobblin/converter/ToAvroConverterBase.java  |  4 +-
 .../filter/AvroProjectionConverter.java         | 18 ++--
 .../filter/AvroSchemaFieldRemover.java          |  2 +-
 ...blinTrackingEventFlattenFilterConverter.java | 18 ++--
 .../gobblin/crypto/CredentialStoreFactory.java  |  4 +-
 .../gobblin/crypto/EncryptionConfigParser.java  | 12 +--
 .../gobblin/crypto/EncryptionFactory.java       |  4 +-
 .../instrumented/GobblinMetricsKeys.java        |  4 +-
 .../gobblin/instrumented/Instrumentable.java    |  8 +-
 .../gobblin/instrumented/Instrumented.java      | 28 +++---
 .../converter/InstrumentedConverter.java        |  6 +-
 .../converter/InstrumentedConverterBase.java    | 22 ++---
 .../InstrumentedConverterDecorator.java         | 24 +++---
 .../extractor/InstrumentedExtractor.java        |  8 +-
 .../extractor/InstrumentedExtractorBase.java    | 30 +++----
 .../InstrumentedExtractorDecorator.java         | 24 +++---
 .../fork/InstrumentedForkOperator.java          |  4 +-
 .../fork/InstrumentedForkOperatorBase.java      | 20 ++---
 .../fork/InstrumentedForkOperatorDecorator.java | 14 +--
 .../InstrumentedRowLevelPolicy.java             |  4 +-
 .../InstrumentedRowLevelPolicyBase.java         | 18 ++--
 .../InstrumentedRowLevelPolicyDecorator.java    | 14 +--
 .../writer/InstrumentedDataWriter.java          |  4 +-
 .../writer/InstrumentedDataWriterBase.java      | 22 ++---
 .../writer/InstrumentedDataWriterDecorator.java | 24 +++---
 ...trumentedPartitionedDataWriterDecorator.java |  8 +-
 .../DefaultCheckpointableWatermark.java         |  4 +-
 .../source/extractor/JobCommitPolicy.java       |  6 +-
 .../source/extractor/WorkUnitRetryPolicy.java   |  2 +-
 .../extractor/extract/AbstractSource.java       | 22 ++---
 .../extractor/extract/EventBasedExtractor.java  |  6 +-
 .../extractor/extract/EventBasedSource.java     |  4 +-
 .../source/extractor/extract/LongWatermark.java |  6 +-
 .../limiter/LimiterConfigurationKeys.java       |  2 +-
 .../apache/gobblin/test/AnyToJsonConverter.java | 12 +--
 .../gobblin/test/AnyToStringConverter.java      | 12 +--
 .../gobblin/test/SequentialTestSource.java      | 34 ++++----
 .../org/apache/gobblin/test/TestRecord.java     |  2 +-
 .../writer/AcknowledgableRecordEnvelope.java    |  8 +-
 .../gobblin/writer/AcknowledgableWatermark.java |  6 +-
 .../apache/gobblin/writer/AsyncDataWriter.java  |  4 +-
 .../gobblin/writer/AsyncWriterManager.java      | 30 +++----
 .../java/org/apache/gobblin/writer/Batch.java   |  6 +-
 .../apache/gobblin/writer/BatchAccumulator.java |  4 +-
 .../gobblin/writer/BatchAsyncDataWriter.java    |  4 +-
 .../gobblin/writer/BufferedAsyncDataWriter.java |  4 +-
 .../gobblin/writer/BytesBoundedBatch.java       |  4 +-
 .../writer/FineGrainedWatermarkTracker.java     | 22 ++---
 .../writer/FutureWrappedWriteCallback.java      |  2 +-
 .../gobblin/writer/GenericWriteResponse.java    |  2 +-
 .../writer/GenericWriteResponseWrapper.java     |  2 +-
 .../gobblin/writer/LastWatermarkTracker.java    |  4 +-
 .../writer/MultiWriterWatermarkManager.java     |  6 +-
 .../writer/MultiWriterWatermarkTracker.java     |  4 +-
 .../writer/PartitionAwareDataWriterBuilder.java |  4 +-
 .../org/apache/gobblin/writer/RecordFuture.java |  4 +-
 .../apache/gobblin/writer/RecordMetadata.java   |  4 +-
 .../writer/SequentialBasedBatchAccumulator.java |  4 +-
 .../apache/gobblin/writer/SyncDataWriter.java   |  4 +-
 .../writer/TrackerBasedWatermarkManager.java    |  6 +-
 .../gobblin/writer/WatermarkAwareWriter.java    |  8 +-
 .../writer/WatermarkAwareWriterWrapper.java     |  6 +-
 .../apache/gobblin/writer/WatermarkManager.java |  4 +-
 .../apache/gobblin/writer/WatermarkTracker.java |  4 +-
 .../gobblin/writer/WatermarkTrackerFactory.java |  2 +-
 .../apache/gobblin/writer/WriteCallback.java    |  4 +-
 .../apache/gobblin/writer/WriteResponse.java    |  2 +-
 .../gobblin/writer/WriteResponseFuture.java     |  2 +-
 .../gobblin/writer/WriteResponseMapper.java     |  2 +-
 .../writer/exception/NonTransientException.java |  2 +-
 .../writer/partitioner/WriterPartitioner.java   |  2 +-
 .../converter/AsyncConverter1to1Test.java       | 10 +--
 .../converter/SamplingConverterTest.java        |  4 +-
 .../converter/SingleRecordIterableTest.java     |  2 +-
 .../filter/AvroSchemaFieldRemoverTest.java      |  2 +-
 ...TrackingEventFlattenFilterConverterTest.java |  6 +-
 .../crypto/EncryptionConfigParserTest.java      |  6 +-
 .../converter/InstrumentedConverterTest.java    | 20 ++---
 .../extractor/InstrumentedExtractorTest.java    | 20 ++---
 .../fork/InstrumentedForkOperatorTest.java      | 14 +--
 .../InstrumentedRowLevelPolicyTest.java         | 16 ++--
 .../writer/InstrumentedDataWriterTest.java      | 18 ++--
 .../extractor/extract/AbstractSourceTest.java   | 16 ++--
 .../gobblin/writer/AsyncWriterManagerTest.java  | 20 ++---
 .../writer/FineGrainedWatermarkTrackerTest.java | 10 +--
 .../writer/MultiWriterWatermarkManagerTest.java | 10 +--
 .../gobblin/writer/WatermarkTrackerTest.java    |  6 +-
 .../gobblin/async/AsyncDataDispatcher.java      |  2 +-
 .../org/apache/gobblin/async/AsyncRequest.java  |  4 +-
 .../gobblin/async/AsyncRequestBuilder.java      |  2 +-
 .../apache/gobblin/async/BufferedRecord.java    |  4 +-
 .../apache/gobblin/async/DispatchException.java |  2 +-
 .../gobblin/commit/FsRenameCommitStep.java      | 10 +--
 .../SpeculativeAttemptAwareConstruct.java       |  4 +-
 .../apache/gobblin/config/ConfigBuilder.java    |  2 +-
 .../apache/gobblin/converter/EmptyIterable.java |  2 +-
 .../GobblinMetricsPinotFlattenerConverter.java  |  4 +-
 .../gobblin/converter/StringSchemaInjector.java |  4 +-
 .../avro/AvroFieldRetrieverConverter.java       | 20 ++---
 .../avro/AvroRecordToAvroWritableConverter.java | 10 +--
 .../avro/AvroToAvroCopyableConverter.java       | 16 ++--
 .../converter/avro/AvroToBytesConverter.java    | 10 +--
 .../converter/avro/BytesToAvroConverter.java    | 10 +--
 .../avro/FlattenNestedKeyConverter.java         | 18 ++--
 .../avro/JsonElementConversionFactory.java      |  6 +-
 .../avro/JsonIntermediateToAvroConverter.java   | 20 ++---
 .../avro/UnsupportedDateTypeException.java      |  2 +-
 .../converter/csv/CsvToJsonConverter.java       | 16 ++--
 .../converter/csv/CsvToJsonConverterV2.java     | 12 +--
 .../filter/AvroFieldsPickConverter.java         | 16 ++--
 .../converter/filter/AvroFilterConverter.java   | 20 ++---
 .../http/AvroToRestJsonEntryConverter.java      | 12 +--
 .../gobblin/converter/http/RestEntry.java       |  2 +-
 .../ConverterInitializerFactory.java            | 12 +--
 .../initializer/MultiConverterInitializer.java  |  6 +-
 .../JsonStringToJsonIntermediateConverter.java  | 12 +--
 .../converter/json/JsonToStringConverter.java   | 10 +--
 .../objectstore/ObjectStoreConverter.java       | 12 +--
 .../objectstore/ObjectStoreDeleteConverter.java | 16 ++--
 .../converter/serde/HiveSerDeConverter.java     | 16 ++--
 .../string/ObjectToStringConverter.java         | 12 +--
 .../converter/string/StringFilterConverter.java | 18 ++--
 .../string/StringSplitterConverter.java         | 14 +--
 .../string/StringSplitterToListConverter.java   | 16 ++--
 .../string/StringToBytesConverter.java          | 10 +--
 .../converter/string/TextToStringConverter.java | 12 +--
 .../gobblin/fork/CopyableGenericRecord.java     |  2 +-
 .../org/apache/gobblin/fork/CopyableSchema.java |  2 +-
 .../gobblin/fork/IdentityForkOperator.java      |  6 +-
 .../http/DefaultHttpClientConfigurator.java     |  6 +-
 .../gobblin/http/HttpClientConfigurator.java    |  4 +-
 .../http/HttpClientConfiguratorLoader.java      |  6 +-
 .../gobblin/initializer/MultiInitializer.java   |  2 +-
 .../java/org/apache/gobblin/net/Request.java    |  2 +-
 .../policies/avro/AvroHeaderGuidPolicy.java     |  6 +-
 .../avro/AvroHeaderTimestampPolicy.java         |  6 +-
 .../AvroRecordTimestampLowerBoundPolicy.java    | 10 +--
 .../gobblin/policies/count/RowCountPolicy.java  |  8 +-
 .../policies/count/RowCountRangePolicy.java     |  8 +-
 .../schema/SchemaCompatibilityPolicy.java       |  8 +-
 .../policies/schema/SchemaRowCheckPolicy.java   |  6 +-
 .../time/RecordTimestampLowerBoundPolicy.java   | 10 +--
 .../gobblin/publisher/BaseDataPublisher.java    | 28 +++---
 .../BaseDataPublisherWithHiveRegistration.java  |  6 +-
 .../publisher/CommitSequencePublisher.java      | 16 ++--
 .../publisher/HiveRegistrationPublisher.java    | 26 +++---
 .../apache/gobblin/publisher/NoopPublisher.java |  6 +-
 .../apache/gobblin/publisher/TaskPublisher.java |  8 +-
 .../gobblin/publisher/TaskPublisherBuilder.java |  6 +-
 .../publisher/TaskPublisherBuilderFactory.java  |  6 +-
 .../publisher/TimePartitionedDataPublisher.java | 12 +--
 .../publisher/TimestampDataPublisher.java       | 10 +--
 ...estampDataPublisherWithHiveRegistration.java |  8 +-
 .../row/RowLevelErrFileWriter.java              |  4 +-
 .../row/RowLevelPolicyCheckResults.java         |  2 +-
 .../row/RowLevelPolicyChecker.java              | 24 +++---
 .../row/RowLevelPolicyCheckerBuilder.java       | 10 +--
 .../RowLevelPolicyCheckerBuilderFactory.java    |  4 +-
 .../task/TaskLevelPolicyCheckResults.java       |  2 +-
 .../task/TaskLevelPolicyChecker.java            |  2 +-
 .../task/TaskLevelPolicyCheckerBuilder.java     |  8 +-
 .../TaskLevelPolicyCheckerBuilderFactory.java   |  4 +-
 .../recordaccess/AvroGenericRecordAccessor.java |  4 +-
 .../recordaccess/CoreRecordAccessProvider.java  |  2 +-
 .../RecordAccessorProviderFactory.java          |  2 +-
 .../apache/gobblin/retry/RetryerFactory.java    |  4 +-
 .../gobblin/security/ssl/SSLContextFactory.java |  6 +-
 .../source/DatePartitionedAvroFileSource.java   | 12 +--
 .../source/DatePartitionedDailyAvroSource.java  |  8 +-
 .../source/DatePartitionedNestedRetriever.java  | 16 ++--
 .../source/PartitionAwareFileRetriever.java     |  4 +-
 .../PartitionAwareFileRetrieverUtils.java       | 14 +--
 .../source/PartitionedFileSourceBase.java       | 30 +++----
 .../source/RegexBasedPartitionedRetriever.java  | 10 +--
 .../source/RegexPartitionedAvroFileSource.java  |  8 +-
 .../DatePartitionedAvroFileExtractor.java       |  6 +-
 .../source/extractor/DummyExtractor.java        |  6 +-
 .../exception/ExtractPrepareException.java      |  2 +-
 .../exception/HighWatermarkException.java       |  2 +-
 .../extractor/exception/MetadataException.java  |  2 +-
 .../exception/RecordCountException.java         |  2 +-
 .../exception/RestApiClientException.java       |  2 +-
 .../exception/RestApiConnectionException.java   |  2 +-
 .../exception/RestApiProcessingException.java   |  2 +-
 .../extractor/exception/SchemaException.java    |  2 +-
 .../source/extractor/extract/Command.java       |  2 +-
 .../source/extractor/extract/CommandOutput.java |  2 +-
 .../source/extractor/extract/CommandType.java   |  2 +-
 .../source/extractor/extract/ExtractType.java   |  2 +-
 .../extract/ProtocolSpecificLayer.java          | 16 ++--
 .../extractor/extract/QueryBasedExtractor.java  | 38 ++++-----
 .../extractor/extract/QueryBasedSource.java     | 48 +++++------
 .../extractor/extract/SourceSpecificLayer.java  | 14 +--
 .../extract/restapi/RestApiCommand.java         |  6 +-
 .../extract/restapi/RestApiCommandOutput.java   |  4 +-
 .../extract/restapi/RestApiConnector.java       | 18 ++--
 .../extract/restapi/RestApiExtractor.java       | 34 ++++----
 .../extract/restapi/RestApiSpecificLayer.java   |  4 +-
 .../extractor/extract/sftp/SftpExtractor.java   |  6 +-
 .../extractor/extract/sftp/SftpFsHelper.java    | 14 +--
 .../extract/sftp/SftpLightWeightFileSystem.java | 12 +--
 .../extractor/extract/sftp/SftpSource.java      | 12 +--
 .../extractor/filebased/CsvFileDownloader.java  |  6 +-
 .../extractor/filebased/FileBasedExtractor.java | 14 +--
 .../extractor/filebased/FileBasedHelper.java    |  2 +-
 .../filebased/FileBasedHelperException.java     |  2 +-
 .../extractor/filebased/FileBasedSource.java    | 18 ++--
 .../extractor/filebased/FileByteIterator.java   |  2 +-
 .../extractor/filebased/FileDownloader.java     |  4 +-
 .../extractor/filebased/GZIPFileDownloader.java |  4 +-
 .../filebased/SingleFileDownloader.java         |  4 +-
 .../filebased/SizeAwareFileBasedHelper.java     |  2 +-
 .../SizeAwareFileBasedHelperDecorator.java      |  4 +-
 .../filebased/TextFileBasedSource.java          | 14 +--
 .../TimestampAwareFileBasedHelper.java          |  2 +-
 .../TokenBasedFileInputStreamExtractor.java     | 10 +--
 .../filebased/TokenizedFileDownloader.java      |  4 +-
 .../extractor/hadoop/AvroFileExtractor.java     | 10 +--
 .../source/extractor/hadoop/AvroFileSource.java | 14 +--
 .../source/extractor/hadoop/AvroFsHelper.java   | 14 +--
 .../hadoop/HadoopFileInputExtractor.java        |  6 +-
 .../extractor/hadoop/HadoopFileInputSource.java | 20 ++---
 .../source/extractor/hadoop/HadoopFsHelper.java | 16 ++--
 .../extractor/hadoop/HadoopTextInputSource.java |  6 +-
 .../hadoop/OldApiHadoopFileInputExtractor.java  |  6 +-
 .../hadoop/OldApiHadoopFileInputSource.java     | 20 ++---
 .../hadoop/OldApiHadoopTextInputSource.java     |  6 +-
 .../hadoop/OldApiWritableFileExtractor.java     |  2 +-
 .../hadoop/OldApiWritableFileSource.java        | 10 +--
 .../extractor/partition/AppendMaxLimitType.java |  2 +-
 .../source/extractor/partition/Partition.java   | 12 +--
 .../source/extractor/partition/Partitioner.java | 22 ++---
 .../source/extractor/resultset/RecordSet.java   |  2 +-
 .../extractor/resultset/RecordSetList.java      |  2 +-
 .../source/extractor/schema/ArrayDataType.java  |  2 +-
 .../extractor/schema/ColumnAttributes.java      |  2 +-
 .../source/extractor/schema/ColumnNameCase.java |  2 +-
 .../source/extractor/schema/DataType.java       |  2 +-
 .../source/extractor/schema/EnumDataType.java   |  2 +-
 .../source/extractor/schema/MapDataType.java    |  2 +-
 .../gobblin/source/extractor/schema/Schema.java |  2 +-
 .../extractor/utils/InputStreamCSVReader.java   |  4 +-
 .../source/extractor/utils/ProxyFsInput.java    |  2 +-
 .../gobblin/source/extractor/utils/Utils.java   |  6 +-
 .../extractor/watermark/DateWatermark.java      |  6 +-
 .../extractor/watermark/HourWatermark.java      |  6 +-
 .../source/extractor/watermark/Predicate.java   |  2 +-
 .../extractor/watermark/SimpleWatermark.java    |  6 +-
 .../extractor/watermark/TimestampWatermark.java |  6 +-
 .../source/extractor/watermark/Watermark.java   |  4 +-
 .../extractor/watermark/WatermarkPredicate.java |  4 +-
 .../extractor/watermark/WatermarkType.java      |  2 +-
 .../workunit/MultiWorkUnitWeightedQueue.java    |  2 +-
 .../apache/gobblin/state/ConstructState.java    |  8 +-
 .../java/org/apache/gobblin/util/TestUtils.java | 14 +--
 .../gobblin/writer/AbstractAsyncDataWriter.java | 14 +--
 .../gobblin/writer/AvroDataWriterBuilder.java   |  2 +-
 .../gobblin/writer/AvroHdfsDataWriter.java      | 10 +--
 .../writer/CloseOnFlushWriterWrapper.java       | 14 +--
 .../apache/gobblin/writer/ConsoleWriter.java    |  6 +-
 .../gobblin/writer/ConsoleWriterBuilder.java    |  2 +-
 .../writer/DataWriterWrapperBuilder.java        |  4 +-
 .../org/apache/gobblin/writer/FsDataWriter.java | 24 +++---
 .../gobblin/writer/FsDataWriterBuilder.java     | 14 +--
 .../writer/HiveWritableHdfsDataWriter.java      |  4 +-
 .../HiveWritableHdfsDataWriterBuilder.java      |  6 +-
 .../gobblin/writer/MetadataAwareWriter.java     |  4 +-
 .../gobblin/writer/MetadataWriterWrapper.java   | 14 +--
 .../gobblin/writer/PartitionedDataWriter.java   | 26 +++---
 .../org/apache/gobblin/writer/Retriable.java    |  2 +-
 .../org/apache/gobblin/writer/RetryWriter.java  | 18 ++--
 ...SchemaBasedPartitionedDataWriterBuilder.java |  6 +-
 .../apache/gobblin/writer/SimpleDataWriter.java |  6 +-
 .../gobblin/writer/SimpleDataWriterBuilder.java | 12 +--
 .../apache/gobblin/writer/ThrottleWriter.java   | 20 ++---
 .../gobblin/writer/http/AbstractHttpWriter.java | 10 +--
 .../writer/http/AbstractHttpWriterBuilder.java  | 12 +--
 .../DelegatingHttpClientConnectionManager.java  |  2 +-
 .../apache/gobblin/writer/http/HttpWriter.java  |  2 +-
 .../gobblin/writer/http/HttpWriterBuilder.java  |  4 +-
 .../writer/http/HttpWriterDecoration.java       |  2 +-
 .../writer/http/HttpWriterDecorator.java        |  2 +-
 .../gobblin/writer/http/RestJsonWriter.java     |  4 +-
 .../writer/http/RestJsonWriterBuilder.java      |  6 +-
 .../apache/gobblin/writer/http/RestWriter.java  |  4 +-
 .../gobblin/writer/http/RestWriterBuilder.java  |  6 +-
 .../http/SalesForceRestWriterBuilder.java       | 12 +--
 .../writer/http/SalesforceRestWriter.java       |  6 +-
 .../http/UnexpectedResponseException.java       |  2 +-
 .../initializer/MultiWriterInitializer.java     |  6 +-
 .../initializer/WriterInitializerFactory.java   | 12 +--
 .../writer/objectstore/ObjectStoreClient.java   |  6 +-
 .../objectstore/ObjectStoreDeleteOperation.java |  6 +-
 .../objectstore/ObjectStoreOperation.java       |  6 +-
 .../ObjectStoreOperationBuilder.java            |  4 +-
 .../writer/objectstore/ObjectStoreWriter.java   |  8 +-
 .../objectstore/response/DeleteResponse.java    |  2 +-
 .../objectstore/response/GetObjectResponse.java |  4 +-
 .../SchemaBasedWriterPartitioner.java           |  4 +-
 .../TimeBasedAvroWriterPartitioner.java         | 10 +--
 .../partitioner/TimeBasedWriterPartitioner.java | 10 +--
 .../WorkUnitStateWriterPartitioner.java         |  6 +-
 .../writer/test/GobblinTestEventBusWriter.java  | 14 +--
 .../writer/test/TestingEventBusAsserter.java    |  4 +-
 .../gobblin/writer/test/TestingEventBuses.java  |  2 +-
 .../gobblin/async/AsyncDataDispatcherTest.java  |  4 +-
 .../gobblin/commit/FsRenameCommitStepTest.java  |  4 +-
 .../apache/gobblin/configuration/StateTest.java |  2 +-
 .../configuration/WorkUnitStateTest.java        |  6 +-
 .../workunit/MultiWorkUnitTest.java             |  6 +-
 .../gobblin/converter/EmptyIterableTest.java    |  2 +-
 ...bblinMetricsPinotFlattenerConverterTest.java | 16 ++--
 .../avro/AvroToBytesConverterTest.java          |  8 +-
 .../avro/BytesToAvroConverterTest.java          |  8 +-
 .../avro/FlattenNestedKeyConverterTest.java     | 10 +--
 .../JsonIntermediateToAvroConverterTest.java    | 10 +--
 .../converter/csv/CsvToJsonConverterV2Test.java |  6 +-
 .../filter/AvroFieldsPickConverterTest.java     |  8 +-
 .../http/AvroToRestJsonEntryConverterTest.java  |  6 +-
 .../ObjectStoreDeleteConverterTest.java         |  4 +-
 .../string/ObjectToStringConverterTest.java     |  8 +-
 .../string/StringFilterConverterTest.java       |  8 +-
 .../string/StringSplitterConverterTest.java     |  8 +-
 .../StringSplitterToListConverterTest.java      |  8 +-
 .../string/TextToStringConverterTest.java       |  6 +-
 .../gobblin/fork/CopyableGenericRecordTest.java |  2 +-
 .../apache/gobblin/fork/CopyableSchemaTest.java |  2 +-
 .../gobblin/fork/IdentityForkOperatorTest.java  |  6 +-
 .../TestDefaultHttpClientConfiguration.java     |  6 +-
 .../http/TestHttpClientConfiguratorLoader.java  |  4 +-
 .../gobblin/instrumented/InstrumentedTest.java  | 14 +--
 .../policies/count/RowCountRangePolicyTest.java | 10 +--
 .../publisher/BaseDataPublisherTest.java        | 20 ++---
 .../RowCountTaskLevelPolicyTest.java            | 14 +--
 .../RowLevelQualityCheckerTest.java             | 12 +--
 .../TaskLevelQualityCheckerTest.java            | 14 +--
 .../gobblin/qualitychecker/TestConstants.java   |  2 +-
 .../qualitychecker/TestRowLevelPolicy.java      |  6 +-
 .../qualitychecker/TestRowLevelPolicyFail.java  |  6 +-
 .../qualitychecker/TestTaskLevelPolicy.java     |  6 +-
 .../row/FrontLoadedSamplerTest.java             |  2 +-
 .../AvroGenericRecordAccessorTest.java          |  2 +-
 .../RecordAccessorProviderFactoryTest.java      |  2 +-
 .../security/ssl/SSLContextFactoryTest.java     |  2 +-
 .../org/apache/gobblin/serde/HiveSerDeTest.java | 34 ++++----
 .../RegexBasedPartitionedRetrieverTest.java     |  6 +-
 .../DatePartitionedAvroFileExtractorTest.java   | 36 ++++----
 .../extract/QueryBasedExtractorTest.java        | 30 +++----
 .../extractor/extract/QueryBasedSourceTest.java | 22 ++---
 .../filebased/FileBasedExtractorTest.java       | 10 +--
 .../filebased/FileBasedSourceTest.java          | 20 ++---
 .../filebased/TokenizedFileDownloaderTest.java  |  2 +-
 .../hadoop/HadoopFileInputSourceTest.java       |  8 +-
 .../extractor/hadoop/HadoopFsHelperTest.java    |  8 +-
 .../hadoop/OldApiHadoopFileInputSourceTest.java | 14 +--
 .../extractor/partition/PartitionerTest.java    | 12 +--
 .../extractor/watermark/DateWatermarkTest.java  |  2 +-
 .../extractor/watermark/HourWatermarkTest.java  |  2 +-
 .../watermark/SimpleWatermarkTest.java          |  4 +-
 .../watermark/TimestampWatermarkTest.java       |  4 +-
 .../MultiWorkUnitWeightedQueueTest.java         |  2 +-
 .../gobblin/state/ConstructStateTest.java       |  6 +-
 .../gobblin/writer/AvroHdfsDataWriterTest.java  |  8 +-
 .../writer/CloseOnFlushWriterWrapperTest.java   |  8 +-
 .../gobblin/writer/ConsoleWriterTest.java       | 10 +--
 .../apache/gobblin/writer/DestinationTest.java  |  4 +-
 .../writer/MetadataWriterWrapperTest.java       | 12 +--
 .../gobblin/writer/PartitionedWriterTest.java   | 18 ++--
 .../apache/gobblin/writer/RetryWriterTest.java  | 10 +--
 .../gobblin/writer/SimpleDataWriterTest.java    | 12 +--
 .../apache/gobblin/writer/TestConstants.java    |  2 +-
 .../gobblin/writer/ThrottleWriterTest.java      | 10 +--
 .../writer/http/SalesforceRestWriterTest.java   | 10 +--
 .../objectstore/ObjectStoreWriterTest.java      | 10 +--
 .../SchemaBasedWriterPartitionerTest.java       |  2 +-
 .../TimeBasedAvroWriterPartitionerTest.java     | 20 ++---
 .../test/GobblinTestEventBusWriterTest.java     |  8 +-
 .../test/TestPartitionAwareWriterBuilder.java   |  8 +-
 .../gobblin/writer/test/TestPartitioner.java    |  6 +-
 .../test/TestingEventBusAsserterTest.java       |  2 +-
 .../resources/converter/record_with_arrays.avsc |  2 +-
 .../conversion/hive/avro/AvroSchemaManager.java | 14 +--
 .../hive/avro/SchemaNotFoundException.java      |  2 +-
 .../converter/AbstractAvroToOrcConverter.java   | 36 ++++----
 .../HiveAvroToFlattenedOrcConverter.java        |  8 +-
 .../converter/HiveAvroToNestedOrcConverter.java |  6 +-
 .../hive/dataset/ConvertibleHiveDataset.java    | 10 +--
 .../dataset/ConvertibleHiveDatasetFinder.java   |  6 +-
 .../QueryBasedHiveConversionEntity.java         | 20 ++---
 .../entities/QueryBasedHivePublishEntity.java   |  2 +-
 .../hive/entities/SchemaAwareHivePartition.java |  2 +-
 .../hive/entities/SchemaAwareHiveTable.java     |  2 +-
 .../conversion/hive/events/EventConstants.java  |  4 +-
 .../hive/events/EventWorkunitUtils.java         | 14 +--
 .../hive/extractor/HiveBaseExtractor.java       | 16 ++--
 .../extractor/HiveBaseExtractorFactory.java     |  4 +-
 .../hive/extractor/HiveConvertExtractor.java    | 22 ++---
 .../extractor/HiveConvertExtractorFactory.java  |  4 +-
 .../provider/DatePatternUpdateProvider.java     |  4 +-
 .../hive/provider/HdfsBasedUpdateProvider.java  |  6 +-
 .../HiveMetastoreBasedUpdateProvider.java       |  4 +-
 .../hive/provider/HiveUnitUpdateProvider.java   |  2 +-
 .../hive/provider/UpdateNotFoundException.java  |  2 +-
 .../hive/provider/UpdateProviderFactory.java    | 10 +--
 .../hive/publisher/HiveConvertPublisher.java    | 54 ++++++------
 .../hive/query/HiveAvroORCQueryGenerator.java   |  6 +-
 .../query/HiveValidationQueryGenerator.java     |  6 +-
 .../hive/source/BackfillHiveSource.java         |  8 +-
 .../hive/source/HiveAvroToOrcSource.java        | 10 +--
 .../conversion/hive/source/HiveSource.java      | 70 +++++++--------
 .../conversion/hive/source/HiveWorkUnit.java    |  8 +-
 .../hive/watermarker/HiveSourceWatermarker.java | 12 +--
 .../HiveSourceWatermarkerFactory.java           |  4 +-
 .../watermarker/MultiKeyValueLongWatermark.java |  4 +-
 .../watermarker/PartitionLevelWatermarker.java  | 36 ++++----
 .../hive/watermarker/TableLevelWatermarker.java | 14 +--
 .../hive/writer/HiveQueryExecutionWriter.java   | 18 ++--
 .../hive/writer/HiveQueryWriterBuilder.java     | 10 +--
 .../management/copy/AllEqualComparator.java     |  2 +-
 .../management/copy/CloseableFsCopySource.java  | 16 ++--
 .../copy/ConcurrentBoundedWorkUnitList.java     |  6 +-
 .../data/management/copy/CopyConfiguration.java | 14 +--
 .../data/management/copy/CopyContext.java       |  2 +-
 .../data/management/copy/CopyEntity.java        |  8 +-
 .../data/management/copy/CopyResourcePool.java  |  8 +-
 .../data/management/copy/CopySource.java        | 90 ++++++++++----------
 .../data/management/copy/CopyableDataset.java   |  4 +-
 .../management/copy/CopyableDatasetBase.java    |  4 +-
 .../copy/CopyableDatasetMetadata.java           |  2 +-
 .../data/management/copy/CopyableFile.java      | 10 +--
 .../management/copy/CopyableFileFilter.java     |  2 +-
 .../copy/CopyableGlobDatasetFinder.java         |  4 +-
 .../management/copy/FileAwareInputStream.java   |  2 +-
 .../copy/IterableCopyableDataset.java           |  4 +-
 .../copy/IterableCopyableDatasetImpl.java       |  6 +-
 .../management/copy/OwnerAndPermission.java     |  2 +-
 .../management/copy/PreserveAttributes.java     |  2 +-
 .../copy/ReadyCopyableFileFilter.java           |  4 +-
 .../copy/RecursiveCopyableDataset.java          | 18 ++--
 .../management/copy/RecursivePathFinder.java    | 12 +--
 .../copy/SubsetFilesCopyableDataset.java        | 12 +--
 .../copy/SubsetFilesCopyableDatasetFinder.java  | 14 +--
 .../copy/TimestampBasedCopyableDataset.java     | 28 +++---
 .../copy/converter/DecryptConverter.java        | 16 ++--
 .../copy/converter/DistcpConverter.java         | 18 ++--
 .../copy/converter/UnGzipConverter.java         |  6 +-
 .../copy/entities/CommitStepCopyEntity.java     |  6 +-
 .../copy/entities/PostPublishStep.java          |  4 +-
 .../copy/entities/PrePublishStep.java           |  4 +-
 ...loseableFsFileAwareInputStreamExtractor.java |  8 +-
 .../copy/extractor/EmptyExtractor.java          |  6 +-
 .../FileAwareInputStreamExtractor.java          | 16 ++--
 .../copy/hive/HiveCopyEntityHelper.java         | 50 +++++------
 .../data/management/copy/hive/HiveDataset.java  | 34 ++++----
 .../management/copy/hive/HiveDatasetFinder.java | 30 +++----
 .../data/management/copy/hive/HiveFileSet.java  |  6 +-
 .../copy/hive/HiveLocationDescriptor.java       |  6 +-
 .../copy/hive/HivePartitionExtendedFilter.java  |  2 +-
 .../HivePartitionExtendedFilterFactory.java     |  2 +-
 .../copy/hive/HivePartitionFileSet.java         | 24 +++---
 .../hive/HivePartitionsDeregisterFileSet.java   |  4 +-
 .../HiveTableLocationNotMatchException.java     |  2 +-
 .../copy/hive/HiveTargetPathHelper.java         |  4 +-
 .../data/management/copy/hive/HiveUtils.java    |  2 +-
 .../copy/hive/PartitionFilterGenerator.java     |  2 +-
 .../PathBasedHivePartitionFilterFactory.java    | 10 +--
 .../copy/hive/PathBasedPartitionFilter.java     |  4 +-
 .../copy/hive/UnpartitionedTableFileSet.java    | 12 +--
 .../hive/avro/HiveAvroCopyEntityHelper.java     |  6 +-
 .../LookbackPartitionFilterGenerator.java       |  8 +-
 .../management/copy/predicates/AlwaysTrue.java  |  2 +-
 ...itionTableRegistrationTimeSkipPredicate.java |  8 +-
 .../RegistrationTimeSkipPredicate.java          | 10 +--
 .../RootDirectoryModtimeSkipPredicate.java      |  8 +-
 .../copy/prioritization/FileSetComparator.java  |  6 +-
 .../PrioritizedCopyableDataset.java             | 12 +--
 .../copy/publisher/CopyDataPublisher.java       | 52 +++++------
 .../publisher/CopyEventSubmitterHelper.java     | 14 +--
 .../publisher/DeletingCopyDataPublisher.java    | 22 ++---
 .../copy/recovery/RecoveryHelper.java           | 12 +--
 .../ConfigBasedCopyableDatasetFinder.java       |  6 +-
 .../copy/replication/ConfigBasedDataset.java    | 22 ++---
 .../replication/ConfigBasedDatasetsFinder.java  | 30 +++----
 .../replication/ConfigBasedMultiDatasets.java   |  8 +-
 .../management/copy/replication/CopyRoute.java  |  2 +-
 .../copy/replication/CopyRouteGenerator.java    |  2 +-
 .../replication/CopyRouteGeneratorBase.java     |  2 +-
 .../CopyRouteGeneratorOptimizedLatency.java     |  6 +-
 ...RouteGeneratorOptimizedNetworkBandwidth.java |  4 +-
 ...neratorOptimizedNetworkBandwidthForTest.java |  2 +-
 .../CopyRouteGeneratorOptimizer.java            |  2 +-
 .../copy/replication/DataFlowTopology.java      |  2 +-
 .../DataFlowTopologyPickerByHadoopFsSource.java |  4 +-
 .../DataFlowTopologyPickerBySource.java         |  2 +-
 .../management/copy/replication/EndPoint.java   |  6 +-
 .../copy/replication/EndPointFactory.java       |  2 +-
 .../copy/replication/HadoopFsEndPoint.java      |  4 +-
 .../replication/HadoopFsEndPointDataset.java    |  6 +-
 .../replication/HadoopFsEndPointFactory.java    |  4 +-
 .../copy/replication/HadoopFsReplicaConfig.java |  2 +-
 .../replication/ReplicaHadoopFsEndPoint.java    |  8 +-
 .../replication/ReplicationConfiguration.java   |  4 +-
 .../copy/replication/ReplicationCopyMode.java   |  2 +-
 .../ReplicationDataValidPathPicker.java         | 10 +--
 .../copy/replication/ReplicationMetaData.java   |  2 +-
 .../replication/SourceHadoopFsEndPoint.java     |  8 +-
 .../WatermarkMetadataGenerationCommitStep.java  |  6 +-
 .../copy/replication/WatermarkMetadataUtil.java |  6 +-
 .../CopyableFileWatermarkGenerator.java         |  8 +-
 .../watermark/CopyableFileWatermarkHelper.java  | 10 +--
 .../FullPathCopyableFileWatermarkGenerator.java | 10 +--
 .../copy/watermark/StringWatermark.java         |  8 +-
 .../writer/FileAwareInputStreamDataWriter.java  | 64 +++++++-------
 .../FileAwareInputStreamDataWriterBuilder.java  | 12 +--
 .../writer/TarArchiveInputStreamDataWriter.java | 12 +--
 .../TarArchiveInputStreamDataWriterBuilder.java |  8 +-
 .../data/management/dataset/Dataset.java        |  2 +-
 .../data/management/dataset/DatasetUtils.java   | 10 +--
 .../dataset/DefaultFileSystemGlobFinder.java    |  6 +-
 .../data/management/dataset/DummyDataset.java   | 10 +--
 .../SimpleDatasetHierarchicalPrioritizer.java   | 14 +--
 .../dataset/SimpleDatasetRequest.java           | 16 ++--
 .../dataset/SimpleDatasetRequestor.java         |  6 +-
 .../management/hive/HiveConfigClientUtils.java  |  6 +-
 .../management/hive/HiveRegistrableDataset.java |  8 +-
 .../partition/CopyableDatasetRequestor.java     | 18 ++--
 .../gobblin/data/management/partition/File.java |  2 +-
 .../data/management/partition/FileSet.java      | 12 +--
 .../partition/FileSetResourceEstimator.java     | 12 +--
 .../management/partition/StaticFileSet.java     |  6 +-
 .../policy/CombineSelectionPolicy.java          |  8 +-
 .../EmbeddedRetentionSelectionPolicy.java       |  6 +-
 .../policy/NewestKSelectionPolicy.java          |  4 +-
 .../policy/SelectAfterTimeBasedPolicy.java      |  8 +-
 .../data/management/policy/SelectAllPolicy.java |  4 +-
 .../policy/SelectBeforeTimeBasedPolicy.java     |  8 +-
 .../policy/SelectBetweenTimeBasedPolicy.java    |  8 +-
 .../management/policy/SelectNothingPolicy.java  |  4 +-
 .../policy/VersionSelectionPolicy.java          |  4 +-
 .../management/retention/DatasetCleaner.java    | 32 +++----
 .../management/retention/RetentionEvents.java   |  4 +-
 .../retention/action/AccessControlAction.java   | 12 +--
 .../action/MultiAccessControlAction.java        | 10 +--
 .../retention/action/RetentionAction.java       | 22 ++---
 .../retention/dataset/CleanableDataset.java     |  6 +-
 .../retention/dataset/CleanableDatasetBase.java | 10 +--
 .../retention/dataset/CleanableHiveDataset.java | 24 +++---
 .../dataset/ConfigurableCleanableDataset.java   | 24 +++---
 .../retention/dataset/FsCleanableHelper.java    | 12 +--
 .../dataset/ModificationTimeDataset.java        | 12 +--
 .../MultiVersionCleanableDatasetBase.java       | 24 +++---
 .../retention/dataset/SnapshotDataset.java      | 14 +--
 .../retention/dataset/TrackingDataset.java      | 12 +--
 .../finder/CleanableHiveDatasetFinder.java      | 10 +--
 .../retention/dataset/finder/DatasetFinder.java |  6 +-
 .../policy/CombineRetentionPolicy.java          |  6 +-
 .../policy/DeleteAllRetentionPolicy.java        |  4 +-
 .../policy/DeleteNothingRetentionPolicy.java    |  4 +-
 .../policy/NewestKRetentionPolicy.java          |  6 +-
 .../policy/PredicateRetentionPolicy.java        |  4 +-
 .../policy/RawDatasetRetentionPolicy.java       |  8 +-
 .../retention/policy/RetentionPolicy.java       |  4 +-
 .../policy/TimeBasedRetentionPolicy.java        | 10 +--
 .../policy/predicates/WhitelistPredicate.java   |  6 +-
 .../ConfigBasedCleanabledDatasetFinder.java     | 12 +--
 .../profile/ConfigurableGlobDatasetFinder.java  | 12 +--
 .../profile/GlobCleanableDatasetFinder.java     |  6 +-
 .../profile/ManagedCleanableDatasetFinder.java  | 20 ++---
 .../profile/ModificationTimeDatasetProfile.java |  6 +-
 .../profile/MultiCleanableDatasetFinder.java    |  4 +-
 .../retention/profile/MultiDatasetFinder.java   | 20 ++---
 .../profile/ProxyableDatasetProfile.java        | 16 ++--
 .../profile/SnapshotDatasetProfile.java         |  6 +-
 .../profile/TrackingDatasetProfile.java         |  8 +-
 .../retention/version/DatasetVersion.java       |  4 +-
 .../version/FileStatusDatasetVersion.java       |  2 +-
 .../version/HiveDatasetVersionCleaner.java      | 14 +--
 .../retention/version/StringDatasetVersion.java |  2 +-
 .../version/TimestampedDatasetVersion.java      |  2 +-
 .../retention/version/VersionCleaner.java       |  6 +-
 .../version/finder/DatasetVersionFinder.java    |  4 +-
 .../finder/DateTimeDatasetVersionFinder.java    |  6 +-
 .../finder/FileLevelTimestampVersionFinder.java |  8 +-
 .../finder/GlobModTimeDatasetVersionFinder.java |  6 +-
 .../finder/ModDateTimeDatasetVersionFinder.java |  8 +-
 .../version/finder/SingleVersionFinder.java     | 10 +--
 .../finder/UnixTimestampVersionFinder.java      |  6 +-
 .../retention/version/finder/VersionFinder.java |  4 +-
 .../finder/WatermarkDatasetVersionFinder.java   |  6 +-
 .../data/management/trash/AsyncTrash.java       |  8 +-
 .../management/trash/GobblinProxiedTrash.java   |  2 +-
 .../data/management/trash/GobblinTrash.java     |  2 +-
 .../trash/ImmediateDeletionTrash.java           |  4 +-
 .../data/management/trash/MockTrash.java        |  2 +-
 .../trash/NoopSnapshotCleanupPolicy.java        |  2 +-
 .../data/management/trash/ProxiedTrash.java     |  4 +-
 .../management/trash/SnapshotCleanupPolicy.java |  2 +-
 .../data/management/trash/TestTrash.java        |  2 +-
 .../trash/TimeBasedSnapshotCleanupPolicy.java   |  2 +-
 .../gobblin/data/management/trash/Trash.java    |  4 +-
 .../data/management/trash/TrashFactory.java     |  2 +-
 .../data/management/version/DatasetVersion.java |  2 +-
 .../management/version/FileStatusAware.java     |  2 +-
 .../version/FileStatusDatasetVersion.java       |  2 +-
 .../FileStatusTimestampedDatasetVersion.java    |  2 +-
 .../version/FileSystemDatasetVersion.java       |  2 +-
 .../management/version/HiveDatasetVersion.java  |  2 +-
 .../version/StringDatasetVersion.java           |  2 +-
 .../version/TimestampedDatasetVersion.java      |  2 +-
 .../version/TimestampedHiveDatasetVersion.java  |  2 +-
 .../finder/AbstractDatasetVersionFinder.java    | 10 +--
 .../AbstractHiveDatasetVersionFinder.java       | 14 +--
 .../version/finder/DatasetVersionFinder.java    |  6 +-
 .../finder/DatePartitionHiveVersionFinder.java  |  8 +-
 .../finder/DateTimeDatasetVersionFinder.java    | 10 +--
 .../finder/FileLevelTimestampVersionFinder.java | 12 +--
 .../finder/GlobModTimeDatasetVersionFinder.java |  6 +-
 .../finder/ModDateTimeDatasetVersionFinder.java | 10 +--
 .../version/finder/SingleVersionFinder.java     | 12 +--
 .../finder/UnixTimestampVersionFinder.java      |  8 +-
 .../version/finder/VersionFinder.java           |  6 +-
 .../finder/WatermarkDatasetVersionFinder.java   |  6 +-
 .../runtime/embedded/EmbeddedGobblinDistcp.java | 22 ++---
 .../runtime/retention/DatasetCleanerCli.java    |  8 +-
 .../util/commit/DeleteFileCommitStep.java       | 10 +--
 .../SimpleHiveDatasetTieringPrioritizer.java    | 20 ++---
 .../util/test/RetentionTestDataGenerator.java   |  6 +-
 .../gobblin/util/test/RetentionTestHelper.java  | 22 ++---
 .../management/ConversionHiveTestUtils.java     |  8 +-
 .../conversion/hive/BackfillHiveSourceTest.java |  8 +-
 .../hive/CopyPartitionParametersTest.java       |  6 +-
 .../conversion/hive/HiveSourceTest.java         | 20 ++---
 .../hive/LocalHiveMetastoreTestUtils.java       |  6 +-
 .../converter/HiveAvroToOrcConverterTest.java   | 20 ++---
 .../hive/converter/HiveSchemaEvolutionTest.java |  8 +-
 .../dataset/ConvertibleHiveDatasetTest.java     |  8 +-
 .../provider/DatePatternUpdateProviderTest.java |  2 +-
 .../util/HiveAvroORCQueryGeneratorTest.java     |  8 +-
 .../PartitionLevelWatermarkerTest.java          | 20 ++---
 .../watermarker/TableLevelWatermarkerTest.java  | 12 +--
 .../copy/ConcurrentBoundedWorkUnitListTest.java |  8 +-
 .../copy/CopySourcePrioritizationTest.java      | 22 ++---
 .../data/management/copy/CopySourceTest.java    | 14 +--
 .../copy/CopyableDatasetMetadataTest.java       |  4 +-
 .../data/management/copy/CopyableFileTest.java  |  6 +-
 .../data/management/copy/CopyableFileUtils.java |  2 +-
 .../management/copy/PreserveAttributesTest.java |  4 +-
 .../copy/ReadyCopyableFileFilterTest.java       |  4 +-
 .../copy/RecursiveCopyableDatasetTest.java      | 10 +--
 .../management/copy/TestCopyableDataset.java    |  4 +-
 .../copy/TestCopyableDatasetFinder.java         |  4 +-
 .../TestCopyablePartitionableDatasedFinder.java |  4 +-
 .../copy/TestCopyablePartitionableDataset.java  |  2 +-
 .../copy/TimestampBasedCopyableDatasetTest.java | 18 ++--
 .../copy/converter/DecryptConverterTest.java    | 16 ++--
 .../copy/converter/UnGzipConverterTest.java     | 10 +--
 .../extractor/InputStreamExtractorTest.java     | 14 +--
 .../copy/hive/HiveCopyEntityHelperTest.java     | 14 +--
 .../copy/hive/HiveDatasetFinderTest.java        |  6 +-
 .../management/copy/hive/HiveDatasetTest.java   |  4 +-
 .../copy/hive/HiveTargetPathHelperTest.java     |  2 +-
 .../copy/hive/WhitelistBlacklistTest.java       |  2 +-
 .../LookbackPartitionFilterGeneratorTest.java   |  2 +-
 .../RegistrationTimeSkipPredicateTest.java      | 12 +--
 .../copy/publisher/CopyDataPublisherTest.java   | 28 +++---
 .../DeletingCopyDataPublisherTest.java          | 22 ++---
 .../copy/recovery/RecoveryHelperTest.java       | 16 ++--
 .../ConfigBasedDatasetsFinderTest.java          |  2 +-
 .../replication/ConfigBasedDatasetsTest.java    | 26 +++---
 .../replication/CopyRouteGeneratorTest.java     |  6 +-
 .../ReplicationConfigurationTest.java           |  2 +-
 .../FileAwareInputStreamDataWriterTest.java     | 30 +++----
 .../TarArchiveInputStreamDataWriterTest.java    | 28 +++---
 .../data/management/partition/FileSetTest.java  |  6 +-
 .../policy/NewestKSelectionPolicyTest.java      |  4 +-
 .../policy/TimeBasedSelectionPolicyTest.java    |  4 +-
 .../retention/CleanableDatasetBaseTest.java     | 18 ++--
 .../retention/CombineRetentionPolicyTest.java   | 20 ++---
 .../ConfigurableCleanableDatasetTest.java       | 14 +--
 .../retention/DatasetVersionFinderTest.java     | 12 +--
 .../retention/FsCleanableHelperTest.java        | 10 +--
 .../retention/NewestKRetentionPolicyTest.java   |  8 +-
 .../retention/TimeBasedRetentionPolicyTest.java |  6 +-
 .../TimestampedDatasetVersionFinderTest.java    | 10 +--
 .../UnixTimestampVersionFinderTest.java         |  8 +-
 .../WatermarkDatasetVersionFinderTest.java      |  6 +-
 .../retention/action/RetentionActionTest.java   |  4 +-
 .../integration/HiveRetentionTest.java          | 12 +--
 .../integration/RetentionIntegrationTest.java   |  8 +-
 .../retention/sql/SqlBasedRetentionPoc.java     |  2 +-
 .../data/management/retention/sql/SqlUdfs.java  |  2 +-
 .../test/ContainsARetentionPolicy.java          |  2 +-
 .../test/ContainsBRetentionPolicy.java          |  2 +-
 .../test/ContainsCRetentionPolicy.java          |  2 +-
 .../test/ContainsStringRetentionPolicy.java     |  8 +-
 .../version/HiveDatasetVersionCleanerTest.java  |  4 +-
 .../data/management/trash/AsyncTrashTest.java   |  2 +-
 .../data/management/trash/MockTrashTest.java    |  2 +-
 .../management/trash/TestCleanupPolicy.java     |  2 +-
 .../data/management/trash/TestTrashTest.java    |  2 +-
 .../data/management/trash/TrashFactoryTest.java |  2 +-
 .../data/management/trash/TrashTest.java        |  2 +-
 .../data/management/trash/TrashTestBase.java    |  2 +-
 .../data/management/util/PathUtilsTest.java     |  4 +-
 .../DatePartitionedHiveVersionFinderTest.java   |  8 +-
 .../embedded/EmbeddedGobblinDistcpTest.java     |  2 +-
 ...SimpleHiveDatasetTieringPrioritizerTest.java |  6 +-
 .../example/simplejson/SimpleJsonConverter.java | 14 +--
 .../example/simplejson/SimpleJsonExtractor.java | 12 +--
 .../example/simplejson/SimpleJsonSource.java    | 16 ++--
 .../wikipedia/EmbeddedWikipediaExample.java     | 28 +++---
 .../example/wikipedia/WikipediaConverter.java   |  8 +-
 .../example/wikipedia/WikipediaExtractor.java   | 16 ++--
 .../example/wikipedia/WikipediaPartitioner.java |  6 +-
 .../example/wikipedia/WikipediaSource.java      | 24 +++---
 .../org/apache/gobblin/hive/HiveConstants.java  |  4 +-
 .../java/org/apache/gobblin/hive/HiveLock.java  |  4 +-
 .../hive/HiveMetaStoreClientFactory.java        |  2 +-
 .../gobblin/hive/HiveMetastoreClientPool.java   |  6 +-
 .../org/apache/gobblin/hive/HivePartition.java  |  4 +-
 .../gobblin/hive/HivePartitionComparator.java   |  2 +-
 .../org/apache/gobblin/hive/HiveRegProps.java   | 10 +--
 .../org/apache/gobblin/hive/HiveRegister.java   | 22 ++---
 .../apache/gobblin/hive/HiveRegisterStep.java   |  6 +-
 .../apache/gobblin/hive/HiveRegisterUtils.java  | 10 +--
 .../gobblin/hive/HiveRegistrationUnit.java      |  6 +-
 .../hive/HiveRegistrationUnitComparator.java    |  6 +-
 .../apache/gobblin/hive/HiveSerDeManager.java   |  8 +-
 .../apache/gobblin/hive/HiveSerDeWrapper.java   |  6 +-
 .../java/org/apache/gobblin/hive/HiveTable.java |  6 +-
 .../gobblin/hive/HiveTableComparator.java       |  2 +-
 .../gobblin/hive/PartitionDeregisterStep.java   |  6 +-
 .../gobblin/hive/TableDeregisterStep.java       |  4 +-
 .../gobblin/hive/avro/HiveAvroSerDeManager.java | 20 ++---
 .../metastore/HiveMetaStoreBasedRegister.java   | 36 ++++----
 .../metastore/HiveMetaStoreEventHelper.java     | 10 +--
 .../hive/metastore/HiveMetaStoreUtils.java      | 16 ++--
 .../hive/policy/HiveRegistrationPolicy.java     |  6 +-
 .../hive/policy/HiveRegistrationPolicyBase.java | 36 ++++----
 .../policy/HiveSnapshotRegistrationPolicy.java  | 12 +--
 .../org/apache/gobblin/hive/spec/HiveSpec.java  |  8 +-
 .../hive/spec/HiveSpecWithPostActivities.java   |  6 +-
 .../hive/spec/HiveSpecWithPreActivities.java    |  6 +-
 .../hive/spec/HiveSpecWithPredicates.java       |  6 +-
 .../gobblin/hive/spec/SimpleHiveSpec.java       | 12 +--
 .../gobblin/hive/spec/activity/Activity.java    |  6 +-
 .../spec/activity/DropPartitionActivity.java    |  6 +-
 .../hive/spec/activity/DropTableActivity.java   |  4 +-
 .../predicate/PartitionNotExistPredicate.java   |  6 +-
 .../spec/predicate/TableNotExistPredicate.java  |  4 +-
 .../hive/HiveMetaStoreClientFactoryTest.java    |  2 +-
 .../HiveRegistrationUnitComparatorTest.java     |  4 +-
 .../hive/metastore/HiveMetaStoreUtilsTest.java  |  6 +-
 .../policy/HiveRegistrationPolicyBaseTest.java  |  8 +-
 .../metastore/DatabaseJobHistoryStore.java      | 10 +--
 .../gobblin/metastore/DatasetStateStore.java    |  4 +-
 .../apache/gobblin/metastore/FsStateStore.java  | 10 +--
 .../gobblin/metastore/FsStateStoreFactory.java  | 10 +--
 .../metastore/JobHistoryDataSourceProvider.java |  6 +-
 .../gobblin/metastore/JobHistoryStore.java      |  6 +-
 .../gobblin/metastore/MetaStoreModule.java      |  2 +-
 .../gobblin/metastore/MysqlStateStore.java      | 12 +--
 .../metastore/MysqlStateStoreFactory.java       | 10 +--
 .../apache/gobblin/metastore/StateStore.java    |  4 +-
 .../database/DatabaseJobHistoryStoreV100.java   | 34 ++++----
 .../database/DatabaseJobHistoryStoreV101.java   | 32 +++----
 .../database/DatabaseJobHistoryStoreV102.java   |  6 +-
 .../gobblin/metastore/database/Filter.java      |  2 +-
 .../database/SupportedDatabaseVersion.java      |  2 +-
 .../VersionedDatabaseJobHistoryStore.java       |  4 +-
 .../DatasetUrnStateStoreNameParser.java         |  2 +-
 .../GuidDatasetUrnStateStoreNameParser.java     |  4 +-
 .../SimpleDatasetUrnStateStoreNameParser.java   |  2 +-
 .../DatabaseJobHistoryStoreSchemaManager.java   |  4 +-
 .../gobblin/metastore/util/MySqlJdbcUrl.java    |  2 +-
 .../metastore/util/StateStoreCleaner.java       |  8 +-
 .../metastore/DatabaseJobHistoryStoreTest.java  | 34 ++++----
 .../DatabaseJobHistoryStoreV100Test.java        |  2 +-
 .../DatabaseJobHistoryStoreV101Test.java        |  2 +-
 .../gobblin/metastore/FsStateStoreTest.java     |  8 +-
 .../GuidDatasetUrnStateStoreNameParserTest.java |  4 +-
 .../testing/ITestMetastoreDatabase.java         |  2 +-
 .../metastore/testing/TestMetadataDatabase.java |  2 +-
 .../testing/TestMetastoreDatabaseFactory.java   |  2 +-
 .../testing/TestMetastoreDatabaseServer.java    | 10 +--
 .../src/main/avro/FlatGobblinMetric.avsc        |  2 +-
 .../src/main/avro/GobblinTrackingEvent.avsc     |  2 +-
 .../src/main/avro/MetricReport.avsc             |  2 +-
 .../gobblin/metrics/FlatGobblinMetric.java      |  2 +-
 .../gobblin/metrics/GobblinTrackingEvent.java   |  2 +-
 .../org/apache/gobblin/metrics/Metric.java      |  2 +-
 .../apache/gobblin/metrics/MetricReport.java    |  2 +-
 .../MetricsFileSystemInstrumentation.java       | 18 ++--
 .../metrics/ConsoleEventReporterFactory.java    |  4 +-
 .../gobblin/metrics/ConsoleReporterFactory.java |  6 +-
 .../gobblin/metrics/ContextAwareCounter.java    |  6 +-
 .../gobblin/metrics/ContextAwareGauge.java      |  4 +-
 .../gobblin/metrics/ContextAwareHistogram.java  |  4 +-
 .../gobblin/metrics/ContextAwareMeter.java      |  4 +-
 .../gobblin/metrics/ContextAwareMetric.java     |  4 +-
 .../metrics/ContextAwareMetricFactory.java      |  2 +-
 .../gobblin/metrics/ContextAwareTimer.java      |  4 +-
 .../org/apache/gobblin/metrics/Counters.java    |  2 +-
 .../metrics/CustomCodahaleReporterFactory.java  |  2 +-
 .../gobblin/metrics/CustomReporterFactory.java  |  4 +-
 .../apache/gobblin/metrics/InnerCounter.java    |  4 +-
 .../org/apache/gobblin/metrics/InnerGauge.java  |  4 +-
 .../apache/gobblin/metrics/InnerHistogram.java  |  4 +-
 .../org/apache/gobblin/metrics/InnerMeter.java  |  4 +-
 .../gobblin/metrics/InnerMetricContext.java     | 10 +--
 .../org/apache/gobblin/metrics/InnerTimer.java  |  4 +-
 .../apache/gobblin/metrics/Measurements.java    |  2 +-
 .../apache/gobblin/metrics/MetricContext.java   | 12 +--
 .../org/apache/gobblin/metrics/MetricNames.java |  2 +-
 .../gobblin/metrics/RootMetricContext.java      | 14 +--
 .../java/org/apache/gobblin/metrics/Tag.java    |  2 +-
 .../gobblin/metrics/TagBasedMetricFilter.java   |  2 +-
 .../org/apache/gobblin/metrics/Taggable.java    |  2 +-
 .../java/org/apache/gobblin/metrics/Tagged.java |  2 +-
 .../metrics/broker/MetricContextFactory.java    | 28 +++---
 .../metrics/broker/MetricContextKey.java        |  4 +-
 .../broker/SubTaggedMetricContextKey.java       |  2 +-
 .../metrics/context/ContextWeakReference.java   |  8 +-
 .../metrics/context/NameConflictException.java  |  2 +-
 .../metrics/context/ReportableContext.java      |  6 +-
 .../context/filter/AllContextFilter.java        |  8 +-
 .../metrics/context/filter/ContextFilter.java   |  6 +-
 .../context/filter/ContextFilterFactory.java    |  2 +-
 .../apache/gobblin/metrics/event/EventName.java |  2 +-
 .../gobblin/metrics/event/EventSubmitter.java   |  6 +-
 .../apache/gobblin/metrics/event/JobEvent.java  |  4 +-
 .../gobblin/metrics/event/MultiPartEvent.java   | 30 +++----
 .../gobblin/metrics/event/MultiTimingEvent.java |  2 +-
 .../apache/gobblin/metrics/event/TaskEvent.java |  4 +-
 .../gobblin/metrics/event/TimingEvent.java      |  2 +-
 .../gobblin/metrics/event/sla/SlaEventKeys.java |  2 +-
 .../metrics/event/sla/SlaEventSubmitter.java    |  6 +-
 .../metrics/example/ReporterExampleBase.java    | 10 +--
 .../gobblin/metrics/metric/InnerMetric.java     |  4 +-
 .../apache/gobblin/metrics/metric/Metrics.java  |  2 +-
 .../gobblin/metrics/metric/ProxyMetric.java     |  2 +-
 .../metrics/metric/filter/MetricFilters.java    |  2 +-
 .../metric/filter/MetricNameRegexFilter.java    |  2 +-
 .../metrics/metric/filter/MetricTypeFilter.java |  4 +-
 .../metrics/notification/EventNotification.java |  4 +-
 .../MetricContextCleanupNotification.java       |  4 +-
 .../NewMetricContextNotification.java           |  6 +-
 .../metrics/notification/Notification.java      |  2 +-
 .../reporter/ConfiguredScheduledReporter.java   |  8 +-
 .../metrics/reporter/ContextAwareReporter.java  | 20 ++---
 .../reporter/ContextAwareScheduledReporter.java |  4 +-
 .../gobblin/metrics/reporter/EventReporter.java | 16 ++--
 .../metrics/reporter/MetricReportReporter.java  |  8 +-
 .../reporter/OutputStreamEventReporter.java     | 12 +--
 .../metrics/reporter/OutputStreamReporter.java  |  6 +-
 .../RecursiveScheduledMetricReporter.java       |  4 +-
 .../reporter/RecursiveScheduledReporter.java    |  4 +-
 .../metrics/reporter/ScheduledReporter.java     | 16 ++--
 .../reporter/util/AvroBinarySerializer.java     |  2 +-
 .../reporter/util/AvroJsonSerializer.java       |  2 +-
 .../metrics/reporter/util/AvroSerializer.java   |  2 +-
 .../metrics/reporter/util/EventUtils.java       |  4 +-
 .../reporter/util/FixedSchemaVersionWriter.java |  4 +-
 .../reporter/util/MetricReportUtils.java        |  4 +-
 .../reporter/util/NoopSchemaVersionWriter.java  |  4 +-
 .../reporter/util/SchemaVersionWriter.java      |  2 +-
 .../metrics/test/ContextStoreReporter.java      |  6 +-
 .../gobblin/metrics/test/MetricsAssert.java     | 10 +--
 .../gobblin/metrics/test/TestConstants.java     |  2 +-
 .../gobblin/metrics/test/TimestampedValue.java  |  2 +-
 .../MetricsFileSystemInstrumentationTest.java   |  2 +-
 .../metrics/ContextAwareMetricFactoryTest.java  |  4 +-
 .../gobblin/metrics/MetricContextTest.java      |  6 +-
 .../metrics/OutputStreamReporterTest.java       |  4 +-
 .../gobblin/metrics/RootMetricContextTest.java  | 12 +--
 .../org/apache/gobblin/metrics/TagTest.java     |  2 +-
 .../org/apache/gobblin/metrics/TaggedTest.java  |  2 +-
 .../broker/MetricContextFactoryTest.java        | 14 +--
 .../metrics/callback/NotificationStore.java     |  4 +-
 .../metric/filter/MetricFiltersTest.java        |  2 +-
 .../filter/MetricNameRegexFilterTest.java       |  2 +-
 .../metric/filter/MetricTypeFilterTest.java     |  2 +-
 .../metrics/performance/Incrementer.java        |  2 +-
 .../performance/MetricsPerformanceTest.java     |  2 +-
 .../metrics/performance/MetricsUpdater.java     |  6 +-
 .../metrics/performance/PerformanceUtils.java   |  4 +-
 .../java/org/apache/gobblin/MetricsHelper.java  |  4 +-
 .../apache/gobblin/metrics/GobblinMetrics.java  | 28 +++---
 .../gobblin/metrics/GobblinMetricsRegistry.java |  6 +-
 .../metrics/reporter/PrefixContextFilter.java   | 10 +--
 .../metrics/reporter/ScheduledReporterTest.java | 12 +--
 .../avro/AvroToJsonBytesConverter.java          |  2 +-
 .../AvroToJsonBytesWithMetadataConverter.java   | 10 +--
 .../converter/avro/AvroToJsonConverter.java     | 10 +--
 .../AvroToJsonRecordWithMetadataConverter.java  | 14 +--
 .../avro/AvroToJsonStringConverter.java         |  2 +-
 .../avro/AvroToJsonStringConverterBase.java     | 10 +--
 ...roToJsonRecordWithMetadataConverterTest.java | 12 +--
 .../avro/AvroToJsonStringConverterTest.java     | 10 +--
 .../azkaban/AzkabanCompactionJobLauncher.java   | 20 ++---
 .../gobblin/azkaban/AzkabanGobblinDaemon.java   |  8 +-
 .../azkaban/AzkabanGobblinYarnAppLauncher.java  |  6 +-
 .../azkaban/AzkabanIntegrationTestLauncher.java |  6 +-
 .../gobblin/azkaban/AzkabanJobLauncher.java     | 34 ++++----
 .../azkaban/AzkabanStateStoreCleanerJob.java    |  4 +-
 .../org/apache/gobblin/azkaban/AzkabanTags.java |  2 +-
 .../hive/validation/ValidationJob.java          | 52 +++++------
 .../retention/Avro2OrcStaleDatasetCleaner.java  | 26 +++---
 .../management/retention/DatasetCleanerJob.java |  2 +-
 .../management/trash/TrashCollectorJob.java     |  2 +-
 .../org/apache/gobblin/codec/Base64Codec.java   |  2 +-
 .../org/apache/gobblin/codec/GzipCodec.java     |  4 +-
 .../compliance/ComplianceConfigurationKeys.java |  2 +-
 .../gobblin/compliance/ComplianceEvents.java    |  2 +-
 .../gobblin/compliance/ComplianceJob.java       | 24 +++---
 .../gobblin/compliance/DatasetDescriptor.java   |  2 +-
 .../compliance/DatasetDescriptorImpl.java       |  2 +-
 .../compliance/HivePartitionDataset.java        |  6 +-
 .../compliance/HivePartitionDatasetPolicy.java  |  2 +-
 .../gobblin/compliance/HivePartitionFinder.java | 18 ++--
 .../compliance/HivePartitionVersion.java        |  4 +-
 .../compliance/HivePartitionVersionFinder.java  | 14 +--
 .../compliance/HivePartitionVersionPolicy.java  |  4 +-
 .../compliance/HiveProxyQueryExecutor.java      |  8 +-
 .../org/apache/gobblin/compliance/Policy.java   |  2 +-
 .../gobblin/compliance/QueryExecutor.java       |  2 +-
 .../azkaban/ComplianceAzkabanJob.java           |  8 +-
 .../gobblin/compliance/purger/CommitPolicy.java |  2 +-
 .../purger/HivePurgerCommitPolicy.java          |  2 +-
 .../compliance/purger/HivePurgerConverter.java  |  8 +-
 .../compliance/purger/HivePurgerExtractor.java  | 18 ++--
 .../compliance/purger/HivePurgerPolicy.java     |  6 +-
 .../compliance/purger/HivePurgerPublisher.java  | 28 +++---
 .../purger/HivePurgerQueryTemplate.java         |  4 +-
 .../compliance/purger/HivePurgerSource.java     | 36 ++++----
 .../compliance/purger/HivePurgerWriter.java     |  4 +-
 .../purger/HivePurgerWriterBuilder.java         |  6 +-
 .../gobblin/compliance/purger/PurgePolicy.java  |  2 +-
 .../compliance/purger/PurgeableDataset.java     |  4 +-
 .../purger/PurgeableHivePartitionDataset.java   | 16 ++--
 .../PurgeableHivePartitionDatasetSchema.java    |  2 +-
 .../compliance/restore/AdhocRestorePolicy.java  | 14 +--
 .../restore/ComplianceRestoreJob.java           | 20 ++---
 .../restore/HivePartitionRestorePolicy.java     |  6 +-
 .../compliance/restore/LKGRestorePolicy.java    | 18 ++--
 .../compliance/restore/RestorableDataset.java   |  4 +-
 .../restore/RestorableHivePartitionDataset.java | 20 ++---
 .../RestorableHivePartitionDatasetFinder.java   | 12 +--
 .../compliance/restore/RestorePolicy.java       |  2 +-
 .../CleanableHivePartitionDataset.java          | 20 ++---
 .../CleanableHivePartitionDatasetFinder.java    | 10 +--
 .../retention/ComplianceRetentionJob.java       | 36 ++++----
 .../HivePartitionRetentionVersion.java          |  6 +-
 .../HivePartitionVersionRetentionCleaner.java   | 20 ++---
 ...ePartitionVersionRetentionCleanerPolicy.java | 12 +--
 .../HivePartitionVersionRetentionReaper.java    | 28 +++---
 ...vePartitionVersionRetentionReaperPolicy.java | 12 +--
 .../HivePartitionVersionRetentionRunner.java    | 10 +--
 .../gobblin/compliance/utils/DatasetUtils.java  |  4 +-
 .../compliance/utils/PartitionUtils.java        |  4 +-
 .../gobblin/compliance/utils/ProxyUtils.java    | 14 +--
 .../validation/ComplianceValidationJob.java     | 20 ++---
 .../validation/ValidatableDataset.java          |  4 +-
 .../purger/HivePurgerConverterTest.java         |  4 +-
 .../purger/HivePurgerExtractorTest.java         |  2 +-
 .../compliance/purger/HivePurgerWriterTest.java |  2 +-
 .../gobblin/couchbase/common/TupleDocument.java |  2 +-
 .../converter/AnyToCouchbaseJsonConverter.java  | 16 ++--
 .../AvroToCouchbaseTupleConverter.java          | 14 +--
 .../writer/CouchbaseEnvironmentFactory.java     |  2 +-
 .../couchbase/writer/CouchbaseWriter.java       | 22 ++---
 .../writer/CouchbaseWriterBuilder.java          | 14 +--
 .../CouchbaseWriterConfigurationKeys.java       |  2 +-
 .../gobblin/couchbase/CouchbaseTestServer.java  |  4 +-
 .../AnyToCouchbaseJsonConverterTest.java        |  8 +-
 .../AvroToCouchbaseTupleConverterTest.java      |  6 +-
 .../couchbase/writer/CouchbaseWriterTest.java   | 26 +++---
 .../AvroStringFieldEncryptorConverter.java      |  6 +-
 ...ordToEncryptedSerializedRecordConverter.java | 10 +--
 .../StringFieldEncryptorConverter.java          | 12 +--
 .../crypto/GobblinEncryptionProvider.java       |  6 +-
 .../crypto/JCEKSKeystoreCredentialStoreCli.java |  8 +-
 .../AvroStringFieldEncryptorConverterTest.java  |  8 +-
 ...oEncryptedSerializedRecordConverterTest.java | 14 +--
 .../crypto/GobblinEncryptionProviderTest.java   |  4 +-
 .../src/test/resources/record_with_arrays.avsc  |  2 +-
 .../gobblin/crypto/EncodingBenchmark.java       |  2 +-
 ...oEncryptedSerializedRecordConverterBase.java |  8 +-
 .../gobblin/crypto/Base64KeyToStringCodec.java  |  2 +-
 .../org/apache/gobblin/crypto/GPGCodec.java     |  4 +-
 .../apache/gobblin/crypto/GPGFileDecryptor.java |  2 +-
 .../gobblin/crypto/HexKeyToStringCodec.java     |  2 +-
 .../crypto/JCEKSKeystoreCredentialStore.java    |  2 +-
 .../gobblin/crypto/JsonCredentialStore.java     |  2 +-
 .../apache/gobblin/crypto/KeyToStringCodec.java |  2 +-
 .../apache/gobblin/crypto/RotatingAESCodec.java |  6 +-
 .../JCEKSKeystoreCredentialStoreTest.java       |  2 +-
 .../gobblin/crypto/JsonCredentialStoreTest.java |  2 +-
 .../gobblin/crypto/KeyToStringCodecTest.java    |  2 +-
 .../gobblin/crypto/RotatingAESCodecTest.java    |  2 +-
 .../gobblin/eventhub/EventhubMetricNames.java   |  6 +-
 .../writer/BatchedEventhubDataWriter.java       |  4 +-
 .../writer/EventhubBatchAccumulator.java        |  4 +-
 .../eventhub/writer/EventhubDataWriter.java     | 26 +++---
 .../writer/EventhubDataWriterBuilder.java       | 16 ++--
 .../eventhub/writer/EventhubRequest.java        |  2 +-
 .../writer/BatchedEventhubDataWriterTest.java   |  4 +-
 .../writer/EventhubAccumulatorTest.java         |  6 +-
 .../eventhub/writer/EventhubBatchTest.java      |  6 +-
 .../eventhub/writer/EventhubDataWriterTest.java |  8 +-
 .../apache/gobblin/metastore/ZkStateStore.java  |  6 +-
 .../ZkStateStoreConfigurationKeys.java          |  2 +-
 .../gobblin/metastore/ZkStateStoreFactory.java  | 10 +--
 .../gobblin/runtime/ZkDatasetStateStore.java    |  8 +-
 .../runtime/ZkDatasetStateStoreFactory.java     | 12 +--
 .../runtime/StateStoreWatermarkStorageTest.java | 18 ++--
 .../runtime/ZkDatasetStateStoreTest.java        | 20 ++---
 .../src/main/avro/HttpOperation.avsc            |  2 +-
 .../src/main/avro/HttpRequestReponse.avsc       |  2 +-
 .../converter/AsyncHttpJoinConverter.java       | 36 ++++----
 .../converter/AvroApacheHttpJoinConverter.java  | 20 ++---
 .../converter/AvroHttpJoinConverter.java        | 14 +--
 .../gobblin/converter/AvroR2JoinConverter.java  | 28 +++---
 .../gobblin/converter/HttpJoinConverter.java    | 30 +++----
 .../gobblin/http/ApacheHttpAsyncClient.java     | 10 +--
 .../apache/gobblin/http/ApacheHttpClient.java   | 10 +--
 .../apache/gobblin/http/ApacheHttpRequest.java  |  4 +-
 .../gobblin/http/ApacheHttpRequestBuilder.java  |  8 +-
 .../gobblin/http/ApacheHttpResponseHandler.java |  6 +-
 .../gobblin/http/ApacheHttpResponseStatus.java  |  2 +-
 .../org/apache/gobblin/http/HttpClient.java     |  4 +-
 .../apache/gobblin/http/ResponseHandler.java    |  4 +-
 .../org/apache/gobblin/http/ResponseStatus.java |  2 +-
 .../org/apache/gobblin/http/StatusType.java     |  2 +-
 .../gobblin/http/ThrottledHttpClient.java       | 22 ++---
 .../org/apache/gobblin/r2/D2ClientProxy.java    |  2 +-
 .../java/org/apache/gobblin/r2/R2Client.java    | 10 +--
 .../org/apache/gobblin/r2/R2ClientFactory.java  |  4 +-
 .../apache/gobblin/r2/R2HttpClientProxy.java    |  2 +-
 .../java/org/apache/gobblin/r2/R2Request.java   |  4 +-
 .../org/apache/gobblin/r2/R2ResponseStatus.java |  6 +-
 .../apache/gobblin/r2/R2RestRequestBuilder.java | 10 +--
 .../gobblin/r2/R2RestResponseHandler.java       | 20 ++---
 .../org/apache/gobblin/utils/HttpConstants.java |  2 +-
 .../org/apache/gobblin/utils/HttpUtils.java     | 10 +--
 .../apache/gobblin/writer/AsyncHttpWriter.java  | 16 ++--
 .../gobblin/writer/AsyncHttpWriterBuilder.java  | 26 +++---
 .../gobblin/writer/AvroHttpWriterBuilder.java   | 12 +--
 .../gobblin/writer/R2RestWriterBuilder.java     | 14 +--
 .../java/org/apache/gobblin/HttpTestUtils.java  |  4 +-
 .../http/ApacheHttpRequestBuilderTest.java      |  8 +-
 .../apache/gobblin/r2/R2ClientFactoryTest.java  |  4 +-
 .../gobblin/r2/R2RestRequestBuilderTest.java    | 10 +--
 .../org/apache/gobblin/util/HttpUtilsTest.java  | 10 +--
 .../gobblin/writer/AsyncHttpWriterTest.java     | 38 ++++-----
 .../kafka/client/Kafka08ConsumerClient.java     | 12 +--
 .../kafka/serialize/LiAvroDeserializer.java     |  8 +-
 .../kafka/serialize/LiAvroSerializer.java       |  4 +-
 .../gobblin/kafka/tool/KafkaCheckpoint.java     |  2 +-
 .../gobblin/kafka/tool/SimpleKafkaConsumer.java | 10 +--
 .../gobblin/kafka/writer/Kafka08DataWriter.java | 16 ++--
 .../kafka/writer/KafkaDataWriterBuilder.java    | 14 +--
 .../gobblin/metrics/KafkaReportingFormats.java  | 14 +--
 .../metrics/kafka/KafkaAvroEventReporter.java   | 14 +--
 .../metrics/kafka/KafkaAvroReporter.java        | 18 ++--
 .../metrics/kafka/KafkaEventReporter.java       | 16 ++--
 .../gobblin/metrics/kafka/KafkaPusher.java      |  2 +-
 .../gobblin/metrics/kafka/KafkaReporter.java    | 22 ++---
 .../metrics/kafka/KafkaReporterFactory.java     | 12 +--
 .../metrics/kafka/ProducerCloseable.java        |  2 +-
 .../SimpleKafkaSpecExecutorInstance.java        | 12 +--
 ...SimpleKafkaSpecExecutorInstanceConsumer.java | 32 +++----
 ...SimpleKafkaSpecExecutorInstanceProducer.java | 22 ++---
 ...eamingKafkaSpecExecutorInstanceConsumer.java | 20 ++---
 .../kafka/KafkaDeserializerExtractor.java       | 28 +++---
 .../extract/kafka/KafkaDeserializerSource.java  |  6 +-
 .../extract/kafka/KafkaGsonDeserializer.java    |  2 +-
 .../extractor/extract/kafka/KafkaWrapper.java   | 12 +--
 .../test/java/StandaloneTestKafkaServer.java    |  2 +-
 .../gobblin/kafka/FlakyKafkaProducer.java       |  4 +-
 .../org/apache/gobblin/kafka/KafkaTestBase.java |  4 +-
 .../Kafka08DataWriterIntegrationTest.java       |  8 +-
 .../kafka/writer/Kafka08DataWriterTest.java     | 20 ++---
 .../kafka/writer/Kafka08DataWriterUnitTest.java |  2 +-
 .../reporter/KafkaAvroEventReporterTest.java    | 14 +--
 ...AvroEventReporterWithSchemaRegistryTest.java | 14 +--
 .../metrics/reporter/KafkaAvroReporterTest.java | 12 +--
 .../reporter/KafkaEventReporterTest.java        | 14 +--
 .../metrics/reporter/KafkaPusherTest.java       |  4 +-
 .../metrics/reporter/KafkaReporterTest.java     | 18 ++--
 .../gobblin/metrics/reporter/KafkaTestBase.java |  2 +-
 .../metrics/reporter/MockKafkaPusher.java       |  6 +-
 .../SimpleKafkaSpecExecutorInstanceTest.java    | 18 ++--
 .../StreamingKafkaSpecExecutorInstanceTest.java | 20 ++---
 .../kafka/ConfluentKafkaSchemaRegistryTest.java |  6 +-
 .../kafka/KafkaDeserializerExtractorTest.java   | 48 +++++------
 .../kafka/KafkaGsonDeserializerTest.java        |  2 +-
 .../extract/kafka/KafkaWrapperTest.java         |  6 +-
 .../kafka/SimpleKafkaSchemaRegistryTest.java    |  4 +-
 .../kafka/client/Kafka09ConsumerClient.java     | 12 +--
 .../kafka/serialize/LiAvroDeserializer.java     |  8 +-
 .../kafka/serialize/LiAvroSerializer.java       |  4 +-
 .../gobblin/kafka/writer/Kafka09DataWriter.java | 12 +--
 .../kafka/writer/KafkaDataWriterBuilder.java    |  4 +-
 .../kafka/KafkaSimpleStreamingExtractor.java    | 36 ++++----
 .../kafka/KafkaSimpleStreamingSource.java       | 22 ++---
 .../org/apache/gobblin/kafka/KafkaTestBase.java |  4 +-
 .../kafka/client/Kafka09ConsumerClientTest.java |  8 +-
 .../extract/kafka/KafkaSimpleStreamingTest.java | 28 +++---
 .../kafka/writer/Kafka09DataWriterTest.java     | 22 ++---
 .../converter/EnvelopeSchemaConverter.java      | 18 ++--
 .../LiKafkaByteArrayMsgToAvroConverter.java     | 18 ++--
 .../client/AbstractBaseKafkaConsumerClient.java | 10 +--
 .../kafka/client/BaseKafkaConsumerRecord.java   |  2 +-
 .../kafka/client/ByteArrayBasedKafkaRecord.java |  2 +-
 .../kafka/client/DecodeableKafkaRecord.java     |  2 +-
 .../client/GobblinKafkaConsumerClient.java      | 10 +--
 .../kafka/client/KafkaConsumerRecord.java       |  2 +-
 .../schemareg/CachingKafkaSchemaRegistry.java   |  2 +-
 .../ConfigDrivenMd5SchemaRegistry.java          |  8 +-
 .../kafka/schemareg/HttpClientFactory.java      |  2 +-
 .../kafka/schemareg/KafkaSchemaRegistry.java    |  2 +-
 .../KafkaSchemaRegistryConfigurationKeys.java   |  2 +-
 .../schemareg/KafkaSchemaRegistryFactory.java   |  2 +-
 .../kafka/schemareg/LiKafkaSchemaRegistry.java  |  8 +-
 .../schemareg/SchemaRegistryException.java      |  2 +-
 .../kafka/serialize/LiAvroDeserializerBase.java |  8 +-
 .../kafka/serialize/LiAvroSerDeHelper.java      |  6 +-
 .../kafka/serialize/LiAvroSerializerBase.java   |  6 +-
 .../gobblin/kafka/serialize/MD5Digest.java      |  2 +-
 .../kafka/serialize/SerializationException.java |  2 +-
 .../writer/BaseKafkaDataWriterBuilder.java      | 14 +--
 .../writer/KafkaWriterConfigurationKeys.java    |  2 +-
 .../gobblin/kafka/writer/KafkaWriterHelper.java |  8 +-
 .../kafka/writer/KafkaWriterMetricNames.java    |  2 +-
 .../metrics/kafka/KafkaAvroSchemaRegistry.java  |  8 +-
 .../kafka/KafkaAvroSchemaRegistryFactory.java   |  2 +-
 .../metrics/kafka/KafkaSchemaRegistry.java      |  2 +-
 .../kafka/KafkaSchemaRegistryFactory.java       |  2 +-
 .../metrics/kafka/SchemaRegistryException.java  |  2 +-
 .../util/SchemaRegistryVersionWriter.java       |  8 +-
 .../extract/kafka/ConfigStoreUtils.java         | 24 +++---
 .../kafka/ConfluentKafkaSchemaRegistry.java     |  6 +-
 .../kafka/FixedSchemaKafkaAvroExtractor.java    |  6 +-
 .../extract/kafka/KafkaAvroExtractor.java       | 16 ++--
 .../extractor/extract/kafka/KafkaExtractor.java | 32 +++----
 .../KafkaOffsetRetrievalFailureException.java   |  2 +-
 .../extractor/extract/kafka/KafkaPartition.java |  2 +-
 .../extractor/extract/kafka/KafkaRecord.java    |  2 +-
 .../extract/kafka/KafkaSimpleExtractor.java     | 10 +--
 .../extract/kafka/KafkaSimpleJsonExtractor.java |  8 +-
 .../extract/kafka/KafkaSimpleSource.java        |  6 +-
 .../extractor/extract/kafka/KafkaSource.java    | 44 +++++-----
 .../extractor/extract/kafka/KafkaTopic.java     |  2 +-
 .../extractor/extract/kafka/KafkaUtils.java     |  6 +-
 .../extract/kafka/MultiLongWatermark.java       |  4 +-
 .../kafka/PreviousOffsetNotFoundException.java  |  2 +-
 .../kafka/SimpleKafkaSchemaRegistry.java        |  6 +-
 .../kafka/StartOffsetOutOfRangeException.java   |  2 +-
 .../extract/kafka/UniversalKafkaSource.java     | 10 +--
 ...AvgRecordSizeBasedWorkUnitSizeEstimator.java | 14 +--
 ...AvgRecordTimeBasedWorkUnitSizeEstimator.java | 14 +--
 .../packer/KafkaBiLevelWorkUnitPacker.java      | 12 +--
 .../packer/KafkaSingleLevelWorkUnitPacker.java  | 10 +--
 .../workunit/packer/KafkaWorkUnitPacker.java    | 28 +++---
 .../packer/KafkaWorkUnitSizeEstimator.java      |  4 +-
 .../converter/EnvelopeSchemaConverterTest.java  |  8 +-
 .../KafkaAvroSchemaRegistryForTest.java         |  8 +-
 .../CachingKafkaSchemaRegistryTest.java         |  2 +-
 .../gobblin/kafka/serialize/MD5DigestTest.java  |  2 +-
 .../converter/MetadataConverterWrapper.java     | 10 +--
 ...thMetadataToEnvelopedRecordWithMetadata.java | 10 +--
 .../metadata/GlobalMetadataCollector.java       |  4 +-
 .../DatasetAwareFsMetadataProvider.java         |  4 +-
 .../provider/DatasetAwareMetadataProvider.java  |  6 +-
 .../DatasetAwareMetadataProviderFactory.java    |  2 +-
 .../provider/MetadataAwareFileSystem.java       | 20 ++---
 .../provider/PermissionMetadataParser.java      |  4 +-
 .../provider/SimpleConfigMetadataProvider.java  |  6 +-
 .../provider/SimpleMetadataProviderFactory.java |  6 +-
 .../gobblin/metadata/types/GlobalMetadata.java  |  2 +-
 .../types/GlobalMetadataJsonMerger.java         |  6 +-
 .../apache/gobblin/metadata/types/Metadata.java |  2 +-
 .../types/StaticStringMetadataMerger.java       |  6 +-
 .../apache/gobblin/type/ContentTypeUtils.java   |  4 +-
 .../apache/gobblin/type/RecordWithMetadata.java |  4 +-
 .../type/SerializedRecordWithMetadata.java      |  4 +-
 .../converter/MetadataConverterWrapperTest.java |  8 +-
 ...tadataToEnvelopedRecordWithMetadataTest.java |  6 +-
 .../metadata/GlobalMetadataCollectorTest.java   |  4 +-
 .../metadata/types/GlobalMetadataTest.java      |  2 +-
 .../graphite/GraphiteConnectionType.java        |  2 +-
 .../metrics/graphite/GraphiteEventReporter.java | 20 ++---
 .../metrics/graphite/GraphitePusher.java        |  2 +-
 .../metrics/graphite/GraphiteReporter.java      | 12 +--
 .../graphite/GraphiteEventReporterTest.java     | 18 ++--
 .../metrics/graphite/GraphiteReporterTest.java  | 24 +++---
 .../metrics/graphite/TestGraphiteSender.java    |  4 +-
 .../hadoop/AbstractHadoopCounterReporter.java   |  8 +-
 .../metrics/hadoop/HadoopCounterReporter.java   |  6 +-
 .../hadoop/NewAPIHadoopCounterReporter.java     |  6 +-
 .../hadoop/HadoopCounterReporterTest.java       |  8 +-
 .../hadoop/NewAPIHadoopCounterReporterTest.java |  8 +-
 .../influxdb/InfluxDBConnectionType.java        |  2 +-
 .../metrics/influxdb/InfluxDBEventReporter.java | 14 +--
 .../metrics/influxdb/InfluxDBPusher.java        |  2 +-
 .../metrics/influxdb/InfluxDBReporter.java      | 12 +--
 .../influxdb/InfluxDBEventReporterTest.java     | 18 ++--
 .../metrics/influxdb/InfluxDBReporterTest.java  | 26 +++---
 .../gobblin/metrics/influxdb/TestInfluxDB.java  |  4 +-
 .../AvroToJdbcEntryConverterInitializer.java    | 20 ++---
 .../jdbc/AvroToJdbcEntryConverter.java          | 24 +++---
 .../gobblin/converter/jdbc/JdbcEntryData.java   |  2 +-
 .../gobblin/converter/jdbc/JdbcEntryDatum.java  |  2 +-
 .../converter/jdbc/JdbcEntryMetaDatum.java      |  2 +-
 .../gobblin/converter/jdbc/JdbcEntrySchema.java |  2 +-
 .../apache/gobblin/converter/jdbc/JdbcType.java |  2 +-
 .../apache/gobblin/publisher/JdbcPublisher.java | 18 ++--
 .../extractor/extract/jdbc/MysqlSource.java     | 12 +--
 .../extractor/extract/jdbc/OracleSource.java    | 12 +--
 .../extractor/extract/jdbc/SqlServerSource.java | 12 +--
 .../extractor/extract/jdbc/TeradataSource.java  | 12 +--
 .../apache/gobblin/source/jdbc/JdbcCommand.java |  6 +-
 .../source/jdbc/JdbcCommandFormatException.java |  2 +-
 .../gobblin/source/jdbc/JdbcCommandOutput.java  |  4 +-
 .../gobblin/source/jdbc/JdbcExtractor.java      | 42 ++++-----
 .../gobblin/source/jdbc/JdbcProvider.java       |  4 +-
 .../gobblin/source/jdbc/JdbcSpecificLayer.java  |  2 +-
 .../gobblin/source/jdbc/MysqlExtractor.java     | 24 +++---
 .../gobblin/source/jdbc/OracleExtractor.java    | 24 +++---
 .../gobblin/source/jdbc/SqlQueryUtils.java      |  2 +-
 .../gobblin/source/jdbc/SqlServerExtractor.java | 24 +++---
 .../gobblin/source/jdbc/TeradataExtractor.java  | 28 +++---
 .../org/apache/gobblin/writer/JdbcWriter.java   | 20 ++---
 .../gobblin/writer/JdbcWriterBuilder.java       | 16 ++--
 .../commands/BaseJdbcBufferedInserter.java      |  8 +-
 .../commands/GenericJdbcBufferedInserter.java   |  8 +-
 .../writer/commands/JdbcBufferedInserter.java   |  6 +-
 .../writer/commands/JdbcWriterCommands.java     |  4 +-
 .../commands/JdbcWriterCommandsFactory.java     | 12 +--
 .../writer/commands/MySqlBufferedInserter.java  |  8 +-
 .../writer/commands/MySqlWriterCommands.java    |  8 +-
 .../commands/TeradataBufferedInserter.java      |  8 +-
 .../writer/commands/TeradataWriterCommands.java | 12 +--
 .../initializer/JdbcWriterInitializer.java      | 26 +++---
 .../jdbc/AvroToJdbcEntryConverterTest.java      | 18 ++--
 .../gobblin/source/TimestampWatermarkTest.java  | 10 +--
 .../gobblin/source/jdbc/JdbcExtractorTest.java  | 14 +--
 .../gobblin/source/jdbc/MockJdbcColumn.java     |  2 +-
 .../source/jdbc/OracleExtractorTest.java        |  8 +-
 .../gobblin/source/jdbc/SqlQueryUtilsTest.java  |  2 +-
 .../writer/JdbcBufferedInserterTestBase.java    | 10 +--
 .../gobblin/writer/JdbcPublisherTest.java       | 14 +--
 .../gobblin/writer/JdbcWriterCommandsTest.java  |  8 +-
 .../writer/JdbcWriterInitializerTest.java       | 20 ++---
 .../apache/gobblin/writer/JdbcWriterTest.java   | 10 +--
 .../writer/MySqlBufferedInserterTest.java       | 14 +--
 .../writer/TeradataBufferedInserterTest.java    | 12 +--
 .../google/AsyncIteratorWithDataSink.java       |  2 +-
 .../ingestion/google/DayPartitioner.java        |  8 +-
 .../GoggleIngestionConfigurationKeys.java       |  2 +-
 .../ingestion/google/util/SchemaUtil.java       |  4 +-
 .../google/webmaster/GoogleWebMasterSource.java | 18 ++--
 .../webmaster/GoogleWebMasterSourceDaily.java   | 28 +++---
 .../google/webmaster/GoogleWebmasterClient.java |  2 +-
 .../webmaster/GoogleWebmasterClientImpl.java    |  4 +-
 .../webmaster/GoogleWebmasterDataFetcher.java   |  2 +-
 .../GoogleWebmasterDataFetcherImpl.java         | 14 +--
 .../GoogleWebmasterDayPartitioner.java          |  6 +-
 .../webmaster/GoogleWebmasterExtractor.java     | 14 +--
 .../GoogleWebmasterExtractorIterator.java       | 12 +--
 .../google/webmaster/GoogleWebmasterFilter.java |  2 +-
 .../ingestion/google/webmaster/ProducerJob.java |  2 +-
 .../google/webmaster/SimpleProducerJob.java     |  2 +-
 .../google/webmaster/TrieBasedProducerJob.java  |  2 +-
 .../ingestion/google/webmaster/UrlGrouper.java  |  2 +-
 .../ingestion/google/webmaster/UrlTrie.java     |  2 +-
 .../ingestion/google/webmaster/UrlTrieNode.java |  2 +-
 .../webmaster/UrlTriePostOrderIterator.java     |  2 +-
 .../google/webmaster/UrlTriePrefixGrouper.java  |  2 +-
 .../GoogleAnalyticsUnsampledExtractor.java      | 34 ++++----
 .../google/GoogleAnalyticsUnsampledSource.java  |  8 +-
 .../extractor/extract/google/GoogleCommon.java  |  2 +-
 .../extract/google/GoogleCommonKeys.java        |  2 +-
 .../extract/google/GoogleDriveExtractor.java    |  8 +-
 .../extract/google/GoogleDriveFileSystem.java   | 12 +--
 .../extract/google/GoogleDriveFsHelper.java     |  8 +-
 .../extract/google/GoogleDriveSource.java       | 18 ++--
 .../GoogleWebmasterDataFetcherImplTest.java     |  4 +-
 .../GoogleWebmasterExtractorIteratorTest.java   |  4 +-
 .../webmaster/GoogleWebmasterExtractorTest.java | 16 ++--
 .../google/webmaster/ProducerJobTest.java       |  2 +-
 .../google/webmaster/SimpleProducerJobTest.java |  2 +-
 .../webmaster/TrieBasedProducerJobTest.java     |  2 +-
 .../webmaster/UrlTriePostOrderIteratorTest.java |  2 +-
 .../webmaster/UrlTriePrefixGrouperTest.java     |  4 +-
 .../ingestion/google/webmaster/UrlTrieTest.java |  2 +-
 .../GoogleAnalyticsUnsampledExtractorTest.java  | 12 +--
 .../google/GoogleDriveFileSystemTest.java       |  2 +-
 .../extract/google/GoogleDriveFsHelperTest.java |  8 +-
 .../filebased/GoogleDriveSourceTest.java        | 14 +--
 .../gobblin.rest.jobExecutions.restspec.json    |  4 +-
 .../apache/gobblin/rest/JobExecutionInfo.pdsc   |  2 +-
 .../apache/gobblin/rest/JobExecutionQuery.pdsc  |  2 +-
 .../gobblin/rest/JobExecutionQueryResult.pdsc   |  2 +-
 .../pegasus/org/apache/gobblin/rest/Metric.pdsc |  2 +-
 .../pegasus/org/apache/gobblin/rest/Table.pdsc  |  2 +-
 .../apache/gobblin/rest/TaskExecutionInfo.pdsc  |  2 +-
 .../org/apache/gobblin/rest/TimeRange.pdsc      |  2 +-
 .../gobblin.rest.jobExecutions.snapshot.json    | 32 +++----
 .../gobblin/rest/JobExecutionInfoClient.java    |  2 +-
 .../gobblin/rest/JobExecutionInfoResource.java  |  4 +-
 .../gobblin/rest/JobExecutionInfoServer.java    |  8 +-
 .../rest/JobExecutionInfoServerTest.java        | 12 +--
 .../gobblin.service.flowconfigs.restspec.json   |  4 +-
 .../gobblin.service.flowstatuses.restspec.json  |  4 +-
 .../apache/gobblin/service/ExecutionStatus.pdsc |  2 +-
 .../org/apache/gobblin/service/FlowConfig.pdsc  |  2 +-
 .../org/apache/gobblin/service/FlowId.pdsc      |  2 +-
 .../apache/gobblin/service/FlowStatistics.pdsc  |  2 +-
 .../org/apache/gobblin/service/FlowStatus.pdsc  |  2 +-
 .../apache/gobblin/service/FlowStatusId.pdsc    |  2 +-
 .../org/apache/gobblin/service/JobId.pdsc       |  2 +-
 .../org/apache/gobblin/service/JobState.pdsc    |  2 +-
 .../apache/gobblin/service/JobStatistics.pdsc   |  2 +-
 .../org/apache/gobblin/service/JobStatus.pdsc   |  2 +-
 .../org/apache/gobblin/service/Schedule.pdsc    |  2 +-
 .../gobblin.service.flowconfigs.snapshot.json   | 10 +--
 .../gobblin.service.flowstatuses.snapshot.json  | 22 ++---
 .../gobblin/service/FlowConfigClient.java       |  2 +-
 .../gobblin/service/FlowStatusClient.java       |  2 +-
 .../apache/gobblin/service/FlowConfigTest.java  | 10 +--
 .../apache/gobblin/service/FlowStatusTest.java  | 12 +--
 .../gobblin/service/FlowConfigsResource.java    | 12 +--
 .../gobblin/service/FlowStatusResource.java     |  6 +-
 .../service/validator/CronValidator.java        |  2 +-
 .../service/validator/TemplateUriValidator.java |  2 +-
 .../gobblin/restli/EmbeddedRestliServer.java    |  2 +-
 .../gobblin/restli/SharedRestClientFactory.java | 22 ++---
 .../gobblin/restli/SharedRestClientKey.java     |  4 +-
 .../apache/gobblin/restli/UriRestClientKey.java |  2 +-
 ...blin.restli.throttling.permits.restspec.json |  4 +-
 .../restli/throttling/PermitAllocation.pdsc     |  2 +-
 .../restli/throttling/PermitRequest.pdsc        |  2 +-
 .../gobblin/restli/throttling/Policy.pdsc       |  2 +-
 ...blin.restli.throttling.permits.snapshot.json |  8 +-
 .../util/limiter/BatchedPermitsRequester.java   | 12 +--
 .../RedirectAwareRestClientRequestSender.java   | 30 +++----
 .../gobblin/util/limiter/RequestSender.java     |  6 +-
 .../util/limiter/RestClientRequestSender.java   | 10 +--
 .../util/limiter/RestliLimiterFactory.java      | 30 +++----
 .../util/limiter/RestliServiceBasedLimiter.java |  8 +-
 .../stressTest/FixedOperationsStressor.java     |  4 +-
 .../util/limiter/stressTest/MRStressTest.java   | 30 +++----
 .../stressTest/RandomDelayStartStressor.java    |  4 +-
 .../stressTest/RandomRuntimeStressor.java       |  4 +-
 .../RateComputingLimiterContainer.java          |  8 +-
 .../limiter/stressTest/StressTestUtils.java     |  2 +-
 .../util/limiter/stressTest/Stressor.java       |  4 +-
 .../restli/throttling/LocalStressTest.java      | 20 ++---
 .../restli/throttling/ThrottlingClientTest.java |  8 +-
 .../limiter/BatchedPermitsRequesterTest.java    |  8 +-
 .../gobblin/util/limiter/MockRequester.java     |  8 +-
 .../util/limiter/RestliLimiterFactoryTest.java  | 20 ++---
 .../limiter/RestliServiceBasedLimiterTest.java  | 22 ++---
 .../ConfigClientBasedPolicyFactory.java         | 18 ++--
 .../restli/throttling/CountBasedPolicy.java     | 10 +--
 .../restli/throttling/DynamicTokenBucket.java   |  2 +-
 .../gobblin/restli/throttling/LeaderFinder.java |  2 +-
 .../throttling/LimiterServerResource.java       | 20 ++---
 .../gobblin/restli/throttling/NoopPolicy.java   | 10 +--
 .../restli/throttling/PoliciesResource.java     | 16 ++--
 .../gobblin/restli/throttling/QPSPolicy.java    | 10 +--
 .../ThrottlingGuiceServletConfig.java           | 14 +--
 .../restli/throttling/ThrottlingPolicy.java     |  2 +-
 .../throttling/ThrottlingPolicyFactory.java     | 24 +++---
 .../throttling/ThrottlingServerScopes.java      |  8 +-
 .../gobblin/restli/throttling/TokenBucket.java  |  2 +-
 .../gobblin/restli/throttling/URIMetadata.java  |  2 +-
 .../throttling/ZookeeperLeaderElection.java     |  4 +-
 .../throttling/ConfigStoreBasedPolicyTest.java  |  8 +-
 .../throttling/DynamicTokenBucketTest.java      |  2 +-
 .../throttling/LimiterServerResourceTest.java   |  8 +-
 .../restli/throttling/PoliciesResourceTest.java |  6 +-
 .../gobblin/restli/throttling/TestFailover.java |  2 +-
 .../restli/throttling/TokenBucketTest.java      |  2 +-
 ...adoopKerberosKeytabAuthenticationPlugin.java | 16 ++--
 ...adoopKerberosKeytabAuthenticationPlugin.java |  6 +-
 .../gobblin/runtime/fork/MockTaskContext.java   | 16 ++--
 gobblin-runtime/src/main/avro/AvroJobSpec.avsc  |  2 +-
 .../gobblin/runtime/AbstractJobLauncher.java    | 86 +++++++++----------
 .../runtime/AbstractTaskStateTracker.java       | 10 +--
 .../apache/gobblin/runtime/BaseLimiterType.java |  2 +-
 .../runtime/BoundedBlockingRecordQueue.java     |  4 +-
 .../runtime/CheckpointableWatermarkState.java   |  6 +-
 .../gobblin/runtime/CountBasedLimiter.java      |  2 +-
 .../gobblin/runtime/CountUpAndDownLatch.java    |  2 +-
 .../gobblin/runtime/DefaultLimiterFactory.java  |  2 +-
 .../gobblin/runtime/EventMetadataUtils.java     |  4 +-
 .../apache/gobblin/runtime/ExecutionModel.java  |  4 +-
 .../runtime/ForkBranchMismatchException.java    |  2 +-
 .../apache/gobblin/runtime/ForkException.java   |  2 +-
 .../gobblin/runtime/FsDatasetStateStore.java    | 24 +++---
 .../runtime/FsDatasetStateStoreFactory.java     |  6 +-
 .../runtime/GobblinMultiTaskAttempt.java        | 40 ++++-----
 .../org/apache/gobblin/runtime/JobContext.java  | 54 ++++++------
 .../apache/gobblin/runtime/JobException.java    |  2 +-
 .../runtime/JobExecutionEventSubmitter.java     | 28 +++---
 .../org/apache/gobblin/runtime/JobLauncher.java |  4 +-
 .../gobblin/runtime/JobLauncherFactory.java     | 14 +--
 .../org/apache/gobblin/runtime/JobState.java    | 36 ++++----
 .../org/apache/gobblin/runtime/Limiter.java     |  2 +-
 .../runtime/LimitingExtractorDecorator.java     | 20 ++---
 .../apache/gobblin/runtime/MultiConverter.java  | 22 ++---
 .../gobblin/runtime/MysqlDatasetStateStore.java |  8 +-
 .../runtime/MysqlDatasetStateStoreFactory.java  | 10 +--
 .../gobblin/runtime/NewTaskCompletionEvent.java |  2 +-
 .../gobblin/runtime/NonRefillableLimiter.java   |  2 +-
 .../gobblin/runtime/NoopDatasetStateStore.java  |  8 +-
 .../runtime/NoopEventMetadataGenerator.java     |  8 +-
 .../gobblin/runtime/PoolBasedLimiter.java       |  2 +-
 .../gobblin/runtime/RateBasedLimiter.java       |  2 +-
 .../gobblin/runtime/SafeDatasetCommit.java      | 26 +++---
 .../apache/gobblin/runtime/SourceDecorator.java | 20 ++---
 .../StateStoreBasedWatermarkStorage.java        | 16 ++--
 .../StateStoreBasedWatermarkStorageCli.java     | 10 +--
 .../gobblin/runtime/StreamModelTaskRunner.java  | 30 +++----
 .../java/org/apache/gobblin/runtime/Task.java   | 78 ++++++++---------
 .../gobblin/runtime/TaskConfigurationKeys.java  |  2 +-
 .../org/apache/gobblin/runtime/TaskContext.java | 54 ++++++------
 .../apache/gobblin/runtime/TaskExecutor.java    | 10 +--
 .../runtime/TaskInstantiationException.java     |  2 +-
 .../org/apache/gobblin/runtime/TaskState.java   | 30 +++----
 .../runtime/TaskStateCollectorService.java      | 10 +--
 .../gobblin/runtime/TaskStateTracker.java       |  2 +-
 .../gobblin/runtime/TimeBasedLimiter.java       |  2 +-
 .../gobblin/runtime/api/Configurable.java       |  4 +-
 .../runtime/api/EventMetadataGenerator.java     |  6 +-
 .../apache/gobblin/runtime/api/FlowSpec.java    |  8 +-
 .../runtime/api/GobblinInstanceDriver.java      |  8 +-
 .../runtime/api/GobblinInstanceEnvironment.java |  8 +-
 .../runtime/api/GobblinInstanceLauncher.java    |  4 +-
 .../runtime/api/GobblinInstancePlugin.java      |  2 +-
 .../api/GobblinInstancePluginFactory.java       |  2 +-
 .../apache/gobblin/runtime/api/JobCatalog.java  | 14 +--
 .../gobblin/runtime/api/JobCatalogListener.java |  6 +-
 .../api/JobCatalogListenersContainer.java       |  2 +-
 .../runtime/api/JobCatalogWithTemplates.java    |  2 +-
 .../gobblin/runtime/api/JobExecution.java       |  4 +-
 .../gobblin/runtime/api/JobExecutionDriver.java |  2 +-
 .../runtime/api/JobExecutionLauncher.java       | 10 +--
 .../gobblin/runtime/api/JobExecutionResult.java |  4 +-
 .../gobblin/runtime/api/JobExecutionState.java  |  8 +-
 .../runtime/api/JobExecutionStateListener.java  |  8 +-
 .../api/JobExecutionStateListenerContainer.java |  4 +-
 .../gobblin/runtime/api/JobExecutionStatus.java |  4 +-
 .../runtime/api/JobLifecycleListener.java       |  6 +-
 .../api/JobLifecycleListenersContainer.java     |  2 +-
 .../org/apache/gobblin/runtime/api/JobSpec.java | 10 +--
 .../gobblin/runtime/api/JobSpecMonitor.java     |  2 +-
 .../runtime/api/JobSpecMonitorFactory.java      |  2 +-
 .../runtime/api/JobSpecNotFoundException.java   |  2 +-
 .../gobblin/runtime/api/JobSpecSchedule.java    |  2 +-
 .../gobblin/runtime/api/JobSpecScheduler.java   |  4 +-
 .../runtime/api/JobSpecSchedulerListener.java   |  4 +-
 .../api/JobSpecSchedulerListenersContainer.java |  2 +-
 .../apache/gobblin/runtime/api/JobTemplate.java |  2 +-
 .../gobblin/runtime/api/MutableJobCatalog.java  |  4 +-
 .../gobblin/runtime/api/MutableSpecCatalog.java |  2 +-
 .../apache/gobblin/runtime/api/SpecCatalog.java | 12 +--
 .../runtime/api/SpecCatalogListener.java        |  4 +-
 .../api/SpecCatalogListenersContainer.java      |  2 +-
 .../gobblin/runtime/api/SpecCompiler.java       |  4 +-
 .../runtime/api/SpecNotFoundException.java      |  2 +-
 .../apache/gobblin/runtime/api/SpecSerDe.java   |  2 +-
 .../apache/gobblin/runtime/api/SpecStore.java   |  2 +-
 .../gobblin/runtime/api/TopologySpec.java       | 12 +--
 .../gobblin/runtime/api/package-info.java       |  2 +-
 .../runtime/app/ApplicationException.java       |  4 +-
 .../runtime/app/ApplicationLauncher.java        |  6 +-
 .../runtime/app/ServiceBasedAppLauncher.java    | 22 ++---
 .../gobblin/runtime/cli/CliEmbeddedGobblin.java |  8 +-
 .../apache/gobblin/runtime/cli/CliOptions.java  |  4 +-
 ...ructorAndPublicMethodsGobblinCliFactory.java |  4 +-
 .../runtime/cli/EmbeddedGobblinCliFactory.java  |  4 +-
 .../gobblin/runtime/cli/PasswordManagerCLI.java |  6 +-
 .../cli/PublicMethodsGobblinCliFactory.java     |  6 +-
 .../runtime/commit/DatasetStateCommitStep.java  | 18 ++--
 .../runtime/commit/FsCommitSequenceStore.java   | 18 ++--
 .../gobblin/runtime/crypto/DecryptCli.java      | 10 +--
 .../runtime/embedded/EmbeddedGobblin.java       | 76 ++++++++---------
 .../gobblin/runtime/fork/AsynchronousFork.java  | 18 ++--
 .../org/apache/gobblin/runtime/fork/Fork.java   | 72 ++++++++--------
 .../gobblin/runtime/fork/SynchronousFork.java   | 12 +--
 .../DefaultGobblinInstanceDriverImpl.java       | 50 +++++------
 .../SimpleGobblinInstanceEnvironment.java       | 16 ++--
 .../instance/StandardGobblinInstanceDriver.java | 56 ++++++------
 .../StandardGobblinInstanceLauncher.java        | 30 +++----
 .../instance/hadoop/HadoopConfigLoader.java     |  2 +-
 .../instance/plugin/BaseIdlePluginImpl.java     |  8 +-
 .../runtime/job_catalog/CachingJobCatalog.java  | 14 +--
 .../runtime/job_catalog/FSJobCatalog.java       | 28 +++---
 .../FSPathAlterationListenerAdaptor.java        | 10 +--
 .../job_catalog/ImmutableFSJobCatalog.java      | 24 +++---
 .../runtime/job_catalog/InMemoryJobCatalog.java | 16 ++--
 .../runtime/job_catalog/JobCatalogBase.java     | 16 ++--
 .../job_catalog/JobCatalogListenersList.java    | 12 +--
 .../job_catalog/MutableCachingJobCatalog.java   |  6 +-
 .../job_catalog/MutableJobCatalogBase.java      | 10 +--
 .../job_catalog/NonObservingFSJobCatalog.java   | 14 +--
 .../PackagedTemplatesJobCatalogDecorator.java   | 14 +--
 .../runtime/job_catalog/StaticJobCatalog.java   | 12 +--
 .../job_exec/JobLauncherExecutionDriver.java    | 72 ++++++++--------
 .../gobblin/runtime/job_exec/package-info.java  |  2 +-
 .../job_monitor/AvroJobSpecKafkaJobMonitor.java | 36 ++++----
 .../job_monitor/KafkaAvroJobMonitor.java        | 14 +--
 .../runtime/job_monitor/KafkaJobMonitor.java    | 16 ++--
 .../job_monitor/SLAEventKafkaJobMonitor.java    | 28 +++---
 .../runtime/job_spec/ResolvedJobSpec.java       | 20 ++---
 .../runtime/kafka/HighLevelConsumer.java        | 14 +--
 .../listeners/AbstractCloseableJobListener.java |  2 +-
 .../runtime/listeners/AbstractJobListener.java  |  4 +-
 .../runtime/listeners/CloseableJobListener.java |  2 +-
 .../listeners/EmailNotificationJobListener.java | 10 +--
 .../JobExecutionEventSubmitterListener.java     |  6 +-
 .../gobblin/runtime/listeners/JobListener.java  |  6 +-
 .../gobblin/runtime/listeners/JobListeners.java |  6 +-
 .../runtime/listeners/RunOnceJobListener.java   |  8 +-
 .../runtime/local/CliLocalJobLauncher.java      | 16 ++--
 .../gobblin/runtime/local/LocalJobLauncher.java | 32 +++----
 .../runtime/local/LocalTaskStateTracker.java    | 18 ++--
 .../locks/AbstractJobLockFactoryManager.java    |  2 +-
 .../gobblin/runtime/locks/FileBasedJobLock.java |  4 +-
 .../runtime/locks/FileBasedJobLockFactory.java  |  8 +-
 .../locks/FileBasedJobLockFactoryManager.java   |  6 +-
 .../apache/gobblin/runtime/locks/JobLock.java   |  2 +-
 .../runtime/locks/JobLockEventListener.java     |  2 +-
 .../gobblin/runtime/locks/JobLockException.java |  2 +-
 .../gobblin/runtime/locks/JobLockFactory.java   |  4 +-
 .../runtime/locks/JobLockFactoryManager.java    |  2 +-
 .../locks/LegacyJobLockFactoryManager.java      |  4 +-
 .../runtime/locks/ListenableJobLock.java        |  2 +-
 .../runtime/locks/ZookeeperBasedJobLock.java    |  4 +-
 .../runtime/mapreduce/CliMRJobLauncher.java     | 16 ++--
 .../mapreduce/GobblinOutputCommitter.java       | 18 ++--
 .../runtime/mapreduce/GobblinOutputFormat.java  |  2 +-
 .../mapreduce/GobblinWorkUnitsInputFormat.java  |  2 +-
 .../runtime/mapreduce/MRJobLauncher.java        | 62 +++++++-------
 .../gobblin/runtime/mapreduce/MRTask.java       | 12 +--
 .../runtime/mapreduce/MRTaskFactory.java        | 14 +--
 .../runtime/mapreduce/MRTaskStateTracker.java   | 16 ++--
 .../gobblin/runtime/metrics/RuntimeMetrics.java |  2 +-
 .../plugins/GobblinInstancePluginUtils.java     |  6 +-
 .../runtime/plugins/PluginStaticKeys.java       |  2 +-
 .../plugins/email/EmailNotificationPlugin.java  | 30 +++----
 .../plugins/metrics/GobblinMetricsPlugin.java   | 16 ++--
 .../scheduler/AbstractJobSpecScheduler.java     | 10 +--
 .../DefaultJobSpecSchedulerListenerImpl.java    |  8 +-
 .../scheduler/ImmediateJobSpecScheduler.java    | 12 +--
 .../scheduler/JobSpecSchedulerListeners.java    | 12 +--
 .../scheduler/QuartzJobSpecScheduler.java       | 16 ++--
 .../runtime/services/JMXReportingService.java   |  2 +-
 .../services/MetricsReportingService.java       |  4 +-
 .../runtime/spec_catalog/FlowCatalog.java       | 34 ++++----
 .../spec_catalog/SpecCatalogListenersList.java  | 10 +--
 .../runtime/spec_catalog/TopologyCatalog.java   | 34 ++++----
 .../InMemorySpecExecutorInstanceProducer.java   | 12 +--
 .../gobblin/runtime/spec_store/FSSpecStore.java | 16 ++--
 .../runtime/std/DefaultConfigurableImpl.java    |  6 +-
 .../std/DefaultJobCatalogListenerImpl.java      |  6 +-
 .../DefaultJobExecutionStateListenerImpl.java   |  8 +-
 .../std/DefaultJobLifecycleListenerImpl.java    | 14 +--
 .../runtime/std/DefaultJobSpecScheduleImpl.java |  6 +-
 .../std/FilteredJobLifecycleListener.java       | 14 +--
 .../runtime/std/JobExecutionStateListeners.java | 12 +--
 .../runtime/std/JobExecutionUpdatable.java      | 12 +--
 .../runtime/std/JobLifecycleListenersList.java  | 24 +++---
 .../gobblin/runtime/std/JobSpecFilter.java      |  4 +-
 .../gobblin/runtime/task/BaseAbstractTask.java  | 12 +--
 .../apache/gobblin/runtime/task/FailedTask.java | 16 ++--
 .../gobblin/runtime/task/TaskFactory.java       |  8 +-
 .../apache/gobblin/runtime/task/TaskIFace.java  |  8 +-
 .../gobblin/runtime/task/TaskIFaceWrapper.java  | 16 ++--
 .../apache/gobblin/runtime/task/TaskUtils.java  |  4 +-
 .../template/HOCONInputStreamJobTemplate.java   | 10 +--
 .../runtime/template/InheritingJobTemplate.java |  8 +-
 .../template/PullFileToConfigConverter.java     | 16 ++--
 .../template/ResourceBasedJobTemplate.java      |  8 +-
 .../runtime/template/StaticJobTemplate.java     | 14 +--
 .../gobblin/runtime/util/ClustersNames.java     |  2 +-
 .../apache/gobblin/runtime/util/JobMetrics.java | 16 ++--
 .../runtime/util/JobStateToJsonConverter.java   | 12 +--
 .../gobblin/runtime/util/MetricGroup.java       |  2 +-
 .../util/MultiWorkUnitUnpackingIterator.java    |  6 +-
 .../gobblin/runtime/util/RuntimeConstructs.java |  4 +-
 .../gobblin/runtime/util/StateStores.java       | 16 ++--
 .../gobblin/runtime/util/TaskMetrics.java       | 14 +--
 .../gobblin/scheduler/BaseGobblinJob.java       |  2 +-
 .../apache/gobblin/scheduler/JobScheduler.java  | 22 ++---
 ...PathAlterationListenerAdaptorForMonitor.java | 16 ++--
 .../gobblin/scheduler/SchedulerDaemon.java      |  6 +-
 .../gobblin/scheduler/SchedulerService.java     |  8 +-
 .../gobblin/service/monitoring/FlowStatus.java  |  4 +-
 .../service/monitoring/FlowStatusGenerator.java |  4 +-
 .../gobblin/service/monitoring/JobStatus.java   |  4 +-
 .../service/monitoring/JobStatusRetriever.java  |  4 +-
 .../LatestFlowExecutionIdTracker.java           |  2 +-
 .../org/apache/gobblin/util/SchedulerUtils.java | 18 ++--
 .../gobblin/performance/PerformanceTest.java    | 10 +--
 .../runtime/BoundedBlockingRecordQueueTest.java |  2 +-
 .../runtime/CountUpAndDownLatchTest.java        |  2 +-
 .../gobblin/runtime/DatasetStateStoreTest.java  | 30 +++----
 .../apache/gobblin/runtime/DummyJobContext.java | 14 +--
 .../runtime/FsDatasetStateStoreTest.java        | 10 +--
 .../gobblin/runtime/JobBrokerInjectionTest.java | 56 ++++++------
 .../apache/gobblin/runtime/JobContextTest.java  |  8 +-
 .../runtime/JobExecutionEventSubmitterTest.java |  8 +-
 .../gobblin/runtime/JobLauncherTestHelper.java  | 24 +++---
 .../gobblin/runtime/JobListenersTest.java       |  8 +-
 .../apache/gobblin/runtime/JobStateTest.java    | 12 +--
 .../gobblin/runtime/LimiterStopEventTest.java   | 12 +--
 .../gobblin/runtime/MultiConverterTest.java     | 16 ++--
 .../runtime/MysqlDatasetStateStoreTest.java     | 22 ++---
 .../apache/gobblin/runtime/TaskContextTest.java | 16 ++--
 .../gobblin/runtime/TaskContinuousTest.java     | 42 ++++-----
 .../runtime/TaskStateCollectorServiceTest.java  |  6 +-
 .../apache/gobblin/runtime/TaskStateTest.java   |  8 +-
 .../org/apache/gobblin/runtime/TaskTest.java    | 34 ++++----
 .../gobblin/runtime/TestRecordStream.java       | 46 +++++-----
 .../runtime/TestWorkUnitStreamSource.java       | 24 +++---
 .../runtime/api/TestJobExecutionState.java      | 14 +--
 .../apache/gobblin/runtime/api/TestJobSpec.java |  4 +-
 .../runtime/commit/CommitSequenceTest.java      | 12 +--
 .../commit/FsCommitSequenceStoreTest.java       | 18 ++--
 .../runtime/embedded/EmbeddedGobblinTest.java   | 14 +--
 .../TestDefaultGobblinInstanceDriverImpl.java   | 26 +++---
 .../TestStandardGobblinInstanceDriver.java      | 16 ++--
 .../TestStandardGobblinInstanceLauncher.java    | 32 +++----
 .../instance/hadoop/TestHadoopConfigLoader.java |  2 +-
 .../job_catalog/FSJobCatalogHelperTest.java     | 22 ++---
 ...ackagedTemplatesJobCatalogDecoratorTest.java | 10 +--
 .../runtime/job_catalog/TestFSJobCatalog.java   | 16 ++--
 .../job_catalog/TestImmutableFSJobCatalog.java  |  4 +-
 .../job_catalog/TestInMemoryJobCatalog.java     | 14 +--
 .../TestJobCatalogListenersList.java            |  6 +-
 .../TestMutableCachingJobCatalog.java           |  8 +-
 .../TestNonObservingFSJobCatalog.java           | 16 ++--
 .../TestJobLauncherExecutionDriver.java         | 16 ++--
 .../job_monitor/KafkaAvroJobMonitorTest.java    | 24 +++---
 .../job_monitor/KafkaJobMonitorTest.java        |  4 +-
 .../runtime/job_monitor/MockKafkaStream.java    |  2 +-
 .../job_monitor/MockedKafkaJobMonitor.java      | 10 +--
 .../SLAEventKafkaJobMonitorTest.java            | 16 ++--
 .../runtime/kafka/HighLevelConsumerTest.java    |  4 +-
 .../runtime/kafka/MockedHighLevelConsumer.java  |  6 +-
 .../runtime/local/LocalJobLauncherTest.java     | 26 +++---
 .../FileBasedJobLockFactoryManagerTest.java     |  4 +-
 .../runtime/locks/FileBasedJobLockTest.java     |  4 +-
 .../gobblin/runtime/locks/JobLockTest.java      |  2 +-
 .../locks/LegacyJobLockFactoryManagerTest.java  |  4 +-
 .../locks/ZookeeperBasedJobLockTest.java        |  4 +-
 .../mapreduce/GobblinOutputCommitterTest.java   | 10 +--
 .../GobblinWorkUnitsInputFormatTest.java        |  2 +-
 .../runtime/mapreduce/MRJobLauncherTest.java    | 26 +++---
 .../runtime/mapreduce/MRTaskFactoryTest.java    | 20 ++---
 .../TestImmediateJobSpecScheduler.java          |  8 +-
 .../scheduler/TestQuartzJobSpecScheduler.java   | 10 +--
 .../std/TestDefaultConfigurableImpl.java        |  4 +-
 .../std/TestFilteredJobLifecycleListener.java   | 14 +--
 .../std/TestJobExecutionStateListeners.java     | 12 +--
 .../std/TestJobLifecycleListenersList.java      | 12 +--
 .../gobblin/runtime/std/TestJobSpecFilter.java  |  4 +-
 .../template/InheritingJobTemplateTest.java     |  8 +-
 .../template/ResourceBasedJobTemplateTest.java  |  2 +-
 .../runtime/template/StaticJobTemplateTest.java |  6 +-
 .../gobblin/runtime/util/JobMetricsTest.java    | 16 ++--
 .../util/JobStateToJsonConverterTest.java       |  2 +-
 .../MultiWorkUnitUnpackingIteratorTest.java     |  6 +-
 .../gobblin/runtime/util/TaskMetricsTest.java   | 16 ++--
 .../scheduler/JobConfigFileMonitorTest.java     |  6 +-
 .../filebased/TextFileBasedSourceTest.java      | 12 +--
 .../gobblin/spec_catalog/FlowCatalogTest.java   | 18 ++--
 .../spec_catalog/TopologyCatalogTest.java       | 18 ++--
 .../org/apache/gobblin/task/CustomTaskTest.java | 10 +--
 .../task/EventBusPublishingTaskFactory.java     | 32 +++----
 .../org/apache/gobblin/test/TestConverter.java  |  8 +-
 .../org/apache/gobblin/test/TestConverter2.java | 16 ++--
 .../apache/gobblin/test/TestDataPublisher.java  | 10 +--
 .../org/apache/gobblin/test/TestExtractor.java  |  8 +-
 .../org/apache/gobblin/test/TestSource.java     | 22 ++---
 .../apache/gobblin/util/SchedulerUtilsTest.java | 10 +--
 .../org/apache/gobblin/util/TemplateTest.java   | 10 +--
 .../salesforce/SalesforceConfigurationKeys.java |  2 +-
 .../gobblin/salesforce/SalesforceConnector.java | 12 +--
 .../gobblin/salesforce/SalesforceExtractor.java | 50 +++++------
 .../gobblin/salesforce/SalesforceSource.java    | 40 ++++-----
 .../salesforce/SalesforceSourceTest.java        |  2 +-
 .../org/apache/gobblin/service/HelixUtils.java  |  4 +-
 .../gobblin/service/ServiceConfigKeys.java      | 10 +--
 .../gobblin/service/ServiceMetricNames.java     |  2 +-
 .../modules/core/GobblinServiceManager.java     | 50 +++++------
 .../flow/IdentityFlowToJobSpecCompiler.java     | 40 ++++-----
 .../modules/orchestration/Orchestrator.java     | 38 ++++-----
 .../scheduler/GobblinServiceJobScheduler.java   | 34 ++++----
 .../ConfigBasedTopologySpecFactory.java         | 14 +--
 .../modules/topology/TopologySpecFactory.java   |  6 +-
 .../modules/core/GobblinServiceHATest.java      | 32 +++----
 .../modules/core/GobblinServiceManagerTest.java | 30 +++----
 .../core/IdentityFlowToJobSpecCompilerTest.java | 24 +++---
 .../modules/orchestration/OrchestratorTest.java | 26 +++---
 .../ConfigBasedTopologySpecFactoryTest.java     | 10 +--
 .../test/execution/operator/SetupOperator.java  |  2 +-
 .../execution/validator/ValidationRule.java     |  2 +-
 .../test/setup/config/ConfigStepsGenerator.java |  2 +-
 .../apache/gobblin/test/setup/config/Step.java  |  2 +-
 .../test/setup/config/TestHarnessLauncher.java  |  2 +-
 .../gobblin/GobblinLocalJobLauncherUtils.java   |  6 +-
 .../org/apache/gobblin/TestAvroExtractor.java   |  8 +-
 .../java/org/apache/gobblin/TestAvroSource.java | 10 +--
 .../gobblin/TestSkipWorkUnitsPublisher.java     |  6 +-
 .../apache/gobblin/TestSkipWorkUnitsSource.java | 12 +--
 .../WriterOutputFormatIntegrationTest.java      |  4 +-
 .../data/management/CopyIntegrationTest.java    |  8 +-
 .../apache/gobblin/test/ConstantTimingType.java |  2 +-
 .../org/apache/gobblin/test/ErrorManager.java   |  4 +-
 .../org/apache/gobblin/test/NthTimingType.java  |  2 +-
 .../java/org/apache/gobblin/test/TestUtils.java |  2 +-
 .../org/apache/gobblin/test/TimingManager.java  |  2 +-
 .../org/apache/gobblin/test/TimingResult.java   |  2 +-
 .../org/apache/gobblin/test/TimingType.java     |  2 +-
 .../gobblin/test/crypto/InsecureShiftCodec.java |  4 +-
 .../test/crypto/TestEncryptionProvider.java     | 10 +--
 .../test/crypto/TestRandomCredentialStore.java  |  4 +-
 .../apache/gobblin/test/ErrorManagerTest.java   |  2 +-
 .../gobblin/test/RandomCredentialStoreTest.java |  8 +-
 .../apache/gobblin/tunnel/AcceptHandler.java    |  2 +-
 .../java/org/apache/gobblin/tunnel/Config.java  |  2 +-
 .../org/apache/gobblin/tunnel/HandlerState.java |  2 +-
 .../gobblin/tunnel/ProxySetupHandler.java       |  4 +-
 .../apache/gobblin/tunnel/ReadWriteHandler.java |  2 +-
 .../java/org/apache/gobblin/tunnel/Tunnel.java  |  4 +-
 .../gobblin/tunnel/ConnectProxyServer.java      |  2 +-
 .../apache/gobblin/tunnel/DoubleEchoServer.java |  2 +-
 .../org/apache/gobblin/tunnel/EasyThread.java   |  2 +-
 .../org/apache/gobblin/tunnel/MockServer.java   |  2 +-
 .../tunnel/TalkFirstDoubleEchoServer.java       |  2 +-
 .../apache/gobblin/tunnel/TalkPastServer.java   |  2 +-
 .../TestTunnelWithArbitraryTCPTraffic.java      |  2 +-
 .../org/apache/gobblin/tunnel/TunnelTest.java   |  2 +-
 .../broker/BrokerConfigurationKeyGenerator.java |  8 +-
 .../gobblin/broker/DefaultBrokerCache.java      | 10 +--
 .../org/apache/gobblin/broker/EmptyKey.java     |  4 +-
 .../broker/KeyedScopedConfigViewImpl.java       | 10 +--
 .../gobblin/broker/NonExtendableBrokerView.java |  6 +-
 .../apache/gobblin/broker/ResourceInstance.java |  4 +-
 .../org/apache/gobblin/broker/ScopeWrapper.java |  6 +-
 .../broker/SharedResourcesBrokerFactory.java    | 10 +--
 .../broker/SharedResourcesBrokerImpl.java       | 18 ++--
 .../broker/SharedResourcesBrokerUtils.java      |  4 +-
 .../apache/gobblin/broker/TTLResourceEntry.java |  2 +-
 .../org/apache/gobblin/broker/package-info.java |  2 +-
 .../copy/hive/WhitelistBlacklist.java           |  2 +-
 .../gobblin/runtime/cli/CliApplication.java     |  2 +-
 .../gobblin/runtime/cli/CliObjectFactory.java   |  2 +-
 .../gobblin/runtime/cli/CliObjectOption.java    |  2 +-
 .../gobblin/runtime/cli/CliObjectSupport.java   |  2 +-
 ...tructorAndPublicMethodsCliObjectFactory.java |  2 +-
 .../apache/gobblin/runtime/cli/GobblinCli.java  |  6 +-
 .../apache/gobblin/runtime/cli/NotOnCli.java    |  2 +-
 .../cli/PublicMethodsCliObjectFactory.java      |  2 +-
 .../gobblin/util/ApplicationLauncherUtils.java  |  2 +-
 .../apache/gobblin/util/AutoCloseableLock.java  |  2 +-
 .../gobblin/util/AutoReturnableObject.java      |  2 +-
 .../org/apache/gobblin/util/AvroFlattener.java  |  2 +-
 .../java/org/apache/gobblin/util/AvroUtils.java |  2 +-
 .../org/apache/gobblin/util/AzkabanTags.java    |  2 +-
 .../gobblin/util/CLIPasswordEncryptor.java      |  4 +-
 .../apache/gobblin/util/ClusterNameTags.java    |  2 +-
 .../org/apache/gobblin/util/ClustersNames.java  |  2 +-
 .../org/apache/gobblin/util/ConfigUtils.java    |  6 +-
 .../apache/gobblin/util/DatasetFilterUtils.java |  4 +-
 .../apache/gobblin/util/DatePartitionType.java  |  2 +-
 .../java/org/apache/gobblin/util/Either.java    |  2 +-
 .../org/apache/gobblin/util/EmailUtils.java     |  8 +-
 .../org/apache/gobblin/util/EmptyIterable.java  |  2 +-
 .../org/apache/gobblin/util/ExecutorsUtils.java | 10 +--
 .../apache/gobblin/util/ExponentialBackoff.java |  2 +-
 .../org/apache/gobblin/util/FileListUtils.java  |  2 +-
 .../apache/gobblin/util/ForkOperatorUtils.java  |  8 +-
 .../org/apache/gobblin/util/HadoopUtils.java    | 12 +--
 .../gobblin/util/HeapDumpForTaskUtils.java      |  4 +-
 .../apache/gobblin/util/HiveJdbcConnector.java  |  4 +-
 .../java/org/apache/gobblin/util/HostUtils.java |  2 +-
 .../main/java/org/apache/gobblin/util/Id.java   |  2 +-
 .../gobblin/util/ImmutableProperties.java       |  2 +-
 .../gobblin/util/JobConfigurationUtils.java     |  4 +-
 .../apache/gobblin/util/JobLauncherUtils.java   | 10 +--
 .../java/org/apache/gobblin/util/JvmUtils.java  |  2 +-
 .../util/LoggingUncaughtExceptionHandler.java   |  2 +-
 .../org/apache/gobblin/util/NoopCloseable.java  |  2 +-
 .../org/apache/gobblin/util/ParallelRunner.java |  4 +-
 .../java/org/apache/gobblin/util/PathUtils.java |  2 +-
 .../java/org/apache/gobblin/util/PortUtils.java |  2 +-
 .../apache/gobblin/util/PropertiesUtils.java    |  2 +-
 .../gobblin/util/ProxiedFileSystemCache.java    |  6 +-
 .../gobblin/util/ProxiedFileSystemUtils.java    |  6 +-
 .../gobblin/util/ProxiedFileSystemWrapper.java  |  6 +-
 .../org/apache/gobblin/util/PublisherUtils.java | 10 +--
 .../org/apache/gobblin/util/PullFileLoader.java |  4 +-
 .../gobblin/util/RateControlledFileSystem.java  |  8 +-
 .../apache/gobblin/util/SerializationUtils.java |  4 +-
 .../apache/gobblin/util/StringParsingUtils.java |  2 +-
 .../org/apache/gobblin/util/TemplateUtils.java  |  4 +-
 .../apache/gobblin/util/TimeRangeChecker.java   |  4 +-
 .../gobblin/util/WritableShimSerialization.java |  4 +-
 .../org/apache/gobblin/util/WriterUtils.java    | 10 +--
 .../gobblin/util/binpacking/FieldWeighter.java  |  6 +-
 .../WorstFitDecreasingBinPacking.java           | 10 +--
 .../apache/gobblin/util/callbacks/Callback.java |  2 +-
 .../gobblin/util/callbacks/CallbackResult.java  |  2 +-
 .../util/callbacks/CallbacksDispatcher.java     |  4 +-
 .../gobblin/util/callbacks/package-info.java    |  2 +-
 .../gobblin/util/concurrent/AutoResetEvent.java |  2 +-
 .../util/concurrent/CancellableTask.java        |  2 +-
 .../HashedWheelTimerTaskScheduler.java          |  4 +-
 .../ScheduledExecutorServiceTaskScheduler.java  |  4 +-
 .../gobblin/util/concurrent/ScheduledTask.java  |  2 +-
 .../gobblin/util/concurrent/TaskScheduler.java  |  2 +-
 .../util/concurrent/TaskSchedulerFactory.java   |  2 +-
 .../util/concurrent/TaskSchedulerType.java      |  2 +-
 .../gobblin/util/dataset/DatasetUtils.java      |  8 +-
 .../util/deprecation/DeprecationUtils.java      |  4 +-
 .../util/executors/ForceQueuePolicy.java        |  2 +-
 .../util/executors/IteratorExecutor.java        |  6 +-
 .../util/executors/MDCPropagatingCallable.java  |  2 +-
 .../MDCPropagatingExecutorService.java          |  2 +-
 .../util/executors/MDCPropagatingRunnable.java  |  2 +-
 .../MDCPropagatingScheduledExecutorService.java |  2 +-
 .../gobblin/util/executors/ScalingQueue.java    |  2 +-
 .../executors/ScalingThreadPoolExecutor.java    |  2 +-
 ...CatchingPathAlterationListenerDecorator.java |  4 +-
 .../util/filesystem/FileStatusEntry.java        |  2 +-
 .../util/filesystem/FileSystemDecorator.java    |  6 +-
 .../util/filesystem/FileSystemFactory.java      | 18 ++--
 .../filesystem/FileSystemInstrumentation.java   |  2 +-
 .../FileSystemInstrumentationFactory.java       |  8 +-
 .../gobblin/util/filesystem/FileSystemKey.java  |  4 +-
 .../util/filesystem/FileSystemLimiterKey.java   |  6 +-
 .../util/filesystem/InstrumentedFileSystem.java |  6 +-
 .../filesystem/InstrumentedFileSystemUtils.java |  2 +-
 .../filesystem/InstrumentedHDFSFileSystem.java  |  2 +-
 .../filesystem/InstrumentedLocalFileSystem.java |  2 +-
 .../InstrumentedWebHDFSFileSystem.java          |  2 +-
 .../util/filesystem/PathAlterationListener.java |  2 +-
 .../PathAlterationListenerAdaptor.java          |  2 +-
 .../util/filesystem/PathAlterationObserver.java |  4 +-
 .../PathAlterationObserverScheduler.java        |  4 +-
 .../util/filesystem/ThrottledFileSystem.java    | 18 ++--
 .../gobblin/util/filters/AndPathFilter.java     |  2 +-
 .../gobblin/util/filters/HiddenFilter.java      |  2 +-
 .../gobblin/util/filters/RegexPathFilter.java   |  2 +-
 .../gobblin/util/filters/TarGpgPathFilter.java  |  2 +-
 .../java/org/apache/gobblin/util/guid/Guid.java |  2 +-
 .../org/apache/gobblin/util/guid/HasGuid.java   |  2 +-
 .../apache/gobblin/util/hadoop/TokenUtils.java  |  4 +-
 .../gobblin/util/http/HttpLimiterKey.java       |  4 +-
 .../util/io/AdditionalCloseableInputStream.java |  2 +-
 .../gobblin/util/io/BatchedMeterDecorator.java  |  4 +-
 .../gobblin/util/io/CloseableHttpConn.java      |  2 +-
 .../gobblin/util/io/FilterStreamUnpacker.java   |  2 +-
 .../gobblin/util/io/GsonInterfaceAdapter.java   |  2 +-
 .../gobblin/util/io/MeteredInputStream.java     |  2 +-
 .../gobblin/util/io/MeteredOutputStream.java    |  2 +-
 .../apache/gobblin/util/io/MeteredStream.java   |  2 +-
 .../gobblin/util/io/SeekableFSInputStream.java  |  2 +-
 .../apache/gobblin/util/io/StreamCopier.java    |  4 +-
 .../util/io/StreamCopierSharedLimiterKey.java   |  6 +-
 .../apache/gobblin/util/io/StreamThrottler.java | 28 +++---
 .../org/apache/gobblin/util/io/StreamUtils.java |  4 +-
 .../gobblin/util/io/ThrottledInputStream.java   |  4 +-
 .../util/iterators/InterruptibleIterator.java   |  2 +-
 .../gobblin/util/jdbc/DataSourceBuilder.java    |  6 +-
 .../gobblin/util/jdbc/DataSourceModule.java     |  2 +-
 .../gobblin/util/jdbc/DataSourceProvider.java   |  4 +-
 .../org/apache/gobblin/util/json/JsonUtils.java |  2 +-
 .../gobblin/util/limiter/BaseLimiterType.java   |  2 +-
 .../gobblin/util/limiter/CountBasedLimiter.java |  4 +-
 .../util/limiter/DefaultLimiterFactory.java     |  4 +-
 .../apache/gobblin/util/limiter/Limiter.java    |  2 +-
 .../gobblin/util/limiter/LimiterFactory.java    |  2 +-
 .../gobblin/util/limiter/MultiLimiter.java      |  2 +-
 .../util/limiter/NonRefillableLimiter.java      |  2 +-
 .../gobblin/util/limiter/NoopLimiter.java       |  2 +-
 .../util/limiter/NotEnoughPermitsException.java |  4 +-
 .../gobblin/util/limiter/PoolBasedLimiter.java  |  4 +-
 .../gobblin/util/limiter/RateBasedLimiter.java  |  4 +-
 .../gobblin/util/limiter/TimeBasedLimiter.java  |  6 +-
 .../limiter/broker/SharedLimiterFactory.java    | 34 ++++----
 .../util/limiter/broker/SharedLimiterKey.java   |  4 +-
 .../util/logs/Log4jConfigurationHelper.java     |  2 +-
 .../org/apache/gobblin/util/logs/LogCopier.java | 16 ++--
 .../CompactionRecordCountProvider.java          |  4 +-
 .../IngestionRecordCountProvider.java           |  4 +-
 .../LateFileRecordCountProvider.java            |  4 +-
 .../reflection/GobblinConstructorUtils.java     |  2 +-
 .../AllocatedRequestsIterator.java              |  2 +-
 .../AllocatedRequestsIteratorBase.java          |  2 +-
 .../request_allocation/BruteForceAllocator.java |  2 +-
 .../ConcurrentBoundedPriorityIterable.java      |  2 +-
 .../request_allocation/GreedyAllocator.java     |  4 +-
 .../HierarchicalAllocator.java                  |  2 +-
 .../HierarchicalPrioritizer.java                |  2 +-
 .../request_allocation/PreOrderAllocator.java   |  4 +-
 .../PriorityIterableBasedRequestAllocator.java  |  8 +-
 .../PriorityMultiIterator.java                  |  2 +-
 .../request_allocation/PushDownRequestor.java   |  2 +-
 .../util/request_allocation/Request.java        |  2 +-
 .../request_allocation/RequestAllocator.java    |  2 +-
 .../RequestAllocatorConfig.java                 |  2 +-
 .../RequestAllocatorUtils.java                  |  4 +-
 .../util/request_allocation/Requestor.java      |  2 +-
 .../request_allocation/ResourceEstimator.java   |  2 +-
 .../util/request_allocation/ResourcePool.java   |  2 +-
 .../request_allocation/ResourceRequirement.java |  2 +-
 .../SimpleHierarchicalPrioritizer.java          |  2 +-
 .../util/request_allocation/VectorAlgebra.java  |  2 +-
 .../util/service/StandardServiceConfig.java     |  2 +-
 .../gobblin/util/test/FastSequentialSource.java | 14 +--
 .../gobblin/util/test/HelloWorldSource.java     | 18 ++--
 .../apache/gobblin/util/test/StdoutWriter.java  |  6 +-
 .../apache/gobblin/util/test/TestingSource.java | 14 +--
 .../gobblin/broker/AutoscopedFactoryTest.java   |  8 +-
 .../broker/DefaultGobblinBrokerTest.java        | 24 +++---
 .../gobblin/broker/GobblinBrokerConfTest.java   |  8 +-
 .../broker/GobblinBrokerCreationTest.java       | 10 +--
 .../broker/KeyedScopedConfigViewImplTest.java   |  4 +-
 .../SharedResourcesBrokerFactoryTest.java       |  6 +-
 .../org/apache/gobblin/broker/TestFactory.java  | 16 ++--
 .../gobblin/broker/TestFactoryWithRedirect.java | 10 +--
 .../apache/gobblin/broker/TestResourceKey.java  |  4 +-
 ...torAndPublicMethodsCliObjectFactoryTest.java |  2 +-
 .../cli/PublicMethodsCliObjectFactoryTest.java  |  2 +-
 .../apache/gobblin/util/AvroFlattenerTest.java  |  2 +-
 .../org/apache/gobblin/util/AvroUtilsTest.java  |  2 +-
 .../apache/gobblin/util/ClustersNamesTest.java  |  2 +-
 .../apache/gobblin/util/ConfigUtilsTest.java    |  6 +-
 .../gobblin/util/DatePartitionTypeTest.java     |  2 +-
 .../apache/gobblin/util/ExecutorsUtilsTest.java |  2 +-
 .../apache/gobblin/util/FileListUtilsTest.java  |  2 +-
 .../gobblin/util/ForkOperatorUtilsTest.java     |  8 +-
 .../apache/gobblin/util/HadoopUtilsTest.java    |  4 +-
 .../gobblin/util/HeapDumpForTaskUtilsTest.java  |  2 +-
 .../gobblin/util/JobLauncherUtilsTest.java      | 16 ++--
 .../LoggingUncaughtExceptionHandlerTest.java    |  2 +-
 .../apache/gobblin/util/ParallelRunnerTest.java | 12 +--
 .../org/apache/gobblin/util/PortUtilsTest.java  |  2 +-
 .../gobblin/util/PropertiesUtilsTest.java       |  2 +-
 .../apache/gobblin/util/PullFileLoaderTest.java |  4 +-
 .../util/RatedControlledFileSystemTest.java     |  6 +-
 .../gobblin/util/SerializationUtilsTest.java    |  4 +-
 .../gobblin/util/StringParsingUtilsTest.java    |  2 +-
 .../gobblin/util/TestImmutableProperties.java   |  2 +-
 .../gobblin/util/TimeRangeCheckerTest.java      |  4 +-
 .../apache/gobblin/util/WriterUtilsTest.java    | 16 ++--
 .../WorstFitDecreasingBinPackingTest.java       | 10 +--
 .../util/callbacks/TestCallbacksDispatcher.java |  2 +-
 .../HashedWheelTimerTaskSchedulerTest.java      |  2 +-
 ...heduledExecutorServiceTaskSchedulerTest.java |  2 +-
 .../concurrent/TaskSchedulerFactoryTest.java    |  2 +-
 .../util/concurrent/TaskSchedulerTest.java      |  2 +-
 .../gobblin/util/dataset/DatasetUtilsTest.java  |  6 +-
 .../util/executors/IteratorExecutorTest.java    |  4 +-
 .../util/filesystem/FileSystemFactoryTest.java  | 12 +--
 .../InstrumentedLocalFileSystemTest.java        |  4 +-
 .../filesystem/ThrottledFileSystemTest.java     |  8 +-
 .../util/filters/RegexPathFilterTest.java       |  2 +-
 .../org/apache/gobblin/util/guid/GuidTest.java  |  2 +-
 .../util/io/GsonInterfaceAdapterTest.java       |  6 +-
 .../gobblin/util/io/MeteredInputStreamTest.java |  2 +-
 .../util/io/MeteredOutputStreamTest.java        |  2 +-
 .../gobblin/util/io/StreamCopierTest.java       |  4 +-
 .../apache/gobblin/util/io/StreamUtilsTest.java |  2 +-
 .../util/io/ThrottledInputStreamTest.java       |  6 +-
 .../util/limiter/CountBasedLimiterTest.java     |  6 +-
 .../util/limiter/DefaultLimiterFactoryTest.java |  4 +-
 .../gobblin/util/limiter/MultiLimiterTest.java  |  2 +-
 .../util/limiter/RateBasedLimiterTest.java      |  6 +-
 .../util/limiter/TimeBasedLimiterTest.java      |  6 +-
 .../broker/SharedLimiterFactoryTest.java        | 26 +++---
 .../CompactionRecordCountProviderTest.java      |  2 +-
 .../IngestionRecordCountProviderTest.java       |  2 +-
 .../reflection/GobblinConstructorUtilsTest.java |  2 +-
 .../BruteForceAllocatorTest.java                |  2 +-
 .../ConcurrentBoundedPriorityIterableTest.java  |  2 +-
 .../request_allocation/GreedyAllocatorTest.java |  2 +-
 .../HierarchicalAllocatorTest.java              |  2 +-
 .../PreOrderAllocatorTest.java                  |  2 +-
 .../request_allocation/ResourcePoolTest.java    |  2 +-
 .../util/request_allocation/StringRequest.java  |  2 +-
 .../request_allocation/StringRequestor.java     |  2 +-
 .../request_allocation/VectorAlgebraTest.java   |  2 +-
 .../org/apache/gobblin/util/test/BaseClass.java |  2 +-
 .../apache/gobblin/util/test/ExtendedClass.java |  2 +-
 .../org/apache/gobblin/util/test/TestClass.java |  2 +-
 .../gobblin/util/test/TestHelloWorldSource.java | 12 +--
 .../gobblin/yarn/GobblinApplicationMaster.java  | 14 +--
 .../gobblin/yarn/GobblinYarnAppLauncher.java    | 32 +++----
 .../yarn/GobblinYarnConfigurationKeys.java      |  2 +-
 .../gobblin/yarn/GobblinYarnEventConstants.java |  2 +-
 .../gobblin/yarn/GobblinYarnLogSource.java      |  4 +-
 .../gobblin/yarn/GobblinYarnMetricTagNames.java |  2 +-
 .../gobblin/yarn/GobblinYarnTaskRunner.java     | 12 +--
 .../gobblin/yarn/HelixMessageSubTypes.java      |  2 +-
 .../gobblin/yarn/YarnAppSecurityManager.java    |  6 +-
 .../yarn/YarnContainerSecurityManager.java      |  4 +-
 .../org/apache/gobblin/yarn/YarnHelixUtils.java |  2 +-
 .../org/apache/gobblin/yarn/YarnService.java    | 32 +++----
 .../event/ApplicationReportArrivalEvent.java    |  2 +-
 .../yarn/event/ContainerShutdownRequest.java    |  2 +-
 .../yarn/event/DelegationTokenUpdatedEvent.java |  2 +-
 .../event/GetApplicationReportFailureEvent.java |  2 +-
 .../gobblin/yarn/event/NewContainerRequest.java |  2 +-
 .../yarn/GobblinYarnAppLauncherTest.java        | 16 ++--
 .../gobblin/yarn/YarnSecurityManagerTest.java   | 10 +--
 gradle/scripts/defaultBuildProperties.gradle    |  4 +-
 2410 files changed, 10266 insertions(+), 10266 deletions(-)
----------------------------------------------------------------------



Mime
View raw message