Roll back unnecessary changes

ClickHouse · Jul 26, 2022 · d7a6f77 · d7a6f77
1 parent 9633bf8
commit d7a6f77
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/clickhouse-client/src/main/java/com/clickhouse/client/data/ClickHouseStreamResponse.java b/clickhouse-client/src/main/java/com/clickhouse/client/data/ClickHouseStreamResponse.java
@@ -70,7 +70,6 @@ protected ClickHouseStreamResponse(ClickHouseConfig config, ClickHouseInputStrea
 
         this.config = config;
         this.input = input;
-        this.closed = false;
 
         boolean hasError = true;
         try {

diff --git a/clickhouse-client/src/test/java/com/clickhouse/client/ClientIntegrationTest.java b/clickhouse-client/src/test/java/com/clickhouse/client/ClientIntegrationTest.java
@@ -1445,7 +1445,7 @@ public void testErrorDuringInsert() throws Exception {
     @Test(groups = "integration")
     public void testErrorDuringQuery() throws Exception {
         ClickHouseNode server = getServer();
-        String query = "select number, throwIf(number>=10000000) from numbers(50000000)";
+        String query = "select number, throwIf(number>=100000000) from numbers(500000000)";
         long count = 0L;
         try (ClickHouseClient client = getClient();
                 ClickHouseResponse resp = client.connect(server).format(ClickHouseFormat.RowBinaryWithNamesAndTypes)