13 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/LocalTimeTypeInfo.java (72:92, 17%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/GenericRecordAvroTypeInfo.java (48:68, 28%) 13 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeinfo/SqlTimeTypeInfo.java (70:90, 17%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/GenericRecordAvroTypeInfo.java (48:68, 28%) 11 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java (617:635, 3%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java (341:359, 5%) 8 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/MapTypeInfo.java (79:90, 13%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/GenericRecordAvroTypeInfo.java (48:59, 17%) 8 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/ListTypeInfo.java (67:78, 15%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/GenericRecordAvroTypeInfo.java (48:59, 17%) 7 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java (265:277, 2%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java (245:257, 3%) 7 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/io/BinaryInputFormat.java (398:405, 3%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroInputFormat.java (189:196, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java (267:273, 2%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/UnloadableDummyTypeSerializer.java (116:123, 10%) - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/util/StringBasedID.java (47:53, 28%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/time/Time.java (85:91, 15%) - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/types/Row.java (148:154, 8%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/typeutils/BackwardsCompatibleSerializerSnapshot.java (86:93, 17%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) 6 duplicated lines in: - flink-core/src/main/java/org/apache/flink/api/common/restartstrategy/RestartStrategies.java (224:230, 4%) - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%)