7 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/GenericRecordAvroTypeInfo.java (48:58, 15%) - flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/transform/LongValueWithProperHashCode.java (109:119, 7%) 7 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/GenericRecordAvroTypeInfo.java (48:58, 15%) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ValueArrayTypeInfo.java (83:93, 6%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (117:123, 5%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (198:204, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/EventId.java (55:61, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java (101:107, 12%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNode.java (67:73, 7%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNode.java (67:73, 7%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/NodeId.java (56:62, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/EventId.java (55:61, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/SkipToElementStrategy.java (103:109, 11%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/SkipToElementStrategy.java (103:109, 11%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/NodeId.java (56:62, 6%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferEdge.java (70:76, 6%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/SkipToElementStrategy.java (103:109, 11%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/EventId.java (55:61, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java (101:107, 12%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (117:123, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (198:204, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferEdge.java (70:76, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNode.java (67:73, 7%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (167:173, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (78:84, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/EventId.java (55:61, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNode.java (67:73, 7%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/EventId.java (55:61, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (78:84, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (167:173, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (117:123, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (198:204, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java (101:107, 12%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (198:204, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/NodeId.java (56:62, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferEdge.java (70:76, 6%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/EventId.java (55:61, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/NodeId.java (56:62, 6%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferEdge.java (70:76, 6%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNode.java (67:73, 7%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java (101:107, 12%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (198:204, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (117:123, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (117:123, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNode.java (67:73, 7%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java (101:107, 12%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/EventId.java (55:61, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNode.java (67:73, 7%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/NodeId.java (56:62, 6%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferEdge.java (70:76, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/EventId.java (55:61, 8%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/SkipToElementStrategy.java (103:109, 11%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/SkipToElementStrategy.java (103:109, 11%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/EventId.java (55:61, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNode.java (67:73, 7%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/EventId.java (55:61, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java (101:107, 12%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/GenericRecordAvroTypeInfo.java (58:65, 13%) - flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/types/valuearray/ValueArrayTypeInfo.java (67:74, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java (101:107, 12%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/SkipToElementStrategy.java (103:109, 11%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNode.java (67:73, 7%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/NodeId.java (56:62, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (198:204, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (117:123, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/NodeId.java (56:62, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/EventId.java (55:61, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferEdge.java (70:76, 6%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (78:84, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (167:173, 5%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (78:84, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNode.java (67:73, 7%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (167:173, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/SkipToElementStrategy.java (103:109, 11%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNode.java (67:73, 7%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/SkipToElementStrategy.java (103:109, 11%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (198:204, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (117:123, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/EventId.java (55:61, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (78:84, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferEdge.java (70:76, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (198:204, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/NodeId.java (56:62, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (117:123, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/NodeId.java (56:62, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (167:173, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (78:84, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNode.java (67:73, 7%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNode.java (67:73, 7%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNode.java (67:73, 7%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (198:204, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (117:123, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (167:173, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/NodeId.java (56:62, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java (86:92, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNode.java (67:73, 7%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/SkipToElementStrategy.java (103:109, 11%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/EventId.java (55:61, 8%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (78:84, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (167:173, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/NodeId.java (56:62, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java (101:107, 12%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/SkipToElementStrategy.java (103:109, 11%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (117:123, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (198:204, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferEdge.java (70:76, 6%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferEdge.java (70:76, 6%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (167:173, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (78:84, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/SkipToElementStrategy.java (103:109, 11%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java (101:107, 12%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferEdge.java (70:76, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (167:173, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (167:173, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (78:84, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (78:84, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (78:84, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/SkipToElementStrategy.java (103:109, 11%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (167:173, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java (101:107, 12%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferEdge.java (70:76, 6%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java (101:107, 12%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferEdge.java (70:76, 6%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/SkipToElementStrategy.java (103:109, 11%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/SkipToElementStrategy.java (103:109, 11%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/NodeId.java (56:62, 6%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java (101:107, 12%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (117:123, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (198:204, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/GenericRecordAvroTypeInfo.java (58:65, 13%) - flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/transform/LongValueWithProperHashCode.java (93:100, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferEdge.java (70:76, 6%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (198:204, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java (101:107, 12%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java (86:92, 16%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (117:123, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferEdge.java (70:76, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferEdge.java (70:76, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (117:123, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (198:204, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (198:204, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (117:123, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (167:173, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDeserializationSchema.java (179:185, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (78:84, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (198:204, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (117:123, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (78:84, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (167:173, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (78:84, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataDeserializationSchema.java (118:124, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/EventId.java (55:61, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (198:204, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (117:123, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (167:173, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java (143:149, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (78:84, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/EventId.java (55:61, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/EventId.java (55:61, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/EventId.java (55:61, 8%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferEdge.java (70:76, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java (101:107, 12%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (167:173, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (78:84, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java (102:108, 14%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNode.java (67:73, 7%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonDeserializationSchema.java (166:172, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/SkipToElementStrategy.java (103:109, 11%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/NodeId.java (56:62, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/SkipToElementStrategy.java (103:109, 11%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (117:123, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java (216:222, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java (198:204, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java (175:181, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/NodeId.java (56:62, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowSerializationSchema.java (175:181, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/NodeId.java (56:62, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/NodeId.java (56:62, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java (104:110, 2%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java (101:107, 12%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java (154:160, 3%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/SkipToElementStrategy.java (103:109, 11%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (167:173, 5%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroSerializationSchema.java (167:173, 8%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (167:173, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java (78:84, 5%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferNode.java (67:73, 7%) 6 duplicated lines in: - flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroSerializationSchema.java (100:106, 12%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/NodeId.java (56:62, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java (151:157, 7%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java (101:107, 12%) 6 duplicated lines in: - flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProvider.java (58:64, 19%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBufferEdge.java (70:76, 6%) 6 duplicated lines in: - flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonDeserializationSchema.java (163:169, 6%) - flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java (101:107, 12%)