Skip to content

Commit 6e441a3

Browse files
committed
update test for upsert iceberg sink
1 parent 457140d commit 6e441a3

File tree

2 files changed

+7
-1
lines changed

2 files changed

+7
-1
lines changed

ci/scripts/e2e-iceberg-sink-test.sh

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@ spark-3.3.1-bin-hadoop3/bin/spark-sql --packages $DEPENDENCIES \
8686

8787
# check sink destination using shell
8888
if cat ./spark-output/*.csv | sort | awk -F "," '{
89-
if ($1 == 1 && $2 == 2 && $3 == "1-2") c1++;
89+
if ($1 == 1 && $2 == 50 && $3 == "1-50") c1++;
9090
if ($1 == 13 && $2 == 2 && $3 == "13-2") c2++;
9191
if ($1 == 21 && $2 == 2 && $3 == "21-2") c3++;
9292
if ($1 == 2 && $2 == 2 && $3 == "2-2") c4++;

e2e_test/sink/iceberg_sink.slt

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,12 @@ INSERT INTO t6 VALUES (1, 2, '1-2'), (2, 2, '2-2'), (3, 2, '3-2'), (5, 2, '5-2')
2323
statement ok
2424
FLUSH;
2525

26+
statement ok
27+
INSERT INTO t6 VALUES (1, 50, '1-50');
28+
29+
statement ok
30+
FLUSH;
31+
2632
statement ok
2733
DROP SINK s6;
2834

0 commit comments

Comments
 (0)