write rejected

version 1.2.0

Write rejected when insert data via java interface:
`spark.scheduler.ResultTask.runTask(ResultTask.scala:90) spark.scheduler.Task.run(Task.scala:131)
spark.executor.Executor$TaskRunner.$anonfun$run$3(Executor.scala:506) spark.util.Utils$.tryWithSafeFinally(Utils.scala:1491)
spark.executor.Executor$TaskRunner.run(Executor.scala:509)
concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) Thread.run(Thread.java:750)
.iotdb.rpc.StatementExecutionException: 606: The write is rejected because the wal directory size has reached the thresholold 53687091200 bytes. You may need to adjust the flush policy of the storage engine or the IoTConsen:
iotdb.session.Session.insertByGroup(Session.java:3254)
iotdb.session.Session.insertRecordsWithLeaderCache(Session.java:2178) iotdb.session.Session.insertAlignedRecords(Session.java:1671)
seatunnel.connectors.seatunnel.iotdb.sink.IoTDBSinkClient.insertAlignedRecords(IoTDBSinkClient.java:217).seatunnel.connectors.seatunnel.iotdb.sink.IoTDBSinkClient.flush(IoTDBSinkClient.java:160)`

Change which parameter can avoid this?

Inizia con l’eccezione della soglia WAL nel percorso di scrittura segnalato, seguendo Session.insertAlignedRecords e i file seatunnel IoTDBSinkClient menzionati nel trace. Identifica quale configurazione controlla il limite WAL di 53687091200 byte e come si relaziona alla policy di flush; il lavoro è completato quando gli inserimenti tramite l’interfaccia Java non falliscono più con il rifiuto dovuto alle dimensioni del WAL.

Scritto dal modello di indicizzazione a partire dal testo della issue.