diff --git a/ci/scripts/e2e-doris-sink-test.sh b/ci/scripts/e2e-doris-sink-test.sh index 7c4c8ec1c7c41..859dd411469dd 100755 --- a/ci/scripts/e2e-doris-sink-test.sh +++ b/ci/scripts/e2e-doris-sink-test.sh @@ -31,7 +31,7 @@ echo "--- create doris table" apt-get update -y && apt-get install -y mysql-client sleep 2 mysql -uroot -P 9030 -h doris-server -e "CREATE database demo;use demo; -CREATE table demo_bhv_table(v1 int,v2 smallint,v3 bigint,v4 float,v5 double,v6 string,v7 datev2,v8 datetime,v9 boolean) UNIQUE KEY(\`v1\`) +CREATE table demo_bhv_table(v1 int,v2 smallint,v3 bigint,v4 float,v5 double,v6 string,v7 datev2,v8 datetime,v9 boolean,v10 json) UNIQUE KEY(\`v1\`) DISTRIBUTED BY HASH(\`v1\`) BUCKETS 1 PROPERTIES ( \"replication_allocation\" = \"tag.location.default: 1\" @@ -47,7 +47,7 @@ mysql -uroot -P 9030 -h doris-server -e "select * from demo.demo_bhv_table" > ./ if cat ./query_result.csv | sed '1d; s/\t/,/g' | awk -F "," '{ - exit !($1 == 1 && $2 == 1 && $3 == 1 && $4 == 1.1 && $5 == 1.2 && $6 == "test" && $7 == "2013-01-01" && $8 == "2013-01-01 01:01:01" && $9 == 0); }'; then + exit !($1 == 1 && $2 == 1 && $3 == 1 && $4 == 1.1 && $5 == 1.2 && $6 == "test" && $7 == "2013-01-01" && $8 == "2013-01-01 01:01:01" && $9 == 0 && $10 == "{\"a\":1}"); }'; then echo "Doris sink check passed" else cat ./query_result.csv diff --git a/e2e_test/sink/doris_sink.slt b/e2e_test/sink/doris_sink.slt index 3401e73a4784e..3242206badaea 100644 --- a/e2e_test/sink/doris_sink.slt +++ b/e2e_test/sink/doris_sink.slt @@ -1,5 +1,5 @@ statement ok -CREATE TABLE t6 (v1 int primary key, v2 smallint, v3 bigint, v4 real, v5 float, v6 varchar, v7 date, v8 timestamp, v9 boolean); +CREATE TABLE t6 (v1 int primary key, v2 smallint, v3 bigint, v4 real, v5 float, v6 varchar, v7 date, v8 timestamp, v9 boolean, v10 jsonb); statement ok CREATE MATERIALIZED VIEW mv6 AS SELECT * FROM t6; @@ -19,7 +19,7 @@ FROM ); statement ok -INSERT INTO t6 VALUES (1, 1, 1, 1.1, 1.2, 'test', '2013-01-01', '2013-01-01 01:01:01' , false); +INSERT INTO t6 VALUES (1, 1, 1, 1.1, 1.2, 'test', '2013-01-01', '2013-01-01 01:01:01' , false, '{"a":1}'); statement ok FLUSH;