Open
Conversation
Signed-off-by: PengFei Li <lpengfei2016@gmail.com>
- 新增ContainerAwareRedirectStrategy类处理容器环境重定向 - 修复StarRocks FE重定向到localhost/127.0.0.1时无法访问的问题 - 支持多BE节点的端口到主机名映射 - 添加完整的单元测试覆盖(5个测试用例) - 保持向后兼容性，不影响正常重定向流程 解决Issues: Docker环境中使用'load-url'='starrocks:8030'时连接127.0.0.1:8040失败 测试验证: 所有单元测试通过，编译检查通过 Signed-off-by: zhangzhefang <zhangzhefang@msn.cn>
zhangzhefang-github
force-pushed
the
analyze-v1.2.11
branch
from
da95581 to
f1e97f3
Compare
Author
|
Hi, all checks have passed. |
|
|
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.
What type of PR is this：
Which issues of this PR fixes ：
Fixes #438
Problem Summary(Required) ：
问题描述
在Docker环境中使用StarRocks Flink连接器时，当配置
'load-url' = 'starrocks:8030'时，StarRocks FE会将Stream Load请求重定向到127.0.0.1:8040（BE节点），但这个地址在容器间网络中无法访问，导致连接失败。触发场景
解决方案
主要修改
ContainerAwareRedirectStrategy.java- 核心重定向策略实现DefaultStreamLoader.java- 集成新的重定向策略TransactionStreamLoader.java- 集成新的重定向策略ContainerAwareRedirectStrategyTest.java- 完整的单元测试覆盖Checklist: