[feature][PES][datasource] implement starrocks task retry mechanism#5386
Merged
casionone merged 2 commits intoapache:dev-1.9.0from Mar 26, 2026
Merged
Conversation
- 引入ComputationEngineUtils工具类，提供向entrance发送消息的功能 - 添加配置项支持上下文语句和JDBC SET语句的错误索引调整 - 实现任务重试逻辑，支持JDBC和aiSQL类型的断点续跑 - 优化结果集别名数量管理，确保重试时状态正确恢复 - 新增TaskRetryInterceptor拦截器，动态为任务添加重试开关 - 增强错误处理机制，支持多种错误场景的正则匹配重试 - 修复任务重试时结果目录重复创建的问题 - 扩展ResponseTaskStatusWithExecuteCodeIndex协议，增加aliasNum字段 - 优化JDBC任务重试时的SQL索引调整逻辑，处理SET语句场景 - 增加StarRocks引擎类型支持和相关配置选项
aiceflower
changed the title
aiceflower
changed the title
aiceflower
changed the title
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
3 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Search before asking
Problem Description
StarRocks tasks lack retry mechanism for handling transient failures.
Description
Implement StarRocks task retry mechanism to automatically retry failed tasks.
Use case
When StarRocks tasks fail due to transient errors (network issues, temporary overload), the system can automatically retry instead of failing immediately.
Solutions
Implemented StarRocks task retry mechanism with configurable retry count and interval.
Anything else
None.
Are you willing to submit a PR?