-
2 votesanswersviews
HiBench中FlinkKafkaConsumer的容错能力
我正在运行一些实验来测试Apache Flink的容错功能 . 我目前正在使用HiBench框架和为Flink实现的WordCount微基准测试 . 我注意到如果我在执行期间杀死了一个TaskManager，Flink运算符的状态在自动“重新部署”之后被恢复，但是从基准发送到Kafka的许多（全部？）元组被遗漏（存储在Kafka中但未在Flink中接收） ） . 似乎在恢复之后， FlinkKaf...