diff --git a/flow/connectors/clickhouse/clickhouse.go b/flow/connectors/clickhouse/clickhouse.go
index b7434c2b18..1320bf8a92 100644
--- a/flow/connectors/clickhouse/clickhouse.go
+++ b/flow/connectors/clickhouse/clickhouse.go
@@ -6,6 +6,7 @@ import (
 	"crypto/x509"
 	"errors"
 	"fmt"
+	"io"
 	"log/slog"
 	"maps"
 	"net/url"
@@ -296,7 +297,7 @@ func isRetryableException(err error) bool {
 		_, yes := retryableExceptions[ex.Code]
 		return yes
 	}
-	return false
+	return errors.Is(err, io.EOF)
 }
 
 //nolint:unparam