exception or error caused a run to abort: Found class akka.actor.ActorPath, but interface was expected at akka.testkit.TestActorRef$.apply(TestActorRef.scala:141)
atakka.testkit.TestActorRef
我很确定这跟"mongoCol.insert“有关。我想知道代码是否有什么根本的错误。或者我应该使用Akka中的“原子{...}”来避免这个问题。$EntryIterator.next(LinkedHashMap.java:392) at scala.concurrent.forkjoin.ForkJoinPool$AdaptedRunnabl
").option("kafka.bootstrap.servers", "localhost:9092").option("topic", "alerts").save()java.lang.RuntimeException: org.apache.spark.sql.kafka010.KafkaSourceProvider does not allow create table as select.
at scala.sys.package