Skip to content

Commit d7a6f77

Browse files
committed
Roll back unnecessary changes
1 parent 9633bf8 commit d7a6f77

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

clickhouse-client/src/main/java/com/clickhouse/client/data/ClickHouseStreamResponse.java

-1
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,6 @@ protected ClickHouseStreamResponse(ClickHouseConfig config, ClickHouseInputStrea
7070

7171
this.config = config;
7272
this.input = input;
73-
this.closed = false;
7473

7574
boolean hasError = true;
7675
try {

clickhouse-client/src/test/java/com/clickhouse/client/ClientIntegrationTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1445,7 +1445,7 @@ public void testErrorDuringInsert() throws Exception {
14451445
@Test(groups = "integration")
14461446
public void testErrorDuringQuery() throws Exception {
14471447
ClickHouseNode server = getServer();
1448-
String query = "select number, throwIf(number>=10000000) from numbers(50000000)";
1448+
String query = "select number, throwIf(number>=100000000) from numbers(500000000)";
14491449
long count = 0L;
14501450
try (ClickHouseClient client = getClient();
14511451
ClickHouseResponse resp = client.connect(server).format(ClickHouseFormat.RowBinaryWithNamesAndTypes)

0 commit comments

Comments
 (0)