代码日常运行都没问题突然报错如下pymongo.errors.CursorNotFound: cursor id 1598856597812 not found根据异常找到报错位置如下def initMaterialOrgAll(self):materialAndEnterpriseIdList = formmongodbUtil.findAll("form_ins_d0fd94e7-df33-4

最近公司上云，所有大数据环境都迁移到云上。在进行项目迁移时候发现运行报错py4j.protocol.Py4JJavaError: An error occurred while calling None.org.apache.spark.api.java.JavaSparkContext.: java.lang.NullPointerExceptionat org.apache.spark.Spa

目录背景1：scala版本2：pyspark版本注意：以下都是采坑点RabbitMQ启用MQTT功能背景平常我们会实时监听kafka的数据，并且与流处理框架比如sparkstreaming和flink进行连接进行消费处理，这一套非常成熟且有官方工具包。但是目前有业务场景需要接收rabbitmq的数据，这就比较麻烦了，因为不想kafka有直接的kafkautils能创建流。在sspark1.6以前的

Exception in thread "main" org.apache.hadoop.hbase.client.RetriesExhaustedException: Can't get the locationsat org.apache.hadoop.hbase.client.RpcRetryingCallerWithReadReplicas.getRegionLocations(RpcRe