diff --git a/contrib/codecs/rdwr/codec.go b/contrib/codecs/rdwr/codec.go
index e1a4316ebc92eb06fababdb3bf451a203bb93979..082635ba45a071321ad7beba731e733da1f001ba 100644
--- a/contrib/codecs/rdwr/codec.go
+++ b/contrib/codecs/rdwr/codec.go
@@ -93,9 +93,6 @@ func (c *Codec) Write(p []byte) (n int, err error) {
 func (c *Codec) Flush() (err error) {
 	c.wrLock.Lock()
 	defer c.wrLock.Unlock()
-	if c.wr.Len() == 0 {
-		return nil
-	}
 	defer c.wr.Reset()
 	err = c.wr.WriteByte('\n')
 	if err != nil {