代码之家 › 专栏 › 技术社区 › xiang qi

结构化流媒体程序无法连续运行。运行几分钟后,打印[INFO]StateStore:57

spark-streaming

xiang qi · 技术社区 · 2 年前

运行几分钟后,程序似乎停止运行,并继续打印[INFO]StateStore:57-检索到对StateStoreCoordinator的引用:org.apache.spark.sql.execution.streaming.state.StateStoreCoordinatorRef@567563ae,不再生成结果

我不明白问题出在哪里。我希望程序继续运行并进行一些修改

0 回复 | 直到 2 年前

推荐文章

xiang qi · 结构化流媒体程序无法连续运行。运行几分钟后,打印[INFO]StateStore:57

2 年前

user3692015 · 流处理如何处理历史聚合?

2 年前

data_pikachu · 班级组织。阿帕奇。hadoop。财政司司长。s3a。啊。尝试从Spark在S3存储桶上写入数据时,未找到IAMInstanceCredentialsProvider

4 年前

sharon gur · Kafka spark同步流处理作业

8 年前

vijay · Spark streaming作业日志大小溢出

8 年前

Pawan · Spark Streaming中setJars()方法的输入应该是什么

8 年前

Frank · Spark Streaming kafka偏移量管理

8 年前

a.moussa · 线程“main”java中出现异常。lang.NoClassDefFoundError:org/apache/spark/streaming/StreamingContext

8 年前

Francesco · 在Spark Streaming中将StreamingContext与接收器分离

8 年前

maxness · Spark将Kafka输入流另存为Json文件

8 年前