为了更快的定位您的问题，请提供以下信息，谢谢
【详述】问题详细描述
日志显示: error_msg=Cancelled by pipeline engine
表中分区: 一大堆分区是空的 但是也有部分数据成功写入了
表数据量: 完全写入的数据量是2亿 实际写入6000万
be.INFO.log.20250708-034826:I20250708 11:18:40.417494 140680292570688 local_tablets_channel.cpp:933] LocalTabletsChannel txn_id: 46378701 load_id: 22b71306-5ba5-11f0-bde4-0242f591ea1f sink_id: 0 incremental open delta writer: [395919630:1][395919633:2]
be.INFO.log.20250708-034826:I20250708 11:18:45.869036 140680326141504 local_tablets_channel.cpp:933] LocalTabletsChannel txn_id: 46378701 load_id: 22b71306-5ba5-11f0-bde4-0242f591ea1f sink_id: 0 incremental open delta writer: [395921875:1][395921878:1]
be.INFO.log.20250708-034826:I20250708 11:19:08.163632 140680292570688 local_tablets_channel.cpp:933] LocalTabletsChannel txn_id: 46378701 load_id: 22b71306-5ba5-11f0-bde4-0242f591ea1f sink_id: 0 incremental open delta writer: [395926729:2][395926732:1]
be.INFO.log.20250708-034826:I20250708 11:19:09.689755 140680342926912 local_tablets_channel.cpp:933] LocalTabletsChannel txn_id: 46378701 load_id: 22b71306-5ba5-11f0-bde4-0242f591ea1f sink_id: 0 incremental open delta writer: [395926782:1][395926785:1]
be.INFO.log.20250708-034826:I20250708 11:19:19.450425 140680334534208 local_tablets_channel.cpp:933] LocalTabletsChannel txn_id: 46378701 load_id: 22b71306-5ba5-11f0-bde4-0242f591ea1f sink_id: 0 incremental open delta writer: [395927188:1][395927191:1]
be.INFO.log.20250708-034826:I20250708 11:19:19.824251 140680317748800 local_tablets_channel.cpp:933] LocalTabletsChannel txn_id: 46378701 load_id: 22b71306-5ba5-11f0-bde4-0242f591ea1f sink_id: 0 incremental open delta writer: [395927213:2][395927216:1]
be.INFO.log.20250708-034826:I20250708 11:19:20.335360 140680292570688 local_tablets_channel.cpp:933] LocalTabletsChannel txn_id: 46378701 load_id: 22b71306-5ba5-11f0-bde4-0242f591ea1f sink_id: 0 incremental open delta writer: [395927234:2][395927237:1]
be.INFO.log.20250708-034826:I20250708 11:19:22.131330 140680326141504 local_tablets_channel.cpp:933] LocalTabletsChannel txn_id: 46378701 load_id: 22b71306-5ba5-11f0-bde4-0242f591ea1f sink_id: 0 incremental open delta writer: [395927296:2][395927299:1]
be.INFO.log.20250708-034826:I20250708 11:19:28.824170 140558569813568 tablet_sink.cpp:414] load_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701automatic partition rpc begin request TCreatePartitionRequest(txn_id=46378701, db_id=10379, table_id=395837166, partition_values=[[yxfz_174579], [xcxx_077128]])
be.INFO.log.20250708-034826:I20250708 11:19:28.833071 140558569813568 tablet_sink.cpp:434] load_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701automatic partition rpc end response TCreatePartitionResult(status=TStatus(status_code=OK, error_msgs=), partitions=[TOlapTablePartition(id=395927187, start_key=, end_key=, num_buckets=3, ind
exes=[TOlapTableIndexTablets(index_id=395837167, tablets=[395927188, 395927191, 395927194])], start_keys=, end_keys=, in_keys=[[TExprNode(node_type=STRING_LITERAL, type=TTypeDesc(types=[TTypeNode(type=SCALAR, scalar_type=TScalarType(type=VARCHAR, len=-1, precision=, scale=), struct_fields=, is_named=)]), opcode=, num_c
hildren=0, agg_expr=, bool_literal=, case_expr=, date_literal=, float_literal=, int_literal=, in_predicate=, is_null_pred=, like_pred=, literal_pred=, slot_ref=, string_literal=TStringLiteral(value=yxfz_174579), tuple_is_null_pred=, info_func=, decimal_literal=, output_scale=-1
, fn_call_expr=, large_int_literal=, output_column=, output_type=, vector_opcode=, fn=, vararg_start_idx=, child_type=, vslot_ref=, used_subfield_names=, binary_literal=, copy_flag=, check_is_out_of_bounds=, use_vectorized=, has_nullable_child=0, is_nullable=0, child_type_desc=
, is_monotonic=1, dict_query_expr=, dictionary_get_expr=, is_index_only_filter=0)]], is_shadow_partition=0), TOlapTablePartition(id=395926781, start_key=, end_key=, num_buckets=3, indexes=[TOlapTableIndexTablets(index_id=395837167, tablets=[395926782, 395926785, 395926788])], start_keys=, end_keys=, in_keys=[[TExprNode
(node_type=STRING_LITERAL, type=TTypeDesc(types=[TTypeNode(type=SCALAR, scalar_type=TScalarType(type=VARCHAR, len=-1, precision=, scale=), struct_fields=, is_named=)]), opcode=, num_children=0, agg_expr=, bool_literal=, case_expr=, date_literal=, float_literal=, int_literal=, in_predicate=
, is_null_pred=, like_pred=, literal_pred=, slot_ref=, string_literal=TStringLiteral(value=xcxx_077128), tuple_is_null_pred=, info_func=, decimal_literal=, output_scale=-1, fn_call_expr=, large_int_literal=, output_column=, output_type=, vector_opcode=, fn=, vararg_start_idx=,
child_type=, vslot_ref=, used_subfield_names=, binary_literal=, copy_flag=, check_is_out_of_bounds=, use_vectorized=, has_nullable_child=0, is_nullable=0, child_type_desc=, is_monotonic=1, dict_query_expr=, dictionary_get_expr=, is_index_only_filter=0)]], is_shadow_partition=0)], tablets=[TTabletLocat
ion(tablet_id=395927188, node_ids=[10002, 10003]), TTabletLocation(tablet_id=395927191, node_ids=[10002, 10001]), TTabletLocation(tablet_id=395927194, node_ids=[10003, 10001]), TTabletLocation(tablet_id=395926782, node_ids=[10002, 10003]), TTabletLocation(tablet_id=395926785, node_ids=[10002, 10001]), TTabletLocation(tablet_id=395926788, node_ids=[10001, 10003
])], nodes=[TNodeInfo(id=10001, option=0, host=172.17.9.108, async_internal_port=8060), TNodeInfo(id=10002, option=0, host=172.17.9.106, async_internal_port=8060), TNodeInfo(id=10003, option=0, host=172.17.9.107, async_internal_port=8060)])
be.INFO.log.20250708-034826:I20250708 11:19:29.511829 140558569813568 tablet_sink.cpp:414] load_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701automatic partition rpc begin request TCreatePartitionRequest(txn_id=46378701, db_id=10379, table_id=395837166, partition_values=[[xjnxd_959693]])
be.INFO.log.20250708-034826:I20250708 11:19:29.515112 140558569813568 tablet_sink.cpp:434] load_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701automatic partition rpc end response TCreatePartitionResult(status=TStatus(status_code=OK, error_msgs=), partitions=[TOlapTablePartition(id=395926728, start_key=, end_key=, num_buckets=3, ind
exes=[TOlapTableIndexTablets(index_id=395837167, tablets=[395926729, 395926732, 395926735])], start_keys=, end_keys=, in_keys=[[TExprNode(node_type=STRING_LITERAL, type=TTypeDesc(types=[TTypeNode(type=SCALAR, scalar_type=TScalarType(type=VARCHAR, len=-1, precision=, scale=), struct_fields=, is_named=)]), opcode=, num_c
hildren=0, agg_expr=, bool_literal=, case_expr=, date_literal=, float_literal=, int_literal=, in_predicate=, is_null_pred=, like_pred=, literal_pred=, slot_ref=, string_literal=TStringLiteral(value=xjnxd_959693), tuple_is_null_pred=, info_func=, decimal_literal=, output_scale=-
1, fn_call_expr=, large_int_literal=, output_column=, output_type=, vector_opcode=, fn=, vararg_start_idx=, child_type=, vslot_ref=, used_subfield_names=, binary_literal=, copy_flag=, check_is_out_of_bounds=, use_vectorized=, has_nullable_child=0, is_nullable=0, child_type_desc
=, is_monotonic=1, dict_query_expr=, dictionary_get_expr=, is_index_only_filter=0)]], is_shadow_partition=0)], tablets=[TTabletLocation(tablet_id=395926729, node_ids=[10003, 10002]), TTabletLocation(tablet_id=395926732, node_ids=[10002, 10001]), TTabletLocation(tablet_id=395926735, node_ids=[10001, 10003])], nodes=[TNodeInfo(id=10001, option=
0, host=172.17.9.108, async_internal_port=8060), TNodeInfo(id=10002, option=0, host=172.17.9.106, async_internal_port=8060), TNodeInfo(id=10003, option=0, host=172.17.9.107, async_internal_port=8060)])
be.INFO.log.20250708-034826:I20250708 11:19:29.572230 140558569813568 tablet_sink.cpp:414] load_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701automatic partition rpc begin request TCreatePartitionRequest(txn_id=46378701, db_id=10379, table_id=395837166, partition_values=[[shsgf_722079], [ddhx_213010], [yljjdkqzzmd_706982], [qd_055922]])
be.INFO.log.20250708-034826:I20250708 11:19:29.612222 140558569813568 tablet_sink.cpp:434] load_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701automatic partition rpc end response TCreatePartitionResult(status=TStatus(status_code=OK, error_msgs=), partitions=[TOlapTablePartition(id=395927295, start_key=, end_key=, num_buckets=3, ind
exes=[TOlapTableIndexTablets(index_id=395837167, tablets=[395927296, 395927299, 395927302])], start_keys=, end_keys=, in_keys=[[TExprNode(node_type=STRING_LITERAL, type=TTypeDesc(types=[TTypeNode(type=SCALAR, scalar_type=TScalarType(type=VARCHAR, len=-1, precision=, scale=), struct_fields=, is_named=)]), opcode=, num_c
hildren=0, agg_expr=, bool_literal=, case_expr=, date_literal=, float_literal=, int_literal=, in_predicate=, is_null_pred=, like_pred=, literal_pred=, slot_ref=, string_literal=TStringLiteral(value=shsgf_722079), tuple_is_null_pred=, info_func=, decimal_literal=, output_scale=-
1, fn_call_expr=, large_int_literal=, output_column=, output_type=, vector_opcode=, fn=, vararg_start_idx=, child_type=, vslot_ref=, used_subfield_names=, binary_literal=, copy_flag=, check_is_out_of_bounds=, use_vectorized=, has_nullable_child=0, is_nullable=0, child_type_desc
=, is_monotonic=1, dict_query_expr=, dictionary_get_expr=, is_index_only_filter=0)]], is_shadow_partition=0), TOlapTablePartition(id=395927233, start_key=, end_key=, num_buckets=3, indexes=[TOlapTableIndexTablets(index_id=395837167, tablets=[395927234, 395927237, 395927240])], start_keys=, end_keys=, in_keys=[[TExprNod
e(node_type=STRING_LITERAL, type=TTypeDesc(types=[TTypeNode(type=SCALAR, scalar_type=TScalarType(type=VARCHAR, len=-1, precision=, scale=), struct_fields=, is_named=)]), opcode=, num_children=0, agg_expr=, bool_literal=, case_expr=, date_literal=, float_literal=, int_literal=, in_predicate=<null
, is_null_pred=, like_pred=, literal_pred=, slot_ref=, string_literal=TStringLiteral(value=ddhx_213010), tuple_is_null_pred=, info_func=, decimal_literal=, output_scale=-1, fn_call_expr=, large_int_literal=, output_column=, output_type=, vector_opcode=, fn=, vararg_start_idx=,
child_type=, vslot_ref=, used_subfield_names=, binary_literal=, copy_flag=, check_is_out_of_bounds=, use_vectorized=, has_nullable_child=0, is_nullable=0, child_type_desc=, is_monotonic=1, dict_query_expr=, dictionary_get_expr=, is_index_only_filter=0)]], is_shadow_partition=0), TOlapTablePartition(i
d=395927518, start_key=, end_key=, num_buckets=3, indexes=[TOlapTableIndexTablets(index_id=395837167, tablets=[395927519, 395927522, 395927525])], start_keys=, end_keys=, in_keys=[[TExprNode(node_type=STRING_LITERAL, type=TTypeDesc(types=[TTypeNode(type=SCALAR, scalar_type=TScalarType(type=VARCHAR, len=-1, precision=, scale=
), struct_fields=, is_named=)]), opcode=, num_children=0, agg_expr=, bool_literal=, case_expr=, date_literal=, float_literal=, int_literal=, in_predicate=, is_null_pred=, like_pred=, literal_pred=, slot_ref=, string_literal=TStringLiteral(value=yljjdkqzzmd_706982), tuple_is_nul
l_pred=, info_func=, decimal_literal=, output_scale=-1, fn_call_expr=, large_int_literal=, output_column=, output_type=, vector_opcode=, fn=, vararg_start_idx=, child_type=, vslot_ref=, used_subfield_names=, binary_literal=, copy_flag=, check_is_out_of_bounds=, use_
vectorized=, has_nullable_child=0, is_nullable=0, child_type_desc=, is_monotonic=1, dict_query_expr=, dictionary_get_expr=, is_index_only_filter=0)]], is_shadow_partition=0), TOlapTablePartition(id=395927528, start_key=, end_key=, num_buckets=3, indexes=[TOlapTableIndexTablets(index_id=395837167, tablets=[395927529, 39592753
2, 395927535])], start_keys=, end_keys=, in_keys=[[TExprNode(node_type=STRING_LITERAL, type=TTypeDesc(types=[TTypeNode(type=SCALAR, scalar_type=TScalarType(type=VARCHAR, len=-1, precision=, scale=), struct_fields=, is_named=)]), opcode=, num_children=0, agg_expr=, bool_literal=, case_expr=, date_liter
al=, float_literal=, int_literal=, in_predicate=, is_null_pred=, like_pred=, literal_pred=, slot_ref=, string_literal=TStringLiteral(value=qd_055922), tuple_is_null_pred=, info_func=, decimal_literal=, output_scale=-1, fn_call_expr=, large_int_literal=, output_column=, output_t
ype=, vector_opcode=, fn=, vararg_start_idx=, child_type=, vslot_ref=, used_subfield_names=, binary_literal=, copy_flag=, check_is_out_of_bounds=, use_vectorized=, has_nullable_child=0, is_nullable=0, child_type_desc=, is_monotonic=1, dict_query_expr=, dictionary_get_expr=, is_
index_only_filter=0)]], is_shadow_partition=0)], tablets=[TTabletLocation(tablet_id=395927296, node_ids=[10003, 10002]), TTabletLocation(tablet_id=395927299, node_ids=[10002, 10001]), TTabletLocation(tablet_id=395927302, node_ids=[10003, 10001]), TTabletLocation(tablet_id=395927234, node_ids=[10003, 10002]), TTabletLocation(tablet_id=395927237, node_ids=[10002
, 10001]), TTabletLocation(tablet_id=395927240, node_ids=[10003, 10001]), TTabletLocation(tablet_id=395927519, node_ids=[10003, 10002]), TTabletLocation(tablet_id=395927522, node_ids=[10002, 10001]), TTabletLocation(tablet_id=395927525, node_ids=[10003, 10001]), TTabletLocation(tablet_id=395927529, node_ids=[10002, 10003]), TTabletLocation(tablet_id=395927532,
node_ids=[10001, 10002]), TTabletLocation(tablet_id=395927535, node_ids=[10003, 10001])], nodes=[TNodeInfo(id=10001, option=0, host=172.17.9.108, async_internal_port=8060), TNodeInfo(id=10002, option=0, host=172.17.9.106, async_internal_port=8060), TNodeInfo(id=10003, option=0, host=172.17.9.107, async_internal_port=8060)])
be.INFO.log.20250708-034826:I20250708 11:19:29.631594 140680317748800 local_tablets_channel.cpp:933] LocalTabletsChannel txn_id: 46378701 load_id: 22b71306-5ba5-11f0-bde4-0242f591ea1f sink_id: 0 incremental open delta writer: [395927519:2][395927522:1][395927529:1][395927532:2]
be.INFO.log.20250708-034826:I20250708 11:19:29.966011 140558569813568 tablet_sink.cpp:414] load_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701automatic partition rpc begin request TCreatePartitionRequest(txn_id=46378701, db_id=10379, table_id=395837166, partition_values=[[bjxydhw_264036]])
be.INFO.log.20250708-034826:I20250708 11:19:30.048250 140558569813568 tablet_sink.cpp:434] load_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701automatic partition rpc end response TCreatePartitionResult(status=TStatus(status_code=OK, error_msgs=), partitions=[TOlapTablePartition(id=395927542, start_key=, end_key=, num_buckets=3, ind
exes=[TOlapTableIndexTablets(index_id=395837167, tablets=[395927543, 395927546, 395927549])], start_keys=, end_keys=, in_keys=[[TExprNode(node_type=STRING_LITERAL, type=TTypeDesc(types=[TTypeNode(type=SCALAR, scalar_type=TScalarType(type=VARCHAR, len=-1, precision=, scale=), struct_fields=, is_named=)]), opcode=, num_c
hildren=0, agg_expr=, bool_literal=, case_expr=, date_literal=, float_literal=, int_literal=, in_predicate=, is_null_pred=, like_pred=, literal_pred=, slot_ref=, string_literal=TStringLiteral(value=bjxydhw_264036), tuple_is_null_pred=, info_func=, decimal_literal=, output_scale
=-1, fn_call_expr=, large_int_literal=, output_column=, output_type=, vector_opcode=, fn=, vararg_start_idx=, child_type=, vslot_ref=, used_subfield_names=, binary_literal=, copy_flag=, check_is_out_of_bounds=, use_vectorized=, has_nullable_child=0, is_nullable=0, child_type_de
sc=, is_monotonic=1, dict_query_expr=, dictionary_get_expr=, is_index_only_filter=0)]], is_shadow_partition=0)], tablets=[TTabletLocation(tablet_id=395927543, node_ids=[10003, 10002]), TTabletLocation(tablet_id=395927546, node_ids=[10002, 10001]), TTabletLocation(tablet_id=395927549, node_ids=[10001, 10003])], nodes=[TNodeInfo(id=10001, optio
n=0, host=172.17.9.108, async_internal_port=8060), TNodeInfo(id=10002, option=0, host=172.17.9.106, async_internal_port=8060), TNodeInfo(id=10003, option=0, host=172.17.9.107, async_internal_port=8060)])
be.INFO.log.20250708-034826:I20250708 11:19:30.053894 140680334534208 local_tablets_channel.cpp:933] LocalTabletsChannel txn_id: 46378701 load_id: 22b71306-5ba5-11f0-bde4-0242f591ea1f sink_id: 0 incremental open delta writer: [395927543:2][395927546:1]
be.INFO.log.20250708-034826:I20250708 11:19:33.767563 140680326141504 local_tablets_channel.cpp:933] LocalTabletsChannel txn_id: 46378701 load_id: 22b71306-5ba5-11f0-bde4-0242f591ea1f sink_id: 0 incremental open delta writer: [395929203:1][395929206:1]
be.INFO.log.20250708-034826:I20250708 11:19:34.355734 140680284177984 local_tablets_channel.cpp:933] LocalTabletsChannel txn_id: 46378701 load_id: 22b71306-5ba5-11f0-bde4-0242f591ea1f sink_id: 0 incremental open delta writer: [395929245:1][395929248:2]
be.INFO.log.20250708-034826:I20250708 11:19:34.789044 140680309356096 local_tablets_channel.cpp:933] LocalTabletsChannel txn_id: 46378701 load_id: 22b71306-5ba5-11f0-bde4-0242f591ea1f sink_id: 0 incremental open delta writer: [395930636:1][395930639:1]
be.INFO.log.20250708-034826:I20250708 11:19:43.398191 140680334534208 local_tablets_channel.cpp:933] LocalTabletsChannel txn_id: 46378701 load_id: 22b71306-5ba5-11f0-bde4-0242f591ea1f sink_id: 0 incremental open delta writer: [395932856:1][395932859:2]
be.INFO.log.20250708-034826:I20250708 11:19:46.853795 140678470297152 tablet_sink.cpp:414] load_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701automatic partition rpc begin request TCreatePartitionRequest(txn_id=46378701, db_id=10379, table_id=395837166, partition_values=[[hllfsnz_334805]])
be.INFO.log.20250708-034826:I20250708 11:19:46.858033 140678470297152 tablet_sink.cpp:434] load_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701automatic partition rpc end response TCreatePartitionResult(status=TStatus(status_code=OK, error_msgs=), partitions=[TOlapTablePartition(id=395930635, start_key=, end_key=, num_buckets=3, ind
exes=[TOlapTableIndexTablets(index_id=395837167, tablets=[395930636, 395930639, 395930642])], start_keys=, end_keys=, in_keys=[[TExprNode(node_type=STRING_LITERAL, type=TTypeDesc(types=[TTypeNode(type=SCALAR, scalar_type=TScalarType(type=VARCHAR, len=-1, precision=, scale=), struct_fields=, is_named=)]), opcode=, num_c
hildren=0, agg_expr=, bool_literal=, case_expr=, date_literal=, float_literal=, int_literal=, in_predicate=, is_null_pred=, like_pred=, literal_pred=, slot_ref=, string_literal=TStringLiteral(value=hllfsnz_334805), tuple_is_null_pred=, info_func=, decimal_literal=, output_scale
=-1, fn_call_expr=, large_int_literal=, output_column=, output_type=, vector_opcode=, fn=, vararg_start_idx=, child_type=, vslot_ref=, used_subfield_names=, binary_literal=, copy_flag=, check_is_out_of_bounds=, use_vectorized=, has_nullable_child=0, is_nullable=0, child_type_de
sc=, is_monotonic=1, dict_query_expr=, dictionary_get_expr=, is_index_only_filter=0)]], is_shadow_partition=0)], tablets=[TTabletLocation(tablet_id=395930636, node_ids=[10002, 10003]), TTabletLocation(tablet_id=395930639, node_ids=[10002, 10001]), TTabletLocation(tablet_id=395930642, node_ids=[10001, 10003])], nodes=[TNodeInfo(id=10001, optio
n=0, host=172.17.9.108, async_internal_port=8060), TNodeInfo(id=10002, option=0, host=172.17.9.106, async_internal_port=8060), TNodeInfo(id=10003, option=0, host=172.17.9.107, async_internal_port=8060)])
be.INFO.log.20250708-034826:I20250708 11:19:48.004013 140678470297152 tablet_sink.cpp:414] load_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701automatic partition rpc begin request TCreatePartitionRequest(txn_id=46378701, db_id=10379, table_id=395837166, partition_values=[[xdjj_508960]])
be.INFO.log.20250708-034826:I20250708 11:19:48.008070 140678470297152 tablet_sink.cpp:434] load_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701automatic partition rpc end response TCreatePartitionResult(status=TStatus(status_code=OK, error_msgs=), partitions=[TOlapTablePartition(id=395919629, start_key=, end_key=, num_buckets=3, ind
exes=[TOlapTableIndexTablets(index_id=395837167, tablets=[395919630, 395919633, 395919636])], start_keys=, end_keys=, in_keys=[[TExprNode(node_type=STRING_LITERAL, type=TTypeDesc(types=[TTypeNode(type=SCALAR, scalar_type=TScalarType(type=VARCHAR, len=-1, precision=, scale=), struct_fields=, is_named=)]), opcode=, num_c
hildren=0, agg_expr=, bool_literal=, case_expr=, date_literal=, float_literal=, int_literal=, in_predicate=, is_null_pred=, like_pred=, literal_pred=, slot_ref=, string_literal=TStringLiteral(value=xdjj_508960), tuple_is_null_pred=, info_func=, decimal_literal=, output_scale=-1
, fn_call_expr=, large_int_literal=, output_column=, output_type=, vector_opcode=, fn=, vararg_start_idx=, child_type=, vslot_ref=, used_subfield_names=, binary_literal=, copy_flag=, check_is_out_of_bounds=, use_vectorized=, has_nullable_child=0, is_nullable=0, child_type_desc=
, is_monotonic=1, dict_query_expr=, dictionary_get_expr=, is_index_only_filter=0)]], is_shadow_partition=0)], tablets=[TTabletLocation(tablet_id=395919630, node_ids=[10002, 10003]), TTabletLocation(tablet_id=395919633, node_ids=[10001, 10002]), TTabletLocation(tablet_id=395919636, node_ids=[10001, 10003])], nodes=[TNodeInfo(id=10001, option=0
, host=172.17.9.108, async_internal_port=8060), TNodeInfo(id=10002, option=0, host=172.17.9.106, async_internal_port=8060), TNodeInfo(id=10003, option=0, host=172.17.9.107, async_internal_port=8060)])
be.INFO.log.20250708-034826:I20250708 11:19:55.896469 140681634272832 internal_service.cpp:521] cancel query ctx, query_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, reason: UserCancel
be.INFO.log.20250708-034826:I20250708 11:19:55.896495 140681634272832 fragment_context.cpp:189] [Driver] Canceled, query_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, instance_id=22b71306-5ba5-11f0-bde4-0242f591ea2c, reason=UserCancel
be.INFO.log.20250708-034826:I20250708 11:19:55.896502 140681634272832 fragment_context.cpp:189] [Driver] Canceled, query_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, instance_id=22b71306-5ba5-11f0-bde4-0242f591ea33, reason=UserCancel
be.INFO.log.20250708-034826:I20250708 11:19:55.896510 140681634272832 fragment_context.cpp:189] [Driver] Canceled, query_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, instance_id=22b71306-5ba5-11f0-bde4-0242f591ea21, reason=UserCancel
be.INFO.log.20250708-034826:W20250708 11:19:55.901757 140681483204160 pipeline_driver.cpp:567] cancel pipeline driver error [driver=query_id=22b71306-5ba5-11f0-bde4-0242f591ea1f fragment_id=22b71306-5ba5-11f0-bde4-0242f591ea21 driver=driver_8_6, status=INPUT_EMPTY, operator-chain: [exchange_source_8_0x7ff3f686ff90(X) -> spillable_hash_join_probe_12_0x7feabb3bd
310(X)(HashJoiner=0x7ff3f686e910) -> project_13_0x7ff3ec3bde10(X) -> spillable_hash_join_probe_17_0x7feabb3bd810(X)(HashJoiner=0x7ff3f67c8790) -> project_18_0x7ff3ec645110(X) -> spillable_hash_join_probe_22_0x7feabb3bdd10(X)(HashJoiner=0x7ff448040e10) -> project_23_0x7ff3ec9c2310(X) -> olap_table_sink_-1_0x7ff3ec9e7e10(X)]]: Cancelled: Cancelled by pipeline en
gine
be.INFO.log.20250708-034826:W20250708 11:19:55.901832 140681483204160 tablet_sink_sender.cpp:250] close channel failed. channel_name=NodeChannel[10001], load_info=load_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701, parallel=1, compress_type=2, error_msg=Cancelled by pipeline engine
be.INFO.log.20250708-034826:W20250708 11:19:55.901843 140681483204160 tablet_sink_sender.cpp:250] close channel failed. channel_name=NodeChannel[10003], load_info=load_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701, parallel=1, compress_type=2, error_msg=Cancelled by pipeline engine
be.INFO.log.20250708-034826:W20250708 11:19:55.901850 140681483204160 tablet_sink_sender.cpp:250] close channel failed. channel_name=NodeChannel[10002], load_info=load_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701, parallel=1, compress_type=2, error_msg=Cancelled by pipeline engine
be.INFO.log.20250708-034826:W20250708 11:19:55.917407 140681441240640 tablet_sink_sender.cpp:299] close channel failed. channel_name=NodeChannel[10001], load_info=load_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701, parallel=1, compress_type=2, error_msg=Cancelled by pipeline engine
be.INFO.log.20250708-034826:W20250708 11:19:55.917444 140681441240640 tablet_sink_sender.cpp:299] close channel failed. channel_name=NodeChannel[10003], load_info=load_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701, parallel=1, compress_type=2, error_msg=Cancelled by pipeline engine
be.INFO.log.20250708-034826:W20250708 11:19:55.917454 140681441240640 tablet_sink_sender.cpp:299] close channel failed. channel_name=NodeChannel[10002], load_info=load_id=22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701, parallel=1, compress_type=2, error_msg=Cancelled by pipeline engine
be.INFO.log.20250708-034826:I20250708 11:19:55.917491 140681441240640 tablet_sink_sender.cpp:348] Olap table sink statistics. load_id: 22b71306-5ba5-11f0-bde4-0242f591ea1f, txn_id: 46378701, add chunk time(ms)/wait lock time(ms)/num: {10002:(813)(0)(34)} {10003:(111)(0)(17)} {10001:(131)(0)(23)}
be.INFO.log.20250708-034826:I20250708 11:19:55.970922 140681458026048 query_context.cpp:61] finished query_id:22b71306-5ba5-11f0-bde4-0242f591ea1f context life time:2269268934574 cpu costs:432152328060 peak memusage:2290756088 scan_bytes:4288576160 spilled bytes:11237072973
(END)
【背景】做过哪些操作？
【业务影响】
【是否存算分离】
【StarRocks版本】例如：3.2.12
【集群规模】例如：3fe（1 follower+2observer）+5be（fe与be混部）
【机器信息】CPU虚拟核/内存/网卡，例如：48C/64G/万兆
【联系方式】为了在解决问题过程中能及时联系到您获取一些日志信息，请补充下您的联系方式，例如：社区群16-可乐鸡或者邮箱，谢谢
【附件】
- fe.log/beINFO/相应截图
- 慢查询：
- Profile信息
- 并行度：show variables like ‘%parallel_fragment_exec_instance_num%’;
- pipeline是否开启：show variables like ‘%pipeline%’;
- be节点cpu和内存使用率截图
- 查询报错：
- query_dump，怎么获取query_dump文件
- be crash
- be.out
- 外表查询报错
- be.out和fe.warn.log