duplicated block id: 1
size: 8 cleaned lines of code
in 2 files:
 - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java (462:471)
 - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/TextIO.java (321:330)

duplicated block id: 2
size: 8 cleaned lines of code
in 2 files:
 - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/BigQueryIO.java (871:880)
 - sdk/src/main/java/com/google/cloud/dataflow/sdk/io/TextIO.java (705:714)

duplicated block id: 3
size: 8 cleaned lines of code
in 2 files:
 - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroReaderFactory.java (42:51)
 - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/UngroupedShuffleReaderFactory.java (38:47)

duplicated block id: 4
size: 8 cleaned lines of code
in 2 files:
 - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextReaderFactory.java (48:57)
 - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/InMemoryReaderFactory.java (40:49)

duplicated block id: 5
size: 7 cleaned lines of code
in 2 files:
 - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/MergedCombiningValue.java (57:65)
 - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/WindmillStateInternals.java (474:482)

duplicated block id: 6
size: 6 cleaned lines of code
in 2 files:
 - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/state/InMemoryStateInternals.java (101:108)
 - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/ReduceFnRunner.java (561:568)

duplicated block id: 7
size: 6 cleaned lines of code
in 2 files:
 - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/FlattenOperation.java (25:32)
 - sdk/src/main/java/com/google/cloud/dataflow/sdk/util/common/worker/ReceivingOperation.java (37:44)

duplicated block id: 8
size: 6 cleaned lines of code
in 2 files:
 - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/AvroSinkFactory.java (39:46)
 - sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/worker/TextSinkFactory.java (36:43)