Failed

org.apache.spark.sql.kafka010.KafkaSinkBatchSuiteV2.(It is not a test it is a sbt.testing.SuiteSelector)

Failing for the past 1 build (Since #5035 )

Error Message

org.apache.zookeeper.KeeperException$SessionExpiredException: KeeperErrorCode = Session expired for /config/users

Stacktrace

sbt.ForkMain$ForkError: org.apache.zookeeper.KeeperException$SessionExpiredException: KeeperErrorCode = Session expired for /config/users
	at org.apache.zookeeper.KeeperException.create(KeeperException.java:134)
	at org.apache.zookeeper.KeeperException.create(KeeperException.java:54)
	at kafka.zookeeper.AsyncResponse.maybeThrow(ZooKeeperClient.scala:561)
	at kafka.zk.KafkaZkClient.createRecursive(KafkaZkClient.scala:1640)
	at kafka.zk.KafkaZkClient.makeSurePersistentPathExists(KafkaZkClient.scala:1562)
	at kafka.zk.KafkaZkClient.$anonfun$createTopLevelPaths$1(KafkaZkClient.scala:1554)
	at kafka.zk.KafkaZkClient.$anonfun$createTopLevelPaths$1$adapted(KafkaZkClient.scala:1554)
	at scala.collection.immutable.List.foreach(List.scala:392)
	at kafka.zk.KafkaZkClient.createTopLevelPaths(KafkaZkClient.scala:1554)
	at kafka.server.KafkaServer.initZkClient(KafkaServer.scala:400)
	at kafka.server.KafkaServer.startup(KafkaServer.scala:207)
	at org.apache.spark.sql.kafka010.KafkaTestUtils.$anonfun$setupEmbeddedKafkaServer$1(KafkaTestUtils.scala:287)
	at org.apache.spark.sql.kafka010.KafkaTestUtils.$anonfun$setupEmbeddedKafkaServer$1$adapted(KafkaTestUtils.scala:283)
	at org.apache.spark.util.Utils$.$anonfun$startServiceOnPort$2(Utils.scala:2256)
	at scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:158)
	at org.apache.spark.util.Utils$.startServiceOnPort(Utils.scala:2248)
	at org.apache.spark.sql.kafka010.KafkaTestUtils.setupEmbeddedKafkaServer(KafkaTestUtils.scala:290)
	at org.apache.spark.sql.kafka010.KafkaTestUtils.setup(KafkaTestUtils.scala:315)
	at org.apache.spark.sql.kafka010.KafkaSinkSuiteBase.beforeAll(KafkaSinkSuite.scala:51)
	at org.scalatest.BeforeAndAfterAll.liftedTree1$1(BeforeAndAfterAll.scala:212)
	at org.scalatest.BeforeAndAfterAll.run(BeforeAndAfterAll.scala:210)
	at org.scalatest.BeforeAndAfterAll.run$(BeforeAndAfterAll.scala:208)
	at org.apache.spark.SparkFunSuite.run(SparkFunSuite.scala:58)
	at org.scalatest.tools.Framework.org$scalatest$tools$Framework$$runSuite(Framework.scala:317)
	at org.scalatest.tools.Framework$ScalaTestTask.execute(Framework.scala:510)
	at sbt.ForkMain$Run$2.call(ForkMain.java:296)
	at sbt.ForkMain$Run$2.call(ForkMain.java:286)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)