diff --git a/contrib/codecs/websocket/codec.go b/contrib/codecs/websocket/codec.go
index 4a39c6fd2b5f74537db97dfb9f1ff8cf23de2911..862ba5546046a8a2c9c8d517a1b55b4b4ecd09d3 100644
--- a/contrib/codecs/websocket/codec.go
+++ b/contrib/codecs/websocket/codec.go
@@ -119,14 +119,6 @@ func (c *Codec) Flush() error {
 	c.wrLock.Lock()
 	defer c.wrLock.Unlock()
 	if c.currentFrame == nil {
-		wr, err := c.conn.Writer(c.ctx, websocket.MessageText)
-		if err != nil {
-			return err
-		}
-		err = wr.Close()
-		if err != nil {
-			return err
-		}
 		return nil
 	}
 	err := c.currentFrame.Close()