Xinyu Tan created IOTDB-6156:
--------------------------------
Summary: Fixed TConfiguration invalidly in Thrift AsyncServer For
IoTConsensus
Key: IOTDB-6156
URL: https://issues.apache.org/jira/browse/IOTDB-6156
Project: Apache IoTDB
Issue Type: Bug
Reporter: Xinyu Tan
Assignee: Xinyu Tan
In a user scenario, the machine configuration is as follows:
3c3d 3 replicas,
1 database
1 device
2 measurement
1 client
insertAlignTablet interface
batchSize 10000000
time_partition_interval=3144960000000
The IoTConsensus data synchronization error occurs after writing to the cluster.
{code:java}
2023-09-14 12:11:50,888 [pool-19-IoTDB-IoTConsensusRPC-Processor-5] WARN
o.a.t.s.AbstractNonblockingServer$AsyncFrameBuffer:606 - Exception while
invoking!
org.apache.thrift.transport.TTransportException: MaxMessageSize reached
at
org.apache.thrift.transport.TEndpointTransport.countConsumedMessageBytes(TEndpointTransport.java:96)
at
org.apache.thrift.transport.TMemoryInputTransport.read(TMemoryInputTransport.java:97)
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:109)
at
org.apache.iotdb.rpc.AutoScalingBufferReadTransport.fill(AutoScalingBufferReadTransport.java:38)
at
org.apache.iotdb.rpc.TElasticFramedTransport.readFrame(TElasticFramedTransport.java:128)
at
org.apache.iotdb.rpc.TElasticFramedTransport.read(TElasticFramedTransport.java:108)
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:109)
at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:463)
at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:361)
at
org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:244)
at org.apache.thrift.TBaseAsyncProcessor.process(TBaseAsyncProcessor.java:52)
at
org.apache.thrift.server.AbstractNonblockingServer$AsyncFrameBuffer.invoke(AbstractNonblockingServer.java:603)
at org.apache.thrift.server.Invocation.run(Invocation.java:18)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
{code}
This is mainly due to the use of AsyncServer in IoTConsensus. At present, the
default maximum size of message is 100M instead of 512M, so it needs to be
updated
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
