Используйте Flink для вызова API драйвера arangodb Java для вставки данных в arangodb и сообщения об ошибке «Идентификатор транзакции уже используется» - PullRequest
Новая
       5

Используйте Flink для вызова API драйвера arangodb Java для вставки данных в arangodb и сообщения об ошибке «Идентификатор транзакции уже используется»

0 голосов
/ 07 января 2020

Используйте Flink для вызова arangodb Java драйвера API для вставки данных в arangodb и сообщения об ошибке err «идентификатор транзакции уже используется» 

Caused by: TimerException{com.arangodb.ArangoDBException: Response: 500, Error: 1590 - AQL: error, cluster node: 'PRMR-c338134b-023c-438d-b672-d5f954c2882c', endpoint: 'tcp://192.168.2.137:8530', error: 'transaction ID already used' (while optimizing plan)}
    at org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService$TriggerTask.run(SystemProcessingTimeService.java:284)
    ... 7 more
Caused by: com.arangodb.ArangoDBException: Response: 500, Error: 1590 - AQL: error, cluster node: 'PRMR-c338134b-023c-438d-b672-d5f954c2882c', endpoint: 'tcp://xxx:8530', error: 'transaction ID already used' (while optimizing plan)
    at com.arangodb.internal.util.ResponseUtils.checkError(ResponseUtils.java:53)
    at com.arangodb.internal.velocystream.VstCommunication.checkError(VstCommunication.java:149)
    at com.arangodb.internal.velocystream.VstCommunicationSync.execute(VstCommunicationSync.java:128)
    at com.arangodb.internal.velocystream.VstCommunicationSync.execute(VstCommunicationSync.java:42)
    at com.arangodb.internal.velocystream.VstCommunication.execute(VstCommunication.java:132)
    at com.arangodb.internal.velocystream.VstProtocol.execute(VstProtocol.java:47)
    at com.arangodb.internal.ArangoExecutorSync.execute(ArangoExecutorSync.java:71)
    at com.arangodb.internal.ArangoExecutorSync.execute(ArangoExecutorSync.java:53)

1 Ответ

0 голосов
/ 09 января 2020

Это похоже на ошибку в arangodb и должно быть исправлено в более поздних версиях.

...