duplicated block id: 1
size: 12 cleaned lines of code
in 2 files:
 - statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/binders/ingress/v1/RoutableKinesisIngressSpec.java (163:177)
 - statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/binders/ingress/v1/RoutableKafkaIngressSpec.java (181:195)

duplicated block id: 2
size: 11 cleaned lines of code
in 2 files:
 - statefun-kinesis-io/src/main/java/org/apache/flink/statefun/sdk/kinesis/ingress/KinesisIngressStartupPosition.java (91:104)
 - statefun-kafka-io/src/main/java/org/apache/flink/statefun/sdk/kafka/KafkaIngressStartupPosition.java (220:233)

duplicated block id: 3
size: 9 cleaned lines of code
in 2 files:
 - statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/MessageBuilder.java (93:103)
 - statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/EgressMessageBuilder.java (77:87)

duplicated block id: 4
size: 8 cleaned lines of code
in 2 files:
 - statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/Address.java (62:71)
 - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/Address.java (62:71)

duplicated block id: 5
size: 6 cleaned lines of code
in 2 files:
 - statefun-flink/statefun-flink-datastream/src/main/java/org/apache/flink/statefun/flink/datastream/StatefulFunctionDataStreamBuilder.java (154:161)
 - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsUniverse.java (182:189)