duplicated block id: 1 size: 22 cleaned lines of code in 2 files: - src/main/java/com/aliyun/emr/example/spark/streaming/SparkMNSJavaDemo.java (59:85) - src/main/java/com/aliyun/emr/example/spark/streaming/SparkRocketMQJavaDemo.java (68:94) duplicated block id: 2 size: 18 cleaned lines of code in 2 files: - src/main/scala/com/aliyun/emr/example/spark/SparkMaxComputeDemo.scala (31:50) - src/main/scala/com/aliyun/emr/example/spark/sql/ODPSDataSourceSample.scala (27:46) duplicated block id: 3 size: 16 cleaned lines of code in 2 files: - src/main/java/com/aliyun/emr/example/spark/sql/streaming/SparkSLSContinuousStructuredStreamingJavaDemo.java (32:51) - src/main/java/com/aliyun/emr/example/spark/sql/streaming/SparkSLSStructuredStreamingJavaDemo.java (34:53) duplicated block id: 4 size: 14 cleaned lines of code in 2 files: - src/main/java/com/aliyun/emr/example/spark/streaming/JavaLoghubWordCount.java (78:94) - src/main/java/com/aliyun/emr/example/spark/streaming/SparkRocketMQJavaDemo.java (78:94) duplicated block id: 5 size: 14 cleaned lines of code in 2 files: - src/main/java/com/aliyun/emr/example/spark/streaming/JavaLoghubWordCount.java (78:94) - src/main/java/com/aliyun/emr/example/spark/streaming/SparkMNSJavaDemo.java (69:85) duplicated block id: 6 size: 10 cleaned lines of code in 2 files: - src/main/java/com/aliyun/emr/example/spark/sql/streaming/SparkSLSContinuousStructuredStreamingJavaDemo.java (53:64) - src/main/java/com/aliyun/emr/example/spark/sql/streaming/SparkSLSStructuredStreamingJavaDemo.java (55:66) duplicated block id: 7 size: 10 cleaned lines of code in 2 files: - src/main/java/com/aliyun/emr/example/storm/benchmark/WindowedWordCount.java (62:81) - src/main/java/com/aliyun/emr/example/storm/benchmark/WordCount.java (51:69) duplicated block id: 8 size: 9 cleaned lines of code in 2 files: - src/main/scala/com/aliyun/emr/example/spark/streaming/DirectSparkSLSDemo.scala (31:41) - src/main/scala/com/aliyun/emr/example/spark/streaming/SparkSLSDemo.scala (32:42) duplicated block id: 9 size: 9 cleaned lines of code in 2 files: - src/main/java/com/aliyun/emr/example/spark/sql/streaming/SparkSLSStructuredStreamingJavaDemo.java (62:70) - src/main/scala/com/aliyun/emr/example/spark/sql/streaming/SparkSLSStructuredStreamingDemo.scala (51:59) duplicated block id: 10 size: 8 cleaned lines of code in 2 files: - src/main/java/com/aliyun/emr/example/spark/sql/streaming/SparkSLSContinuousStructuredStreamingJavaDemo.java (60:67) - src/main/scala/com/aliyun/emr/example/spark/sql/streaming/SparkSLSContinuousStructuredStreamingDemo.scala (52:59) duplicated block id: 11 size: 8 cleaned lines of code in 2 files: - src/main/scala/com/aliyun/emr/example/spark/sql/streaming/SparkSLSContinuousStructuredStreamingDemo.scala (49:56) - src/main/scala/com/aliyun/emr/example/spark/sql/streaming/SparkSLSStructuredStreamingDemo.scala (48:55) duplicated block id: 12 size: 8 cleaned lines of code in 2 files: - src/main/scala/com/aliyun/emr/example/spark/sql/streaming/SparkSLSContinuousStructuredStreamingDemo.scala (28:38) - src/main/scala/com/aliyun/emr/example/spark/sql/streaming/SparkSLSStructuredStreamingDemo.scala (27:37) duplicated block id: 13 size: 8 cleaned lines of code in 2 files: - src/main/scala/com/aliyun/emr/example/spark/streaming/SparkDatahubDemo.scala (61:68) - src/main/scala/com/aliyun/emr/example/spark/streaming/SparkDatahubDemo.scala (73:80) duplicated block id: 14 size: 8 cleaned lines of code in 2 files: - src/main/scala/com/aliyun/emr/example/spark/streaming/SparkHBaseDemo.scala (53:60) - src/main/scala/com/aliyun/emr/example/spark/streaming/SparkRocketMQDemo.scala (35:42) duplicated block id: 15 size: 7 cleaned lines of code in 2 files: - src/main/java/com/aliyun/emr/example/storm/benchmark/WindowedWordCount.java (34:40) - src/main/java/com/aliyun/emr/example/storm/benchmark/WordCount.java (29:35) duplicated block id: 16 size: 6 cleaned lines of code in 2 files: - src/main/java/com/aliyun/emr/example/spark/streaming/JavaLoghubWordCount.java (68:74) - src/main/java/com/aliyun/emr/example/spark/streaming/SparkRocketMQJavaDemo.java (68:74) duplicated block id: 17 size: 6 cleaned lines of code in 2 files: - src/main/scala/com/aliyun/emr/example/spark/streaming/SparkHBaseDemo.scala (81:86) - src/main/scala/com/aliyun/emr/example/spark/streaming/SparkRocketMQDemo.scala (67:72) duplicated block id: 18 size: 6 cleaned lines of code in 2 files: - src/main/java/com/aliyun/emr/example/spark/streaming/JavaLoghubWordCount.java (68:74) - src/main/java/com/aliyun/emr/example/spark/streaming/SparkMNSJavaDemo.java (59:65)