23 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/WritableTypeInfo.java (72:104, 32%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/EnumTypeInfo.java (62:94, 38%) 19 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/WritableTypeInfo.java (72:98, 26%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/GenericTypeInfo.java (45:71, 29%) 19 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/WritableTypeInfo.java (72:98, 26%) - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/PrimitiveArrayTypeInfo.java (101:127, 19%) 19 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/WritableTypeInfo.java (72:98, 26%) - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/BasicArrayTypeInfo.java (69:95, 20%) 17 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (136:164, 18%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/ValueComparator.java (155:183, 19%) 17 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (136:164, 18%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/GenericTypeComparator.java (151:177, 20%) 16 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/WritableTypeInfo.java (72:93, 22%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/ObjectArrayTypeInfo.java (48:69, 21%) 16 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/WritableTypeInfo.java (72:93, 22%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/EitherTypeInfo.java (55:76, 23%) 15 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/WritableTypeInfo.java (78:98, 21%) - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/BasicTypeInfo.java (132:152, 12%) 14 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (111:132, 15%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/CopyableValueComparator.java (103:124, 17%) 14 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (111:132, 15%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/ValueComparator.java (117:138, 15%) 12 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableSerializer.java (66:85, 12%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/ValueSerializer.java (92:111, 11%) 11 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/WritableTypeInfo.java (72:86, 15%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/PojoTypeInfo.java (101:116, 4%) 11 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/WritableTypeInfo.java (84:98, 15%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/ValueTypeInfo.java (102:116, 8%) 11 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/WritableTypeInfo.java (72:86, 15%) - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/NothingTypeInfo.java (35:49, 23%) 10 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (145:164, 10%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/CopyableValueComparator.java (136:155, 12%) 10 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (112:127, 10%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/GenericTypeComparator.java (127:142, 11%) 9 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (136:152, 9%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/LocalDateComparator.java (92:104, 9%) 9 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (136:152, 9%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/BasicTypeComparator.java (88:100, 19%) 9 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (152:164, 9%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoComparator.java (305:317, 4%) 9 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (136:152, 9%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/LocalDateTimeComparator.java (96:108, 11%) 9 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (152:164, 9%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/TupleComparatorBase.java (238:250, 6%) 8 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (56:67, 8%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/ValueComparator.java (57:68, 8%) 8 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (80:91, 8%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/ValueComparator.java (81:92, 8%) 8 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (80:91, 8%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/CopyableValueComparator.java (74:85, 10%) 8 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (169:178, 8%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/ValueComparator.java (142:151, 8%) 7 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableSerializer.java (126:134, 7%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/ValueComparator.java (142:150, 7%) 7 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (169:177, 7%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/ValueSerializer.java (137:145, 6%) 7 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (98:108, 7%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/CopyableValueComparator.java (92:102, 8%) 7 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableSerializer.java (126:134, 7%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/ValueSerializer.java (137:145, 6%) 7 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (152:162, 7%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/BasicTypeComparator.java (78:88, 15%) 7 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (98:108, 7%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/ValueComparator.java (102:112, 7%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (511:517, 1%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RowElasticsearchSinkFunction.java (126:132, 7%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java (200:206, 8%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcDmlOptions.java (71:77, 8%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RowElasticsearchSinkFunction.java (126:132, 7%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTablePartition.java (70:76, 16%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConfiguration.java (150:156, 7%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSink.java (212:218, 7%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/options/HBaseWriteOptions.java (70:76, 10%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (511:517, 1%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/TimestampedHiveInputSplit.java (106:112, 5%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (511:517, 1%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (348:354, 1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/TimestampedHiveInputSplit.java (106:112, 5%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSinkBase.java (114:120, 9%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (233:239, 1%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (295:301, 3%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceBase.java (227:233, 3%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSink.java (233:239, 3%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (242:248, 3%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSinkBase.java (114:120, 9%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (233:239, 1%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceBase.java (227:233, 3%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (296:302, 3%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSinkBase.java (114:120, 9%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSourceBase.java (130:136, 6%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (194:200, 3%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConfiguration.java (150:156, 7%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcDmlOptions.java (71:77, 8%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1439:1445, <1%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/options/HBaseOptions.java (67:73, 10%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (348:354, 1%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java (200:206, 8%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (194:200, 3%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/options/HBaseWriteOptions.java (70:76, 10%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1395:1401, <1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1395:1401, <1%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSourceBase.java (130:136, 6%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (194:200, 3%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1395:1401, <1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (242:248, 3%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1421:1427, <1%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (295:301, 3%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (348:354, 1%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1439:1445, <1%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTablePartition.java (70:76, 16%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConfiguration.java (150:156, 7%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceBase.java (227:233, 3%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (122:131, 6%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/DoubleValueComparator.java (105:114, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (296:302, 3%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java (200:206, 8%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkBase.java (131:137, 8%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java (58:64, 11%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (242:248, 3%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableInputSplit.java (54:60, 20%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (348:354, 1%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1139:1145, <1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1421:1427, <1%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1678:1684, <1%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RowElasticsearchSinkFunction.java (126:132, 7%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConfiguration.java (150:156, 7%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1439:1445, <1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1395:1401, <1%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (233:239, 1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (233:239, 1%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/WritableTypeInfo.java (90:97, 8%) - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/NothingTypeInfo.java (53:60, 12%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcDmlOptions.java (71:77, 8%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSourceBase.java (130:136, 6%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (242:248, 3%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1139:1145, <1%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (296:302, 3%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkBase.java (131:137, 8%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableInputSplit.java (54:60, 20%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcDmlOptions.java (71:77, 8%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (295:301, 3%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSink.java (233:239, 3%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1678:1684, <1%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSourceBase.java (130:136, 6%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/TimestampedHiveInputSplit.java (106:112, 5%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSourceBase.java (130:136, 6%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSinkBase.java (114:120, 9%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (194:200, 3%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcDmlOptions.java (71:77, 8%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (194:200, 3%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1139:1145, <1%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/options/HBaseWriteOptions.java (70:76, 10%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (242:248, 3%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkBase.java (131:137, 8%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/PostgresTablePath.java (80:87, 15%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/TimestampedHiveInputSplit.java (106:112, 5%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (242:248, 3%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1439:1445, <1%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (242:248, 3%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (242:248, 3%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (122:131, 6%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/FloatValueComparator.java (105:114, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1421:1427, <1%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/options/HBaseWriteOptions.java (70:76, 10%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1139:1145, <1%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSink.java (212:218, 7%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTablePartition.java (70:76, 16%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConfiguration.java (150:156, 7%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1678:1684, <1%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (511:517, 1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableInputSplit.java (54:60, 20%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1678:1684, <1%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (194:200, 3%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/options/HBaseWriteOptions.java (70:76, 10%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (194:200, 3%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSink.java (233:239, 3%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (194:200, 3%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/PostgresTablePath.java (80:87, 15%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSink.java (212:218, 7%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSink.java (212:218, 7%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1439:1445, <1%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTablePartition.java (70:76, 16%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java (200:206, 8%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/options/HBaseOptions.java (67:73, 10%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/options/HBaseOptions.java (67:73, 10%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (242:248, 3%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1678:1684, <1%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1139:1145, <1%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1139:1145, <1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSink.java (216:222, 4%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (194:200, 3%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSink.java (216:222, 4%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (348:354, 1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (295:301, 3%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (296:302, 3%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (242:248, 3%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/options/HBaseOptions.java (67:73, 10%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java (58:64, 11%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (157:164, 6%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/array/PrimitiveArrayComparator.java (110:117, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/TimestampedHiveInputSplit.java (106:112, 5%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java (58:64, 11%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcDmlOptions.java (71:77, 8%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (511:517, 1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSink.java (233:239, 3%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1139:1145, <1%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (194:200, 3%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/TimestampedHiveInputSplit.java (106:112, 5%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableInputSplit.java (54:60, 20%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSinkBase.java (114:120, 9%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RowElasticsearchSinkFunction.java (126:132, 7%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (295:301, 3%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (295:301, 3%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/options/HBaseOptions.java (67:73, 10%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (296:302, 3%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTablePartition.java (70:76, 16%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/PostgresTablePath.java (80:87, 15%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RowElasticsearchSinkFunction.java (126:132, 7%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSink.java (216:222, 4%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (242:248, 3%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (233:239, 1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1421:1427, <1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkBase.java (131:137, 8%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java (200:206, 8%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1496:1505, <1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/InstantSerializer.java (97:106, 11%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (296:302, 3%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1395:1401, <1%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1439:1445, <1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1439:1445, <1%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (348:354, 1%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSink.java (212:218, 7%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableInputSplit.java (54:60, 20%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (194:200, 3%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java (58:64, 11%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1395:1401, <1%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java (58:64, 11%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (194:200, 3%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSinkBase.java (114:120, 9%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableInputSplit.java (54:60, 20%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/PostgresTablePath.java (80:87, 15%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RowElasticsearchSinkFunction.java (126:132, 7%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (233:239, 1%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1421:1427, <1%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1184:1190, <1%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (242:248, 3%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSinkBase.java (114:120, 9%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (194:200, 3%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (44:53, 6%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/ValueComparator.java (45:54, 6%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (242:248, 3%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkBase.java (131:137, 8%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSink.java (216:222, 4%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/options/HBaseWriteOptions.java (70:76, 10%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/WritableTypeInfo.java (102:109, 8%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/GenericTypeInfo.java (75:82, 9%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkBase.java (131:137, 8%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSink.java (233:239, 3%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1678:1684, <1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveTableInputSplit.java (54:60, 20%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1421:1427, <1%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSink.java (233:239, 3%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1678:1684, <1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/options/HBaseOptions.java (67:73, 10%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/Elasticsearch7UpsertTableSink.java (233:239, 3%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java (200:206, 8%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSink.java (212:218, 7%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (111:120, 6%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/DoubleValueComparator.java (94:103, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1184:1190, <1%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (511:517, 1%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RowElasticsearchSinkFunction.java (126:132, 7%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (242:248, 3%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/PostgresTablePath.java (80:87, 15%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcDmlOptions.java (71:77, 8%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java (58:64, 11%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSink.java (212:218, 7%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1753:1762, <1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/InstantSerializer.java (97:106, 11%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceBase.java (227:233, 3%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java (296:302, 3%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConfiguration.java (150:156, 7%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTablePartition.java (70:76, 16%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceBase.java (227:233, 3%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchConfiguration.java (150:156, 7%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1421:1427, <1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkBase.java (131:137, 8%) - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/PostgresTablePath.java (80:87, 15%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSink.java (216:222, 4%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1184:1190, <1%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (511:517, 1%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSourceBase.java (130:136, 6%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/TimestampedHiveInputSplit.java (106:112, 5%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/options/HBaseOptions.java (67:73, 10%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceBase.java (227:233, 3%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/options/HBaseWriteOptions.java (70:76, 10%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableComparator.java (111:120, 6%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/FloatValueComparator.java (94:103, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1184:1190, <1%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/PostgresTablePath.java (80:87, 15%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSourceBase.java (130:136, 6%) - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java (200:206, 8%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSink.java (216:222, 4%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (233:239, 1%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkBase.java (348:354, 1%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1184:1190, <1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTablePartition.java (70:76, 16%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) 6 duplicated lines in: - flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java (58:64, 11%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1184:1190, <1%) - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (194:200, 3%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java (295:301, 3%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/Elasticsearch6UpsertTableSink.java (216:222, 4%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceBase.java (227:233, 3%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) 6 duplicated lines in: - flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/WritableTypeInfo.java (78:85, 8%) - flink-core/src/main/java/org/apache/flink/api/java/typeutils/ValueTypeInfo.java (133:140, 4%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java (1395:1401, <1%) - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) 6 duplicated lines in: - flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java (1184:1190, <1%) - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%)