我的flink作业假装在sink operator处失败，sink operator将数据发送到mqtt。我已经尝试了.setBufferTimeout(0)在前一个接收操作符和增加并行度，正如你可以看到在图片。但它不起作用。有人能帮忙吗？谢谢
.setBufferTimeout(0)
dw1jzc5e1#
1.根据flink文件应避免缓冲区超时为0，因为它可能导致严重的性能下降。1.您使用的是什么Flume连接器？1.你的Flume操作员的批量是多少？所有这些因素都与接收器的写入性能有关。
1条答案
按热度按时间dw1jzc5e1#
1.根据flink文件
应避免缓冲区超时为0，因为它可能导致严重的性能下降。
1.您使用的是什么Flume连接器？
1.你的Flume操作员的批量是多少？
所有这些因素都与接收器的写入性能有关。