6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackKey.java (40:46, 27%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/FunctionType.java (68:74, 21%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/remote/RemoteValueTypeInfo.java (77:83, 13%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/EgressType.java (62:68, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/TaggedBootstrapDataSerializer.java (172:178, 4%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/EgressIdentifier.java (75:81, 17%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/di/ObjectContainer.java (154:160, 6%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/EgressType.java (62:68, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/SubtaskFeedbackKey.java (41:47, 23%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/EgressType.java (62:68, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/SubtaskFeedbackKey.java (41:47, 23%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/IngressType.java (62:68, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/operator/StateBootstrapFunctionRegistry.java (154:160, 8%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/EgressIdentifier.java (75:81, 17%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/remote/RemoteValueTypeInfo.java (77:83, 13%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/Address.java (61:67, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/operator/StateBootstrapFunctionRegistry.java (154:160, 8%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/EgressType.java (62:68, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/TaggedBootstrapDataTypeInfo.java (106:112, 10%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/EgressIdentifier.java (75:81, 17%) 6 duplicated lines in: - statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/TaggedBootstrapDataTypeInfo.java (106:112, 10%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/FunctionType.java (68:74, 21%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/di/ObjectContainer.java (154:160, 6%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/FunctionType.java (68:74, 21%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/SubtaskFeedbackKey.java (41:47, 23%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/IngressIdentifier.java (75:81, 17%) 6 duplicated lines in: - statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/TaggedBootstrapDataSerializer.java (172:178, 4%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/IngressIdentifier.java (75:81, 17%) 6 duplicated lines in: - statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/TaggedBootstrapDataTypeInfo.java (106:112, 10%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/IngressIdentifier.java (75:81, 17%) 6 duplicated lines in: - statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/protobuf/ProtobufTypeInformation.java (76:82, 13%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/IngressIdentifier.java (75:81, 17%) 6 duplicated lines in: - statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/TaggedBootstrapDataSerializer.java (172:178, 4%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/IngressType.java (62:68, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/di/ObjectContainer.java (154:160, 6%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/EgressIdentifier.java (75:81, 17%) 6 duplicated lines in: - statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/operator/StateBootstrapFunctionRegistry.java (154:160, 8%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/FunctionType.java (68:74, 21%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/SubtaskFeedbackKey.java (41:47, 23%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/EgressIdentifier.java (75:81, 17%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/SubtaskFeedbackKey.java (41:47, 23%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/Address.java (61:67, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/operator/StateBootstrapFunctionRegistry.java (154:160, 8%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/Address.java (61:67, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/SubtaskFeedbackKey.java (41:47, 23%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/FunctionType.java (68:74, 21%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackKey.java (40:46, 27%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/IngressIdentifier.java (75:81, 17%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/remote/RemoteValueTypeInfo.java (77:83, 13%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/IngressIdentifier.java (75:81, 17%) 6 duplicated lines in: - statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/TaggedBootstrapDataTypeInfo.java (106:112, 10%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/Address.java (61:67, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/remote/RemoteValueTypeInfo.java (77:83, 13%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/EgressIdentifier.java (75:81, 17%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/remote/RemoteValueTypeInfo.java (77:83, 13%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/IngressType.java (62:68, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/TaggedBootstrapDataTypeInfo.java (106:112, 10%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/EgressType.java (62:68, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/protobuf/ProtobufTypeInformation.java (76:82, 13%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/IngressType.java (62:68, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackKey.java (40:46, 27%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/EgressIdentifier.java (75:81, 17%) 6 duplicated lines in: - statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/protobuf/ProtobufTypeInformation.java (76:82, 13%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/FunctionType.java (68:74, 21%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/di/ObjectContainer.java (154:160, 6%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/IngressIdentifier.java (75:81, 17%) 6 duplicated lines in: - statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/protobuf/ProtobufTypeInformation.java (76:82, 13%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/EgressType.java (62:68, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/protobuf/ProtobufTypeInformation.java (76:82, 13%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/EgressIdentifier.java (75:81, 17%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/di/ObjectContainer.java (154:160, 6%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/IngressType.java (62:68, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/TaggedBootstrapDataSerializer.java (172:178, 4%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/FunctionType.java (68:74, 21%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackKey.java (40:46, 27%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/Address.java (61:67, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/TaggedBootstrapDataSerializer.java (172:178, 4%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/Address.java (61:67, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackKey.java (40:46, 27%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/IngressType.java (62:68, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/operator/StateBootstrapFunctionRegistry.java (154:160, 8%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/io/IngressIdentifier.java (75:81, 17%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/di/ObjectContainer.java (154:160, 6%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/Address.java (61:67, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/types/remote/RemoteValueTypeInfo.java (77:83, 13%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/FunctionType.java (68:74, 21%) 6 duplicated lines in: - statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/TaggedBootstrapDataTypeInfo.java (106:112, 10%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/IngressType.java (62:68, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/FeedbackKey.java (40:46, 27%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/EgressType.java (62:68, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/protobuf/ProtobufTypeInformation.java (76:82, 13%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/Address.java (61:67, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/operator/StateBootstrapFunctionRegistry.java (154:160, 8%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/IngressType.java (62:68, 22%) 6 duplicated lines in: - statefun-flink/statefun-flink-state-processor/src/main/java/org/apache/flink/statefun/flink/state/processor/union/TaggedBootstrapDataSerializer.java (172:178, 4%) - statefun-sdk-embedded/src/main/java/org/apache/flink/statefun/sdk/EgressType.java (62:68, 22%)