gRPC cannot insert many fields

[JeasGo]

I add some fields When I use gRPC insert , but it reports an error, I use the case that is the clickhouse-java/examples/client/src/main/java/com/clickhouse/examples/jdbc/ Main.java , just like this code

The error is

`15:22:50.224 [grpc-default-executor-0] ERROR com.clickhouse.client.grpc.ClickHouseStreamObserver - Server error: Code=32, DB::Exception: Attempt to read after eof: While executing BinaryRowInputFormat
15:22:50.224 [grpc-default-executor-0] ERROR com.clickhouse.client.grpc.ClickHouseStreamObserver - 0. DB::Exception::Exception(DB::Exception::MessageMasked&&, int, bool) @ 0xddb0cd5 in /usr/bin/clickhouse

1. ? @ 0x887d9d6 in /usr/bin/clickhouse
2. ? @ 0x887d823 in /usr/bin/clickhouse
3. ? @ 0xddfd7d3 in /usr/bin/clickhouse
4. DB::SerializationString::deserializeBinary(DB::IColumn&, DB::ReadBuffer&, DB::FormatSettings const&) const @ 0x1279ba64 in /usr/bin/clickhouse
5. DB::BinaryFormatReader::readField(DB::IColumn&, std::__1::shared_ptr<DB::IDataType const> const&, std::__1::shared_ptr<DB::ISerialization const> const&, bool, std::__1::basic_string<char, std::__1::char_traits, std::__1::allocator> const&) @ 0x1475a896 in /usr/bin/clickhouse
6. DB::RowInputFormatWithNamesAndTypes::readRow(std::__1::vector<COWDB::IColumn::mutable_ptrDB::IColumn, std::__1::allocator<COWDB::IColumn::mutable_ptrDB::IColumn>>&, DB::RowReadExtension&) @ 0x1475d918 in /usr/bin/clickhouse
7. DB::IRowInputFormat::generate() @ 0x1473cdee in /usr/bin/clickhouse
8. DB::ISource::tryGenerate() @ 0x146c1455 in /usr/bin/clickhouse
9. DB::ISource::work() @ 0x146c0fc6 in /usr/bin/clickhouse
10. DB::ExecutionThreadContext::executeTask() @ 0x146db246 in /usr/bin/clickhouse
11. DB::PipelineExecutor::executeStepImpl(unsigned long, std::__1::atomic*) @ 0x146d035c in /usr/bin/clickhouse
12. DB::PipelineExecutor::executeStep(std::__1::atomic*) @ 0x146cf028 in /usr/bin/clickhouse
13. DB::PullingPipelineExecutor::pull(DB::Chunk&) @ 0x146e09b7 in /usr/bin/clickhouse
14. DB::PullingPipelineExecutor::pull(DB::Block&) @ 0x146e0b73 in /usr/bin/clickhouse
15. ? @ 0x145ee879 in /usr/bin/clickhouse
16. ? @ 0x145eab4e in /usr/bin/clickhouse
17. ThreadPoolImplstd::__1::thread::worker(std::__1::__list_iterator<std::__1::thread, void*>) @ 0xde7dd56 in /usr/bin/clickhouse
18. ? @ 0xde83081 in /usr/bin/clickhouse
19. ? @ 0x7febac555b43 in ?
20. ? @ 0x7febac5e7a00 in ?
    `

[zhicwu]

Will it work if you switch to http protocol? gRPC is experimental and problematic, I should probably drop it someday to avoid confusion.

By the way, you no longer has to use DataStreamFactory explicitly, but request.data(ClickHouseWriter), for example:

clickhouse-java/clickhouse-jdbc/src/test/java/com/clickhouse/jdbc/ClickHousePreparedStatementTest.java

Lines 1640 to 1656 in 6ce0d38

	try (PreparedStatement ps = conn
	.prepareStatement(
	"INSERT INTO test_insert_with_format(s,i)SETTINGS insert_null_as_default=1 format JSONEachRow")) {
	Assert.assertTrue(ps instanceof StreamBasedPreparedStatement);
	ps.setString(1, "{\"i\":null,\"s\":null}");
	ps.addBatch();
	ps.setObject(1, "{\"i\":1,\"s\":\"one\"}");
	ps.addBatch();
	ps.setObject(1, new ClickHouseWriter() {
	@Override
	public void write(ClickHouseOutputStream out) throws IOException {
	out.write("{\"i\":2,\"s\":\"22\"}".getBytes());
	}
	});
	ps.addBatch();
	Assert.assertEquals(ps.executeBatch(), new int[] { 1, 1, 1 });
	}