这两个问题均属于Spark的常见错误。

对于第一个问题，BlockManager正在从死亡执行器中移除RDD，可能是由于某个节点崩溃或宕机，导致该节点上的RDD丢失。这可能导致任务失败或产生运行时错误。您可以尝试在配置文件中增加以下参数，以增加节点故障的容错性并缓解此问题：

spark.task.maxFailures：任务失败的最大次数（默认值为4）。

spark.task.retries：任务重试的最大次数（默认值为10）。

对于第二个问题，Streaming query失败“RpcTimeoutException: 在120秒内无法从null接收任何回复”，可能是由于网络故障或资源不足导致的长时间等待请求的回复。解决此问题的一种方法是增加等待时间。在SparkConf中增加以下参数：

spark.rpc.askTimeout：允许等待回复的时间（默认为120秒）。

然后在SparkSession中设置该配置：

val spark = SparkSession.builder.appName("SparkExample").config("spark.rpc.askTimeout", "180").getOrCreate()

这将增加等待时间并缓解您遇到的问题。