diff --git a/cmd/thalos/server.go b/cmd/thalos/server.go
index 9191666..a9b38b3 100644
--- a/cmd/thalos/server.go
+++ b/cmd/thalos/server.go
@@ -15,6 +15,7 @@ import (
 	"github.com/cenkalti/backoff/v4"
 	eos "github.com/eoscanada/eos-go"
 	shipclient "github.com/eosswedenorg-go/antelope-ship-client"
+	shipws "github.com/eosswedenorg-go/antelope-ship-client/websocket"
 	"github.com/eosswedenorg-go/pid"
 	"github.com/eosswedenorg/thalos/api/message"
 	_ "github.com/eosswedenorg/thalos/api/message/json"
@@ -113,6 +114,11 @@ func readerLoop(conf *config.Config, running *bool, shClient *shipclient.Stream,
 				return
 			}
 
+			if shipws.IsCloseError(err) {
+				log.Info("SHIP Connection closed")
+				return
+			}
+
 			log.WithError(err).Error("Failed to read from ship")
 		}
 	}