Replies: 2 comments
-
建议英文提问,如使用中文提问,可以去ask.selectdb.com中文技术论坛。 |
Beta Was this translation helpful? Give feedback.
0 replies
-
我看过1.2版本的源码,spark写入并行度由bucket数量决定; |
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
-
设置的参数为:
.option("doris.sink.task.use.repartition", "true")
.option("doris.sink.task.partition.size", "1")
但doris的合并压力太大,还是产生了太多次streamload请求,收到报错。
detailMessage = current running txns on db 11341 is 1000, larger than limit 1000
Beta Was this translation helpful? Give feedback.
All reactions