Skip to content

Commit f456910

Browse files
committed
Update README.md file
1 parent df6cc98 commit f456910

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

README.md

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -167,9 +167,9 @@ Planned for a future release — a complete end-to-end example will be added onc
167167
| int/Integer | Enum16 || Serialize.writeInt16 |
168168
| java.util.UUID | UUID || Serialize.writeIntUUID |
169169
| String | JSON || N/A |
170-
| Array<Type> | Array<Type> | | N/A |
171-
| Map<K,V> | Map<K,V> | | N/A |
172-
| Tuple<Type,..> | Map<T1,T2,..> | | N/A |
170+
| Array<Type> | Array<Type> | | Serialize.writeArray |
171+
| Map<K,V> | Map<K,V> | | Serialize.writeMap |
172+
| Tuple<Type,..> | Tuple<T1,T2,..> | | Serialize.writeTuple |
173173
| Object | Variant || N/A |
174174

175175
* A ZoneId must also be provided when performing date operations.

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
@@ -287,7 +287,7 @@ void SimplePOJODataTest() throws Exception {
287287
simplePOJOs.sinkTo(simplePOJOSink);
288288
int rows = executeAsyncJob(env, tableName, 10, EXPECTED_ROWS);
289289
Assertions.assertEquals(EXPECTED_ROWS, rows);
290-
ClickHouseServerForTests.showData(tableName);
290+
// ClickHouseServerForTests.showData(tableName);
291291
}
292292

293293
@Test
@@ -537,7 +537,7 @@ void SimplePOJODataTooManyPartsTest() throws Exception {
537537
simplePOJOs.sinkTo(simplePOJOSink);
538538
int rows = executeAsyncJob(env, tableName, 100, EXPECTED_ROWS);
539539
Assertions.assertEquals(EXPECTED_ROWS, rows);
540-
ClickHouseServerForTests.showData("simple_too_many_parts_pojo");
540+
// ClickHouseServerForTests.showData("simple_too_many_parts_pojo");
541541
//ClickHouseServerForTests.executeSql(String.format("SYSTEM START MERGES `%s.%s`", getDatabase(), tableName));
542542
}
543543

0 commit comments

Comments
 (0)