Re: Exception: Could not perform checkpoint

Mon, 17 May 2021 03:01:12 -0700 

看源码是在
catch里面的（应该是在executeCheckpointing的时候报错了，但是catch里面还有一个nullpoint没catch导致程序退出）：
if (LOG.isDebugEnabled()) {
                                        LOG.debug("{} - did NOT finish 
synchronous part of checkpoint {}. " +
                                                        "Alignment duration: {} 
ms, snapshot duration {} ms",
                                                owner.getName(), 
checkpointMetaData.getCheckpointId(),
                                                
checkpointMetrics.getAlignmentDurationNanos() / 1_000_000,
                                                
checkpointMetrics.getSyncDurationMillis());
                                }

的 checkpointMetrics.getAlignmentDurationNanos() / 1_000_000,
部分报错的。建议关掉 debug日志看看。



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复