knative
diff --git a/‎Gopkg.lock‎
Lines changed: 2 additions & 2 deletions b/‎Gopkg.lock‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎vendor/knative.dev/pkg/websocket/connection.go‎
Lines changed: 5 additions & 1 deletion b/‎vendor/knative.dev/pkg/websocket/connection.go‎
Lines changed: 5 additions & 1 deletion
@@ -106,7 +106,11 @@ func NewDurableSendingConnection(target string, logger *zap.SugaredLogger) *Mana
 // go func() {for range messageChan {}}
 func NewDurableConnection(target string, messageChan chan []byte, logger *zap.SugaredLogger) *ManagedConnection {
 	websocketConnectionFactory := func() (rawConnection, error) {
-		dialer := websocket.DefaultDialer
+		dialer := &websocket.Dialer{
+			// This needs to be relatively short to avoid the connection getting blackholed for a long time
+			// by restarting the serving side of the connection behind a Kubernetes Service.
+			HandshakeTimeout: 3 * time.Second,
+		}
 		conn, _, err := dialer.Dial(target, nil)
 		if err != nil {
 			logger.Errorw("Websocket connection could not be established", zap.Error(err))