【详述】be节点崩溃
【背景】flink实时stream load导入
【业务影响】数据导入失败
【StarRocks版本】3.0.3
【集群规模】例如：1fe+3be（fe与be分开部署）
【机器信息】be fe每台8C/32G，
【附件】
0）show backends报错信息
java.net.ConnectException: Connection refused (Connection refused)
1）be.out:
*** Aborted at 1691638144 (unix time) try “date -d @1691638144” if you are using GNU date ***
PC: @ 0x30dfcdb strings::memcpy_inlined()
*** SIGSEGV (@0x0) received by PID 18909 (TID 0x7f365f364700) from PID 0; stack trace: ***
@ 0x62e4042 google::(anonymous namespace)::FailureSignalHandler()
@ 0x7f36de222630 (unknown)
@ 0x30dfcdb strings::memcpy_inlined()
@ 0x46ed293 starrocks::ColumnVisitorMutableAdapter<>::visit()
@ 0x31d8c6c starrocks::ColumnFactory<>::accept_mutable()
@ 0x46ee0a8 starrocks::serde::ColumnArraySerde::deserialize()
@ 0x46ee2ed starrocks::ColumnVisitorMutableAdapter<>::visit()
@ 0x569ee0c starrocks::ColumnFactory<>::accept_mutable()
@ 0x46ee0a8 starrocks::serde::ColumnArraySerde::deserialize()
@ 0x59fd40d starrocks::serde::ProtobufChunkDeserializer::deserialize()
@ 0x4fc0055 starrocks::DataStreamRecvr::SenderQueue::deserialize_chunk()
@ 0x4fc3eba starrocks::DataStreamRecvr::PipelineSenderQueue::get_chunk()
@ 0x4f36843 starrocks::DataStreamRecvr::get_chunk_for_pipeline()
@ 0x33da4da starrocks::pipeline::ExchangeSourceOperator::pull_chunk()
@ 0x3111362 starrocks::pipeline::PipelineDriver::process()
@ 0x579287b starrocks::pipeline::GlobalDriverExecutor::worker_thread()
@ 0x50e93c2 starrocks::ThreadPool::dispatch_thread()
@ 0x50e3eba starrocks:
:supervise_thread()
@ 0x7f36de21aea5 start_thread
@ 0x7f36dd835b0d clone
@ 0x0 (unknown)
2）be.WARNING
W0810 17:27:11.222873 2913 tablet_updates.cpp:1245] wait_for_version slow(5045ms) version:2519.1 tablet:10513 #version:172 [2351.1 2519.1@171 2519.1] pending: rowsets:1[id/seg/row/del/byte/compaction]: [3067/1/6016416/0/51.57 MB/204.43 MB]
W0810 17:27:11.567271 2637 fragment_context.cpp:123] [Driver] Canceled, query_id=13055aec-3760-11ee-bfe4-fa163e5ed54d, instance_id=13055aec-3760-11ee-bfe4-fa163e5ed54e, reason=InternalError
W0810 17:27:11.567389 2655 pipeline_driver.cpp:597] fragment_id 13055aec-3760-11ee-bfe4-fa163e5ed54e driver query_id=13055aec-3760-11ee-bfe4-fa163e5ed54d fragment_id=13055aec-3760-11ee-bfe4-fa163e5ed54e driver=0x7f9b79d0af90, status=PRECONDITION_BLOCK, operator-chain: [local_exchange_source-100_0x7f9c0168b710(X) -> hash_join_probe_75_0x7f9b79bf0f90(X)(HashJoiner=0x7f9bc8259810) -> chunk_accumulate_75_0x7f9b79d08c90(X) -> project_76_0x7f9b79d09910(X) -> local_sort_sink_77_0x7f9b79d0a310(X)] cancels operator local_sort_sink_77_0x7f9b79d0a310(X) with finished error runtime state is cancelled
W0810 17:27:11.567430 2655 pipeline_driver.cpp:597] fragment_id 13055aec-3760-11ee-bfe4-fa163e5ed54e driver query_id=13055aec-3760-11ee-bfe4-fa163e5ed54d fragment_id=13055aec-3760-11ee-bfe4-fa163e5ed54e driver=0x7f9b7a934310, status=PRECONDITION_BLOCK, operator-chain: [local_exchange_source-100_0x7f9bdc6c6e10(X) -> hash_join_probe_75_0x7f9b79d0bc10(X)(HashJoiner=0x7f9bc8693690) -> chunk_accumulate_75_0x7f9b79d0c890(X) -> project_76_0x7f9b7a932290(X) -> local_sort_sink_77_0x7f9b7a933190(X)] cancels operator local_sort_sink_77_0x7f9b7a933190(X) with finished error runtime state is cancelled
W0810 17:27:11.567443 2655 pipeline_driver.cpp:597] fragment_id 13055aec-3760-11ee-bfe4-fa163e5ed54e driver query_id=13055aec-3760-11ee-bfe4-fa163e5ed54d fragment_id=13055aec-3760-11ee-bfe4-fa163e5ed54e driver=0x7f9b7b414f10, status=PRECONDITION_BLOCK, operator-chain: [local_exchange_source-100_0x7f9bdc6c7190(X) -> hash_join_probe_75_0x7f9b7a934f90(X)(HashJoiner=0x7f9bc88d0c90) -> chunk_accumulate_75_0x7f9b7a935c10(X) -> project_76_0x7f9b7a936890(X) -> local_sort_sink_77_0x7f9b7b414290(X)] cancels operator local_sort_sink_77_0x7f9b7b414290(X) with finished error runtime state is cancelled
W0810 17:27:11.567457 2655 pipeline_driver.cpp:597] fragment_id 13055aec-3760-11ee-bfe4-fa163e5ed54e driver query_id=13055aec-3760-11ee-bfe4-fa163e5ed54d fragment_id=13055aec-3760-11ee-bfe4-fa163e5ed54e driver=0x7f9b7b500510, status=PRECONDITION_BLOCK, operator-chain: [local_exchange_source-100_0x7f9bdc706910(X) -> hash_join_probe_75_0x7f9b7b416310(X)(HashJoiner=0x7f9bc94df090) -> chunk_accumulate_75_0x7f9b7b417490(X) -> project_76_0x7f9b7b417e90(X) -> local_sort_sink_77_0x7f9b7b418b10(X)] cancels operator local_sort_sink_77_0x7f9b7b418b10(X) with finished error runtime state is cancelled
W0810 17:27:11.570050 2642 fragment_context.cpp:123] [Driver] Canceled, query_id=13055aec-3760-11ee-bfe4-fa163e5ed54d, instance_id=13055aec-3760-11ee-bfe4-fa163e5ed552, reason=InternalError
W0810 17:27:11.570087 2638 fragment_context.cpp:123] [Driver] Canceled, query_id=13055aec-3760-11ee-bfe4-fa163e5ed54d, instance_id=13055aec-3760-11ee-bfe4-fa163e5ed555, reason=InternalError
W0810 17:27:11.570120 2636 fragment_context.cpp:123] [Driver] Canceled, query_id=13055aec-3760-11ee-bfe4-fa163e5ed54d, instance_id=13055aec-3760-11ee-bfe4-fa163e5ed557, reason=InternalError
W0810 17:27:11.573426 2639 fragment_context.cpp:123] [Driver] Canceled, query_id=13055aec-3760-11ee-bfe4-fa163e5ed54d, instance_id=13055aec-3760-11ee-bfe4-fa163e5ed55a, reason=InternalError
W0810 17:27:11.576058 2643 fragment_context.cpp:123] [Driver] Canceled, query_id=13055aec-3760-11ee-bfe4-fa163e5ed54d, instance_id=13055aec-3760-11ee-bfe4-fa163e5ed55e, reason=InternalError
W0810 17:27:11.578809 2640 fragment_context.cpp:123] [Driver] Canceled, query_id=13055aec-3760-11ee-bfe4-fa163e5ed54d, instance_id=13055aec-3760-11ee-bfe4-fa163e5ed561, reason=InternalError
W0810 17:27:11.581440 2641 fragment_context.cpp:123] [Driver] Canceled, query_id=13055aec-3760-11ee-bfe4-fa163e5ed54d, instance_id=13055aec-3760-11ee-bfe4-fa163e5ed564, reason=InternalError
W0810 17:27:11.583712 2637 fragment_context.cpp:123] [Driver] Canceled, query_id=13055aec-3760-11ee-bfe4-fa163e5ed54d, instance_id=13055aec-3760-11ee-bfe4-fa163e5ed567, reason=InternalError
W0810 17:27:11.558677 2894 input_messenger.cpp:226] Fail to read from Socket{id=8589935965 fd=740 addr=10.2.111.40:59842:8060} (0x7f9a2d974340): Connection reset by peer [104]
W0810 17:27:11.558645 2892 input_messenger.cpp:226] Fail to read from Socket{id=678 fd=736 addr=10.2.111.40:8060:39596} (0x7f9bdcd50080): Connection reset by peer [104]
W0810 17:27:12.153731 2895 disposable_closure.h:50] brpc failed, error=Host is down, error_text=[E104]Fail to read from Socket{id=678 fd=736 addr=10.2.111.40:8060:39596} (0x0x7f9bdcd50080): Connection reset by peer [R1][E112]Not connected to 10.2.111.40:8060 yet, server_id=678 [R2][E112]Not connected to 10.2.111.40:8060 yet, server_id=678 [R3][E112]Not connected to 10.2.111.40:8060 yet, server_id=678
W0810 17:27:12.153781 2895 sink_buffer.cpp:342] transmit chunk rpc failed:1474544b-3760-11ee-bfe4-fa163e5ed56f
W0810 17:27:12.153738 2892 disposable_closure.h:50] brpc failed, error=Host is down, error_text=[E104]Fail to read from Socket{id=678 fd=736 addr=10.2.111.40:8060:39596} (0x0x7f9bdcd50080): Connection reset by peer [R1][E112]Not connected to 10.2.111.40:8060 yet, server_id=678 [R2][E112]Not connected to 10.2.111.40:8060 yet, server_id=678 [R3][E112]Not connected to 10.2.111.40:8060 yet, server_id=678
W0810 17:27:12.153860 2892 sink_buffer.cpp:342] transmit chunk rpc failed:13055aec-3760-11ee-bfe4-fa163e5ed565
W0810 17:27:12.153760 2894 disposable_closure.h:50] brpc failed, error=Host is down, error_text=[E104]Fail to read from Socket{id=678 fd=736 addr=10.2.111.40:8060:39596} (0x0x7f9bdcd50080): Connection reset by peer [R1][E112]Not connected to 10.2.111.40:8060 yet, server_id=678 [R2][E112]Not connected to 10.2.111.40:8060 yet, server_id=678 [R3][E112]Not connected to 10.2.111.40:8060 yet, server_id=678
W0810 17:27:12.153887 2894 sink_buffer.cpp:342] transmit chunk rpc failed:13055aec-3760-11ee-bfe4-fa163e5ed565
W0810 17:27:12.158380 2642 fragment_context.cpp:123] [Driver] Canceled, query_id=1474544b-3760-11ee-bfe4-fa163e5ed54d, instance_id=1474544b-3760-11ee-bfe4-fa163e5ed581, reason=InternalError
W0810 17:27:12.159818 2637 fragment_context.cpp:123] [Driver] Canceled, query_id=1474544b-3760-11ee-bfe4-fa163e5ed54d, instance_id=1474544b-3760-11ee-bfe4-fa163e5ed55d, reason=InternalError
W0810 17:27:12.159875 2637 fragment_context.cpp:123] [Driver] Canceled, query_id=1474544b-3760-11ee-bfe4-fa163e5ed54d, instance_id=1474544b-3760-11ee-bfe4-fa163e5ed56b, reason=InternalError
W0810 17:27:12.163959 2643 fragment_context.cpp:123] [Driver] Canceled, query_id=1474544b-3760-11ee-bfe4-fa163e5ed54d, instance_id=1474544b-3760-11ee-bfe4-fa163e5ed56e, reason=InternalError
您好 这个是稳定复现的吗 一启动stream load任务就会失败？
目前有stream load任务和一些查询任务，目前一段be运行一段时间后就报这个错
目前我们把stream load任务关了后，观察了一段时间，发现还是报相同的错误，应该是一些查询任务导致的be崩溃
目前排查下来是这个sql导致的be崩溃：
select temp.source_header_num,
temp.source_line_num,
(select count() > 0
from sinv_rcv_trx_line srtl33
join sinv_rcv_trx_header srth33 on srtl33.rcv_trx_header_id = srth33.rcv_trx_header_id
JOIN sinv_rcv_trx_order_link srto33 ON srtl33.order_link_id = srto33.order_link_id
JOIN sinv_rcv_record_strategy_mapping srrsm33
ON srrsm33.rcv_trx_header_id = srtl33.rcv_trx_header_id and
srrsm33.rcv_trx_line_id = srtl33.rcv_trx_line_id and srrsm33.master_flag = 1
left JOIN sinv_rcv_strategy_line srsl33 ON srrsm33.strategy_line_id = srsl33.strategy_line_id
left join sinv_rcv_trx_line srtl44 on srtl33.from_rcv_trx_line_id = srtl44.rcv_trx_line_id
where srtl33.tenant_id = 30
and srtl33.tenant_id = srto33.tenant_id
and srtl33.delete_flag = 0
and srtl33.reverse_flag = 0
and srsl33.node_config_id in (12981, 12984, 12983, 12985, 12986, 12982, 13781)
and (srtl44.complete_flag = 0 or (srtl33.complete_flag = 0 and srrsm33.next_strategy_line_id is not null) or
(srtl33.complete_flag = 0 and srrsm33.next_strategy_line_id is null and
srth33.rcv_status_code != ‘40_FINISHED’))
and srto33.source_header_num = temp.source_header_num
and srto33.source_line_num = temp.source_line_num) take_doing,
(select count() <= 0
from sinv_rcv_trx_line srtl33
join sinv_rcv_trx_header srth33 on srtl33.rcv_trx_header_id = srth33.rcv_trx_header_id JOIN sinv_rcv_trx_order_link srto33
ON srtl33.order_link_id = srto33.order_link_id JOIN sinv_rcv_record_strategy_mapping srrsm33 ON srrsm33.rcv_trx_header_id = srtl33.rcv_trx_header_id and srrsm33.rcv_trx_line_id=srtl33.rcv_trx_line_id and srrsm33.master_flag=1 left JOIN sinv_rcv_strategy_line srsl33 ON srrsm33.strategy_line_id = srsl33.strategy_line_id
where srtl33.tenant_id = 30
and srtl33.tenant_id = srto33.tenant_id
and srtl33.delete_flag = 0
and srtl33.reverse_flag = 0
and srsl33.node_config_id in ( 12981
, 12984
, 12983
, 12985
, 12986
, 12982
, 13781 )
and exists ( select 1 from sinv_rcv_trx_line srtl44 where srtl33.from_rcv_trx_line_id=srtl44.rcv_trx_line_id
and srtl44.complete_flag=0 )
and srto33.source_header_num = temp.source_header_num
and srto33.source_line_num = temp.source_line_num) take_finished,
(select count(*) <= 0
from sinv_rcv_trx_line srtl33
join sinv_rcv_trx_header srth33 on srtl33.rcv_trx_header_id = srth33.rcv_trx_header_id
JOIN sinv_rcv_trx_order_link srto33 ON srtl33.order_link_id = srto33.order_link_id
JOIN sinv_rcv_record_strategy_mapping srrsm33
ON srrsm33.rcv_trx_header_id = srtl33.rcv_trx_header_id and
srrsm33.rcv_trx_line_id = srtl33.rcv_trx_line_id and srrsm33.master_flag = 1
left JOIN sinv_rcv_strategy_line srsl33 ON srrsm33.strategy_line_id = srsl33.strategy_line_id
where srtl33.tenant_id = 30
and srtl33.tenant_id = srto33.tenant_id
and srtl33.delete_flag = 0
and srtl33.reverse_flag = 0
and srsl33.node_config_id in
(12981, 12982, 12983, 12984, 12985, 12986, 14277, 14278, 14753, 14754, 14755, 14756, 14757, 14758)
and exists(select 1
from sinv_rcv_trx_line srtl44
where srtl33.from_rcv_trx_line_id = srtl44.rcv_trx_line_id
and srtl44.complete_flag = 0)
and srto33.source_header_num = temp.source_header_num
and srto33.source_line_num = temp.source_line_num) all_take_finished
from (select ‘20230616004-1’ as source_header_num, ‘20’ as source_line_num
from dual
union all
select ‘PO20230711000003’ as source_header_num, ‘1’ as source_line_num
from dual
union all
select ‘PO20230711000009’ as source_header_num, ‘1’ as source_line_num
from dual) as temp;
CREATE TABLE sinv_rcv_trx_line (
rcv_trx_line_id bigint(20) NOT NULL COMMENT “”,
rcv_trx_header_id bigint(20) NULL COMMENT “采购事务头ID”,
tenant_id bigint(20) NULL COMMENT “租户ID,hpfm_tenant.tenant_id”,
supplier_tenant_id bigint(20) NULL COMMENT “供应商租户ID”,
trx_line_num int(11) NULL COMMENT “事务行号”,
display_trx_line_num varchar(65533) NULL COMMENT “事务展示行号”,
trx_date datetime NULL COMMENT “事务日期”,
trx_year int(11) NULL COMMENT “事务年份”,
rcv_trx_type_id bigint(20) NULL COMMENT “接收事务类型ID”,
move_reason varchar(65533) NULL COMMENT “移动原因说明”,
quantity decimal128(38, 10) NULL COMMENT “事务数量”,
stock_type varchar(65533) NULL COMMENT “库存类型（寄售 CONSIGNMENT、自有 OWN_STOCK）sinv.rcv_trx_stock_type”,
currency_code varchar(65533) NULL COMMENT “币种代码”,
period_name varchar(65533) NULL COMMENT “期间名称”,
net_price decimal128(38, 10) NULL COMMENT “不含税单价”,
tax_included_price decimal128(38, 10) NULL COMMENT “含税单价”,
po_unit_price decimal128(38, 10) NULL COMMENT “订单单价”,
net_amount decimal128(38, 10) NULL COMMENT “不含税金额”,
tax_included_amount decimal128(38, 10) NULL COMMENT “含税金额”,
tax_id bigint(20) NULL COMMENT “税率ID”,
tax_rate decimal128(38, 10) NULL COMMENT “”,
item_id bigint(20) NULL COMMENT “物料ID”,
item_code varchar(65533) NULL COMMENT “物料代码”,
item_name varchar(65533) NULL COMMENT “”,
category_id bigint(20) NULL COMMENT “物料类别ID”,
uom_id bigint(20) NULL COMMENT “单位ID”,
company_id bigint(20) NULL COMMENT “所属公司ID”,
company_name varchar(65533) NULL COMMENT “所属公司描述”,
ou_id bigint(20) NULL COMMENT “所属业务实体ID”,
pur_organization_id bigint(20) NULL COMMENT “采购组织ID”,
inv_organization_id bigint(20) NULL COMMENT “收货组织ID”,
inventory_id bigint(20) NULL COMMENT “收货库房ID”,
locator_id bigint(20) NULL COMMENT “收货库位ID”,
supplier_id bigint(20) NULL COMMENT “供应商ID”,
supplier_num varchar(65533) NULL COMMENT “供应商代码”,
supplier_name varchar(65533) NULL COMMENT “供应商名称”,
supplier_site_id bigint(20) NULL COMMENT “供应商地点ID”,
supplier_company_id bigint(20) NULL COMMENT “供应商公司ID”,
supplier_company_name varchar(65533) NULL COMMENT “供应商公司描述”,
supplier_ou_id bigint(20) NULL COMMENT “合作方业务实体ID”,
entered_trx_price decimal128(38, 10) NULL COMMENT “本币单价”,
entered_trx_amount decimal128(38, 10) NULL COMMENT “本币金额”,
entered_currency_code varchar(65533) NULL COMMENT “本币币种代码”,
rate_type varchar(65533) NULL COMMENT “汇率类型”,
exchange_rate_date date NULL COMMENT “汇率日期”,
exchange_rate decimal128(38, 10) NULL COMMENT “汇率”,
lot_num varchar(65533) NULL COMMENT “批次号”,
serial_num varchar(65533) NULL COMMENT “序列号”,
parent_trx_line_id bigint(20) NULL COMMENT “父事务行ID”,
from_po_header_id bigint(20) NULL COMMENT “来源采购订单头ID”,
from_po_line_id bigint(20) NULL COMMENT “来源采购订单行ID”,
from_po_line_location_id bigint(20) NULL COMMENT “来源采购订单发运行ID”,
from_po_distribution_id bigint(20) NULL COMMENT “来源采购订单分配行ID”,
from_asn_header_id bigint(20) NULL COMMENT “来源送货单头ID”,
from_asn_line_id bigint(20) NULL COMMENT “来源送货单行ID”,
terms_id bigint(20) NULL COMMENT “付款条款ID”,
reverse_flag tinyint(4) NULL COMMENT “反冲标识”,
reverse_trx_line_id bigint(20) NULL COMMENT “反冲事务行ID”,
need_invoice_flag tinyint(4) NULL COMMENT “需要开票标识”,
invoice_closed_flag tinyint(4) NULL COMMENT “发票关闭标识”,
invoice_matched_status varchar(65533) NULL COMMENT “发票匹配状态 sinv.rcv_trx_invoice_matching_status(UNINVOICED,PART_INVOICED,INVOICE_COMPLETE)”,
invoiced_quantity decimal128(38, 10) NULL COMMENT “已开发票数量”,
bill_matched_flag tinyint(4) NULL COMMENT “匹配账单标识”,
matched_bill_detail_id bigint(20) NULL COMMENT “匹配账单明细行ID”,
matched_bill_num varchar(65533) NULL COMMENT “匹配账单编号”,
trx_source_type_id bigint(20) NULL COMMENT “事务来源单据类型id”,
trx_source_line_id bigint(20) NULL COMMENT “事务来源行ID”,
erp_parent_convert_flag tinyint(4) NULL COMMENT “ERP父事务转换标识”,
erp_parent_trx_line_id varchar(65533) NULL COMMENT “ERP父事务行ID”,
erp_parent_trx_num varchar(65533) NULL COMMENT “ERP父事务编号”,
erp_parent_trx_line_num varchar(65533) NULL COMMENT “ERP父事务行编号”,
erp_parent_trx_year int(11) NULL COMMENT “ERP父事务年份”,
erp_source_trx_num varchar(65533) NULL COMMENT “erp源事务号”,
erp_source_trx_line_id varchar(65533) NULL COMMENT “erp源事务行ID”,
erp_source_trx_line_num varchar(65533) NULL COMMENT “erp源事务行编号”,
erp_source_trx_year int(11) NULL COMMENT “erp源事务年份”,
erp_creation_date datetime NULL COMMENT “erp创建日期”,
erp_last_update_date datetime NULL COMMENT “erp最后更新日期”,
remark varchar(65533) NULL COMMENT “备注说明”,
enabled_flag tinyint(4) NULL COMMENT “启用标识”,
start_date date NULL COMMENT “有效期从”,
end_date date NULL COMMENT “有效期至”,
order_seq int(11) NULL COMMENT “排序号”,
object_version_number bigint(20) NULL COMMENT “行版本号，用来处理锁”,
created_by bigint(20) NULL COMMENT “”,
creation_date datetime NULL COMMENT “”,
last_updated_by bigint(20) NULL COMMENT “”,
last_update_date datetime NULL COMMENT “”,
output_stock_flag tinyint(4) NULL COMMENT “备库出库标识”,
billing_date datetime NULL COMMENT “可对账日期”,
agent_id bigint(20) NULL COMMENT “采购员ID”,
invoice_reviewed_status varchar(65533) NULL COMMENT “发票复核状态 sinv.rcv_trx_invoice_review_status(UNREVIEW,PART_REVIEWED,REVIEWED)”,
invoiced_reviewed_quantity decimal128(38, 10) NULL COMMENT “发票复核数量”,
full_reversed_flag tinyint(4) NULL COMMENT “全部冲销标记”,
es_close_flag tinyint(4) NULL COMMENT “外部系统关闭标识 (菲尼克斯项目)”,
attribute_varchar1 varchar(65533) NULL COMMENT “字符扩展字段1”,
attribute_varchar2 varchar(65533) NULL COMMENT “字符扩展字段2”,
attribute_varchar3 varchar(65533) NULL COMMENT “字符扩展字段3”,
attribute_varchar4 varchar(65533) NULL COMMENT “字符扩展字段4”,
attribute_varchar5 varchar(65533) NULL COMMENT “字符扩展字段5”,
attribute_varchar6 varchar(65533) NULL COMMENT “字符扩展字段6”,
attribute_varchar7 varchar(65533) NULL COMMENT “字符扩展字段7”,
attribute_varchar8 varchar(65533) NULL COMMENT “字符扩展字段8”,
attribute_varchar9 varchar(65533) NULL COMMENT “字符扩展字段9”,
attribute_varchar10 varchar(65533) NULL COMMENT “字符扩展字段10”,
attribute_varchar11 varchar(65533) NULL COMMENT “字符扩展字段11”,
attribute_varchar12 varchar(65533) NULL COMMENT “字符扩展字段12”,
attribute_varchar13 varchar(65533) NULL COMMENT “字符扩展字段13”,
attribute_varchar14 varchar(65533) NULL COMMENT “字符扩展字段14”,
attribute_varchar15 varchar(65533) NULL COMMENT “字符扩展字段15”,
attribute_varchar16 varchar(65533) NULL COMMENT “字符扩展字段16”,
attribute_varchar17 varchar(65533) NULL COMMENT “字符扩展字段17”,
attribute_varchar18 varchar(65533) NULL COMMENT “字符扩展字段18”,
attribute_varchar19 varchar(65533) NULL COMMENT “字符扩展字段19”,
attribute_varchar20 varchar(65533) NULL COMMENT “字符扩展字段20”,
attribute_varchar21 varchar(65533) NULL COMMENT “字符扩展字段21”,
attribute_varchar22 varchar(65533) NULL COMMENT “字符扩展字段22”,
attribute_varchar23 varchar(65533) NULL COMMENT “字符扩展字段23”,
attribute_varchar24 varchar(65533) NULL COMMENT “字符扩展字段24”,
attribute_varchar25 varchar(65533) NULL COMMENT “字符扩展字段25”,
attribute_varchar26 varchar(65533) NULL COMMENT “字符扩展字段26”,
attribute_varchar27 varchar(65533) NULL COMMENT “字符扩展字段27”,
attribute_varchar28 varchar(65533) NULL COMMENT “字符扩展字段28”,
attribute_varchar29 varchar(65533) NULL COMMENT “字符扩展字段29”,
attribute_varchar30 varchar(65533) NULL COMMENT “字符扩展字段30”,
attribute_varchar31 varchar(65533) NULL COMMENT “字符扩展字段31”,
attribute_varchar32 varchar(65533) NULL COMMENT “字符扩展字段32”,
attribute_varchar33 varchar(65533) NULL COMMENT “字符扩展字段33”,
attribute_varchar34 varchar(65533) NULL COMMENT “字符扩展字段34”,
attribute_varchar35 varchar(65533) NULL COMMENT “字符扩展字段35”,
attribute_varchar36 varchar(65533) NULL COMMENT “字符扩展字段36”,
attribute_varchar37 varchar(65533) NULL COMMENT “字符扩展字段37”,
attribute_varchar38 varchar(65533) NULL COMMENT “字符扩展字段38”,
attribute_varchar39 varchar(65533) NULL COMMENT “字符扩展字段39”,
attribute_varchar40 varchar(65533) NULL COMMENT “字符扩展字段40”,
attribute_longtext1 varchar(65533) NULL COMMENT “长字符扩展字段1”,
attribute_longtext2 varchar(65533) NULL COMMENT “长字符扩展字段2”,
attribute_longtext3 varchar(65533) NULL COMMENT “长字符扩展字段3”,
attribute_longtext4 varchar(65533) NULL COMMENT “长字符扩展字段4”,
attribute_longtext5 varchar(65533) NULL COMMENT “长字符扩展字段5”,
attribute_longtext6 varchar(65533) NULL COMMENT “长字符扩展字段6”,
attribute_longtext7 varchar(65533) NULL COMMENT “长字符扩展字段7”,
attribute_longtext8 varchar(65533) NULL COMMENT “长字符扩展字段8”,
attribute_longtext9 varchar(65533) NULL COMMENT “长字符扩展字段9”,
attribute_longtext10 varchar(65533) NULL COMMENT “长字符扩展字段10”,
attribute_bigint1 bigint(20) NULL COMMENT “整数扩展字段1”,
attribute_bigint2 bigint(20) NULL COMMENT “整数扩展字段2”,
attribute_bigint3 bigint(20) NULL COMMENT “整数扩展字段3”,
attribute_bigint4 bigint(20) NULL COMMENT “整数扩展字段4”,
attribute_bigint5 bigint(20) NULL COMMENT “整数扩展字段5”,
attribute_bigint6 bigint(20) NULL COMMENT “整数扩展字段6”,
attribute_bigint7 bigint(20) NULL COMMENT “整数扩展字段7”,
attribute_bigint8 bigint(20) NULL COMMENT “整数扩展字段8”,
attribute_bigint9 bigint(20) NULL COMMENT “整数扩展字段9”,
attribute_bigint10 bigint(20) NULL COMMENT “整数扩展字段10”,
attribute_bigint11 bigint(20) NULL COMMENT “整数扩展字段11”,
attribute_bigint12 bigint(20) NULL COMMENT “整数扩展字段12”,
attribute_bigint13 bigint(20) NULL COMMENT “整数扩展字段13”,
attribute_bigint14 bigint(20) NULL COMMENT “整数扩展字段14”,
attribute_bigint15 bigint(20) NULL COMMENT “整数扩展字段15”,
attribute_bigint16 bigint(20) NULL COMMENT “整数扩展字段16”,
attribute_bigint17 bigint(20) NULL COMMENT “整数扩展字段17”,
attribute_bigint18 bigint(20) NULL COMMENT “整数扩展字段18”,
attribute_bigint19 bigint(20) NULL COMMENT “整数扩展字段19”,
attribute_bigint20 bigint(20) NULL COMMENT “整数扩展字段20”,
attribute_bigint21 bigint(20) NULL COMMENT “整数扩展字段21”,
attribute_bigint22 bigint(20) NULL COMMENT “整数扩展字段22”,
attribute_bigint23 bigint(20) NULL COMMENT “整数扩展字段23”,
attribute_bigint24 bigint(20) NULL COMMENT “整数扩展字段24”,
attribute_bigint25 bigint(20) NULL COMMENT “整数扩展字段25”,
attribute_bigint26 bigint(20) NULL COMMENT “整数扩展字段26”,
attribute_bigint27 bigint(20) NULL COMMENT “整数扩展字段27”,
attribute_bigint28 bigint(20) NULL COMMENT “整数扩展字段28”,
attribute_bigint29 bigint(20) NULL COMMENT “整数扩展字段29”,
attribute_bigint30 bigint(20) NULL COMMENT “整数扩展字段30”,
attribute_tinyint1 tinyint(4) NULL COMMENT “小整数扩展字段1”,
attribute_tinyint2 tinyint(4) NULL COMMENT “小整数扩展字段2”,
attribute_tinyint3 tinyint(4) NULL COMMENT “小整数扩展字段3”,
attribute_tinyint4 tinyint(4) NULL COMMENT “小整数扩展字段4”,
attribute_tinyint5 tinyint(4) NULL COMMENT “小整数扩展字段5”,
attribute_tinyint6 tinyint(4) NULL COMMENT “小整数扩展字段6”,
attribute_tinyint7 tinyint(4) NULL COMMENT “小整数扩展字段7”,
attribute_tinyint8 tinyint(4) NULL COMMENT “小整数扩展字段8”,
attribute_tinyint9 tinyint(4) NULL COMMENT “小整数扩展字段9”,
attribute_tinyint10 tinyint(4) NULL COMMENT “小整数扩展字段10”,
attribute_tinyint11 tinyint(4) NULL COMMENT “小整数扩展字段11”,
attribute_tinyint12 tinyint(4) NULL COMMENT “小整数扩展字段12”,
attribute_tinyint13 tinyint(4) NULL COMMENT “小整数扩展字段13”,
attribute_tinyint14 tinyint(4) NULL COMMENT “小整数扩展字段14”,
attribute_tinyint15 tinyint(4) NULL COMMENT “小整数扩展字段15”,
attribute_tinyint16 tinyint(4) NULL COMMENT “小整数扩展字段16”,
attribute_tinyint17 tinyint(4) NULL COMMENT “小整数扩展字段17”,
attribute_tinyint18 tinyint(4) NULL COMMENT “小整数扩展字段18”,
attribute_tinyint19 tinyint(4) NULL COMMENT “小整数扩展字段19”,
attribute_tinyint20 tinyint(4) NULL COMMENT “小整数扩展字段20”,
attribute_decimal1 decimal128(38, 10) NULL COMMENT “小数扩展字段1”,
attribute_decimal2 decimal128(38, 10) NULL COMMENT “小数扩展字段2”,
attribute_decimal3 decimal128(38, 10) NULL COMMENT “小数扩展字段3”,
attribute_decimal4 decimal128(38, 10) NULL COMMENT “小数扩展字段4”,
attribute_decimal5 decimal128(38, 10) NULL COMMENT “小数扩展字段5”,
attribute_decimal6 decimal128(38, 10) NULL COMMENT “小数扩展字段6”,
attribute_decimal7 decimal128(38, 10) NULL COMMENT “小数扩展字段7”,
attribute_decimal8 decimal128(38, 10) NULL COMMENT “小数扩展字段8”,
attribute_decimal9 decimal128(38, 10) NULL COMMENT “小数扩展字段9”,
attribute_decimal10 decimal128(38, 10) NULL COMMENT “小数扩展字段10”,
attribute_decimal11 decimal128(38, 10) NULL COMMENT “小数扩展字段11”,
attribute_decimal12 decimal128(38, 10) NULL COMMENT “小数扩展字段12”,
attribute_decimal13 decimal128(38, 10) NULL COMMENT “小数扩展字段13”,
attribute_decimal14 decimal128(38, 10) NULL COMMENT “小数扩展字段14”,
attribute_decimal15 decimal128(38, 10) NULL COMMENT “小数扩展字段15”,
attribute_decimal16 decimal128(38, 10) NULL COMMENT “小数扩展字段16”,
attribute_decimal17 decimal128(38, 10) NULL COMMENT “小数扩展字段17”,
attribute_decimal18 decimal128(38, 10) NULL COMMENT “小数扩展字段18”,
attribute_decimal19 decimal128(38, 10) NULL COMMENT “小数扩展字段19”,
attribute_decimal20 decimal128(38, 10) NULL COMMENT “小数扩展字段20”,
attribute_decimal21 decimal128(38, 10) NULL COMMENT “小数扩展字段21”,
attribute_decimal22 decimal128(38, 10) NULL COMMENT “小数扩展字段22”,
attribute_decimal23 decimal128(38, 10) NULL COMMENT “小数扩展字段23”,
attribute_decimal24 decimal128(38, 10) NULL COMMENT “小数扩展字段24”,
attribute_decimal25 decimal128(38, 10) NULL COMMENT “小数扩展字段25”,
attribute_decimal26 decimal128(38, 10) NULL COMMENT “小数扩展字段26”,
attribute_decimal27 decimal128(38, 10) NULL COMMENT “小数扩展字段27”,
attribute_decimal28 decimal128(38, 10) NULL COMMENT “小数扩展字段28”,
attribute_decimal29 decimal128(38, 10) NULL COMMENT “小数扩展字段29”,
attribute_decimal30 decimal128(38, 10) NULL COMMENT “小数扩展字段30”,
attribute_datetime1 datetime NULL COMMENT “日期时间扩展字段1”,
attribute_datetime2 datetime NULL COMMENT “日期时间扩展字段2”,
attribute_datetime3 datetime NULL COMMENT “日期时间扩展字段3”,
attribute_datetime4 datetime NULL COMMENT “日期时间扩展字段4”,
attribute_datetime5 datetime NULL COMMENT “日期时间扩展字段5”,
attribute_datetime6 datetime NULL COMMENT “日期时间扩展字段6”,
attribute_datetime7 datetime NULL COMMENT “日期时间扩展字段7”,
attribute_datetime8 datetime NULL COMMENT “日期时间扩展字段8”,
attribute_datetime9 datetime NULL COMMENT “日期时间扩展字段9”,
attribute_datetime10 datetime NULL COMMENT “日期时间扩展字段10”,
attribute_datetime11 datetime NULL COMMENT “日期时间扩展字段11”,
attribute_datetime12 datetime NULL COMMENT “日期时间扩展字段12”,
attribute_datetime13 datetime NULL COMMENT “日期时间扩展字段13”,
attribute_datetime14 datetime NULL COMMENT “日期时间扩展字段14”,
attribute_datetime15 datetime NULL COMMENT “日期时间扩展字段15”,
attribute_datetime16 datetime NULL COMMENT “日期时间扩展字段16”,
attribute_datetime17 datetime NULL COMMENT “日期时间扩展字段17”,
attribute_datetime18 datetime NULL COMMENT “日期时间扩展字段18”,
attribute_datetime19 datetime NULL COMMENT “日期时间扩展字段19”,
attribute_datetime20 datetime NULL COMMENT “日期时间扩展字段20”,
attribute_date1 date NULL COMMENT “日期扩展字段1”,
attribute_date2 date NULL COMMENT “日期扩展字段2”,
attribute_date3 date NULL COMMENT “日期扩展字段3”,
attribute_date4 date NULL COMMENT “日期扩展字段4”,
attribute_date5 date NULL COMMENT “日期扩展字段5”,
attribute_date6 date NULL COMMENT “日期扩展字段6”,
attribute_date7 date NULL COMMENT “日期扩展字段7”,
attribute_date8 date NULL COMMENT “日期扩展字段8”,
attribute_date9 date NULL COMMENT “日期扩展字段9”,
attribute_date10 date NULL COMMENT “日期扩展字段10”,
attribute_date11 date NULL COMMENT “日期扩展字段11”,
attribute_date12 date NULL COMMENT “日期扩展字段12”,
attribute_date13 date NULL COMMENT “日期扩展字段13”,
attribute_date14 date NULL COMMENT “日期扩展字段14”,
attribute_date15 date NULL COMMENT “日期扩展字段15”,
attribute_date16 date NULL COMMENT “日期扩展字段16”,
attribute_date17 date NULL COMMENT “日期扩展字段17”,
attribute_date18 date NULL COMMENT “日期扩展字段18”,
attribute_date19 date NULL COMMENT “日期扩展字段19”,
attribute_date20 date NULL COMMENT “日期扩展字段20”,
reality_receive_date datetime NULL COMMENT "实际接收日期 ",
from_order_flag tinyint(4) NULL COMMENT “是否基于订单接收标识”,
order_link_id bigint(20) NULL COMMENT “事务行和单据映射表”,
from_rcv_trx_line_id bigint(20) NULL COMMENT “来源事务行id”,
occupied_quantity decimal128(38, 10) NULL COMMENT “占用数量”,
secondary_occupied_quantity decimal128(38, 10) NULL COMMENT “辅助占用数量”,
complete_flag tinyint(4) NULL COMMENT “是否执行完毕”,
reversed_quantity decimal128(38, 10) NULL COMMENT “冲销数量”,
secondary_reversed_quantity decimal128(38, 10) NULL COMMENT “辅助冲销数量”,
sinv_line_attachment_uuid varchar(65533) NULL COMMENT “事务行附件”,
reversed_tax_amount decimal128(38, 10) NULL COMMENT “冲销含税金额”,
occupied_tax_amount decimal128(38, 10) NULL COMMENT “占用含税金额”,
delete_flag tinyint(4) NULL COMMENT “删除标识:用来区分接口过来一个事务对应多个订单行的情况”,
org_quantity decimal128(38, 10) NULL COMMENT “原始数量:用来记录数量累加后无法知道原数量的问题”,
secondary_org_quantity decimal128(38, 10) NULL COMMENT “辅助原始数量:用来记录数量累加后无法知道原数量的问题”,
cost_id bigint(20) NULL COMMENT “成本中心主键”,
bill_matched_quantity decimal128(38, 10) NULL COMMENT “对账数量”,
pr_header_id bigint(20) NULL COMMENT “申请头id”,
pr_line_id bigint(20) NULL COMMENT “申请行id”,
reverse_occupied_quantity decimal128(38, 10) NULL COMMENT “冲销占用数量”,
secondary_reverse_occupied_quantity decimal128(38, 10) NULL COMMENT “辅助冲销占用数量”,
reverse_occupied_tax_amount decimal128(38, 10) NULL COMMENT “冲销占用金额（含税）”,
execute_reverse_quantity decimal128(38, 10) NULL COMMENT “执行退回数量”,
execute_reverse_node_config_id bigint(20) NULL COMMENT “执行退回节点”,
srm_created_by bigint(20) NULL COMMENT “单据创建人”,
execute_reverse_rcv_trx_type_id bigint(20) NULL COMMENT “执行退回事务类型id”,
deduction_flag tinyint(4) NULL COMMENT “退料并补料标识”,
link_trx_line_id bigint(20) NULL COMMENT “由三方交易模式产生的事务行id，与事务行表一对一”,
cooperation_supplier_flag tinyint(4) NULL COMMENT “供应商参与协同标识”,
deduction_quantity decimal128(38, 10) NULL COMMENT “退料并补料数量”,
secondary_deduction_quantity decimal128(38, 10) NULL COMMENT “辅助退料并补料数量”,
erp_asn_line_flag tinyint(4) NULL COMMENT “erp事务同步时是否传送货单行id标识”,
unit_price_batch decimal128(38, 10) NULL COMMENT “单位价格批量”,
benchmark_price_type varchar(65533) NULL COMMENT “基准价类型(NET/未税价|TAX/含税价”,
strategy_line_id bigint(20) NULL COMMENT “当前执行策略行id”,
last_strategy_line_id bigint(20) NULL COMMENT “上个执行策略行id”,
next_strategy_line_id bigint(20) NULL COMMENT “下一个执行策略行id”,
other_attachment_uuid varchar(65533) NULL COMMENT “其他附件比如订单，送货单，协议等”,
auth_receive_user_id bigint(20) NULL COMMENT “权限收货人”,
requested_by bigint(20) NULL COMMENT “申请人ID”,
payment_status varchar(65533) NULL COMMENT “付款状态”,
secondary_quantity decimal128(38, 10) NULL COMMENT “辅助数量”,
secondary_uom_id bigint(20) NULL COMMENT “辅助单位”,
secondary_uom_rate decimal128(38, 10) NULL COMMENT “双单位数量换算比例(基本数量/辅助数量)”,
bill_matched_amount decimal128(38, 10) NULL COMMENT “已对账金额”,
invoiced_amount decimal128(38, 10) NULL COMMENT “已开票金额”,
secondary_execute_reverse_quantity decimal128(38, 10) NULL COMMENT “执行辅助退回数量”,
query_strategy_line_id bigint(20) NULL COMMENT “查询策略行id”,
test_speed varchar(65533) NULL COMMENT “测试ddl速度”,
qam_flag tinyint(4) NULL COMMENT “质量整改标识，0-未整改，1-已整改”,
limitless_receipt_flag tinyint(4) NULL COMMENT “无限制收货标识 0/有数量（金额）限制 1/没有数量金额限制”,
pe_supplier varchar(65533) NULL COMMENT “拼接供应商Id”,
storage_time datetime NULL COMMENT “创建时间”
) ENGINE=OLAP
PRIMARY KEY(rcv_trx_line_id)
COMMENT “采购事务行表”
DISTRIBUTED BY HASH(rcv_trx_line_id) BUCKETS 72
PROPERTIES (
“replication_num” = “3”,
“in_memory” = “false”,
“storage_format” = “DEFAULT”,
“enable_persistent_index” = “true”,
“replicated_storage” = “true”,
“compression” = “LZ4”
);
CREATE TABLE sinv_rcv_trx_header (
rcv_trx_header_id bigint(20) NOT NULL COMMENT “”,
tenant_id bigint(20) NULL COMMENT “采购方租户ID,hpfm_tenant.tenant_id”,
supplier_tenant_id bigint(20) NULL COMMENT “2”,
trx_num varchar(65533) NULL COMMENT “接收事务编号”,
display_trx_num varchar(65533) NULL COMMENT “展示事务编号”,
trx_year int(11) NULL COMMENT “事务年份”,
company_id bigint(20) NULL COMMENT “所属公司ID”,
company_name varchar(65533) NULL COMMENT “所属公司描述”,
ou_id bigint(20) NULL COMMENT “所属业务实体ID”,
purchase_org_id bigint(20) NULL COMMENT “采购组织ID”,
trx_date datetime NULL COMMENT “事务日期”,
receipt_num varchar(65533) NULL COMMENT “接收编号”,
receipt_header_date datetime NULL COMMENT “接收头日期”,
process_flag tinyint(4) NULL COMMENT “事务执行标识”,
process_date datetime NULL COMMENT “事务执行日期”,
need_process_flag tinyint(4) NULL COMMENT “需要执行标识”,
supplier_id bigint(20) NULL COMMENT “供应商ID”,
supplier_num varchar(65533) NULL COMMENT “供应商代码”,
supplier_name varchar(65533) NULL COMMENT “供应商名称”,
supplier_site_id bigint(20) NULL COMMENT “供应商地点ID”,
supplier_company_id bigint(20) NULL COMMENT “供应商公司ID”,
supplier_company_name varchar(65533) NULL COMMENT “供应商公司描述”,
supplier_ou_id bigint(20) NULL COMMENT “合作方业务实体ID”,
erp_creation_date datetime NULL COMMENT “erp创建日期”,
erp_last_update_date datetime NULL COMMENT “erp最后更新日期”,
approved_date datetime NULL COMMENT “审批日期”,
receive_amount decimal128(38, 10) NULL COMMENT “接收金额”,
init_flag tinyint(4) NULL COMMENT “是否初始化数据标识”,
quantity_check_flag tinyint(4) NULL COMMENT “数量校验标识（事务执行时，是否校验订单、送货单超量，默认为接口同步的数据，不做数量校验）”,
source_code varchar(65533) NULL COMMENT “数据来源代码，HPFM.DATA_SOURCE”,
external_system_code varchar(65533) NULL COMMENT “外部来源系统代码，比如，多套SAP系统”,
sync_response_status varchar(65533) NULL COMMENT “同步ERP反馈状态”,
sync_response_msg varchar(65533) NULL COMMENT “同步ERP反馈信息”,
remark varchar(65533) NULL COMMENT “备注说明”,
object_version_number bigint(20) NULL COMMENT “行版本号，用来处理锁”,
created_by bigint(20) NULL COMMENT “”,
creation_date datetime NULL COMMENT “”,
last_updated_by bigint(20) NULL COMMENT “”,
last_update_date datetime NULL COMMENT “”,
received_by varchar(65533) NULL COMMENT “验收人”,
rcv_status_code varchar(65533) NULL COMMENT “状态-编码：SPUC.SINV_STATUS”,
sinv_header_attachment_uuid varchar(65533) NULL COMMENT “事务头附件”,
returned_flag tinyint(4) NULL COMMENT “是否退回标志”,
attribute_varchar1 varchar(65533) NULL COMMENT “字符扩展字段1”,
attribute_varchar2 varchar(65533) NULL COMMENT “字符扩展字段2”,
attribute_varchar3 varchar(65533) NULL COMMENT “字符扩展字段3”,
attribute_varchar4 varchar(65533) NULL COMMENT “字符扩展字段4”,
attribute_varchar5 varchar(65533) NULL COMMENT “字符扩展字段5”,
attribute_varchar6 varchar(65533) NULL COMMENT “字符扩展字段6”,
attribute_varchar7 varchar(65533) NULL COMMENT “字符扩展字段7”,
attribute_varchar8 varchar(65533) NULL COMMENT “字符扩展字段8”,
attribute_varchar9 varchar(65533) NULL COMMENT “字符扩展字段9”,
attribute_varchar10 varchar(65533) NULL COMMENT “字符扩展字段10”,
attribute_varchar11 varchar(65533) NULL COMMENT “字符扩展字段11”,
attribute_varchar12 varchar(65533) NULL COMMENT “字符扩展字段12”,
attribute_varchar13 varchar(65533) NULL COMMENT “字符扩展字段13”,
attribute_varchar14 varchar(65533) NULL COMMENT “字符扩展字段14”,
attribute_varchar15 varchar(65533) NULL COMMENT “字符扩展字段15”,
attribute_varchar16 varchar(65533) NULL COMMENT “字符扩展字段16”,
attribute_varchar17 varchar(65533) NULL COMMENT “字符扩展字段17”,
attribute_varchar18 varchar(65533) NULL COMMENT “字符扩展字段18”,
attribute_varchar19 varchar(65533) NULL COMMENT “字符扩展字段19”,
attribute_varchar20 varchar(65533) NULL COMMENT “字符扩展字段20”,
attribute_varchar21 varchar(65533) NULL COMMENT “字符扩展字段21”,
attribute_varchar22 varchar(65533) NULL COMMENT “字符扩展字段22”,
attribute_varchar23 varchar(65533) NULL COMMENT “字符扩展字段23”,
attribute_varchar24 varchar(65533) NULL COMMENT “字符扩展字段24”,
attribute_varchar25 varchar(65533) NULL COMMENT “字符扩展字段25”,
attribute_varchar26 varchar(65533) NULL COMMENT “字符扩展字段26”,
attribute_varchar27 varchar(65533) NULL COMMENT “字符扩展字段27”,
attribute_varchar28 varchar(65533) NULL COMMENT “字符扩展字段28”,
attribute_varchar29 varchar(65533) NULL COMMENT “字符扩展字段29”,
attribute_varchar30 varchar(65533) NULL COMMENT “字符扩展字段30”,
attribute_varchar31 varchar(65533) NULL COMMENT “字符扩展字段31”,
attribute_varchar32 varchar(65533) NULL COMMENT “字符扩展字段32”,
attribute_varchar33 varchar(65533) NULL COMMENT “字符扩展字段33”,
attribute_varchar34 varchar(65533) NULL COMMENT “字符扩展字段34”,
attribute_varchar35 varchar(65533) NULL COMMENT “字符扩展字段35”,
attribute_varchar36 varchar(65533) NULL COMMENT “字符扩展字段36”,
attribute_varchar37 varchar(65533) NULL COMMENT “字符扩展字段37”,
attribute_varchar38 varchar(65533) NULL COMMENT “字符扩展字段38”,
attribute_varchar39 varchar(65533) NULL COMMENT “字符扩展字段39”,
attribute_varchar40 varchar(65533) NULL COMMENT “字符扩展字段40”,
attribute_longtext1 varchar(65533) NULL COMMENT “长字符扩展字段1”,
attribute_longtext2 varchar(65533) NULL COMMENT “长字符扩展字段2”,
attribute_longtext3 varchar(65533) NULL COMMENT “长字符扩展字段3”,
attribute_longtext4 varchar(65533) NULL COMMENT “长字符扩展字段4”,
attribute_longtext5 varchar(65533) NULL COMMENT “长字符扩展字段5”,
attribute_longtext6 varchar(65533) NULL COMMENT “长字符扩展字段6”,
attribute_longtext7 varchar(65533) NULL COMMENT “长字符扩展字段7”,
attribute_longtext8 varchar(65533) NULL COMMENT “长字符扩展字段8”,
attribute_longtext9 varchar(65533) NULL COMMENT “长字符扩展字段9”,
attribute_longtext10 varchar(65533) NULL COMMENT “长字符扩展字段10”,
attribute_bigint1 bigint(20) NULL COMMENT “整数扩展字段1”,
attribute_bigint2 bigint(20) NULL COMMENT “整数扩展字段2”,
attribute_bigint3 bigint(20) NULL COMMENT “整数扩展字段3”,
attribute_bigint4 bigint(20) NULL COMMENT “整数扩展字段4”,
attribute_bigint5 bigint(20) NULL COMMENT “整数扩展字段5”,
attribute_bigint6 bigint(20) NULL COMMENT “整数扩展字段6”,
attribute_bigint7 bigint(20) NULL COMMENT “整数扩展字段7”,
attribute_bigint8 bigint(20) NULL COMMENT “整数扩展字段8”,
attribute_bigint9 bigint(20) NULL COMMENT “整数扩展字段9”,
attribute_bigint10 bigint(20) NULL COMMENT “整数扩展字段10”,
attribute_bigint11 bigint(20) NULL COMMENT “整数扩展字段11”,
attribute_bigint12 bigint(20) NULL COMMENT “整数扩展字段12”,
attribute_bigint13 bigint(20) NULL COMMENT “整数扩展字段13”,
attribute_bigint14 bigint(20) NULL COMMENT “整数扩展字段14”,
attribute_bigint15 bigint(20) NULL COMMENT “整数扩展字段15”,
attribute_bigint16 bigint(20) NULL COMMENT “整数扩展字段16”,
attribute_bigint17 bigint(20) NULL COMMENT “整数扩展字段17”,
attribute_bigint18 bigint(20) NULL COMMENT “整数扩展字段18”,
attribute_bigint19 bigint(20) NULL COMMENT “整数扩展字段19”,
attribute_bigint20 bigint(20) NULL COMMENT “整数扩展字段20”,
attribute_bigint21 bigint(20) NULL COMMENT “整数扩展字段21”,
attribute_bigint22 bigint(20) NULL COMMENT “整数扩展字段22”,
attribute_bigint23 bigint(20) NULL COMMENT “整数扩展字段23”,
attribute_bigint24 bigint(20) NULL COMMENT “整数扩展字段24”,
attribute_bigint25 bigint(20) NULL COMMENT “整数扩展字段25”,
attribute_bigint26 bigint(20) NULL COMMENT “整数扩展字段26”,
attribute_bigint27 bigint(20) NULL COMMENT “整数扩展字段27”,
attribute_bigint28 bigint(20) NULL COMMENT “整数扩展字段28”,
attribute_bigint29 bigint(20) NULL COMMENT “整数扩展字段29”,
attribute_bigint30 bigint(20) NULL COMMENT “整数扩展字段30”,
attribute_tinyint1 tinyint(4) NULL COMMENT “小整数扩展字段1”,
attribute_tinyint2 tinyint(4) NULL COMMENT “小整数扩展字段2”,
attribute_tinyint3 tinyint(4) NULL COMMENT “小整数扩展字段3”,
attribute_tinyint4 tinyint(4) NULL COMMENT “小整数扩展字段4”,
attribute_tinyint5 tinyint(4) NULL COMMENT “小整数扩展字段5”,
attribute_tinyint6 tinyint(4) NULL COMMENT “小整数扩展字段6”,
attribute_tinyint7 tinyint(4) NULL COMMENT “小整数扩展字段7”,
attribute_tinyint8 tinyint(4) NULL COMMENT “小整数扩展字段8”,
attribute_tinyint9 tinyint(4) NULL COMMENT “小整数扩展字段9”,
attribute_tinyint10 tinyint(4) NULL COMMENT “小整数扩展字段10”,
attribute_tinyint11 tinyint(4) NULL COMMENT “小整数扩展字段11”,
attribute_tinyint12 tinyint(4) NULL COMMENT “小整数扩展字段12”,
attribute_tinyint13 tinyint(4) NULL COMMENT “小整数扩展字段13”,
attribute_tinyint14 tinyint(4) NULL COMMENT “小整数扩展字段14”,
attribute_tinyint15 tinyint(4) NULL COMMENT “小整数扩展字段15”,
attribute_tinyint16 tinyint(4) NULL COMMENT “小整数扩展字段16”,
attribute_tinyint17 tinyint(4) NULL COMMENT “小整数扩展字段17”,
attribute_tinyint18 tinyint(4) NULL COMMENT “小整数扩展字段18”,
attribute_tinyint19 tinyint(4) NULL COMMENT “小整数扩展字段19”,
attribute_tinyint20 tinyint(4) NULL COMMENT “小整数扩展字段20”,
attribute_decimal1 decimal128(38, 10) NULL COMMENT “小数扩展字段1”,
attribute_decimal2 decimal128(38, 10) NULL COMMENT “小数扩展字段2”,
attribute_decimal3 decimal128(38, 10) NULL COMMENT “小数扩展字段3”,
attribute_decimal4 decimal128(38, 10) NULL COMMENT “小数扩展字段4”,
attribute_decimal5 decimal128(38, 10) NULL COMMENT “小数扩展字段5”,
attribute_decimal6 decimal128(38, 10) NULL COMMENT “小数扩展字段6”,
attribute_decimal7 decimal128(38, 10) NULL COMMENT “小数扩展字段7”,
attribute_decimal8 decimal128(38, 10) NULL COMMENT “小数扩展字段8”,
attribute_decimal9 decimal128(38, 10) NULL COMMENT “小数扩展字段9”,
attribute_decimal10 decimal128(38, 10) NULL COMMENT “小数扩展字段10”,
attribute_decimal11 decimal128(38, 10) NULL COMMENT “小数扩展字段11”,
attribute_decimal12 decimal128(38, 10) NULL COMMENT “小数扩展字段12”,
attribute_decimal13 decimal128(38, 10) NULL COMMENT “小数扩展字段13”,
attribute_decimal14 decimal128(38, 10) NULL COMMENT “小数扩展字段14”,
attribute_decimal15 decimal128(38, 10) NULL COMMENT “小数扩展字段15”,
attribute_decimal16 decimal128(38, 10) NULL COMMENT “小数扩展字段16”,
attribute_decimal17 decimal128(38, 10) NULL COMMENT “小数扩展字段17”,
attribute_decimal18 decimal128(38, 10) NULL COMMENT “小数扩展字段18”,
attribute_decimal19 decimal128(38, 10) NULL COMMENT “小数扩展字段19”,
attribute_decimal20 decimal128(38, 10) NULL COMMENT “小数扩展字段20”,
attribute_decimal21 decimal128(38, 10) NULL COMMENT “小数扩展字段21”,
attribute_decimal22 decimal128(38, 10) NULL COMMENT “小数扩展字段22”,
attribute_decimal23 decimal128(38, 10) NULL COMMENT “小数扩展字段23”,
attribute_decimal24 decimal128(38, 10) NULL COMMENT “小数扩展字段24”,
attribute_decimal25 decimal128(38, 10) NULL COMMENT “小数扩展字段25”,
attribute_decimal26 decimal128(38, 10) NULL COMMENT “小数扩展字段26”,
attribute_decimal27 decimal128(38, 10) NULL COMMENT “小数扩展字段27”,
attribute_decimal28 decimal128(38, 10) NULL COMMENT “小数扩展字段28”,
attribute_decimal29 decimal128(38, 10) NULL COMMENT “小数扩展字段29”,
attribute_decimal30 decimal128(38, 10) NULL COMMENT “小数扩展字段30”,
attribute_datetime1 datetime NULL COMMENT “日期时间扩展字段1”,
attribute_datetime2 datetime NULL COMMENT “日期时间扩展字段2”,
attribute_datetime3 datetime NULL COMMENT “日期时间扩展字段3”,
attribute_datetime4 datetime NULL COMMENT “日期时间扩展字段4”,
attribute_datetime5 datetime NULL COMMENT “日期时间扩展字段5”,
attribute_datetime6 datetime NULL COMMENT “日期时间扩展字段6”,
attribute_datetime7 datetime NULL COMMENT “日期时间扩展字段7”,
attribute_datetime8 datetime NULL COMMENT “日期时间扩展字段8”,
attribute_datetime9 datetime NULL COMMENT “日期时间扩展字段9”,
attribute_datetime10 datetime NULL COMMENT “日期时间扩展字段10”,
attribute_datetime11 datetime NULL COMMENT “日期时间扩展字段11”,
attribute_datetime12 datetime NULL COMMENT “日期时间扩展字段12”,
attribute_datetime13 datetime NULL COMMENT “日期时间扩展字段13”,
attribute_datetime14 datetime NULL COMMENT “日期时间扩展字段14”,
attribute_datetime15 datetime NULL COMMENT “日期时间扩展字段15”,
attribute_datetime16 datetime NULL COMMENT “日期时间扩展字段16”,
attribute_datetime17 datetime NULL COMMENT “日期时间扩展字段17”,
attribute_datetime18 datetime NULL COMMENT “日期时间扩展字段18”,
attribute_datetime19 datetime NULL COMMENT “日期时间扩展字段19”,
attribute_datetime20 datetime NULL COMMENT “日期时间扩展字段20”,
attribute_date1 date NULL COMMENT “日期扩展字段1”,
attribute_date2 date NULL COMMENT “日期扩展字段2”,
attribute_date3 date NULL COMMENT “日期扩展字段3”,
attribute_date4 date NULL COMMENT “日期扩展字段4”,
attribute_date5 date NULL COMMENT “日期扩展字段5”,
attribute_date6 date NULL COMMENT “日期扩展字段6”,
attribute_date7 date NULL COMMENT “日期扩展字段7”,
attribute_date8 date NULL COMMENT “日期扩展字段8”,
attribute_date9 date NULL COMMENT “日期扩展字段9”,
attribute_date10 date NULL COMMENT “日期扩展字段10”,
attribute_date11 date NULL COMMENT “日期扩展字段11”,
attribute_date12 date NULL COMMENT “日期扩展字段12”,
attribute_date13 date NULL COMMENT “日期扩展字段13”,
attribute_date14 date NULL COMMENT “日期扩展字段14”,
attribute_date15 date NULL COMMENT “日期扩展字段15”,
attribute_date16 date NULL COMMENT “日期扩展字段16”,
attribute_date17 date NULL COMMENT “日期扩展字段17”,
attribute_date18 date NULL COMMENT “日期扩展字段18”,
attribute_date19 date NULL COMMENT “日期扩展字段19”,
attribute_date20 date NULL COMMENT “日期扩展字段20”,
from_node_config_id bigint(20) NULL COMMENT “来源节点id，用于冲销时，记录原始节点”,
srm_created_by bigint(20) NULL COMMENT “单据创建人”,
auto_receive_flag tinyint(4) NULL COMMENT “是否自动收货标志”,
unit_ids varchar(65533) NULL COMMENT “创建人部门集合”,
print_flag tinyint(4) NULL COMMENT “打印标识 0/1”,
print_times int(11) NULL COMMENT “打印次数”,
supplier_receipt_flag tinyint(4) NULL COMMENT “供应商收货标识 1供应商收货，0为采购方收货”,
finished_date datetime NULL COMMENT “SRM事务完成日期”,
appraisal_status tinyint(4) NULL COMMENT “考评状态(SSLM_KPI_PC_HEADER_STATUS)”,
receive_location_address varchar(65533) NULL COMMENT “收货地址定位（GPS）”,
receive_detail_address varchar(65533) NULL COMMENT “收货详细地址”,
mall_trx_num varchar(65533) NULL COMMENT “商城收货/退货单号”,
pe_supplier varchar(65533) NULL COMMENT “拼接供应商Id”,
storage_time datetime NULL COMMENT “创建时间”
) ENGINE=OLAP
PRIMARY KEY(rcv_trx_header_id)
COMMENT “采购事务头表”
DISTRIBUTED BY HASH(rcv_trx_header_id) BUCKETS 42
PROPERTIES (
“replication_num” = “3”,
“in_memory” = “false”,
“storage_format” = “DEFAULT”,
“enable_persistent_index” = “true”,
“replicated_storage” = “true”,
“compression” = “LZ4”
);
CREATE TABLE sinv_rcv_trx_order_link (
order_link_id bigint(20) NOT NULL COMMENT “”,
from_po_header_id bigint(20) NULL COMMENT “来源订单头id”,
from_po_line_id bigint(20) NULL COMMENT “来源订单行id”,
from_po_line_location_id bigint(20) NULL COMMENT “来源发运行id”,
from_display_po_num varchar(65533) NULL COMMENT “来源订单编号”,
from_display_po_line_num varchar(65533) NULL COMMENT “来源订单行号”,
from_display_po_line_location_num varchar(65533) NULL COMMENT “来源订单发运行号”,
from_asn_header_id bigint(20) NULL COMMENT “来源送货单头id”,
from_asn_line_id bigint(20) NULL COMMENT “来源送货单行id”,
from_display_asn_num varchar(65533) NULL COMMENT “来源送货单号”,
from_display_asn_line_num varchar(65533) NULL COMMENT “来源送货单行号”,
from_pc_header_id bigint(20) NULL COMMENT “来源协议头id”,
from_pc_subject_id bigint(20) NULL COMMENT “来源协议标的行id”,
from_pc_num varchar(65533) NULL COMMENT “来源协议号”,
from_pc_subject_num varchar(65533) NULL COMMENT “来源协议行号”,
tenant_id bigint(20) NULL COMMENT “租户ID”,
object_version_number bigint(20) NULL COMMENT “行版本号，用来处理锁”,
CREATED_BY bigint(20) NULL COMMENT “”,
CREATION_DATE datetime NULL COMMENT “”,
LAST_UPDATED_BY bigint(20) NULL COMMENT “”,
LAST_UPDATE_DATE datetime NULL COMMENT “”,
LAST_UPDATE_LOGIN bigint(20) NULL COMMENT “”,
source_header_num varchar(65533) NULL COMMENT “来源单号”,
source_line_num varchar(65533) NULL COMMENT “来源行号”,
strategy_line_id bigint(20) NULL COMMENT “策略行id(弃用)”,
strategy_header_id bigint(20) NULL COMMENT “策略头id”,
from_pc_stage_id bigint(20) NULL COMMENT “协议-阶段id”,
from_slod_asn_header_id bigint(20) NULL COMMENT “发货-送货单头id”,
from_slod_display_asn_num varchar(65533) NULL COMMENT “”,
from_slod_asn_line_id bigint(20) NULL COMMENT “发货-送货单行id”,
from_slod_display_asn_line_num varchar(65533) NULL COMMENT “”,
from_slod_label_header_id bigint(20) NULL COMMENT “发货-标签头id”,
from_slod_display_label_num varchar(65533) NULL COMMENT “”,
from_slod_label_line_id bigint(20) NULL COMMENT “发货-标签行id”,
from_slod_display_label_line_num varchar(65533) NULL COMMENT “”,
from_slod_plan_header_id bigint(20) NULL COMMENT “发货-计划头id”,
from_slod_display_plan_num varchar(65533) NULL COMMENT “”,
from_slod_plan_line_id bigint(20) NULL COMMENT “发货-计划行id”,
from_slod_display_plan_line_num varchar(65533) NULL COMMENT “”,
ec_po_num varchar(65533) NULL COMMENT “电商父订单编号”,
ec_po_sub_num varchar(65533) NULL COMMENT “电商子订单号”,
deliver_time datetime NULL COMMENT “妥投时间”,
actual_quantity decimal128(38, 10) NULL COMMENT “妥投数量”,
bill_type_code varchar(65533) NULL COMMENT “来源单据类型”,
accept_time datetime NULL COMMENT “签收时间”,
carriers_code varchar(65533) NULL COMMENT “承运商编码, 值集 SINV.ASN_CARRIERS”,
project_task_id bigint(20) NULL COMMENT “项目任务id”,
storage_time datetime NULL COMMENT “创建时间”
) ENGINE=OLAP
PRIMARY KEY(order_link_id)
DISTRIBUTED BY HASH(order_link_id) BUCKETS 2
PROPERTIES (
“replication_num” = “3”,
“in_memory” = “false”,
“storage_format” = “DEFAULT”,
“enable_persistent_index” = “true”,
“replicated_storage” = “true”,
“compression” = “LZ4”
);
CREATE TABLE sinv_rcv_record_strategy_mapping (
record_strategy_mapping_id bigint(20) NOT NULL COMMENT “”,
rcv_trx_header_id bigint(20) NULL COMMENT “采购事务头id”,
strategy_line_id bigint(20) NULL COMMENT “策略行id”,
last_strategy_line_id bigint(20) NULL COMMENT “上一个策略行id”,
next_strategy_line_id bigint(20) NULL COMMENT “下一个策略行id”,
initial_node_flag tinyint(4) NULL COMMENT “是否为初始节点：1/0 是/否，初始节点不算接收”,
order_type_code varchar(65533) NULL COMMENT “单据类型code”,
order_type_name varchar(65533) NULL COMMENT “单据类型名称”,
tenant_id bigint(20) NULL COMMENT “租户ID”,
object_version_number bigint(20) NULL COMMENT “行版本号，用来处理锁”,
CREATED_BY bigint(20) NULL COMMENT “”,
CREATION_DATE datetime NULL COMMENT “”,
LAST_UPDATED_BY bigint(20) NULL COMMENT “”,
LAST_UPDATE_DATE datetime NULL COMMENT “”,
LAST_UPDATE_LOGIN bigint(20) NULL COMMENT “”,
rcv_trx_line_id bigint(20) NULL COMMENT “事务行id”,
master_flag tinyint(4) NULL COMMENT “主策略标识”,
strategy_header_id bigint(20) NULL COMMENT “策略头id”,
storage_time datetime NULL COMMENT “创建时间”
) ENGINE=OLAP
PRIMARY KEY(record_strategy_mapping_id)
DISTRIBUTED BY HASH(record_strategy_mapping_id) BUCKETS 1
PROPERTIES (
“replication_num” = “3”,
“in_memory” = “false”,
“storage_format” = “DEFAULT”,
“enable_persistent_index” = “true”,
“replicated_storage” = “true”,
“compression” = “LZ4”
);
CREATE TABLE sinv_rcv_strategy_line (
strategy_line_id bigint(20) NOT NULL COMMENT “”,
strategy_header_id bigint(20) NULL COMMENT “策略头id”,
line_seq int(11) NULL COMMENT “行序号”,
srm_enable tinyint(4) NULL COMMENT “srm操作标识：0/1：erp操作/srm操作”,
subject_type varchar(65533) NULL COMMENT “执行标的”,
last_strategy_line_id bigint(20) NULL COMMENT “上一个策略行id”,
next_strategy_line_id bigint(20) NULL COMMENT “下一个策略行id”,
node_config_id bigint(20) NULL COMMENT “节点id”,
approve_rule_code varchar(65533) NULL COMMENT “审批规则”,
export_ext_enable tinyint(4) NULL COMMENT “导入至外部系统标识”,
tenant_id bigint(20) NULL COMMENT “租户ID”,
object_version_number bigint(20) NULL COMMENT “行版本号，用来处理锁”,
CREATED_BY bigint(20) NULL COMMENT “”,
CREATION_DATE datetime NULL COMMENT “”,
LAST_UPDATED_BY bigint(20) NULL COMMENT “”,
LAST_UPDATE_DATE datetime NULL COMMENT “”,
LAST_UPDATE_LOGIN bigint(20) NULL COMMENT “”,
attribute_varchar1 varchar(65533) NULL COMMENT “字符扩展字段1”,
attribute_varchar2 varchar(65533) NULL COMMENT “字符扩展字段2”,
attribute_varchar3 varchar(65533) NULL COMMENT “字符扩展字段3”,
attribute_varchar4 varchar(65533) NULL COMMENT “字符扩展字段4”,
attribute_varchar5 varchar(65533) NULL COMMENT “字符扩展字段5”,
attribute_varchar6 varchar(65533) NULL COMMENT “字符扩展字段6”,
attribute_varchar7 varchar(65533) NULL COMMENT “字符扩展字段7”,
attribute_varchar8 varchar(65533) NULL COMMENT “字符扩展字段8”,
attribute_varchar9 varchar(65533) NULL COMMENT “字符扩展字段9”,
attribute_varchar10 varchar(65533) NULL COMMENT “字符扩展字段10”,
attribute_varchar11 varchar(65533) NULL COMMENT “字符扩展字段11”,
attribute_varchar12 varchar(65533) NULL COMMENT “字符扩展字段12”,
attribute_varchar13 varchar(65533) NULL COMMENT “字符扩展字段13”,
attribute_varchar14 varchar(65533) NULL COMMENT “字符扩展字段14”,
attribute_varchar15 varchar(65533) NULL COMMENT “字符扩展字段15”,
attribute_varchar16 varchar(65533) NULL COMMENT “字符扩展字段16”,
attribute_varchar17 varchar(65533) NULL COMMENT “字符扩展字段17”,
attribute_varchar18 varchar(65533) NULL COMMENT “字符扩展字段18”,
attribute_varchar19 varchar(65533) NULL COMMENT “字符扩展字段19”,
attribute_varchar20 varchar(65533) NULL COMMENT “字符扩展字段20”,
attribute_varchar21 varchar(65533) NULL COMMENT “字符扩展字段21”,
attribute_varchar22 varchar(65533) NULL COMMENT “字符扩展字段22”,
attribute_varchar23 varchar(65533) NULL COMMENT “字符扩展字段23”,
attribute_varchar24 varchar(65533) NULL COMMENT “字符扩展字段24”,
attribute_varchar25 varchar(65533) NULL COMMENT “字符扩展字段25”,
attribute_varchar26 varchar(65533) NULL COMMENT “字符扩展字段26”,
attribute_varchar27 varchar(65533) NULL COMMENT “字符扩展字段27”,
attribute_varchar28 varchar(65533) NULL COMMENT “字符扩展字段28”,
attribute_varchar29 varchar(65533) NULL COMMENT “字符扩展字段29”,
attribute_varchar30 varchar(65533) NULL COMMENT “字符扩展字段30”,
attribute_varchar31 varchar(65533) NULL COMMENT “字符扩展字段31”,
attribute_varchar32 varchar(65533) NULL COMMENT “字符扩展字段32”,
attribute_varchar33 varchar(65533) NULL COMMENT “字符扩展字段33”,
attribute_varchar34 varchar(65533) NULL COMMENT “字符扩展字段34”,
attribute_varchar35 varchar(65533) NULL COMMENT “字符扩展字段35”,
attribute_varchar36 varchar(65533) NULL COMMENT “字符扩展字段36”,
attribute_varchar37 varchar(65533) NULL COMMENT “字符扩展字段37”,
attribute_varchar38 varchar(65533) NULL COMMENT “字符扩展字段38”,
attribute_varchar39 varchar(65533) NULL COMMENT “字符扩展字段39”,
attribute_varchar40 varchar(65533) NULL COMMENT “字符扩展字段40”,
attribute_longtext1 varchar(65533) NULL COMMENT “长字符扩展字段1”,
attribute_longtext2 varchar(65533) NULL COMMENT “长字符扩展字段2”,
attribute_longtext3 varchar(65533) NULL COMMENT “长字符扩展字段3”,
attribute_longtext4 varchar(65533) NULL COMMENT “长字符扩展字段4”,
attribute_longtext5 varchar(65533) NULL COMMENT “长字符扩展字段5”,
attribute_longtext6 varchar(65533) NULL COMMENT “长字符扩展字段6”,
attribute_longtext7 varchar(65533) NULL COMMENT “长字符扩展字段7”,
attribute_longtext8 varchar(65533) NULL COMMENT “长字符扩展字段8”,
attribute_longtext9 varchar(65533) NULL COMMENT “长字符扩展字段9”,
attribute_longtext10 varchar(65533) NULL COMMENT “长字符扩展字段10”,
attribute_bigint1 bigint(20) NULL COMMENT “整数扩展字段1”,
attribute_bigint2 bigint(20) NULL COMMENT “整数扩展字段2”,
attribute_bigint3 bigint(20) NULL COMMENT “整数扩展字段3”,
attribute_bigint4 bigint(20) NULL COMMENT “整数扩展字段4”,
attribute_bigint5 bigint(20) NULL COMMENT “整数扩展字段5”,
attribute_bigint6 bigint(20) NULL COMMENT “整数扩展字段6”,
attribute_bigint7 bigint(20) NULL COMMENT “整数扩展字段7”,
attribute_bigint8 bigint(20) NULL COMMENT “整数扩展字段8”,
attribute_bigint9 bigint(20) NULL COMMENT “整数扩展字段9”,
attribute_bigint10 bigint(20) NULL COMMENT “整数扩展字段10”,
attribute_bigint11 bigint(20) NULL COMMENT “整数扩展字段11”,
attribute_bigint12 bigint(20) NULL COMMENT “整数扩展字段12”,
attribute_bigint13 bigint(20) NULL COMMENT “整数扩展字段13”,
attribute_bigint14 bigint(20) NULL COMMENT “整数扩展字段14”,
attribute_bigint15 bigint(20) NULL COMMENT “整数扩展字段15”,
attribute_bigint16 bigint(20) NULL COMMENT “整数扩展字段16”,
attribute_bigint17 bigint(20) NULL COMMENT “整数扩展字段17”,
attribute_bigint18 bigint(20) NULL COMMENT “整数扩展字段18”,
attribute_bigint19 bigint(20) NULL COMMENT “整数扩展字段19”,
attribute_bigint20 bigint(20) NULL COMMENT “整数扩展字段20”,
attribute_bigint21 bigint(20) NULL COMMENT “整数扩展字段21”,
attribute_bigint22 bigint(20) NULL COMMENT “整数扩展字段22”,
attribute_bigint23 bigint(20) NULL COMMENT “整数扩展字段23”,
attribute_bigint24 bigint(20) NULL COMMENT “整数扩展字段24”,
attribute_bigint25 bigint(20) NULL COMMENT “整数扩展字段25”,
attribute_bigint26 bigint(20) NULL COMMENT “整数扩展字段26”,
attribute_bigint27 bigint(20) NULL COMMENT “整数扩展字段27”,
attribute_bigint28 bigint(20) NULL COMMENT “整数扩展字段28”,
attribute_bigint29 bigint(20) NULL COMMENT “整数扩展字段29”,
attribute_bigint30 bigint(20) NULL COMMENT “整数扩展字段30”,
attribute_tinyint1 tinyint(4) NULL COMMENT “小整数扩展字段1”,
attribute_tinyint2 tinyint(4) NULL COMMENT “小整数扩展字段2”,
attribute_tinyint3 tinyint(4) NULL COMMENT “小整数扩展字段3”,
attribute_tinyint4 tinyint(4) NULL COMMENT “小整数扩展字段4”,
attribute_tinyint5 tinyint(4) NULL COMMENT “小整数扩展字段5”,
attribute_tinyint6 tinyint(4) NULL COMMENT “小整数扩展字段6”,
attribute_tinyint7 tinyint(4) NULL COMMENT “小整数扩展字段7”,
attribute_tinyint8 tinyint(4) NULL COMMENT “小整数扩展字段8”,
attribute_tinyint9 tinyint(4) NULL COMMENT “小整数扩展字段9”,
attribute_tinyint10 tinyint(4) NULL COMMENT “小整数扩展字段10”,
attribute_tinyint11 tinyint(4) NULL COMMENT “小整数扩展字段11”,
attribute_tinyint12 tinyint(4) NULL COMMENT “小整数扩展字段12”,
attribute_tinyint13 tinyint(4) NULL COMMENT “小整数扩展字段13”,
attribute_tinyint14 tinyint(4) NULL COMMENT “小整数扩展字段14”,
attribute_tinyint15 tinyint(4) NULL COMMENT “小整数扩展字段15”,
attribute_tinyint16 tinyint(4) NULL COMMENT “小整数扩展字段16”,
attribute_tinyint17 tinyint(4) NULL COMMENT “小整数扩展字段17”,
attribute_tinyint18 tinyint(4) NULL COMMENT “小整数扩展字段18”,
attribute_tinyint19 tinyint(4) NULL COMMENT “小整数扩展字段19”,
attribute_tinyint20 tinyint(4) NULL COMMENT “小整数扩展字段20”,
attribute_decimal1 decimal128(38, 10) NULL COMMENT “小数扩展字段1”,
attribute_decimal2 decimal128(38, 10) NULL COMMENT “小数扩展字段2”,
attribute_decimal3 decimal128(38, 10) NULL COMMENT “小数扩展字段3”,
attribute_decimal4 decimal128(38, 10) NULL COMMENT “小数扩展字段4”,
attribute_decimal5 decimal128(38, 10) NULL COMMENT “小数扩展字段5”,
attribute_decimal6 decimal128(38, 10) NULL COMMENT “小数扩展字段6”,
attribute_decimal7 decimal128(38, 10) NULL COMMENT “小数扩展字段7”,
attribute_decimal8 decimal128(38, 10) NULL COMMENT “小数扩展字段8”,
attribute_decimal9 decimal128(38, 10) NULL COMMENT “小数扩展字段9”,
attribute_decimal10 decimal128(38, 10) NULL COMMENT “小数扩展字段10”,
attribute_decimal11 decimal128(38, 10) NULL COMMENT “小数扩展字段11”,
attribute_decimal12 decimal128(38, 10) NULL COMMENT “小数扩展字段12”,
attribute_decimal13 decimal128(38, 10) NULL COMMENT “小数扩展字段13”,
attribute_decimal14 decimal128(38, 10) NULL COMMENT “小数扩展字段14”,
attribute_decimal15 decimal128(38, 10) NULL COMMENT “小数扩展字段15”,
attribute_decimal16 decimal128(38, 10) NULL COMMENT “小数扩展字段16”,
attribute_decimal17 decimal128(38, 10) NULL COMMENT “小数扩展字段17”,
attribute_decimal18 decimal128(38, 10) NULL COMMENT “小数扩展字段18”,
attribute_decimal19 decimal128(38, 10) NULL COMMENT “小数扩展字段19”,
attribute_decimal20 decimal128(38, 10) NULL COMMENT “小数扩展字段20”,
attribute_decimal21 decimal128(38, 10) NULL COMMENT “小数扩展字段21”,
attribute_decimal22 decimal128(38, 10) NULL COMMENT “小数扩展字段22”,
attribute_decimal23 decimal128(38, 10) NULL COMMENT “小数扩展字段23”,
attribute_decimal24 decimal128(38, 10) NULL COMMENT “小数扩展字段24”,
attribute_decimal25 decimal128(38, 10) NULL COMMENT “小数扩展字段25”,
attribute_decimal26 decimal128(38, 10) NULL COMMENT “小数扩展字段26”,
attribute_decimal27 decimal128(38, 10) NULL COMMENT “小数扩展字段27”,
attribute_decimal28 decimal128(38, 10) NULL COMMENT “小数扩展字段28”,
attribute_decimal29 decimal128(38, 10) NULL COMMENT “小数扩展字段29”,
attribute_decimal30 decimal128(38, 10) NULL COMMENT “小数扩展字段30”,
attribute_datetime1 datetime NULL COMMENT “日期时间扩展字段1”,
attribute_datetime2 datetime NULL COMMENT “日期时间扩展字段2”,
attribute_datetime3 datetime NULL COMMENT “日期时间扩展字段3”,
attribute_datetime4 datetime NULL COMMENT “日期时间扩展字段4”,
attribute_datetime5 datetime NULL COMMENT “日期时间扩展字段5”,
attribute_datetime6 datetime NULL COMMENT “日期时间扩展字段6”,
attribute_datetime7 datetime NULL COMMENT “日期时间扩展字段7”,
attribute_datetime8 datetime NULL COMMENT “日期时间扩展字段8”,
attribute_datetime9 datetime NULL COMMENT “日期时间扩展字段9”,
attribute_datetime10 datetime NULL COMMENT “日期时间扩展字段10”,
attribute_datetime11 datetime NULL COMMENT “日期时间扩展字段11”,
attribute_datetime12 datetime NULL COMMENT “日期时间扩展字段12”,
attribute_datetime13 datetime NULL COMMENT “日期时间扩展字段13”,
attribute_datetime14 datetime NULL COMMENT “日期时间扩展字段14”,
attribute_datetime15 datetime NULL COMMENT “日期时间扩展字段15”,
attribute_datetime16 datetime NULL COMMENT “日期时间扩展字段16”,
attribute_datetime17 datetime NULL COMMENT “日期时间扩展字段17”,
attribute_datetime18 datetime NULL COMMENT “日期时间扩展字段18”,
attribute_datetime19 datetime NULL COMMENT “日期时间扩展字段19”,
attribute_datetime20 datetime NULL COMMENT “日期时间扩展字段20”,
attribute_date1 date NULL COMMENT “日期扩展字段1”,
attribute_date2 date NULL COMMENT “日期扩展字段2”,
attribute_date3 date NULL COMMENT “日期扩展字段3”,
attribute_date4 date NULL COMMENT “日期扩展字段4”,
attribute_date5 date NULL COMMENT “日期扩展字段5”,
attribute_date6 date NULL COMMENT “日期扩展字段6”,
attribute_date7 date NULL COMMENT “日期扩展字段7”,
attribute_date8 date NULL COMMENT “日期扩展字段8”,
attribute_date9 date NULL COMMENT “日期扩展字段9”,
attribute_date10 date NULL COMMENT “日期扩展字段10”,
attribute_date11 date NULL COMMENT “日期扩展字段11”,
attribute_date12 date NULL COMMENT “日期扩展字段12”,
attribute_date13 date NULL COMMENT “日期扩展字段13”,
attribute_date14 date NULL COMMENT “日期扩展字段14”,
attribute_date15 date NULL COMMENT “日期扩展字段15”,
attribute_date16 date NULL COMMENT “日期扩展字段16”,
attribute_date17 date NULL COMMENT “日期扩展字段17”,
attribute_date18 date NULL COMMENT “日期扩展字段18”,
attribute_date19 date NULL COMMENT “日期扩展字段19”,
attribute_date20 date NULL COMMENT “日期扩展字段20”,
settle_flag tinyint(4) NULL COMMENT “是否推送结算平台标识”,
finance_reverse_code varchar(65533) NULL COMMENT “”,
auto_receive_rule varchar(65533) NULL COMMENT “单据自动生成规则（自动收货）,SINV.AUTO_RECEIVE_RULE”,
asn_match_rule varchar(65533) NULL COMMENT “匹配送货单规则 FUZZY/EXACT(模糊匹配/精确匹配)”,
over_receive_flag tinyint(4) NULL COMMENT “允许超量收货标识”,
parallel_strategy_header_ids varchar(65533) NULL COMMENT “并行策略头id集合”,
returned_approve_rule varchar(65533) NULL COMMENT “退货审批规则”,
return_asn_match_rule varchar(65533) NULL COMMENT “退货匹配送货单规则 FUZZY/EXACT(模糊匹配/精确匹配)”,
asn_receive_rule varchar(65533) NULL COMMENT “送货单接收规则(无条件控制、非关闭行、非取消行、非关闭非取消行)”,
po_receive_rule varchar(65533) NULL COMMENT “订单接收规则，支持多选然后逗号拼接(值集：SINV_STRATEGY_PO_RECEIVE_RULE)”,
slod_receive_rule varchar(65533) NULL COMMENT “发货单接收规则，支持多选然后逗号拼接(值集：SINV.SLOD_RECEIVE_RULE)”,
export_outsource_flag tinyint(4) NULL COMMENT “当前节点收货数据推送委外协同工作台：是/否（默认否）”,
coop_flag tinyint(4) NULL COMMENT “启用交互:是/否（默认否）”,
tail_difference_quantity decimal128(38, 10) NULL COMMENT “尾差数量”,
export_stock_flag tinyint(4) NULL COMMENT “导出至库存管理工作台:是/否（默认否）”,
storage_time datetime NULL COMMENT “创建时间”
) ENGINE=OLAP
PRIMARY KEY(strategy_line_id)
DISTRIBUTED BY HASH(strategy_line_id) BUCKETS 1
PROPERTIES (
“replication_num” = “3”,
“in_memory” = “false”,
“storage_format” = “DEFAULT”,
“enable_persistent_index” = “true”,
“replicated_storage” = “true”,
“compression” = “LZ4”
);
空表的执行计划：
PLAN FRAGMENT 0
OUTPUT EXPRS:10: expr | 11: expr | 1147: ifnull | 2285: ifnull | 3423: ifnull
PARTITION: HASH_PARTITIONED: 579: source_header_num, 580: source_line_num
RESULT SINK
111:Project
| <slot 10> : 10: expr
| <slot 11> : 11: expr
| <slot 1147> : 1147: ifnull
| <slot 2285> : 2285: ifnull
| <slot 3423> : ifnull(3421: count <= 0, 0)
|
110:HASH JOIN
| join op: LEFT OUTER JOIN (BUCKET_SHUFFLE(S))
| colocate: false, reason:
| equal join conjunct: 10: expr = 2853: source_header_num
| equal join conjunct: 11: expr = 2854: source_line_num
|
|----109:AGGREGATE (merge finalize)
| | output: count(3421: count)
| | group by: 2853: source_header_num, 2854: source_line_num
| |
| 108:EXCHANGE
|
77:Project
| <slot 10> : 10: expr
| <slot 11> : 11: expr
| <slot 1147> : 1147: ifnull
| <slot 2285> : ifnull(2283: count <= 0, 0)
|
76:HASH JOIN
| join op: LEFT OUTER JOIN (BUCKET_SHUFFLE(S))
| colocate: false, reason:
| equal join conjunct: 10: expr = 1715: source_header_num
| equal join conjunct: 11: expr = 1716: source_line_num
|
|----75:AGGREGATE (merge finalize)
| | output: count(2283: count)
| | group by: 1715: source_header_num, 1716: source_line_num
| |
| 74:EXCHANGE
|
43:Project
| <slot 10> : 10: expr
| <slot 11> : 11: expr
| <slot 1147> : ifnull(1145: count > 0, 0)
|
42:HASH JOIN
| join op: RIGHT OUTER JOIN (BUCKET_SHUFFLE(S))
| colocate: false, reason:
| equal join conjunct: 579: source_header_num = 10: expr
| equal join conjunct: 580: source_line_num = 11: expr
|
|----41:EXCHANGE
|
30:AGGREGATE (merge finalize)
| output: count(1145: count)
| group by: 579: source_header_num, 580: source_line_num
|
29:EXCHANGE
PLAN FRAGMENT 1
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 2831: order_link_id
STREAM DATA SINK
EXCHANGE ID: 108
HASH_PARTITIONED: 2853: source_header_num, 2854: source_line_num
107:AGGREGATE (update serialize)
| STREAMING
| output: count(*)
| group by: 2853: source_header_num, 2854: source_line_num
|
106:Project
| <slot 2853> : 2853: source_header_num
| <slot 2854> : 2854: source_line_num
|
105:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 2831: order_link_id = 2553: order_link_id
| equal join conjunct: 2846: tenant_id = 2288: tenant_id
|
|----104:EXCHANGE
|
79:EXCHANGE
PLAN FRAGMENT 2
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 2554: from_rcv_trx_line_id
STREAM DATA SINK
EXCHANGE ID: 104
HASH_PARTITIONED: 2553: order_link_id
103:Project
| <slot 2288> : 2288: tenant_id
| <slot 2553> : 2553: order_link_id
|
102:HASH JOIN
| join op: LEFT SEMI JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 2554: from_rcv_trx_line_id = 3101: rcv_trx_line_id
|
|----101:EXCHANGE
|
98:EXCHANGE
PLAN FRAGMENT 3
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 101
HASH_PARTITIONED: 3101: rcv_trx_line_id
100:Project
| <slot 3101> : 3101: rcv_trx_line_id
|
99:OlapScanNode
TABLE: sinv_rcv_trx_line
PREAGGREGATION: ON
PREDICATES: 3372: complete_flag = 0
partitions=0/1
rollup: sinv_rcv_trx_line
tabletRatio=0/0
tabletList=
cardinality=1
avgRowSize=9.0
numNodes=0
PLAN FRAGMENT 4
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 2287: rcv_trx_header_id
STREAM DATA SINK
EXCHANGE ID: 98
HASH_PARTITIONED: 2554: from_rcv_trx_line_id
97:Project
| <slot 2288> : 2288: tenant_id
| <slot 2553> : 2553: order_link_id
| <slot 2554> : 2554: from_rcv_trx_line_id
|
96:HASH JOIN
| join op: INNER JOIN (BUCKET_SHUFFLE(S))
| colocate: false, reason:
| equal join conjunct: 2287: rcv_trx_header_id = 2880: rcv_trx_header_id
| equal join conjunct: 2286: rcv_trx_line_id = 2894: rcv_trx_line_id
|
|----95:EXCHANGE
|
86:Project
| <slot 2286> : 2286: rcv_trx_line_id
| <slot 2287> : 2287: rcv_trx_header_id
| <slot 2288> : 2288: tenant_id
| <slot 2553> : 2553: order_link_id
| <slot 2554> : 2554: from_rcv_trx_line_id
|
85:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 2287: rcv_trx_header_id = 2604: rcv_trx_header_id
|
|----84:EXCHANGE
|
82:EXCHANGE
PLAN FRAGMENT 5
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 2881: strategy_line_id
STREAM DATA SINK
EXCHANGE ID: 95
HASH_PARTITIONED: 2880: rcv_trx_header_id
94:Project
| <slot 2880> : 2880: rcv_trx_header_id
| <slot 2894> : 2894: rcv_trx_line_id
|
93:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 2881: strategy_line_id = 2898: strategy_line_id
|
|----92:EXCHANGE
|
89:EXCHANGE
PLAN FRAGMENT 6
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 92
HASH_PARTITIONED: 2898: strategy_line_id
91:Project
| <slot 2898> : 2898: strategy_line_id
|
90:OlapScanNode
TABLE: sinv_rcv_strategy_line
PREAGGREGATION: ON
PREDICATES: 2905: node_config_id IN (12981, 12982, 12983, 12984, 12985, 12986, 14277, 14278, 14753, 14754, 14755, 14756, 14757, 14758)
partitions=0/1
rollup: sinv_rcv_strategy_line
tabletRatio=0/0
tabletList=
cardinality=1
avgRowSize=16.0
numNodes=0
PLAN FRAGMENT 7
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 89
HASH_PARTITIONED: 2881: strategy_line_id
88:Project
| <slot 2880> : 2880: rcv_trx_header_id
| <slot 2881> : 2881: strategy_line_id
| <slot 2894> : 2894: rcv_trx_line_id
|
87:OlapScanNode
TABLE: sinv_rcv_record_strategy_mapping
PREAGGREGATION: ON
PREDICATES: 2895: master_flag = 1
partitions=0/1
rollup: sinv_rcv_record_strategy_mapping
tabletRatio=0/0
tabletList=
cardinality=1
avgRowSize=25.0
numNodes=0
PLAN FRAGMENT 8
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 84
HASH_PARTITIONED: 2604: rcv_trx_header_id
83:OlapScanNode
TABLE: sinv_rcv_trx_header
PREAGGREGATION: ON
PREDICATES: 2604: rcv_trx_header_id IS NOT NULL
partitions=0/1
rollup: sinv_rcv_trx_header
tabletRatio=0/0
tabletList=
cardinality=1
avgRowSize=8.0
numNodes=0
PLAN FRAGMENT 9
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 82
HASH_PARTITIONED: 2287: rcv_trx_header_id
81:Project
| <slot 2286> : 2286: rcv_trx_line_id
| <slot 2287> : 2287: rcv_trx_header_id
| <slot 2288> : 2288: tenant_id
| <slot 2553> : 2553: order_link_id
| <slot 2554> : 2554: from_rcv_trx_line_id
|
80:OlapScanNode
TABLE: sinv_rcv_trx_line
PREAGGREGATION: ON
PREDICATES: 2288: tenant_id = 30, 2563: delete_flag = 0, 2342: reverse_flag = 0
partitions=0/1
rollup: sinv_rcv_trx_line
tabletRatio=0/0
tabletList=
cardinality=1
avgRowSize=42.0
numNodes=0
PLAN FRAGMENT 10
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 79
HASH_PARTITIONED: 2831: order_link_id
78:OlapScanNode
TABLE: sinv_rcv_trx_order_link
PREAGGREGATION: ON
PREDICATES: 2846: tenant_id = 30
partitions=0/1
rollup: sinv_rcv_trx_order_link
tabletRatio=0/0
tabletList=
cardinality=1
avgRowSize=29.384691
numNodes=0
PLAN FRAGMENT 11
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 1693: order_link_id
STREAM DATA SINK
EXCHANGE ID: 74
HASH_PARTITIONED: 1715: source_header_num, 1716: source_line_num
73:AGGREGATE (update serialize)
| STREAMING
| output: count(*)
| group by: 1715: source_header_num, 1716: source_line_num
|
72:Project
| <slot 1715> : 1715: source_header_num
| <slot 1716> : 1716: source_line_num
|
71:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 1693: order_link_id = 1415: order_link_id
| equal join conjunct: 1708: tenant_id = 1150: tenant_id
|
|----70:EXCHANGE
|
45:EXCHANGE
PLAN FRAGMENT 12
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 1416: from_rcv_trx_line_id
STREAM DATA SINK
EXCHANGE ID: 70
HASH_PARTITIONED: 1415: order_link_id
69:Project
| <slot 1150> : 1150: tenant_id
| <slot 1415> : 1415: order_link_id
|
68:HASH JOIN
| join op: LEFT SEMI JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 1416: from_rcv_trx_line_id = 1963: rcv_trx_line_id
|
|----67:EXCHANGE
|
64:EXCHANGE
PLAN FRAGMENT 13
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 67
HASH_PARTITIONED: 1963: rcv_trx_line_id
66:Project
| <slot 1963> : 1963: rcv_trx_line_id
|
65:OlapScanNode
TABLE: sinv_rcv_trx_line
PREAGGREGATION: ON
PREDICATES: 2234: complete_flag = 0
partitions=0/1
rollup: sinv_rcv_trx_line
tabletRatio=0/0
tabletList=
cardinality=1
avgRowSize=9.0
numNodes=0
PLAN FRAGMENT 14
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 1149: rcv_trx_header_id
STREAM DATA SINK
EXCHANGE ID: 64
HASH_PARTITIONED: 1416: from_rcv_trx_line_id
63:Project
| <slot 1150> : 1150: tenant_id
| <slot 1415> : 1415: order_link_id
| <slot 1416> : 1416: from_rcv_trx_line_id
|
62:HASH JOIN
| join op: INNER JOIN (BUCKET_SHUFFLE(S))
| colocate: false, reason:
| equal join conjunct: 1149: rcv_trx_header_id = 1742: rcv_trx_header_id
| equal join conjunct: 1148: rcv_trx_line_id = 1756: rcv_trx_line_id
|
|----61:EXCHANGE
|
52:Project
| <slot 1148> : 1148: rcv_trx_line_id
| <slot 1149> : 1149: rcv_trx_header_id
| <slot 1150> : 1150: tenant_id
| <slot 1415> : 1415: order_link_id
| <slot 1416> : 1416: from_rcv_trx_line_id
|
51:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 1149: rcv_trx_header_id = 1466: rcv_trx_header_id
|
|----50:EXCHANGE
|
48:EXCHANGE
PLAN FRAGMENT 15
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 1743: strategy_line_id
STREAM DATA SINK
EXCHANGE ID: 61
HASH_PARTITIONED: 1742: rcv_trx_header_id
60:Project
| <slot 1742> : 1742: rcv_trx_header_id
| <slot 1756> : 1756: rcv_trx_line_id
|
59:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 1743: strategy_line_id = 1760: strategy_line_id
|
|----58:EXCHANGE
|
55:EXCHANGE
PLAN FRAGMENT 16
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 58
HASH_PARTITIONED: 1760: strategy_line_id
57:Project
| <slot 1760> : 1760: strategy_line_id
|
56:OlapScanNode
TABLE: sinv_rcv_strategy_line
PREAGGREGATION: ON
PREDICATES: 1767: node_config_id IN (12981, 12984, 12983, 12985, 12986, 12982, 13781)
partitions=0/1
rollup: sinv_rcv_strategy_line
tabletRatio=0/0
tabletList=
cardinality=1
avgRowSize=16.0
numNodes=0
PLAN FRAGMENT 17
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 55
HASH_PARTITIONED: 1743: strategy_line_id
54:Project
| <slot 1742> : 1742: rcv_trx_header_id
| <slot 1743> : 1743: strategy_line_id
| <slot 1756> : 1756: rcv_trx_line_id
|
53:OlapScanNode
TABLE: sinv_rcv_record_strategy_mapping
PREAGGREGATION: ON
PREDICATES: 1757: master_flag = 1
partitions=0/1
rollup: sinv_rcv_record_strategy_mapping
tabletRatio=0/0
tabletList=
cardinality=1
avgRowSize=25.0
numNodes=0
PLAN FRAGMENT 18
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 50
HASH_PARTITIONED: 1466: rcv_trx_header_id
49:OlapScanNode
TABLE: sinv_rcv_trx_header
PREAGGREGATION: ON
PREDICATES: 1466: rcv_trx_header_id IS NOT NULL
partitions=0/1
rollup: sinv_rcv_trx_header
tabletRatio=0/0
tabletList=
cardinality=1
avgRowSize=8.0
numNodes=0
PLAN FRAGMENT 19
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 48
HASH_PARTITIONED: 1149: rcv_trx_header_id
47:Project
| <slot 1148> : 1148: rcv_trx_line_id
| <slot 1149> : 1149: rcv_trx_header_id
| <slot 1150> : 1150: tenant_id
| <slot 1415> : 1415: order_link_id
| <slot 1416> : 1416: from_rcv_trx_line_id
|
46:OlapScanNode
TABLE: sinv_rcv_trx_line
PREAGGREGATION: ON
PREDICATES: 1150: tenant_id = 30, 1425: delete_flag = 0, 1204: reverse_flag = 0
partitions=0/1
rollup: sinv_rcv_trx_line
tabletRatio=0/0
tabletList=
cardinality=1
avgRowSize=42.0
numNodes=0
PLAN FRAGMENT 20
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 45
HASH_PARTITIONED: 1693: order_link_id
44:OlapScanNode
TABLE: sinv_rcv_trx_order_link
PREAGGREGATION: ON
PREDICATES: 1708: tenant_id = 30
partitions=0/1
rollup: sinv_rcv_trx_order_link
tabletRatio=0/0
tabletList=
cardinality=1
avgRowSize=29.384691
numNodes=0
PLAN FRAGMENT 21
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 41
HASH_PARTITIONED: 10: expr, 11: expr
31:UNION
|
|----37:EXCHANGE
|
|----40:EXCHANGE
|
34:EXCHANGE
PLAN FRAGMENT 22
OUTPUT EXPRS:
PARTITION: UNPARTITIONED
STREAM DATA SINK
EXCHANGE ID: 40
RANDOM
39:Project
| <slot 8> : ‘PO20230711000009’
| <slot 9> : ‘1’
|
38:UNION
constant exprs:
NULL
PLAN FRAGMENT 23
OUTPUT EXPRS:
PARTITION: UNPARTITIONED
STREAM DATA SINK
EXCHANGE ID: 37
RANDOM
36:Project
| <slot 5> : ‘PO20230711000003’
| <slot 6> : ‘1’
|
35:UNION
constant exprs:
NULL
PLAN FRAGMENT 24
OUTPUT EXPRS:
PARTITION: UNPARTITIONED
STREAM DATA SINK
EXCHANGE ID: 34
RANDOM
33:Project
| <slot 2> : ‘20230616004-1’
| <slot 3> : ‘20’
|
32:UNION
constant exprs:
NULL
PLAN FRAGMENT 25
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 280: from_rcv_trx_line_id
STREAM DATA SINK
EXCHANGE ID: 29
HASH_PARTITIONED: 579: source_header_num, 580: source_line_num
28:AGGREGATE (update serialize)
| STREAMING
| output: count(*)
| group by: 579: source_header_num, 580: source_line_num
|
27:Project
| <slot 579> : 579: source_header_num
| <slot 580> : 580: source_line_num
|
26:HASH JOIN
| join op: LEFT OUTER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 280: from_rcv_trx_line_id = 827: rcv_trx_line_id
| other predicates: ((1098: complete_flag = 0) OR ((283: complete_flag = 0) AND (609: next_strategy_line_id IS NOT NULL))) OR (((283: complete_flag = 0) AND (609: next_strategy_line_id IS NULL)) AND (370: rcv_status_code != ‘40_FINISHED’))
|
|----25:EXCHANGE
|
23:EXCHANGE
PLAN FRAGMENT 26
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 25
HASH_PARTITIONED: 827: rcv_trx_line_id
24:OlapScanNode
TABLE: sinv_rcv_trx_line
PREAGGREGATION: ON
partitions=0/1
rollup: sinv_rcv_trx_line
tabletRatio=0/0
tabletList=
cardinality=1
avgRowSize=9.0
numNodes=0
PLAN FRAGMENT 27
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 13: rcv_trx_header_id
STREAM DATA SINK
EXCHANGE ID: 23
HASH_PARTITIONED: 280: from_rcv_trx_line_id
22:Project
| <slot 280> : 280: from_rcv_trx_line_id
| <slot 283> : 283: complete_flag
| <slot 370> : 370: rcv_status_code
| <slot 579> : 579: source_header_num
| <slot 580> : 580: source_line_num
| <slot 609> : 609: next_strategy_line_id
|
21:HASH JOIN
| join op: INNER JOIN (BUCKET_SHUFFLE(S))
| colocate: false, reason:
| equal join conjunct: 13: rcv_trx_header_id = 606: rcv_trx_header_id
| equal join conjunct: 12: rcv_trx_line_id = 620: rcv_trx_line_id
|
|----20:EXCHANGE
|
11:Project
| <slot 12> : 12: rcv_trx_line_id
| <slot 13> : 13: rcv_trx_header_id
| <slot 280> : 280: from_rcv_trx_line_id
| <slot 283> : 283: complete_flag
| <slot 370> : 370: rcv_status_code
| <slot 579> : 579: source_header_num
| <slot 580> : 580: source_line_num
|
10:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 13: rcv_trx_header_id = 330: rcv_trx_header_id
|
|----9:EXCHANGE
|
7:EXCHANGE
PLAN FRAGMENT 28
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 607: strategy_line_id
STREAM DATA SINK
EXCHANGE ID: 20
HASH_PARTITIONED: 606: rcv_trx_header_id
19:Project
| <slot 606> : 606: rcv_trx_header_id
| <slot 609> : 609: next_strategy_line_id
| <slot 620> : 620: rcv_trx_line_id
|
18:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 607: strategy_line_id = 624: strategy_line_id
|
|----17:EXCHANGE
|
14:EXCHANGE
PLAN FRAGMENT 29
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 17
HASH_PARTITIONED: 624: strategy_line_id
16:Project
| <slot 624> : 624: strategy_line_id
|
15:OlapScanNode
TABLE: sinv_rcv_strategy_line
PREAGGREGATION: ON
PREDICATES: 631: node_config_id IN (12981, 12984, 12983, 12985, 12986, 12982, 13781)
partitions=0/1
rollup: sinv_rcv_strategy_line
tabletRatio=0/0
tabletList=
cardinality=1
avgRowSize=16.0
numNodes=0
PLAN FRAGMENT 30
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 14
HASH_PARTITIONED: 607: strategy_line_id
13:Project
| <slot 606> : 606: rcv_trx_header_id
| <slot 607> : 607: strategy_line_id
| <slot 609> : 609: next_strategy_line_id
| <slot 620> : 620: rcv_trx_line_id
|
12:OlapScanNode
TABLE: sinv_rcv_record_strategy_mapping
PREAGGREGATION: ON
PREDICATES: 621: master_flag = 1
partitions=0/1
rollup: sinv_rcv_record_strategy_mapping
tabletRatio=0/0
tabletList=
cardinality=1
avgRowSize=33.0
numNodes=0
PLAN FRAGMENT 31
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 09
HASH_PARTITIONED: 330: rcv_trx_header_id
8:OlapScanNode
TABLE: sinv_rcv_trx_header
PREAGGREGATION: ON
PREDICATES: 330: rcv_trx_header_id IS NOT NULL
partitions=0/1
rollup: sinv_rcv_trx_header
tabletRatio=0/0
tabletList=
cardinality=1
avgRowSize=17.87149
numNodes=0
PLAN FRAGMENT 32
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 279: order_link_id
STREAM DATA SINK
EXCHANGE ID: 07
HASH_PARTITIONED: 13: rcv_trx_header_id
6:Project
| <slot 12> : 12: rcv_trx_line_id
| <slot 13> : 13: rcv_trx_header_id
| <slot 280> : 280: from_rcv_trx_line_id
| <slot 283> : 283: complete_flag
| <slot 579> : 579: source_header_num
| <slot 580> : 580: source_line_num
|
5:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 279: order_link_id = 557: order_link_id
| equal join conjunct: 14: tenant_id = 572: tenant_id
|
|----4:EXCHANGE
|
2:EXCHANGE
PLAN FRAGMENT 33
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 04
HASH_PARTITIONED: 557: order_link_id
3:OlapScanNode
TABLE: sinv_rcv_trx_order_link
PREAGGREGATION: ON
PREDICATES: 572: tenant_id = 30
partitions=0/1
rollup: sinv_rcv_trx_order_link
tabletRatio=0/0
tabletList=
cardinality=1
avgRowSize=29.384691
numNodes=0
PLAN FRAGMENT 34
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 02
HASH_PARTITIONED: 279: order_link_id
1:Project
| <slot 12> : 12: rcv_trx_line_id
| <slot 13> : 13: rcv_trx_header_id
| <slot 14> : 14: tenant_id
| <slot 279> : 279: order_link_id
| <slot 280> : 280: from_rcv_trx_line_id
| <slot 283> : 283: complete_flag
|
0:OlapScanNode
TABLE: sinv_rcv_trx_line
PREAGGREGATION: ON
PREDICATES: 14: tenant_id = 30, 289: delete_flag = 0, 68: reverse_flag = 0
partitions=0/1
rollup: sinv_rcv_trx_line
tabletRatio=0/0
tabletList=
cardinality=1
avgRowSize=43.0
numNodes=0
带数据的执行计划：
PLAN FRAGMENT 0
OUTPUT EXPRS:10: expr | 11: expr | 1147: ifnull | 2285: ifnull | 3423: ifnull
PARTITION: UNPARTITIONED
RESULT SINK
101:EXCHANGE
PLAN FRAGMENT 1
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 2853: source_header_num, 2854: source_line_num
STREAM DATA SINK
EXCHANGE ID: 101
UNPARTITIONED
100:Project
| <slot 10> : 10: expr
| <slot 11> : 11: expr
| <slot 1147> : 1147: ifnull
| <slot 2285> : 2285: ifnull
| <slot 3423> : ifnull(3421: count <= 0, 0)
|
99:HASH JOIN
| join op: RIGHT OUTER JOIN (BUCKET_SHUFFLE(S))
| colocate: false, reason:
| equal join conjunct: 2853: source_header_num = 10: expr
| equal join conjunct: 2854: source_line_num = 11: expr
|
|----98:Project
| | <slot 10> : 10: expr
| | <slot 11> : 11: expr
| | <slot 1147> : 1147: ifnull
| | <slot 2285> : ifnull(2283: count <= 0, 0)
| |
| 97:HASH JOIN
| | join op: RIGHT OUTER JOIN (BUCKET_SHUFFLE(S))
| | colocate: false, reason:
| | equal join conjunct: 1715: source_header_num = 10: expr
| | equal join conjunct: 1716: source_line_num = 11: expr
| |
| |----96:Project
| | | <slot 10> : 10: expr
| | | <slot 11> : 11: expr
| | | <slot 1147> : ifnull(1145: count > 0, 0)
| | |
| | 95:HASH JOIN
| | | join op: RIGHT OUTER JOIN (BUCKET_SHUFFLE(S))
| | | colocate: false, reason:
| | | equal join conjunct: 579: source_header_num = 10: expr
| | | equal join conjunct: 580: source_line_num = 11: expr
| | |
| | |----94:EXCHANGE
| | |
| | 83:AGGREGATE (merge finalize)
| | | output: count(1145: count)
| | | group by: 579: source_header_num, 580: source_line_num
| | |
| | 82:EXCHANGE
| |
| 55:AGGREGATE (merge finalize)
| | output: count(2283: count)
| | group by: 1715: source_header_num, 1716: source_line_num
| |
| 54:EXCHANGE
|
27:AGGREGATE (merge finalize)
| output: count(3421: count)
| group by: 2853: source_header_num, 2854: source_line_num
|
26:EXCHANGE
PLAN FRAGMENT 2
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 94
HASH_PARTITIONED: 10: expr, 11: expr
84:UNION
|
|----90:EXCHANGE
|
|----93:EXCHANGE
|
87:EXCHANGE
PLAN FRAGMENT 3
OUTPUT EXPRS:
PARTITION: UNPARTITIONED
STREAM DATA SINK
EXCHANGE ID: 93
RANDOM
92:Project
| <slot 8> : ‘PO20230711000009’
| <slot 9> : ‘1’
|
91:UNION
constant exprs:
NULL
PLAN FRAGMENT 4
OUTPUT EXPRS:
PARTITION: UNPARTITIONED
STREAM DATA SINK
EXCHANGE ID: 90
RANDOM
89:Project
| <slot 5> : ‘PO20230711000003’
| <slot 6> : ‘1’
|
88:UNION
constant exprs:
NULL
PLAN FRAGMENT 5
OUTPUT EXPRS:
PARTITION: UNPARTITIONED
STREAM DATA SINK
EXCHANGE ID: 87
RANDOM
86:Project
| <slot 2> : ‘20230616004-1’
| <slot 3> : ‘20’
|
85:UNION
constant exprs:
NULL
PLAN FRAGMENT 6
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 82
HASH_PARTITIONED: 579: source_header_num, 580: source_line_num
81:AGGREGATE (update serialize)
| STREAMING
| output: count(*)
| group by: 579: source_header_num, 580: source_line_num
|
80:Project
| <slot 579> : 579: source_header_num
| <slot 580> : 580: source_line_num
|
79:HASH JOIN
| join op: RIGHT OUTER JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 827: rcv_trx_line_id = 280: from_rcv_trx_line_id
| other predicates: ((1098: complete_flag = 0) OR ((283: complete_flag = 0) AND (609: next_strategy_line_id IS NOT NULL))) OR (((283: complete_flag = 0) AND (609: next_strategy_line_id IS NULL)) AND (370: rcv_status_code != ‘40_FINISHED’))
|
|----78:EXCHANGE
|
56:OlapScanNode
TABLE: sinv_rcv_trx_line
PREAGGREGATION: ON
partitions=1/1
rollup: sinv_rcv_trx_line
tabletRatio=72/72
tabletList=28275,28279,28283,28287,28291,28295,28299,28303,28307,28311 …
cardinality=3279791
avgRowSize=9.0
numNodes=0
PLAN FRAGMENT 7
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 78
BUCKET_SHUFFLE_HASH_PARTITIONED: 280: from_rcv_trx_line_id
77:Project
| <slot 280> : 280: from_rcv_trx_line_id
| <slot 283> : 283: complete_flag
| <slot 370> : 370: rcv_status_code
| <slot 579> : 579: source_header_num
| <slot 580> : 580: source_line_num
| <slot 609> : 609: next_strategy_line_id
|
76:HASH JOIN
| join op: INNER JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 330: rcv_trx_header_id = 13: rcv_trx_header_id
|
|----75:EXCHANGE
|
57:OlapScanNode
TABLE: sinv_rcv_trx_header
PREAGGREGATION: ON
partitions=1/1
rollup: sinv_rcv_trx_header
tabletRatio=42/42
tabletList=28104,28108,28112,28116,28120,28124,28128,28132,28136,28140 …
cardinality=1205487
avgRowSize=17.873009
numNodes=0
PLAN FRAGMENT 8
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 75
BUCKET_SHUFFLE_HASH_PARTITIONED: 13: rcv_trx_header_id
74:Project
| <slot 13> : 13: rcv_trx_header_id
| <slot 280> : 280: from_rcv_trx_line_id
| <slot 283> : 283: complete_flag
| <slot 579> : 579: source_header_num
| <slot 580> : 580: source_line_num
| <slot 609> : 609: next_strategy_line_id
|
73:HASH JOIN
| join op: INNER JOIN (BROADCAST)
| colocate: false, reason:
| equal join conjunct: 557: order_link_id = 279: order_link_id
| equal join conjunct: 572: tenant_id = 14: tenant_id
|
|----72:EXCHANGE
|
58:OlapScanNode
TABLE: sinv_rcv_trx_order_link
PREAGGREGATION: ON
PREDICATES: 572: tenant_id = 30
partitions=1/1
rollup: sinv_rcv_trx_order_link
tabletRatio=2/2
tabletList=28566,28570
cardinality=4352
avgRowSize=29.355574
numNodes=0
PLAN FRAGMENT 9
OUTPUT EXPRS:
PARTITION: HASH_PARTITIONED: 606: rcv_trx_header_id, 620: rcv_trx_line_id
STREAM DATA SINK
EXCHANGE ID: 72
UNPARTITIONED
71:Project
| <slot 13> : 13: rcv_trx_header_id
| <slot 14> : 14: tenant_id
| <slot 279> : 279: order_link_id
| <slot 280> : 280: from_rcv_trx_line_id
| <slot 283> : 283: complete_flag
| <slot 609> : 609: next_strategy_line_id
|
70:HASH JOIN
| join op: INNER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 606: rcv_trx_header_id = 13: rcv_trx_header_id
| equal join conjunct: 620: rcv_trx_line_id = 12: rcv_trx_line_id
|
|----69:EXCHANGE
|
66:EXCHANGE
PLAN FRAGMENT 10
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 69
HASH_PARTITIONED: 13: rcv_trx_header_id, 12: rcv_trx_line_id
68:Project
| <slot 12> : 12: rcv_trx_line_id
| <slot 13> : 13: rcv_trx_header_id
| <slot 14> : 14: tenant_id
| <slot 279> : 279: order_link_id
| <slot 280> : 280: from_rcv_trx_line_id
| <slot 283> : 283: complete_flag
|
67:OlapScanNode
TABLE: sinv_rcv_trx_line
PREAGGREGATION: ON
PREDICATES: 14: tenant_id = 30, 289: delete_flag = 0, 68: reverse_flag = 0
partitions=1/1
rollup: sinv_rcv_trx_line
tabletRatio=72/72
tabletList=28275,28279,28283,28287,28291,28295,28299,28303,28307,28311 …
cardinality=2181
avgRowSize=43.0
numNodes=0
PLAN FRAGMENT 11
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 66
HASH_PARTITIONED: 606: rcv_trx_header_id, 620: rcv_trx_line_id
65:Project
| <slot 606> : 606: rcv_trx_header_id
| <slot 609> : 609: next_strategy_line_id
| <slot 620> : 620: rcv_trx_line_id
|
64:HASH JOIN
| join op: INNER JOIN (BROADCAST)
| colocate: false, reason:
| equal join conjunct: 607: strategy_line_id = 624: strategy_line_id
|
|----63:EXCHANGE
|
60:Project
| <slot 606> : 606: rcv_trx_header_id
| <slot 607> : 607: strategy_line_id
| <slot 609> : 609: next_strategy_line_id
| <slot 620> : 620: rcv_trx_line_id
|
59:OlapScanNode
TABLE: sinv_rcv_record_strategy_mapping
PREAGGREGATION: ON
PREDICATES: 621: master_flag = 1
partitions=1/1
rollup: sinv_rcv_record_strategy_mapping
tabletRatio=1/1
tabletList=28076
cardinality=1083786
avgRowSize=33.0
numNodes=0
PLAN FRAGMENT 12
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 63
UNPARTITIONED
62:Project
| <slot 624> : 624: strategy_line_id
|
61:OlapScanNode
TABLE: sinv_rcv_strategy_line
PREAGGREGATION: ON
PREDICATES: 631: node_config_id IN (12981, 12984, 12983, 12985, 12986, 12982, 13781)
partitions=1/1
rollup: sinv_rcv_strategy_line
tabletRatio=1/1
tabletList=28097
cardinality=17
avgRowSize=16.0
numNodes=0
PLAN FRAGMENT 13
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 54
HASH_PARTITIONED: 1715: source_header_num, 1716: source_line_num
53:AGGREGATE (update serialize)
| STREAMING
| output: count(*)
| group by: 1715: source_header_num, 1716: source_line_num
|
52:Project
| <slot 1715> : 1715: source_header_num
| <slot 1716> : 1716: source_line_num
|
51:HASH JOIN
| join op: INNER JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 1693: order_link_id = 1415: order_link_id
| equal join conjunct: 1708: tenant_id = 1150: tenant_id
|
|----50:EXCHANGE
|
28:OlapScanNode
TABLE: sinv_rcv_trx_order_link
PREAGGREGATION: ON
PREDICATES: 1708: tenant_id = 30
partitions=1/1
rollup: sinv_rcv_trx_order_link
tabletRatio=2/2
tabletList=28566,28570
cardinality=4352
avgRowSize=29.355574
numNodes=0
PLAN FRAGMENT 14
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 50
BUCKET_SHUFFLE_HASH_PARTITIONED: 1415: order_link_id
49:Project
| <slot 1150> : 1150: tenant_id
| <slot 1415> : 1415: order_link_id
|
48:HASH JOIN
| join op: INNER JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 1466: rcv_trx_header_id = 1149: rcv_trx_header_id
|
|----47:EXCHANGE
|
29:OlapScanNode
TABLE: sinv_rcv_trx_header
PREAGGREGATION: ON
partitions=1/1
rollup: sinv_rcv_trx_header
tabletRatio=42/42
tabletList=28104,28108,28112,28116,28120,28124,28128,28132,28136,28140 …
cardinality=1205487
avgRowSize=8.0
numNodes=0
PLAN FRAGMENT 15
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 47
BUCKET_SHUFFLE_HASH_PARTITIONED: 1149: rcv_trx_header_id
46:Project
| <slot 1149> : 1149: rcv_trx_header_id
| <slot 1150> : 1150: tenant_id
| <slot 1415> : 1415: order_link_id
|
45:HASH JOIN
| join op: INNER JOIN (BROADCAST)
| colocate: false, reason:
| equal join conjunct: 1743: strategy_line_id = 1760: strategy_line_id
|
|----44:EXCHANGE
|
41:Project
| <slot 1149> : 1149: rcv_trx_header_id
| <slot 1150> : 1150: tenant_id
| <slot 1415> : 1415: order_link_id
| <slot 1743> : 1743: strategy_line_id
|
40:HASH JOIN
| join op: INNER JOIN (BROADCAST)
| colocate: false, reason:
| equal join conjunct: 1742: rcv_trx_header_id = 1149: rcv_trx_header_id
| equal join conjunct: 1756: rcv_trx_line_id = 1148: rcv_trx_line_id
|
|----39:EXCHANGE
|
31:Project
| <slot 1742> : 1742: rcv_trx_header_id
| <slot 1743> : 1743: strategy_line_id
| <slot 1756> : 1756: rcv_trx_line_id
|
30:OlapScanNode
TABLE: sinv_rcv_record_strategy_mapping
PREAGGREGATION: ON
PREDICATES: 1757: master_flag = 1
partitions=1/1
rollup: sinv_rcv_record_strategy_mapping
tabletRatio=1/1
tabletList=28076
cardinality=1083786
avgRowSize=25.0
numNodes=0
PLAN FRAGMENT 16
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 44
UNPARTITIONED
43:Project
| <slot 1760> : 1760: strategy_line_id
|
42:OlapScanNode
TABLE: sinv_rcv_strategy_line
PREAGGREGATION: ON
PREDICATES: 1767: node_config_id IN (12981, 12984, 12983, 12985, 12986, 12982, 13781)
partitions=1/1
rollup: sinv_rcv_strategy_line
tabletRatio=1/1
tabletList=28097
cardinality=17
avgRowSize=16.0
numNodes=0
PLAN FRAGMENT 17
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 39
UNPARTITIONED
38:Project
| <slot 1148> : 1148: rcv_trx_line_id
| <slot 1149> : 1149: rcv_trx_header_id
| <slot 1150> : 1150: tenant_id
| <slot 1415> : 1415: order_link_id
|
37:HASH JOIN
| join op: RIGHT SEMI JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 1963: rcv_trx_line_id = 1416: from_rcv_trx_line_id
|
|----36:EXCHANGE
|
33:Project
| <slot 1963> : 1963: rcv_trx_line_id
|
32:OlapScanNode
TABLE: sinv_rcv_trx_line
PREAGGREGATION: ON
PREDICATES: 2234: complete_flag = 0
partitions=1/1
rollup: sinv_rcv_trx_line
tabletRatio=72/72
tabletList=28275,28279,28283,28287,28291,28295,28299,28303,28307,28311 …
cardinality=1093249
avgRowSize=9.0
numNodes=0
PLAN FRAGMENT 18
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 36
BUCKET_SHUFFLE_HASH_PARTITIONED: 1416: from_rcv_trx_line_id
35:Project
| <slot 1148> : 1148: rcv_trx_line_id
| <slot 1149> : 1149: rcv_trx_header_id
| <slot 1150> : 1150: tenant_id
| <slot 1415> : 1415: order_link_id
| <slot 1416> : 1416: from_rcv_trx_line_id
|
34:OlapScanNode
TABLE: sinv_rcv_trx_line
PREAGGREGATION: ON
PREDICATES: 1150: tenant_id = 30, 1425: delete_flag = 0, 1204: reverse_flag = 0
partitions=1/1
rollup: sinv_rcv_trx_line
tabletRatio=72/72
tabletList=28275,28279,28283,28287,28291,28295,28299,28303,28307,28311 …
cardinality=2181
avgRowSize=42.0
numNodes=0
PLAN FRAGMENT 19
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 26
HASH_PARTITIONED: 2853: source_header_num, 2854: source_line_num
25:AGGREGATE (update serialize)
| STREAMING
| output: count(*)
| group by: 2853: source_header_num, 2854: source_line_num
|
24:Project
| <slot 2853> : 2853: source_header_num
| <slot 2854> : 2854: source_line_num
|
23:HASH JOIN
| join op: INNER JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 2831: order_link_id = 2553: order_link_id
| equal join conjunct: 2846: tenant_id = 2288: tenant_id
|
|----22:EXCHANGE
|
0:OlapScanNode
TABLE: sinv_rcv_trx_order_link
PREAGGREGATION: ON
PREDICATES: 2846: tenant_id = 30
partitions=1/1
rollup: sinv_rcv_trx_order_link
tabletRatio=2/2
tabletList=28566,28570
cardinality=4352
avgRowSize=29.355574
numNodes=0
PLAN FRAGMENT 20
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 22
BUCKET_SHUFFLE_HASH_PARTITIONED: 2553: order_link_id
21:Project
| <slot 2288> : 2288: tenant_id
| <slot 2553> : 2553: order_link_id
|
20:HASH JOIN
| join op: INNER JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 2604: rcv_trx_header_id = 2287: rcv_trx_header_id
|
|----19:EXCHANGE
|
1:OlapScanNode
TABLE: sinv_rcv_trx_header
PREAGGREGATION: ON
partitions=1/1
rollup: sinv_rcv_trx_header
tabletRatio=42/42
tabletList=28104,28108,28112,28116,28120,28124,28128,28132,28136,28140 …
cardinality=1205487
avgRowSize=8.0
numNodes=0
PLAN FRAGMENT 21
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 19
BUCKET_SHUFFLE_HASH_PARTITIONED: 2287: rcv_trx_header_id
18:Project
| <slot 2287> : 2287: rcv_trx_header_id
| <slot 2288> : 2288: tenant_id
| <slot 2553> : 2553: order_link_id
|
17:HASH JOIN
| join op: INNER JOIN (BROADCAST)
| colocate: false, reason:
| equal join conjunct: 2881: strategy_line_id = 2898: strategy_line_id
|
|----16:EXCHANGE
|
13:Project
| <slot 2287> : 2287: rcv_trx_header_id
| <slot 2288> : 2288: tenant_id
| <slot 2553> : 2553: order_link_id
| <slot 2881> : 2881: strategy_line_id
|
12:HASH JOIN
| join op: INNER JOIN (BROADCAST)
| colocate: false, reason:
| equal join conjunct: 2880: rcv_trx_header_id = 2287: rcv_trx_header_id
| equal join conjunct: 2894: rcv_trx_line_id = 2286: rcv_trx_line_id
|
|----11:EXCHANGE
|
3:Project
| <slot 2880> : 2880: rcv_trx_header_id
| <slot 2881> : 2881: strategy_line_id
| <slot 2894> : 2894: rcv_trx_line_id
|
2:OlapScanNode
TABLE: sinv_rcv_record_strategy_mapping
PREAGGREGATION: ON
PREDICATES: 2895: master_flag = 1
partitions=1/1
rollup: sinv_rcv_record_strategy_mapping
tabletRatio=1/1
tabletList=28076
cardinality=1083786
avgRowSize=25.0
numNodes=0
PLAN FRAGMENT 22
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 16
UNPARTITIONED
15:Project
| <slot 2898> : 2898: strategy_line_id
|
14:OlapScanNode
TABLE: sinv_rcv_strategy_line
PREAGGREGATION: ON
PREDICATES: 2905: node_config_id IN (12981, 12982, 12983, 12984, 12985, 12986, 14277, 14278, 14753, 14754, 14755, 14756, 14757, 14758)
partitions=1/1
rollup: sinv_rcv_strategy_line
tabletRatio=1/1
tabletList=28097
cardinality=33
avgRowSize=16.0
numNodes=0
PLAN FRAGMENT 23
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 11
UNPARTITIONED
10:Project
| <slot 2286> : 2286: rcv_trx_line_id
| <slot 2287> : 2287: rcv_trx_header_id
| <slot 2288> : 2288: tenant_id
| <slot 2553> : 2553: order_link_id
|
9:HASH JOIN
| join op: RIGHT SEMI JOIN (BUCKET_SHUFFLE)
| colocate: false, reason:
| equal join conjunct: 3101: rcv_trx_line_id = 2554: from_rcv_trx_line_id
|
|----8:EXCHANGE
|
5:Project
| <slot 3101> : 3101: rcv_trx_line_id
|
4:OlapScanNode
TABLE: sinv_rcv_trx_line
PREAGGREGATION: ON
PREDICATES: 3372: complete_flag = 0
partitions=1/1
rollup: sinv_rcv_trx_line
tabletRatio=72/72
tabletList=28275,28279,28283,28287,28291,28295,28299,28303,28307,28311 …
cardinality=1093249
avgRowSize=9.0
numNodes=0
PLAN FRAGMENT 24
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 08
BUCKET_SHUFFLE_HASH_PARTITIONED: 2554: from_rcv_trx_line_id
7:Project
| <slot 2286> : 2286: rcv_trx_line_id
| <slot 2287> : 2287: rcv_trx_header_id
| <slot 2288> : 2288: tenant_id
| <slot 2553> : 2553: order_link_id
| <slot 2554> : 2554: from_rcv_trx_line_id
|
6:OlapScanNode
TABLE: sinv_rcv_trx_line
PREAGGREGATION: ON
PREDICATES: 2288: tenant_id = 30, 2563: delete_flag = 0, 2342: reverse_flag = 0
partitions=1/1
rollup: sinv_rcv_trx_line
tabletRatio=72/72
tabletList=28275,28279,28283,28287,28291,28295,28299,28303,28307,28311 …
cardinality=2181
avgRowSize=42.0
numNodes=0
好的 我来跟进下 您执行这个sql稳定复现的话 麻烦可以打开下core文件的生成开关生成一个core文件吗 这样定位起来更快捷一些
core文件是？