'Read Kafka data and write into the Apache IoTDB, 818 ERROR

I want to read the Kafka data and write into the Apache IoTDB.But I failed. The error message is below:

    818 ERROR org.apache.iotdb.flink.IoTDBSink                             [] - flush error
        org.apache.iotdb.rpc.StatementExecutionException: 400: 
    The following errors occurred when executing the query, please retry or contact the DBA: [[701@RaftNode(node:Node(internalIp:192.168.0.117, metaPort:9007, nodeIdentifier:2037163866, dataPort:40010, clientPort:6667, clientIp:192.168.0.117), raftId:0):Request timed out. :null],
 [400@RaftNode(node:Node(internalIp:192.168.0.194, metaPort:9007, nodeIdentifier:2037402070, dataPort:40010, clientPort:6667, clientIp:192.168.0.194), raftId:0):Task java.util.concurrent.FutureTask@19411956 rejected from java.util.concurrent.
ThreadPoolExecutor@4a196d1c[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]:null]]
            at org.apache.iotdb.session.Session.insertByGroup(Session.java:2441) ~[blob_p-f631f22c4a4aab7c2e8e93f7982868d513f4f4a0-9999b605325b0d673729821941312a8a:0.12.5]
            at org.apache.iotdb.session.Session.insertRecordsWithLeaderCache(Session.java:1513) ~[blob_p-f631f22c4a4aab7c2e8e93f7982868d513f4f4a0-9999b605325b0d673729821941312a8a:0.12.5]
            at org.apache.iotdb.session.Session.insertRecords(Session.java:1135) ~[blob_p-f631f22c4a4aab7c2e8e93f7982868d513f4f4a0-9999b605325b0d673729821941312a8a:0.12.5]
            at org.apache.iotdb.session.pool.SessionPool.insertRecords(SessionPool.java:584) ~[blob_p-f631f22c4a4aab7c2e8e93f7982868d513f4f4a0-9999b605325b0d673729821941312a8a:0.12.5]
            at org.apache.iotdb.flink.IoTDBSink.flush(IoTDBSink.java:205) ~[blob_p-f631f22c4a4aab7c2e8e93f7982868d513f4f4a0-9999b605325b0d673729821941312a8a:0.13.0]
            at org.apache.iotdb.flink.IoTDBSink.lambda$initScheduler$0(IoTDBSink.java:95) ~[blob_p-f631f22c4a4aab7c2e8e93f7982868d513f4f4a0-9999b605325b0d673729821941312a8a:0.13.0]
            at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_321]
            at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) [?:1.8.0_321]
            at java.util.concurrent.ScheduledThreadPoolExecutor

Solution 1:^[1]

Change system mode to read-only

Solution 2:^[2]

It seems that 192.168.0.194 node's network thread pool was terminated?192.168.0.117 node's request timeout.It is estimated that the service is in an abnormal state of complete unavailability...

Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution	Source
Solution 1	General Grievance
Solution 2	Cecelia Blackt

'Read Kafka data and write into the Apache IoTDB, 818 ERROR

Solution 1:[1]

Solution 2:[2]

Sources

Related Questions

Solution 1:^[1]

Solution 2:^[2]