我们正在从kinesis读取数据,并使用spark结构流将其输出到文件中。当stream.these中没有数据时,kinesis实现正在生成空批吗?空批正在创建空文件作为输出?你知道怎么让spark写出空白文件吗?
发布于 2020-11-27 17:04:07
分区输出修复了空集问题
https://stackoverflow.com/questions/54896072
相似问题