diff --git a/relayer/processor/path_processor.go b/relayer/processor/path_processor.go
index b8b9d4da2..a6e31bd60 100644
--- a/relayer/processor/path_processor.go
+++ b/relayer/processor/path_processor.go
@@ -296,7 +296,12 @@ func (pp *PathProcessor) HandleNewData(chainID string, cacheData ChainProcessorC
 func (pp *PathProcessor) handleFlush(ctx context.Context) {
 	flushTimer := pp.flushInterval
 	if err := pp.flush(ctx); err != nil {
-		pp.log.Warn("Flush not complete", zap.Error(err))
+		pp.log.Warn("Flush not complete",
+			zap.String("chain_id_1", pp.pathEnd1.chainProvider.ChainId()),
+			zap.String("client_id_1", pp.pathEnd1.info.ClientID),
+			zap.String("chain_id_2", pp.pathEnd2.chainProvider.ChainId()),
+			zap.String("client_id_2", pp.pathEnd2.info.ClientID),
+			zap.Error(err))
 		flushTimer = flushFailureRetry
 	}
 	pp.flushTimer.Stop()