我有一个源 A、接收器 B 和接收器 C 的 flink 作业。源 A 将事件发送到接收器 B 和接收器 C，并且它们没有被链接，因为并行度的数量不同。
有一些奇怪的错误。首先，我不断收到失败的检查点，但源操作员不断推进 Kinesis Shard Offset。其次，source 发送的记录数是正整数，而两个 sink 上接收到的记录数都是 0。从 flink 文档中，这些数字是从输入/输出缓冲区中获得的。所以看起来 flink 未能传递这些事件。
我检查了日志，但找不到任何可疑的东西。我认为问题出在 apache flink 中。关于如何进一步缩小问题范围的任何建议？