我有一个星火应用程序,应该在本地模式和本地集群模式下进行测试,使用scalatest。使用此方法提交本地群集模式:
22/05/16 17:45:25 ERROR TaskSchedulerImpl: Lost executor:77)
at org.apache.spark.deploy.worker.Worker$$anonfun$receive$1.applyOrElse(Worker<
, missing required field key{"type":"record","name":"topLevelRecord","fields":[{"name":"a_a$BoundedReaderIterator.start (WorkerCustomSources.java:610)
at org.apache.beam.runners.dataflow.worker.ut