Skip to content

Commit d8401f0

Browse files
authored
consumer(ticdc): fix a panic about csv header decode (#12192)
ref #12179
1 parent 3799eba commit d8401f0

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

pkg/sink/codec/csv/csv_decoder.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ func NewBatchDecoder(ctx context.Context,
7979
// check column name
8080
idx := len(header) - len(tableInfo.Columns)
8181
for i, col := range tableInfo.Columns {
82-
if col.Name.O != header[idx+i] {
82+
if col.Name.L != header[idx+i] {
8383
log.Panic("check column name order failed", zap.Any("col", col.Name.O), zap.Any("header", header[idx+i]))
8484
}
8585
}

tests/integration_tests/csv_storage_basic/data/schema.sql

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -42,12 +42,12 @@ CREATE TABLE multi_data_type
4242
);
4343

4444
CREATE TABLE multi_charset (
45-
id INT,
46-
name varchar(128) CHARACTER SET gbk,
47-
country char(32) CHARACTER SET gbk,
48-
city varchar(64),
45+
`id` INT,
46+
Name varchar(128) CHARACTER SET gbk,
47+
`Country` char(32) CHARACTER SET gbk,
48+
CITY varchar(64),
4949
description text CHARACTER SET gbk,
50-
image tinyblob,
50+
`IMAGE` tinyblob,
5151
PRIMARY KEY (id)
5252
) ENGINE = InnoDB CHARSET = utf8mb4;
5353

@@ -61,4 +61,4 @@ CREATE TABLE binary_columns
6161
t_mediumblob MEDIUMBLOB,
6262
t_longblob LONGBLOB,
6363
PRIMARY KEY (id)
64-
);
64+
);

0 commit comments

Comments
 (0)