Skip to content

Commit 3940236

Browse files
author
Paultagoras
committed
Update InsertTests.java
1 parent 25d296c commit 3940236

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

client-v2/src/test/java/com/clickhouse/client/insert/InsertTests.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -154,7 +154,10 @@ public void insertRawDataSimple(int numberOfRecords) throws Exception {
154154
final String tableName = "raw_data_table";
155155
createTable(String.format("CREATE TABLE IF NOT EXISTS %s (Id UInt32, event_ts Timestamp, name String, p1 Int64, p2 String) ENGINE = MergeTree() ORDER BY ()", tableName));
156156

157-
settings.setInputStreamCopyBufferSize(8198 * 2);
157+
InsertSettings settings = new InsertSettings()
158+
.setDeduplicationToken(RandomStringUtils.randomAlphabetic(36))
159+
.setQueryId(String.valueOf(UUID.randomUUID()))
160+
.setInputStreamCopyBufferSize(8198 * 2);
158161
ByteArrayOutputStream data = new ByteArrayOutputStream();
159162
PrintWriter writer = new PrintWriter(data);
160163
for (int i = 0; i < numberOfRecords; i++) {

0 commit comments

Comments
 (0)