使用Flink StarRocks connector 1.2.8 在看到如下逻辑时,有个疑问,假设作业的并行度是100,有99个subtask commit成功了,只有一个subtask的commit失败了,StarRocks是如何保证一个checkpoint中的数据的事务机制的, Flink 每次checkpoint与StarRocks 事务id什么关系?有没有事务相关的文章介绍?
谢谢!
看这个…
谢谢回复!
上面的文档提到的内容过于简单了,有没有带原理图或者架构图详细介绍
使用Flink StarRocks connector 1.2.8 在看到如下逻辑时,有个疑问,假设作业的并行度是100,有99个subtask commit成功了,只有一个subtask的commit失败了,StarRocks是如何保证一个checkpoint中的数据的事务机制的, Flink 每次checkpoint与StarRocks 事务id什么关系?有没有事务相关的文章介绍?
谢谢!
看这个…
谢谢回复!
上面的文档提到的内容过于简单了,有没有带原理图或者架构图详细介绍