add sink level config output-old-value for open and debezium

pingcap · Apr 19, 2024 · 8ca0b11 · 8ca0b11
1 parent 171311f
commit 8ca0b11
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/sink/codec/open/open_protocol_message.go b/pkg/sink/codec/open/open_protocol_message.go
@@ -115,7 +115,7 @@ func rowChangeToMsg(
 	}
 	value := &messageRow{}
 	if e.IsDelete() {
-		onlyHandleKeyColumns := config.DeleteOnlyHandleKeyColumns || largeMessageOnlyHandleKeyColumns || !config.OpenOutputOldValue
+		onlyHandleKeyColumns := config.DeleteOnlyHandleKeyColumns || largeMessageOnlyHandleKeyColumns
 		value.Delete = rowChangeColumns2CodecColumns(e.GetPreColumns(), onlyHandleKeyColumns)
 		if onlyHandleKeyColumns && len(value.Delete) == 0 {
 			return nil, nil, cerror.ErrOpenProtocolCodecInvalidData.GenWithStack("not found handle key columns for the delete event")