Skip to content

Commit dfa279d

Browse files
committed
Made error handling in same style
1 parent 809298c commit dfa279d

1 file changed

Lines changed: 0 additions & 5 deletions

File tree

  • examples/client-v2-apache-arrow/src/main/java/com/clickhouse/examples/arrow_format

examples/client-v2-apache-arrow/src/main/java/com/clickhouse/examples/arrow_format/ReadWriteArrow.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -90,8 +90,6 @@ private void loadData(Client client) {
9090
InsertSettings insertSettings = new InsertSettings();
9191
insertSettings.compressClientRequest(true);
9292
try (InsertResponse response = client.insert(table, out -> {
93-
// use DataWriter to avoid tmp storage.
94-
//
9593
// DON'T: swallow exceptions thrown by the Arrow writer here. If the writer fails
9694
// mid-stream (I/O error, allocator failure, etc.), only a partial Arrow stream
9795
// reaches the server. The request may still complete and `getWrittenRows()` would
@@ -101,9 +99,6 @@ private void loadData(Client client) {
10199
arrowWriter.start();
102100
arrowWriter.writeBatch();
103101
arrowWriter.end();
104-
} catch (Exception e) {
105-
LOG.error("Failed writing data to output stream", e);
106-
throw new RuntimeException("Failed writing Arrow data to output stream", e);
107102
}
108103
}, ClickHouseFormat.ArrowStream, // Use Arrow Stream Format
109104
insertSettings).get()) {

0 commit comments

Comments
 (0)