transmit chunk rpc failed 3152c937-b0ed-11ed-8510-00163e063d0b

💬 StarRocks 用户问答 常见 FAQ
#1

执行insert 时
transmit chunk rpc failed:3152c937-b0ed-11ed-8510-00163e063d0b
注意是部分SQL执行是报错，其他SQL执行时正常，将查询创建为视图去查询也正常，但是写入失败

【StarRocks版本】2.4.1

执行计划

PLAN FRAGMENT 0
OUTPUT EXPRS:225: now | 146: tenant_id | 147: statistics_date | 149: market_id | 173: country | 175: market | 170: brand | 226: concat | 168: category | 227: concat | 198: supplier | 186: saler_org_id | 185: saler_org | 187: saler_id | 228: coalesce | 192: developer_id | 229: coalesce | 230: coalesce | 231: coalesce | 182: spu | 180: sku | 150: asin | 148: msku | 155: cast | 156: cast | 157: cast | 164: expr | 234: user_array | 159: sum | 160: sum | 161: sum | 162: sum | 233: coalesce
PARTITION: HASH_PARTITIONED: 148: msku

OLAP TABLE SINK
TUPLE ID: 21
RANDOM

32:Project
| <slot 146> : 146: tenant_id
| <slot 147> : 147: statistics_date
| <slot 148> : 148: msku
| <slot 149> : 149: market_id
| <slot 150> : 150: asin
| <slot 155> : 155: cast
| <slot 156> : 156: cast
| <slot 157> : 157: cast
| <slot 159> : 159: sum
| <slot 160> : 160: sum
| <slot 161> : 161: sum
| <slot 162> : 162: sum
| <slot 164> : 164: expr
| <slot 168> : 168: category
| <slot 170> : 170: brand
| <slot 173> : 173: country
| <slot 175> : 175: market
| <slot 180> : 180: sku
| <slot 182> : 182: spu
| <slot 185> : 185: saler_org
| <slot 186> : 186: saler_org_id
| <slot 187> : 187: saler_id
| <slot 192> : 192: developer_id
| <slot 198> : 198: supplier
| <slot 225> : ‘2023-02-20 15:09:09’
| <slot 226> : concat(CAST(169: brand_id AS VARCHAR), ‘-’, 170: brand)
| <slot 227> : concat(CAST(167: category_id AS VARCHAR), ‘-’, 168: category)
| <slot 228> : coalesce(153: selling_manager_name, 188: saler)
| <slot 229> : coalesce(154: product_manager_account, 193: developer)
| <slot 230> : coalesce(152: listing_state, 195: listing_state)
| <slot 231> : coalesce(151: listing_level, 196: listing_level)
| <slot 233> : coalesce(163: sum * CAST(207: cny_reference_rate AS DECIMAL128(8,4)), 0)
| <slot 234> : CAST(concat_ws(’,’, coalesce(216: group_concat, ‘0’), coalesce(224: group_concat, ‘0’), ‘9999’) AS ARRAY)
|
31:HASH JOIN
| join op: LEFT OUTER JOIN (BROADCAST)
| colocate: false, reason:
| equal join conjunct: 148: msku = 221: msku
| equal join conjunct: 149: market_id = 220: market_id
| equal join conjunct: 146: tenant_id = 217: tenant_id
|
|----30:EXCHANGE
|
26:Project
| <slot 146> : 146: tenant_id
| <slot 147> : 147: statistics_date
| <slot 148> : 148: msku
| <slot 149> : 149: market_id
| <slot 150> : 150: asin
| <slot 151> : 151: listing_level
| <slot 152> : 152: listing_state
| <slot 153> : 153: selling_manager_name
| <slot 154> : 154: product_manager_account
| <slot 155> : 155: cast
| <slot 156> : 156: cast
| <slot 157> : 157: cast
| <slot 159> : 159: sum
| <slot 160> : 160: sum
| <slot 161> : 161: sum
| <slot 162> : 162: sum
| <slot 163> : 163: sum
| <slot 164> : 164: expr
| <slot 167> : 167: category_id
| <slot 168> : 168: category
| <slot 169> : 169: brand_id
| <slot 170> : 170: brand
| <slot 173> : 173: country
| <slot 175> : 175: market
| <slot 180> : 180: sku
| <slot 182> : 182: spu
| <slot 185> : 185: saler_org
| <slot 186> : 186: saler_org_id
| <slot 187> : 187: saler_id
| <slot 188> : 188: saler
| <slot 192> : 192: developer_id
| <slot 193> : 193: developer
| <slot 195> : 195: listing_state
| <slot 196> : 196: listing_level
| <slot 198> : 198: supplier
| <slot 207> : 207: cny_reference_rate
| <slot 216> : 216: group_concat
|
25:HASH JOIN
| join op: LEFT OUTER JOIN (BROADCAST)
| colocate: false, reason:
| equal join conjunct: 146: tenant_id = 209: tenant_id
|
|----24:EXCHANGE
|
20:Project
| <slot 146> : 146: tenant_id
| <slot 147> : 147: statistics_date
| <slot 148> : 148: msku
| <slot 149> : 149: market_id
| <slot 150> : 150: asin
| <slot 151> : 151: listing_level
| <slot 152> : 152: listing_state
| <slot 153> : 153: selling_manager_name
| <slot 154> : 154: product_manager_account
| <slot 155> : 155: cast
| <slot 156> : 156: cast
| <slot 157> : 157: cast
| <slot 159> : 159: sum
| <slot 160> : 160: sum
| <slot 161> : 161: sum
| <slot 162> : 162: sum
| <slot 163> : 163: sum
| <slot 164> : 164: expr
| <slot 167> : 167: category_id
| <slot 168> : 168: category
| <slot 169> : 169: brand_id
| <slot 170> : 170: brand
| <slot 173> : 173: country
| <slot 175> : 175: market
| <slot 180> : 180: sku
| <slot 182> : 182: spu
| <slot 185> : 185: saler_org
| <slot 186> : 186: saler_org_id
| <slot 187> : 187: saler_id
| <slot 188> : 188: saler
| <slot 192> : 192: developer_id
| <slot 193> : 193: developer
| <slot 195> : 195: listing_state
| <slot 196> : 196: listing_level
| <slot 198> : 198: supplier
| <slot 207> : 207: cny_reference_rate
|
19:HASH JOIN
| join op: LEFT OUTER JOIN (BROADCAST)
| colocate: false, reason:
| equal join conjunct: 158: currency = 203: currency
| equal join conjunct: 235: left = 204: month_date
| equal join conjunct: 146: tenant_id = 202: tenant_id
|
|----18:EXCHANGE
|
16:Project
| <slot 146> : 146: tenant_id
| <slot 147> : 147: statistics_date
| <slot 148> : 148: msku
| <slot 149> : 149: market_id
| <slot 150> : 150: asin
| <slot 151> : 151: listing_level
| <slot 152> : 152: listing_state
| <slot 153> : 153: selling_manager_name
| <slot 154> : 154: product_manager_account
| <slot 155> : 155: cast
| <slot 156> : 156: cast
| <slot 157> : 157: cast
| <slot 158> : 158: currency
| <slot 159> : 159: sum
| <slot 160> : 160: sum
| <slot 161> : 161: sum
| <slot 162> : 162: sum
| <slot 163> : 163: sum
| <slot 164> : 164: expr
| <slot 167> : 167: category_id
| <slot 168> : 168: category
| <slot 169> : 169: brand_id
| <slot 170> : 170: brand
| <slot 173> : 173: country
| <slot 175> : 175: market
| <slot 180> : 180: sku
| <slot 182> : 182: spu
| <slot 185> : 185: saler_org
| <slot 186> : 186: saler_org_id
| <slot 187> : 187: saler_id
| <slot 188> : 188: saler
| <slot 192> : 192: developer_id
| <slot 193> : 193: developer
| <slot 195> : 195: listing_state
| <slot 196> : 196: listing_level
| <slot 198> : 198: supplier
| <slot 235> : left(CAST(147: statistics_date AS VARCHAR), 7)
|
15:HASH JOIN
| join op: LEFT OUTER JOIN (PARTITIONED)
| colocate: false, reason:
| equal join conjunct: 236: cast = 166: tenant_id
| equal join conjunct: 148: msku = 181: msku
| equal join conjunct: 237: cast = 174: market_id
|
|----14:EXCHANGE
|
12:EXCHANGE

PLAN FRAGMENT 1
OUTPUT EXPRS:
PARTITION: RANDOM

STREAM DATA SINK

#2

看下be的状态，是不是有be挂了？

#3

发下每个be的be.out文件

#4

你好，这个咋解决的？

#5

您好，请问您这边是遇到了同样的问题吗？是否有查看过所有be的状态是否是存活的呢？

#6

你好，我这边部署6台bube，有单台be.WARRING

image
image1127×502 349 KB

#7

fe leader节点执行show backends；看下这个有报错的be的alive状态呢？集群有什么其它表象的错误吗？看着存在be和fe通信的问题、kafka导入失败的问题

#8

show backends, be alive 都是为true。现在问题的表现是执行sql，部分成功，部分失败 报错：transmit chunk rp faild。看着应该是部分be链接失败；

京ICP备2022026421号-1