在我的 SampleTest 应用程序中，我设计的代码就像从客户端接收到新的搜索模式后StreamingContext应该停止（ssc.stop()）并再次从新分配的模式（ssc.start()）开始。
停止StreamingContext ( ssc.stop()) 很好，但是在启动 StreamingContext ( ssc.start()) 时，它将通过akka.pattern.AskTimeoutException:发送到终止的 ref 破坏承诺异常。我也想知道为什么代码中会出现这个异常。
如果需要有关此问题的任何其他信息，请告诉我。
以下指定了我得到的错误和异常。
ERROR network.ConnectionManager: 未找到对应的 SendingConnectionManagerId
spark.SparkException：在 spark.storage.BlockManagerMaster.askDriverWithReply(BlockManagerMaster.scala:127) 在 spark.storage.BlockManagerMaster.updateBlockInfo(BlockManagerMaster. scala:56) 在 spark.storage.BlockManager.spark$storage$BlockManager$$tryToReportBlockStatus(BlockManager.scala:247) 在 spark.storage.BlockManager.reportBlockStatus(BlockManager.scala:217) 在 spark.storage.BlockManager.liftedTree1$1 (BlockManager.scala:560) 在 spark.storage.BlockManager.put(BlockManager.scala:534) 在 spark.streaming.dstream.NetworkReceiver.pushBlock(NetworkInputDStream.scala:147) 在 spark.streaming.dstream.NetworkReceiver$BlockGenerator。spark$streaming$dstream$NetworkReceiver$BlockGenerator$$keepPushingBlocks(NetworkInputDStream.scala:251) 在 spark.streaming.dstream.NetworkReceiver$BlockGenerator$$anon$1.run(NetworkInputDStream.scala:205)