From 16d53cb9b8beeb890d3416c108ba9a5274fb3b33 Mon Sep 17 00:00:00 2001 From: Yimin Chen Date: Fri, 31 Mar 2023 12:24:25 -0700 Subject: [PATCH] Reconnect on a few more gocql errors (#4132) --- .../nosql/nosqlplugin/cassandra/gocql/session.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/common/persistence/nosql/nosqlplugin/cassandra/gocql/session.go b/common/persistence/nosql/nosqlplugin/cassandra/gocql/session.go index c95dc0bbd7a..65736d6910c 100644 --- a/common/persistence/nosql/nosqlplugin/cassandra/gocql/session.go +++ b/common/persistence/nosql/nosqlplugin/cassandra/gocql/session.go @@ -28,6 +28,7 @@ import ( "context" "sync" "sync/atomic" + "syscall" "time" "github.com/gocql/gocql" @@ -181,7 +182,10 @@ func (s *session) handleError( err error, ) { switch err { - case gocql.ErrNoConnections: + case gocql.ErrNoConnections, + gocql.ErrSessionClosed, + gocql.ErrConnectionClosed, + syscall.ECONNRESET: s.refresh() default: // noop