Skip to content

Commit d047793

Browse files
author
och5351
committed
[hotfix][Connector/JDBC] Support PostgreSQL uuid type
1 parent ed5e4ff commit d047793

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

flink-connector-jdbc-postgres/src/test/java/org/apache/flink/connector/jdbc/postgres/database/catalog/PostgresCatalogITCase.java

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -201,9 +201,7 @@ void testUuidTypes() {
201201
tEnv.sqlQuery(String.format("select * from %s", TABLE_UUID_TYPE))
202202
.execute()
203203
.collect());
204-
assertThat(results)
205-
.hasToString(
206-
"[+I[1, 123e4567-e89b-12d3-a456-426614174000]]");
204+
assertThat(results).hasToString("[+I[1, 123e4567-e89b-12d3-a456-426614174000]]");
207205
}
208206

209207
@Test
@@ -213,8 +211,6 @@ void testNullUuidTypes() {
213211
tEnv.sqlQuery(String.format("select * from %s", TABLE_UUID_TYPE2))
214212
.execute()
215213
.collect());
216-
assertThat(results)
217-
.hasToString(
218-
"[+I[1, null]]");
214+
assertThat(results).hasToString("[+I[1, null]]");
219215
}
220216
}

0 commit comments

Comments
 (0)