[feat](doris-catalog) doris cross-cluster insert#60557
[feat](doris-catalog) doris cross-cluster insert#60557TsukiokaKogane wants to merge 7 commits intoapache:masterfrom
Conversation
|
Thank you for your contribution to Apache Doris. Please clearly describe your PR:
|
|
run buildall |
Cloud UT Coverage ReportIncrement line coverage Increment coverage report
|
TPC-H: Total hot run time: 31471 ms |
ClickBench: Total hot run time: 28.23 s |
BE UT Coverage ReportIncrement line coverage Increment coverage report
|
|
run buildall |
Cloud UT Coverage ReportIncrement line coverage Increment coverage report
|
FE UT Coverage ReportIncrement line coverage |
TPC-H: Total hot run time: 31323 ms |
ClickBench: Total hot run time: 28.66 s |
BE UT Coverage ReportIncrement line coverage Increment coverage report
|
BE Regression && UT Coverage ReportIncrement line coverage Increment coverage report
|
FE Regression Coverage ReportIncrement line coverage |
|
run buildall |
|
run buildall |
| // Remote transaction request and Result definitions for cross-cluster export. | ||
| // These structs are used by beginRemoteTxn/commitRemoteTxn/abortRemoteTxn RPCs. | ||
| struct TBeginRemoteTxnRequest { | ||
| 1: required string user |
There was a problem hiding this comment.
always use optional for all fields
| 1: required string user | ||
| 2: required string passwd | ||
| 3: optional string token | ||
| 4: required string db |
There was a problem hiding this comment.
better add catalog, even if currently only support "internal" catalog
| } catch (Exception e) { | ||
| long costMs = System.currentTimeMillis() - startTime; | ||
| LOG.warn("get master address for catalog {} failed, cost={}ms", name, costMs, e); | ||
| throw new RuntimeException(e.getMessage()); |
There was a problem hiding this comment.
| throw new RuntimeException(e.getMessage()); | |
| throw new RuntimeException(Util.getRootCause(e), e); |
Same suggestion for other places
| contains("VOlapScanNode") | ||
| } | ||
| sql """ | ||
| insert OVERWRITE table `${catalog_name}`.`${db_name}`.`test_remote_doris_all_types_insert` select /*+ SET_VAR(enable_nereids_distribute_planner=true, enable_sql_cache=true) */ * from `${catalog_name}`.`${db_name}`.`test_remote_doris_all_types_select_t` |
There was a problem hiding this comment.
What is the behavior of setting these variables?
Does it affect remote cluster?
There was a problem hiding this comment.
And why we set these 2 variables?
Cloud UT Coverage ReportIncrement line coverage Increment coverage report
|
What problem does this PR solve?
Issue Number: close #xxx
Related PR: #60295
Problem Summary:
Release note
None
Check List (For Author)
Test
Behavior changed:
Does this need documentation?
Check List (For Reviewer who merge this PR)