duplicated block id: 1 size: 7 cleaned lines of code in 2 files: - core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSource.scala (468:476) - core/src/main/scala/org/apache/spark/streaming/eventhubs/EventHubsDirectDStream.scala (193:201)