import scala.collection.JavaConverters._
import scala.collection.mutable
val jobGroudId_ages = mutable.Set[Long]()

val threads_ages = (1001 to 1010).map { i =>
  new Thread {
    override def run() {
      sc.setJobGroup(s"$i", s"$i")
      val df = spark.read.option("rowTag", "person").format("xml").load("file:/Users/XXXX/spark-xml/src/test/resources/ages.xml") 
      if(df.schema.fields.isEmpty) {
        println(s"found repro for the ages run $i **********************")
        jobGroudId_ages.add(i)
      }
    }
  }
}


import scala.collection.JavaConverters._
import scala.collection.mutable
val jobGroudId_books = mutable.Set[Long]()

val threads = (1 to 10).map { i =>
  new Thread {
    override def run() {
      sc.setJobGroup(s"$i", s"$i")
      val df = spark.read.option("rowTag", "book").format("xml").load("file:/Users/XXXX/spark-xml/src/test/resources/books.xml") 
      if(df.schema.fields.isEmpty) {
        println(s"found repro for the book run $i **********************")
        jobGroudId_books.add(i)
      }
    }
  }
}

threads_ages.foreach(_.start())
threads.foreach(_.start())
threads_ages.foreach(_.join())
threads.foreach(_.join())
println(s" jobGroudId_books is ${jobGroudId_books.size} ")
println(s" jobGroudId_ages is ${jobGroudId_ages.size} ")