apache-spark - Spark 流式传输旧的活动批次不会得到处理
问题描述
我正在集群上运行火花流应用程序。现在是这样2021/05/07 11:16:50，您可以看到最新的批次已处理：
但是怎么会有8小时前的活跃批次呢？：
为什么他们不被处理？可以看到，这些都是空批次，代码中处理空批次的逻辑是一样的，但是怎么最近的批次都处理完了，8小时前的13个批次还挂在那里呢？有任何想法吗？
解决方案
推荐阅读
- computer-vision - 具有旋转考虑的模式匹配算法
- android - 如何在一行中获取两个cardview项目？
- macos - 在 mac os 上组装 armv8
- machine-learning - 我应该如何读取 RMSPROP 产生的值的总和？
- php - 如何将动态数量的属性传递给函数？
- python - Python什么也不返回
- python - 规范化来自多列数据框的 JSON 对象
- c++ - 为什么打印这个循环队列会导致无限循环？
- ruby - Windows 上的 Ruby 在 cmd 终端中显示错误的 unicode 字符
- python - 类方法中 self=self 的原因是什么？