fix a failed integration test

pingcap · Mar 6, 2023 · 48af35e · 48af35e
1 parent 67aa18e
commit 48af35e
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/cdc/sink/codec/internal/column.go b/cdc/sink/codec/internal/column.go
@@ -94,8 +94,10 @@ func (c *Column) ToRowChangeColumn(name string) *model.Column {
 			if err != nil {
 				log.Panic("invalid column value, please report a bug", zap.Any("col", c), zap.Error(err))
 			}
+			col.Value = []byte(str)
+		} else {
+			col.Value = str
 		}
-		col.Value = str
 	default:
 		col.Value = c.Value
 	}

diff --git a/cdc/sink/codec/open/open_protocol_message_test.go b/cdc/sink/codec/open/open_protocol_message_test.go
@@ -65,7 +65,6 @@ func TestNonBinaryStringCol(t *testing.T) {
 	require.Equal(t, row, row2)
 	mqCol2 := row2.Update["test"]
 	col2 := mqCol2.ToRowChangeColumn("test")
-	col2.Value = string(col2.Value.([]byte))
 	require.Equal(t, col, col2)
 }