6 duplicated lines in:
  - flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/MesosWorkerStore.java (181:187, 8%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java (144:150, 8%)

6 duplicated lines in:
  - flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/MesosWorkerStore.java (181:187, 8%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (593:599, 1%)

6 duplicated lines in:
  - flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/MesosWorkerStore.java (181:187, 8%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (538:544, 1%)

6 duplicated lines in:
  - flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/MesosWorkerStore.java (181:187, 8%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java (775:781, 1%)

6 duplicated lines in:
  - flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/MesosWorkerStore.java (181:187, 8%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java (454:461, 2%)

6 duplicated lines in:
  - flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/MesosWorkerStore.java (181:187, 8%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java (89:95, 5%)

6 duplicated lines in:
  - flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/MesosWorkerStore.java (181:187, 8%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java (353:359, 3%)

6 duplicated lines in:
  - flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/MesosWorkerStore.java (181:187, 8%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java (186:192, 4%)

6 duplicated lines in:
  - flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/store/MesosWorkerStore.java (181:187, 8%)
  - flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputSelection.java (139:145, 8%)