doris 0.14.x flink sql connector doris sink checkpoint fail error replica num 1 is less than quorum replica num 2 while error backends #7400
silentxingtian
started this conversation in
RFC
Replies: 1 comment
-
Increase the batch size or the batch interval. May be the reason. |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
Caused by: java.io.IOException: org.apache.doris.flink.exception.StreamLoadException: stream load error: errCode = 2, detailMessage = Failed to commit txn 4335361. Tablet [14868] success replica num 1 is less than quorum replica num 2 while error backends
at org.apache.doris.flink.table.DorisDynamicOutputFormat.flush(DorisDynamicOutputFormat.java:165)
at org.apache.doris.flink.table.DorisDynamicOutputFormat.lambda$open$0(DorisDynamicOutputFormat.java:92)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
... 1 more
Error occurred when checkpoint commit
flink 1.13.1
当checkpoint 提交的时候,运行一段时间后,提示 be 挂了 ,实际上 show backend 去看 是 alive 状态 ,这个错误就导致
checkpoint失败的原因,请问,有谁遇见过这个问题,能帮忙看看吗
Beta Was this translation helpful? Give feedback.
All reactions