Skip to content

Commit acfdcf4

Browse files
committed
Update create table for ClickHouse 23.7 version compatibility
1 parent c8fc37b commit acfdcf4

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

flink-connector-clickhouse-1.17/src/test/java/org/apache/flink/connector/clickhouse/sink/ClickHouseSinkTests.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -218,7 +218,7 @@ void SimplePOJODataTest() throws Exception {
218218
"uint64Object UInt64," +
219219
"uint128Object UInt128," +
220220
"uint256Object UInt256," +
221-
"decimal Decimal," +
221+
"decimal Decimal(10,5)," +
222222
"decimal32 Decimal32(9)," +
223223
"decimal64 Decimal64(18)," +
224224
"decimal128 Decimal128(38)," +
@@ -506,7 +506,7 @@ void SimplePOJODataTooManyPartsTest() throws Exception {
506506
"uint64Object UInt64," +
507507
"uint128Object UInt128," +
508508
"uint256Object UInt256," +
509-
"decimal Decimal," +
509+
"decimal Decimal(10,5)" +
510510
"decimal32 Decimal32(9)," +
511511
"decimal64 Decimal64(18)," +
512512
"decimal128 Decimal128(38)," +

0 commit comments

Comments
 (0)