Exception in thread “main” org.apache.spark.SparkException: java.nio.channels.ClosedChannelException org.apache.spark.SparkException: Couldn’t find leader offsets for Set([test,0])