8 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/ir/IRDAG.java (149:157, 1%)
  - runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/JobMetric.java (101:109, 11%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/punctuation/Watermark.java (45:51, 26%)
  - runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransport.java (254:260, 4%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/ir/edge/IREdge.java (112:118, 13%)
  - runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/StageEdge.java (118:124, 9%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/punctuation/Watermark.java (45:51, 26%)
  - runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/FileArea.java (65:71, 18%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/ir/edge/IREdge.java (112:118, 13%)
  - runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/FileArea.java (65:71, 18%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ClonedSchedulingProperty.java (128:135, 10%)
  - runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/FileArea.java (65:71, 18%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ClonedSchedulingProperty.java (128:135, 10%)
  - runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransport.java (254:260, 4%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/punctuation/Watermark.java (45:51, 26%)
  - runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/StageEdge.java (118:124, 9%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/HashRange.java (104:110, 13%)
  - runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransport.java (254:260, 4%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/ir/edge/IREdge.java (112:118, 13%)
  - runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransport.java (254:260, 4%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/HashRange.java (104:110, 13%)
  - runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/StageEdge.java (118:124, 9%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/punctuation/LatencyMark.java (95:101, 15%)
  - runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/StageEdge.java (118:124, 9%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/punctuation/LatencyMark.java (95:101, 15%)
  - runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/FileArea.java (65:71, 18%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ClonedSchedulingProperty.java (128:135, 10%)
  - runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/StageEdge.java (118:124, 9%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/punctuation/LatencyMark.java (95:101, 15%)
  - runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransport.java (254:260, 4%)

6 duplicated lines in:
  - common/src/main/java/org/apache/nemo/common/HashRange.java (104:110, 13%)
  - runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/FileArea.java (65:71, 18%)