12 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapMapState.java (171:184, 11%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java (271:285, 3%) 12 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackendBuilder.java (71:82, 13%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackendBuilder.java (135:147, 3%) 12 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/MemoryStateBackend.java (317:328, 13%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java (472:483, 3%) 12 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackend.java (508:519, 7%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java (472:483, 3%) 11 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java (261:271, 5%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java (658:668, 3%) 10 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackend.java (147:156, 47%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java (474:483, 2%) 10 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapReducingState.java (73:92, 17%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBReducingState.java (76:91, 13%) 10 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapFoldingState.java (76:95, 18%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBFoldingState.java (79:94, 22%) 10 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractStateBackend.java (60:69, 37%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java (474:483, 2%) 10 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapListState.java (69:88, 10%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBListState.java (99:114, 5%) 9 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java (128:136, 4%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java (238:246, 2%) 8 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapValueState.java (61:72, 19%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBValueState.java (70:81, 15%) 8 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapSnapshotStrategy.java (145:153, 5%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksFullSnapshotStrategy.java (165:173, 3%) 7 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapAggregatingState.java (75:89, 11%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBFoldingState.java (79:89, 15%) 7 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateMapSnapshot.java (112:118, 4%) - flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteSkipListStateMapSnapshot.java (92:98, 6%) 7 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapReducingState.java (73:87, 12%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBValueState.java (70:80, 13%) 7 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapMapState.java (73:83, 6%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java (104:118, 1%) 7 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapAggregatingState.java (75:89, 11%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBAggregatingState.java (79:89, 8%) 7 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/NestedStateMapSnapshot.java (51:57, 16%) - flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteSkipListStateMapSnapshot.java (92:98, 6%) 7 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapValueState.java (61:71, 16%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBReducingState.java (76:86, 9%) 7 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapFoldingState.java (76:90, 12%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBAggregatingState.java (79:89, 8%) 6 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateMap.java (372:377, 1%) - flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteSkipListStateMap.java (278:283, <1%) 6 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapListState.java (111:117, 6%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java (278:285, 1%) 6 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/MemoryStateBackend.java (302:307, 6%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java (538:543, 1%) 6 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java (104:109, 3%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java (239:244, 1%) 6 duplicated lines in: - flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/AbstractHeapState.java (96:102, 11%) - flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java (278:285, 1%)