специальные настройки требовались? Ошибка что-то типа
java.sql.SQLException: org.apache.http.ConnectionClosedException: Premature end of chunk coded message body: closing chunk expected
at ru.yandex.clickhouse.response.ClickHouseResultSet.hasNext(ClickHouseResultSet.java:164)
at ru.yandex.clickhouse.response.ClickHouseResultSet.next(ClickHouseResultSet.java:200)
. Если сильно уменьшаю кол-во строк в запросе то всё отрабатывает, а на нужном объеме данных увы ( Может кто-то сталкивался.
А как забираете?
Там удобно использовать метод с callback функцией https://github.com/ClickHouse/clickhouse-jdbc#send-data-in-binary-formatted-with-custom-user-callback Но тогда чтение будет немного другим ClickHouseStatement -> ClickHouseRowBinaryInputStream executeQueryClickhouseRowBinaryStream(String sql) для Java 🤷♀️
Это close before read last data. см. https://stackoverflow.com/questions/33633549/org-apache-http-connectionclosedexception-premature-end-of-chunk-coded-message А вне spark, на чистом public void static main этот запрос прозходит?
Обсуждают сегодня