duplicated block id: 1 size: 60 cleaned lines of code in 2 files: - gobblin-modules/gobblin-parquet/src/main/java/org/apache/gobblin/writer/ParquetDataWriterBuilder.java (51:116) - gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/writer/ParquetDataWriterBuilder.java (52:117) duplicated block id: 2 size: 28 cleaned lines of code in 2 files: - gobblin-modules/gobblin-parquet/src/main/java/org/apache/gobblin/converter/parquet/JsonElementConversionFactory.java (75:116) - gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/converter/parquet/JsonElementConversionFactory.java (75:116) duplicated block id: 3 size: 26 cleaned lines of code in 2 files: - gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV101.java (968:999) - gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV100.java (879:910) duplicated block id: 4 size: 23 cleaned lines of code in 2 files: - gobblin-completeness/src/main/java/org/apache/gobblin/completeness/audit/AuditCountHttpClient.java (144:169) - gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/KafkaAuditCountHttpClient.java (155:180) duplicated block id: 5 size: 21 cleaned lines of code in 2 files: - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/yarn/GobblinTemporalYarnTaskRunner.java (65:88) - gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnTaskRunner.java (71:94) duplicated block id: 6 size: 20 cleaned lines of code in 2 files: - gobblin-modules/gobblin-parquet/src/main/java/org/apache/gobblin/converter/parquet/JsonElementConversionFactory.java (413:434) - gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/converter/parquet/JsonElementConversionFactory.java (413:434) duplicated block id: 7 size: 19 cleaned lines of code in 2 files: - gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobSchedulerMetrics.java (51:75) - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobSchedulerMetrics.java (50:74) duplicated block id: 8 size: 18 cleaned lines of code in 2 files: - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/yarn/YarnService.java (467:489) - gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnService.java (700:722) duplicated block id: 9 size: 18 cleaned lines of code in 2 files: - gobblin-modules/gobblin-parquet/src/main/java/org/apache/gobblin/converter/parquet/ParquetGroup.java (65:84) - gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/converter/parquet/ParquetGroup.java (64:83) duplicated block id: 10 size: 18 cleaned lines of code in 3 files: - gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/ComplianceRetentionJob.java (165:184) - gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/validation/ComplianceValidationJob.java (115:134) - gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java (118:137) duplicated block id: 11 size: 18 cleaned lines of code in 2 files: - gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/PostgresqlExtractor.java (121:144) - gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/MysqlExtractor.java (134:156) duplicated block id: 12 size: 18 cleaned lines of code in 2 files: - gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/PostgresqlExtractor.java (215:237) - gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/MysqlExtractor.java (234:256) duplicated block id: 13 size: 15 cleaned lines of code in 3 files: - gobblin-modules/gobblin-kafka-1/src/main/java/org/apache/gobblin/kafka/writer/Kafka1DataWriter.java (120:136) - gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/writer/Kafka09DataWriter.java (130:146) - gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/writer/Kafka08DataWriter.java (127:143) duplicated block id: 14 size: 14 cleaned lines of code in 4 files: - gobblin-modules/gobblin-kafka-1/src/main/java/org/apache/gobblin/kafka/writer/Kafka1DataWriter.java (54:71) - gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/writer/Kafka09DataWriter.java (64:81) - gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/writer/Kafka08DataWriter.java (57:75) - gobblin-core-base/src/main/java/org/apache/gobblin/writer/BufferedAsyncDataWriter.java (54:72) duplicated block id: 15 size: 14 cleaned lines of code in 2 files: - gobblin-modules/gobblin-parquet/src/main/java/org/apache/gobblin/converter/parquet/JsonElementConversionFactory.java (396:411) - gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/converter/parquet/JsonElementConversionFactory.java (396:411) duplicated block id: 16 size: 14 cleaned lines of code in 2 files: - gobblin-modules/gobblin-parquet/src/main/java/org/apache/gobblin/converter/parquet/JsonElementConversionFactory.java (464:479) - gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/converter/parquet/JsonElementConversionFactory.java (464:479) duplicated block id: 17 size: 14 cleaned lines of code in 2 files: - gobblin-modules/gobblin-parquet/src/main/java/org/apache/gobblin/converter/parquet/ParquetGroup.java (97:113) - gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/converter/parquet/ParquetGroup.java (96:112) duplicated block id: 18 size: 13 cleaned lines of code in 2 files: - gobblin-runtime/src/main/java/org/apache/gobblin/runtime/BaseLimiterType.java (63:77) - gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/BaseLimiterType.java (64:78) duplicated block id: 19 size: 13 cleaned lines of code in 2 files: - gobblin-modules/gobblin-kafka-1/src/main/java/org/apache/gobblin/metrics/kafka/KafkaKeyValueProducerPusher.java (49:69) - gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/metrics/kafka/KafkaKeyValueProducerPusher.java (51:71) duplicated block id: 20 size: 12 cleaned lines of code in 2 files: - gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobLauncherListener.java (59:72) - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobLauncherListener.java (59:72) duplicated block id: 21 size: 12 cleaned lines of code in 2 files: - gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobScheduler.java (222:237) - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobScheduler.java (137:152) duplicated block id: 22 size: 12 cleaned lines of code in 2 files: - gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterManager.java (382:395) - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalClusterManager.java (251:264) duplicated block id: 23 size: 12 cleaned lines of code in 2 files: - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/yarn/YarnService.java (293:310) - gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnService.java (451:468) duplicated block id: 24 size: 12 cleaned lines of code in 2 files: - gobblin-modules/gobblin-kafka-1/src/main/java/org/apache/gobblin/metrics/kafka/KafkaProducerPusher.java (46:64) - gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/metrics/kafka/KafkaProducerPusher.java (49:67) duplicated block id: 25 size: 12 cleaned lines of code in 3 files: - gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/PostgresqlExtractor.java (199:212) - gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/SqlServerExtractor.java (278:291) - gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/MysqlExtractor.java (218:231) duplicated block id: 26 size: 11 cleaned lines of code in 2 files: - gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/DateWatermark.java (141:153) - gobblin-core/src/main/java/org/apache/gobblin/source/extractor/watermark/HourWatermark.java (138:150) duplicated block id: 27 size: 11 cleaned lines of code in 2 files: - gobblin-modules/gobblin-parquet/src/main/java/org/apache/gobblin/converter/parquet/ParquetGroup.java (191:203) - gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/converter/parquet/ParquetGroup.java (189:201) duplicated block id: 28 size: 11 cleaned lines of code in 2 files: - gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaKeyValueProducerPusher.java (125:137) - gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaProducerPusher.java (122:134) duplicated block id: 29 size: 10 cleaned lines of code in 2 files: - gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java (390:401) - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalTaskRunner.java (264:275) duplicated block id: 30 size: 10 cleaned lines of code in 2 files: - gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java (794:805) - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalTaskRunner.java (382:393) duplicated block id: 31 size: 10 cleaned lines of code in 2 files: - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/yarn/YarnService.java (727:739) - gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnService.java (1121:1133) duplicated block id: 32 size: 10 cleaned lines of code in 2 files: - gobblin-core/src/main/java/org/apache/gobblin/source/RegexBasedPartitionedRetriever.java (178:190) - gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedNestedRetriever.java (225:237) duplicated block id: 33 size: 10 cleaned lines of code in 2 files: - gobblin-modules/gobblin-kafka-1/src/main/java/org/apache/gobblin/kafka/client/Kafka1ConsumerClient.java (195:207) - gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/client/Kafka09ConsumerClient.java (227:239) duplicated block id: 34 size: 10 cleaned lines of code in 2 files: - gobblin-modules/gobblin-kafka-1/src/main/java/org/apache/gobblin/kafka/client/Kafka1ConsumerClient.java (223:234) - gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/client/Kafka09ConsumerClient.java (255:266) duplicated block id: 35 size: 10 cleaned lines of code in 2 files: - gobblin-admin/src/main/resources/static/js/views/over-view.js (45:56) - gobblin-admin/src/main/resources/static/js/views/job-view.js (49:60) duplicated block id: 36 size: 9 cleaned lines of code in 2 files: - gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixPlanningJobLauncherMetrics.java (39:50) - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalPlanningJobLauncherMetrics.java (40:51) duplicated block id: 37 size: 9 cleaned lines of code in 2 files: - gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/CombineSelectionPolicy.java (183:193) - gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/CombineRetentionPolicy.java (193:203) duplicated block id: 38 size: 9 cleaned lines of code in 2 files: - gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/CombineSelectionPolicy.java (195:205) - gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/CombineRetentionPolicy.java (205:215) duplicated block id: 39 size: 9 cleaned lines of code in 2 files: - gobblin-modules/gobblin-kafka-1/src/main/java/org/apache/gobblin/kafka/writer/Kafka1DataWriter.java (78:88) - gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/writer/Kafka09DataWriter.java (88:98) duplicated block id: 40 size: 9 cleaned lines of code in 2 files: - gobblin-modules/gobblin-parquet/src/main/java/org/apache/gobblin/converter/parquet/JsonElementConversionFactory.java (449:461) - gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/converter/parquet/JsonElementConversionFactory.java (449:461) duplicated block id: 41 size: 9 cleaned lines of code in 2 files: - gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/PostgresBufferedInserter.java (39:50) - gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/MySqlBufferedInserter.java (78:88) duplicated block id: 42 size: 8 cleaned lines of code in 2 files: - gobblin-runtime/src/main/java/org/apache/gobblin/runtime/MysqlDatasetStateStore.java (116:127) - gobblin-modules/gobblin-helix/src/main/java/org/apache/gobblin/runtime/ZkDatasetStateStore.java (107:118) duplicated block id: 43 size: 8 cleaned lines of code in 2 files: - gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java (604:613) - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalTaskRunner.java (336:345) duplicated block id: 44 size: 8 cleaned lines of code in 2 files: - gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobScheduler.java (425:434) - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobScheduler.java (247:256) duplicated block id: 45 size: 8 cleaned lines of code in 2 files: - gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/OpenTelemetryMetrics.java (131:140) - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/metrics/TemporalMetricsHelper.java (118:127) duplicated block id: 46 size: 8 cleaned lines of code in 2 files: - gobblin-modules/gobblin-kafka-1/src/main/java/org/apache/gobblin/kafka/client/Kafka1ConsumerClient.java (118:127) - gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/client/Kafka09ConsumerClient.java (134:143) duplicated block id: 47 size: 8 cleaned lines of code in 2 files: - gobblin-modules/gobblin-parquet/src/main/java/org/apache/gobblin/converter/parquet/JsonElementConversionFactory.java (135:144) - gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/converter/parquet/JsonElementConversionFactory.java (135:144) duplicated block id: 48 size: 8 cleaned lines of code in 2 files: - gobblin-modules/gobblin-parquet/src/main/java/org/apache/gobblin/converter/parquet/ParquetGroup.java (115:124) - gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/converter/parquet/ParquetGroup.java (114:123) duplicated block id: 49 size: 8 cleaned lines of code in 2 files: - gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroEventReporter.java (40:49) - gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroEventKeyValueReporter.java (43:52) duplicated block id: 50 size: 7 cleaned lines of code in 3 files: - gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/FlowSpec.java (363:371) - gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/TopologySpec.java (290:298) - gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpec.java (272:280) duplicated block id: 51 size: 7 cleaned lines of code in 2 files: - gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskState.java (308:317) - gobblin-runtime/src/main/java/org/apache/gobblin/runtime/JobState.java (631:640) duplicated block id: 52 size: 7 cleaned lines of code in 2 files: - gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java (775:784) - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalTaskRunner.java (363:372) duplicated block id: 53 size: 7 cleaned lines of code in 2 files: - gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/OutputStreamEventReporter.java (150:158) - gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/OutputStreamReporter.java (120:128) duplicated block id: 54 size: 7 cleaned lines of code in 2 files: - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/yarn/YarnService.java (689:698) - gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnService.java (1083:1092) duplicated block id: 55 size: 7 cleaned lines of code in 4 files: - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/loadgen/launcher/GenArbitraryLoadJobLauncher.java (68:76) - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/launcher/ExecuteGobblinJobLauncher.java (72:80) - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/launcher/GenerateWorkUnitsJobLauncher.java (61:69) - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/launcher/ProcessWorkUnitsJobLauncher.java (74:82) duplicated block id: 56 size: 7 cleaned lines of code in 3 files: - gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/main/java/org/apache/gobblin/service/FlowExecutionClient.java (198:207) - gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/main/java/org/apache/gobblin/service/FlowConfigV2Client.java (305:314) - gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/main/java/org/apache/gobblin/service/FlowStatusClient.java (162:171) duplicated block id: 57 size: 7 cleaned lines of code in 2 files: - gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaStreamingExtractor.java (194:202) - gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.java (132:140) duplicated block id: 58 size: 7 cleaned lines of code in 2 files: - gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/service/AvroJobSpecDeserializer.java (55:65) - gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/service/AvroJobSpecDeserializer.java (55:65) duplicated block id: 59 size: 7 cleaned lines of code in 3 files: - gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/JdbcWriter.java (113:122) - gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/initializer/JdbcWriterInitializer.java (149:158) - gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/initializer/AvroToJdbcEntryConverterInitializer.java (105:114) duplicated block id: 60 size: 6 cleaned lines of code in 2 files: - gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/ClustersNames.java (34:42) - gobblin-utility/src/main/java/org/apache/gobblin/util/ClustersNames.java (204:212) duplicated block id: 61 size: 6 cleaned lines of code in 2 files: - gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobLifecycleListenersList.java (99:106) - gobblin-runtime/src/main/java/org/apache/gobblin/runtime/std/JobExecutionStateListeners.java (69:76) duplicated block id: 62 size: 6 cleaned lines of code in 2 files: - gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java (321:328) - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalTaskRunner.java (209:216) duplicated block id: 63 size: 6 cleaned lines of code in 2 files: - gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java (451:458) - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalTaskRunner.java (311:318) duplicated block id: 64 size: 6 cleaned lines of code in 2 files: - gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterManager.java (574:581) - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalClusterManager.java (355:362) duplicated block id: 65 size: 6 cleaned lines of code in 2 files: - gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/OutputStreamEventReporter.java (94:101) - gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/OutputStreamReporter.java (344:351) duplicated block id: 66 size: 6 cleaned lines of code in 2 files: - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/yarn/YarnService.java (666:674) - gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnService.java (1060:1068) duplicated block id: 67 size: 6 cleaned lines of code in 2 files: - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/yarn/YarnService.java (742:750) - gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnService.java (1136:1144) duplicated block id: 68 size: 6 cleaned lines of code in 2 files: - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/yarn/YarnService.java (753:761) - gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnService.java (1147:1155) duplicated block id: 69 size: 6 cleaned lines of code in 2 files: - gobblin-temporal/src/main/java/org/apache/gobblin/temporal/yarn/YarnService.java (764:772) - gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnService.java (1158:1166) duplicated block id: 70 size: 6 cleaned lines of code in 2 files: - gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFsHelper.java (139:146) - gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/AvroFsHelper.java (108:115) duplicated block id: 71 size: 6 cleaned lines of code in 2 files: - gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverter.java (250:257) - gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/AvroProjectionConverter.java (89:96) duplicated block id: 72 size: 6 cleaned lines of code in 2 files: - gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/GlobModTimeDatasetVersionFinder.java (70:77) - gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/UnixTimestampVersionFinder.java (50:57) duplicated block id: 73 size: 6 cleaned lines of code in 2 files: - gobblin-modules/gobblin-kafka-1/src/main/java/org/apache/gobblin/kafka/client/Kafka1ConsumerClient.java (150:159) - gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/client/Kafka09ConsumerClient.java (182:191) duplicated block id: 74 size: 6 cleaned lines of code in 2 files: - gobblin-modules/gobblin-kafka-1/src/main/java/org/apache/gobblin/kafka/writer/Kafka1DataWriter.java (111:118) - gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/writer/Kafka09DataWriter.java (121:128) duplicated block id: 75 size: 6 cleaned lines of code in 2 files: - gobblin-modules/gobblin-parquet/src/main/java/org/apache/gobblin/converter/parquet/JsonElementConversionFactory.java (320:327) - gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/converter/parquet/JsonElementConversionFactory.java (320:327) duplicated block id: 76 size: 6 cleaned lines of code in 2 files: - gobblin-modules/gobblin-parquet/src/main/java/org/apache/gobblin/converter/parquet/ParquetGroup.java (231:238) - gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/converter/parquet/ParquetGroup.java (229:236) duplicated block id: 77 size: 6 cleaned lines of code in 2 files: - gobblin-modules/gobblin-parquet/src/main/java/org/apache/gobblin/converter/parquet/JsonIntermediateToParquetGroupConverter.java (43:50) - gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/converter/parquet/JsonIntermediateToParquetGroupConverter.java (42:49) duplicated block id: 78 size: 6 cleaned lines of code in 2 files: - gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroDeserializer.java (47:54) - gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/serialize/LiAvroDeserializer.java (47:54) duplicated block id: 79 size: 6 cleaned lines of code in 2 files: - gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/client/Kafka08ConsumerClient.java (165:172) - gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaWrapper.java (337:344) duplicated block id: 80 size: 6 cleaned lines of code in 2 files: - gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSTaskRunner.java (135:143) - gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSClusterManager.java (125:133)