Skip to content

[computation-governance][computation-engineconn] implement starrocks task retry mechanism#956

Open
v-kkhuang wants to merge 1 commit intoapachemasterfrom
relaese-1.9.0-starrocks-sup-retry
Open

[computation-governance][computation-engineconn] implement starrocks task retry mechanism#956
v-kkhuang wants to merge 1 commit intoapachemasterfrom
relaese-1.9.0-starrocks-sup-retry

Conversation

@v-kkhuang
Copy link

What is the purpose of the change

This PR implements a retry mechanism for StarRocks tasks to improve task reliability and fault tolerance.

Related issues/PRs

Related issues: none
Related pr:none

Brief change log

  • Implement retry mechanism for StarRocks tasks
  • Update Configuration, ComputationExecutorConf
  • Update ComputationExecutor and TaskExecutionServiceImpl

Checklist

  • I have read the Contributing Guidelines on pull requests.
  • I have explained the need for this PR and the problem it solves
  • I have explained the changes or the new features added to this PR
  • I have added tests corresponding to this change
  • I have updated the documentation to reflect this change
  • I have verified that this change is backward compatible (If not, please discuss on the Linkis mailing list first)
  • If this is a code change: I have written unit tests to fully verify the new behavior.

- 引入ComputationEngineUtils工具类,提供向entrance发送消息的功能
- 添加配置项支持上下文语句和JDBC SET语句的错误索引调整
- 实现任务重试逻辑,支持JDBC和aiSQL类型的断点续跑
- 优化结果集别名数量管理,确保重试时状态正确恢复
- 新增TaskRetryInterceptor拦截器,动态为任务添加重试开关
- 增强错误处理机制,支持多种错误场景的正则匹配重试
- 修复任务重试时结果目录重复创建的问题
- 扩展ResponseTaskStatusWithExecuteCodeIndex协议,增加aliasNum字段
- 优化JDBC任务重试时的SQL索引调整逻辑,处理SET语句场景
- 增加StarRocks引擎类型支持和相关配置选项
@v-kkhuang v-kkhuang added the enhancement New feature or request label Mar 18, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

enhancement New feature or request

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant