Re:FlinkKafkaProducer 开启Excatly Once之后 初始化事务状态超时的问题

Sun, 01 Sep 2019 20:49:59 -0700 



2019-09-02 10:24:28,599 INFO  org.apache.flink.runtime.taskmanager.Task         
            - Interval Join -> Sink: Unnamed (1/4) 
(e8b85b6f144879efbb0b4209f226c69b) switched from RUNNING to FAILED.
org.apache.kafka.common.errors.TimeoutException: Timeout expired while 
initializing transactional state in 60000ms.



在 2019-09-02 11:29:35，"陈赋赟" <[email protected]> 写道：

我在flink中使用了kafkaProducer 
并开启了ExcatlyOnce语义，第一次部署在测试环境启动的时候一切正常，然后我再上新版本的时候kill掉了之前的任务，并重现发布了一下，就出现了如下的问题日志里显示在做checkpoint的时候出现了初始化事务状态
 超时过期的异常。
具体异常如下：
 


checkpoint interval设置了30s执行一次
producer事务超时（transaction.timeout.ms）时间设置了5分钟




 





















					回复