gj-zhang

java.sql.SQLException: Broken pipe (Write failed)

2

### Environment - OS version: - JDK version: - ClickHouse Server version: 20.9.3.45 - ClickHouse Native JDBC version: 2.5.4 - (Optional) Spark version: N/A - (Optional) Other components' version: N/A...

### Environment - OS version: - JDK version:1.8 - ClickHouse Server version: 21.8.4.51 - ClickHouse Native JDBC version:2.5.6 - (Optional) Spark version: 2.4.3 - (Optional) Other components' version: N/A ###...

java.nio.BufferOverflowException native jdbc version 2.5.6.

5

### Environment - OS version: - JDK version: 1.8 - ClickHouse Server version: 20.9.3.45 - ClickHouse Native JDBC version: 2.5.6 - (Optional) Spark version: N/A - (Optional) Other components' version:...

How is the mongo client closed in MongoSplitReader?

3

 Only code to close the cursor, no code to close the connection. should we use independent MongoClientProvider for each MongoSplitReader?. @link3280

collStats avgObjSize is double, in mongo 4.4 above

2

org.mongoflink.source.split.SamplingSplitStrategy#getDocumentNumAndAvgSize ```java long avgDocumentBytes = res.getInteger("avgObjSize"); ``` may be ```java double avgDocumentBytes = res.getDouble("avgObjSize"); ```

feat: the extractor can set additional parameters to be passed to the model

1

- [ ] I have looked for existing issues (including closed) about this ## Feature Request ### Motivation i want to use the extractor , with the model 'qwen3-235b-a22b' ,...