flink 任务 numRecordsIn 一直是0
时间: 2023-12-12 09:04:18 浏览: 154
记录数据的时候提示共下载为0
在 Flink 中,`numRecordsIn` 表示在某个算子中输入的记录数,如果该值一直为0,可能存在以下原因:
1. 数据源没有数据:如果数据源没有数据,那么输入到算子中的记录数就会为0。请检查数据源是否正常,并确保数据源中有数据。
2. 算子逻辑错误:如果算子逻辑错误,可能会导致输入的记录数为0。请检查算子逻辑是否正确。
3. 并行度设置错误:如果算子的并行度设置过高,而数据源并没有足够的数据来支持这样的并行度,那么就会出现输入记录数为0的情况。请检查算子的并行度设置是否合理。
4. 数据倾斜:如果数据倾斜严重,可能会导致某些分区没有数据,从而导致输入记录数为0。请检查数据是否倾斜,如果是,请尝试对数据进行重分区或使用 Flink 提供的解决数据倾斜的方法。
希望这些信息能够帮助你找到问题所在。如果问题仍然存在,请提供更多详细信息,以便我能够更好地帮助你解决问题。
阅读全文