使用jdbc执行某个sql时报错:Not found dict for cid

【详述】问题详细描述
【背景】做过哪些操作?
【业务影响】
【StarRocks版本】例如:2.3.3
【集群规模】例如:3fe(3 follower)+3be(fe与be分部)
【机器信息】CPU虚拟核/内存/网卡,例如:16C/64G/万兆
【附件】

问题描述:
直接执行sql没问题,通过jdbc连接方式执行sql报错

sql语句:
SELECT t1.group_id AS group_id, t1.crowd_id AS crowd_id, max(t1.crowd_name) AS crowd_name, max(t1.group_name) AS group_name, max(t1.dt) AS crowd_ct, ifnull(sum(t2.cover_num), 0) AS cover_num, ifnull(sum(t2.conv_num), 0) AS conv_num, ifnull(sum(t2.conv_amt), 0) AS conv_amt FROM (SELECT group_id, crowd_id, max(crowd_name) AS crowd_name, max(group_name) AS group_name, max(dt) AS dt FROM ma_dc_custom_crowd WHERE job_id = ‘10000-33032’ AND target_id = ‘140’ AND job_version = ‘1’ AND group_id IN (‘ff187024-cd07-441b-9ba1-571da4940aee’) AND tenant_id = 10000 GROUP BY group_id, crowd_id) t1 LEFT JOIN (SELECT group_id, crowd_id, cover_num, conv_num, conv_amt FROM ads_ma_crowd_statistics_1d WHERE dt = (SELECT max(dt) FROM ads_ma_crowd_statistics_1d WHERE tenant_id = 10000) AND job_id = ‘10000-33032’ AND target_id = ‘140’ AND job_version = ‘1’ AND group_id IN (‘ff187024-cd07-441b-9ba1-571da4940aee’) AND tenant_id = 10000) t2 ON t1.group_id = t2.group_id AND t1.crowd_id = t2.crowd_id GROUP BY t1.group_id, t1.crowd_id

能提供一下explain costs吗

sql:
explain costs
SELECT
t1.group_id AS group_id,
t1.crowd_id AS crowd_id,
max(t1.crowd_name) AS crowd_name,
max(t1.group_name) AS group_name,
max(t1.dt) AS crowd_ct,
ifnull(sum(t2.cover_num), 0) AS cover_num,
ifnull(sum(t2.conv_num), 0) AS conv_num,
ifnull(sum(t2.conv_amt), 0) AS conv_amt
FROM
(
SELECT
group_id,
crowd_id,
max(crowd_name) AS crowd_name,
max(group_name) AS group_name,
max(dt) AS dt
FROM
ma_dc_custom_crowd
WHERE
job_id = ‘10000-33032’
AND target_id = ‘140’
AND job_version = ‘1’
AND group_id IN (‘ff187024-cd07-441b-9ba1-571da4940aee’)
AND tenant_id = 10000
GROUP BY
group_id,
crowd_id) t1
LEFT JOIN (
SELECT
group_id,
crowd_id,
cover_num,
conv_num,
conv_amt
FROM
ads_ma_crowd_statistics_1d
WHERE
dt = (
SELECT
max(dt)
FROM
ads_ma_crowd_statistics_1d
WHERE
tenant_id = 10000)
AND job_id = ‘10000-33032’
AND target_id = ‘140’
AND job_version = ‘1’
AND group_id IN (‘ff187024-cd07-441b-9ba1-571da4940aee’)
AND tenant_id = 10000) t2 ON
t1.group_id = t2.group_id
AND t1.crowd_id = t2.crowd_id
GROUP BY
t1.group_id,
t1.crowd_id;

—查询计划
PLAN FRAGMENT 0(F08)
Output Exprs:4: group_id | 5: crowd_id | 51: max | 52: max | 53: max | 57: ifnull | 58: ifnull | 59: ifnull
Input Partition: UNPARTITIONED
RESULT SINK

19:EXCHANGE
cardinality: 39

PLAN FRAGMENT 1(F07)

Input Partition: HASH_PARTITIONED: 4: group_id, 5: crowd_id
OutPut Partition: UNPARTITIONED
OutPut Exchange Id: 19

18:Project
| output columns:
| 4 <-> [4: group_id, VARCHAR, true]
| 5 <-> [5: crowd_id, VARCHAR, true]
| 51 <-> [51: max, VARCHAR, true]
| 52 <-> [52: max, VARCHAR, true]
| 53 <-> [53: max, DATE, true]
| 57 <-> ifnull[([54: sum, BIGINT, true], 0); args: BIGINT,BIGINT; result: BIGINT; args nullable: true; result nullable: true]
| 58 <-> ifnull[([55: sum, BIGINT, true], 0); args: BIGINT,BIGINT; result: BIGINT; args nullable: true; result nullable: true]
| 59 <-> ifnull[([56: sum, DECIMAL128(38,4), true], 0); args: DECIMAL128,DECIMAL128; result: DECIMAL128(38,4); args nullable: true; result nullable: true]
| hasNullableGenerateChild: true
| cardinality: 39
| column statistics:
| * group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * ifnull–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * ifnull–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * ifnull–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
17:AGGREGATE (update finalize)
| aggregate: max[([14: max, VARCHAR, true]); args: VARCHAR; result: VARCHAR; args nullable: true; result nullable: true], max[([15: max, VARCHAR, true]); args: VARCHAR; result: VARCHAR; args nullable: true; result nullable: true], max[([16: max, DATE, true]); args: DATE; result: DATE; args nullable: true; result nullable: true], sum[([28: cover_num, INT, true]); args: INT; result: BIGINT; args nullable: true; result nullable: true], sum[([29: conv_num, INT, true]); args: INT; result: BIGINT; args nullable: true; result nullable: true], sum[([30: conv_amt, DECIMAL64(18,4), true]); args: DECIMAL64; result: DECIMAL128(38,4); args nullable: true; result nullable: true]
| group by: [4: group_id, VARCHAR, true], [5: crowd_id, VARCHAR, true]
| hasNullableGenerateChild: true
| cardinality: 39
| column statistics:
| * group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * sum–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * sum–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * sum–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * ifnull–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * ifnull–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * ifnull–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
16:Project
| output columns:
| 4 <-> [4: group_id, VARCHAR, true]
| 5 <-> [5: crowd_id, VARCHAR, true]
| 14 <-> [14: max, VARCHAR, true]
| 15 <-> [15: max, VARCHAR, true]
| 16 <-> [16: max, DATE, true]
| 28 <-> [28: cover_num, INT, true]
| 29 <-> [29: conv_num, INT, true]
| 30 <-> [30: conv_amt, DECIMAL64(18,4), true]
| hasNullableGenerateChild: true
| cardinality: 74
| column statistics:
| * group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * cover_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_amt–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
15:HASH JOIN
| join op: LEFT OUTER JOIN (PARTITIONED)
| equal join conjunct: [4: group_id, VARCHAR, true] = [20: group_id, VARCHAR, true]
| equal join conjunct: [5: crowd_id, VARCHAR, true] = [21: crowd_id, VARCHAR, true]
| output columns: 4, 5, 14, 15, 16, 28, 29, 30
| cardinality: 74
| column statistics:
| * group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * cover_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_amt–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
|----14:EXCHANGE
| cardinality: 60
|
3:EXCHANGE
cardinality: 74

PLAN FRAGMENT 2(F02)

Input Partition: RANDOM
OutPut Partition: HASH_PARTITIONED: 20: group_id, 21: crowd_id
OutPut Exchange Id: 14

13:Project
| output columns:
| 20 <-> [20: group_id, VARCHAR, true]
| 21 <-> [21: crowd_id, VARCHAR, true]
| 28 <-> [28: cover_num, INT, true]
| 29 <-> [29: conv_num, INT, true]
| 30 <-> [30: conv_amt, DECIMAL64(18,4), true]
| cardinality: 60
| column statistics:
| * group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * cover_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_amt–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
12:HASH JOIN
| join op: INNER JOIN (BROADCAST)
| equal join conjunct: [22: dt, DATE, false] = [49: max, DATE, true]
| build runtime filters:
| - filter_id = 0, build_expr = (49: max), remote = false
| output columns: 20, 21, 28, 29, 30
| cardinality: 60
| column statistics:
| * group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * dt–>[1.6506432E9, 1.6546176E9, 0.0, 1.0, 1.0] UNKNOWN
| * cover_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_amt–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
|----11:EXCHANGE
| cardinality: 1
|
5:Project
| output columns:
| 20 <-> [20: group_id, VARCHAR, true]
| 21 <-> [21: crowd_id, VARCHAR, true]
| 22 <-> [22: dt, DATE, false]
| 28 <-> [28: cover_num, INT, true]
| 29 <-> [29: conv_num, INT, true]
| 30 <-> [30: conv_amt, DECIMAL64(18,4), true]
| cardinality: 60
| column statistics:
| * group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * dt–>[1.6506432E9, 1.6546176E9, 0.0, 1.0, 1.0] UNKNOWN
| * cover_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_amt–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
4:OlapScanNode
table: ads_ma_crowd_statistics_1d, rollup: ads_ma_crowd_statistics_1d
preAggregation: on
Predicates: [17: job_id, VARCHAR, true] = ‘10000-33032’, [19: target_id, VARCHAR, true] = ‘140’, [18: job_version, VARCHAR, true] = ‘1’, [20: group_id, VARCHAR, true] = ‘ff187024-cd07-441b-9ba1-571da4940aee’, [24: tenant_id, INT, true] = 10000
partitionsRatio=29/189, tabletsRatio=29/87
tabletList=5990366,5990372,5990378,5990390,5990414,5990420,5990426,5990432,5990444,5990456 …
actualRows=31, avgRowSize=10.0
cardinality: 60
probe runtime filters:
- filter_id = 0, probe_expr = (22: dt)
column statistics:
* job_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* job_version–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* target_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* dt–>[1.6506432E9, 1.6546176E9, 0.0, 1.0, 1.0] UNKNOWN
* tenant_id–>[10000.0, 10000.0, 0.0, 1.0, 1.0] UNKNOWN
* cover_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* conv_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* conv_amt–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN

PLAN FRAGMENT 3(F04)

Input Partition: UNPARTITIONED
OutPut Partition: UNPARTITIONED
OutPut Exchange Id: 11

10:AGGREGATE (merge finalize)
| aggregate: max[([49: max, DATE, true]); args: DATE; result: DATE; args nullable: true; result nullable: true]
| cardinality: 1
| column statistics:
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
9:EXCHANGE
cardinality: 1

PLAN FRAGMENT 4(F03)

Input Partition: RANDOM
OutPut Partition: UNPARTITIONED
OutPut Exchange Id: 09

8:AGGREGATE (update serialize)
| aggregate: max[([38: dt, DATE, false]); args: DATE; result: DATE; args nullable: false; result nullable: true]
| cardinality: 1
| column statistics:
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
7:Project
| output columns:
| 38 <-> [38: dt, DATE, false]
| cardinality: 60
| column statistics:
| * dt–>[1.6506432E9, 1.6546176E9, 0.0, 1.0, 1.0] UNKNOWN
|
6:OlapScanNode
table: ads_ma_crowd_statistics_1d, rollup: ads_ma_crowd_statistics_1d
preAggregation: on
Predicates: [40: tenant_id, INT, true] = 10000
partitionsRatio=29/189, tabletsRatio=87/87
tabletList=5990362,5990364,5990366,5990368,5990370,5990372,5990374,5990376,5990378,5990386 …
actualRows=119, avgRowSize=2.0
cardinality: 60
column statistics:
* dt–>[1.6506432E9, 1.6546176E9, 0.0, 1.0, 1.0] UNKNOWN
* tenant_id–>[10000.0, 10000.0, 0.0, 1.0, 1.0] UNKNOWN

PLAN FRAGMENT 5(F00)

Input Partition: RANDOM
OutPut Partition: HASH_PARTITIONED: 4: group_id, 5: crowd_id
OutPut Exchange Id: 03

2:AGGREGATE (update finalize)
| aggregate: max[([9: crowd_name, VARCHAR, true]); args: VARCHAR; result: VARCHAR; args nullable: true; result nullable: true], max[([11: group_name, VARCHAR, true]); args: VARCHAR; result: VARCHAR; args nullable: true; result nullable: true], max[([8: dt, DATE, false]); args: DATE; result: DATE; args nullable: false; result nullable: true]
| group by: [4: group_id, VARCHAR, true], [5: crowd_id, VARCHAR, true]
| cardinality: 74
| column statistics:
| * group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
1:Project
| output columns:
| 4 <-> [4: group_id, VARCHAR, true]
| 5 <-> [5: crowd_id, VARCHAR, true]
| 8 <-> [8: dt, DATE, false]
| 9 <-> [9: crowd_name, VARCHAR, true]
| 11 <-> [11: group_name, VARCHAR, true]
| cardinality: 141
| column statistics:
| * group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * dt–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_name–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * group_name–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
0:OlapScanNode
table: ma_dc_custom_crowd, rollup: ma_dc_custom_crowd
preAggregation: on
Predicates: [1: job_id, VARCHAR, true] = ‘10000-33032’, [3: target_id, VARCHAR, true] = ‘140’, [2: job_version, VARCHAR, true] = ‘1’, [4: group_id, VARCHAR, true] = ‘ff187024-cd07-441b-9ba1-571da4940aee’, [13: tenant_id, INT, true] = 10000
partitionsRatio=1/1, tabletsRatio=1/3
tabletList=39639
actualRows=99, avgRowSize=9.0
cardinality: 141
column statistics:
* job_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* job_version–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* target_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* dt–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* crowd_name–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* group_name–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* tenant_id–>[10000.0, 10000.0, 0.0, 1.0, 1.0] UNKNOWN

set global cbo_enable_low_cardinality_optimize=false; 先规避下吧

你先对这些表执行一下analyze full table xxx,然后再执行一下explain costs

image

PLAN FRAGMENT 0(F08)
Output Exprs:4: group_id | 5: crowd_id | 51: max | 52: max | 53: max | 57: ifnull | 58: ifnull | 59: ifnull
Input Partition: UNPARTITIONED
RESULT SINK

19:EXCHANGE
cardinality: 39

PLAN FRAGMENT 1(F07)

Input Partition: HASH_PARTITIONED: 4: group_id, 5: crowd_id
OutPut Partition: UNPARTITIONED
OutPut Exchange Id: 19

18:Project
| output columns:
| 4 <-> [4: group_id, VARCHAR, true]
| 5 <-> [5: crowd_id, VARCHAR, true]
| 51 <-> [51: max, VARCHAR, true]
| 52 <-> [52: max, VARCHAR, true]
| 53 <-> [53: max, DATE, true]
| 57 <-> ifnull[([54: sum, BIGINT, true], 0); args: BIGINT,BIGINT; result: BIGINT; args nullable: true; result nullable: true]
| 58 <-> ifnull[([55: sum, BIGINT, true], 0); args: BIGINT,BIGINT; result: BIGINT; args nullable: true; result nullable: true]
| 59 <-> ifnull[([56: sum, DECIMAL128(38,4), true], 0); args: DECIMAL128,DECIMAL128; result: DECIMAL128(38,4); args nullable: true; result nullable: true]
| hasNullableGenerateChild: true
| cardinality: 39
| column statistics:
| * group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * ifnull–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * ifnull–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * ifnull–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
17:AGGREGATE (update finalize)
| aggregate: max[([14: max, VARCHAR, true]); args: VARCHAR; result: VARCHAR; args nullable: true; result nullable: true], max[([15: max, VARCHAR, true]); args: VARCHAR; result: VARCHAR; args nullable: true; result nullable: true], max[([16: max, DATE, true]); args: DATE; result: DATE; args nullable: true; result nullable: true], sum[([28: cover_num, INT, true]); args: INT; result: BIGINT; args nullable: true; result nullable: true], sum[([29: conv_num, INT, true]); args: INT; result: BIGINT; args nullable: true; result nullable: true], sum[([30: conv_amt, DECIMAL64(18,4), true]); args: DECIMAL64; result: DECIMAL128(38,4); args nullable: true; result nullable: true]
| group by: [4: group_id, VARCHAR, true], [5: crowd_id, VARCHAR, true]
| hasNullableGenerateChild: true
| cardinality: 39
| column statistics:
| * group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * sum–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * sum–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * sum–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * ifnull–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * ifnull–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * ifnull–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
16:Project
| output columns:
| 4 <-> [4: group_id, VARCHAR, true]
| 5 <-> [5: crowd_id, VARCHAR, true]
| 14 <-> [14: max, VARCHAR, true]
| 15 <-> [15: max, VARCHAR, true]
| 16 <-> [16: max, DATE, true]
| 28 <-> [28: cover_num, INT, true]
| 29 <-> [29: conv_num, INT, true]
| 30 <-> [30: conv_amt, DECIMAL64(18,4), true]
| hasNullableGenerateChild: true
| cardinality: 74
| column statistics:
| * group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * cover_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_amt–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
15:HASH JOIN
| join op: LEFT OUTER JOIN (PARTITIONED)
| equal join conjunct: [4: group_id, VARCHAR, true] = [20: group_id, VARCHAR, true]
| equal join conjunct: [5: crowd_id, VARCHAR, true] = [21: crowd_id, VARCHAR, true]
| output columns: 4, 5, 14, 15, 16, 28, 29, 30
| cardinality: 74
| column statistics:
| * group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * cover_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_amt–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
|----14:EXCHANGE
| cardinality: 59
|
3:EXCHANGE
cardinality: 74

PLAN FRAGMENT 2(F02)

Input Partition: RANDOM
OutPut Partition: HASH_PARTITIONED: 20: group_id, 21: crowd_id
OutPut Exchange Id: 14

13:Project
| output columns:
| 20 <-> [20: group_id, VARCHAR, true]
| 21 <-> [21: crowd_id, VARCHAR, true]
| 28 <-> [28: cover_num, INT, true]
| 29 <-> [29: conv_num, INT, true]
| 30 <-> [30: conv_amt, DECIMAL64(18,4), true]
| cardinality: 59
| column statistics:
| * group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * cover_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_amt–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
12:HASH JOIN
| join op: INNER JOIN (BROADCAST)
| equal join conjunct: [22: dt, DATE, false] = [49: max, DATE, true]
| build runtime filters:
| - filter_id = 0, build_expr = (49: max), remote = false
| output columns: 20, 21, 28, 29, 30
| cardinality: 59
| column statistics:
| * group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * dt–>[1.6507296E9, 1.6546176E9, 0.0, 1.0, 1.0] UNKNOWN
| * cover_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_amt–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
|----11:EXCHANGE
| cardinality: 1
|
5:Project
| output columns:
| 20 <-> [20: group_id, VARCHAR, true]
| 21 <-> [21: crowd_id, VARCHAR, true]
| 22 <-> [22: dt, DATE, false]
| 28 <-> [28: cover_num, INT, true]
| 29 <-> [29: conv_num, INT, true]
| 30 <-> [30: conv_amt, DECIMAL64(18,4), true]
| cardinality: 59
| column statistics:
| * group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * dt–>[1.6507296E9, 1.6546176E9, 0.0, 1.0, 1.0] UNKNOWN
| * cover_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
| * conv_amt–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
4:OlapScanNode
table: ads_ma_crowd_statistics_1d, rollup: ads_ma_crowd_statistics_1d
preAggregation: on
Predicates: [17: job_id, VARCHAR, true] = ‘10000-33032’, [19: target_id, VARCHAR, true] = ‘140’, [18: job_version, VARCHAR, true] = ‘1’, [20: group_id, VARCHAR, true] = ‘ff187024-cd07-441b-9ba1-571da4940aee’, [24: tenant_id, INT, true] = 10000
partitionsRatio=28/189, tabletsRatio=28/84
tabletList=5990372,5990378,5990390,5990414,5990420,5990426,5990432,5990444,5990456,5990462 …
actualRows=31, avgRowSize=10.0
cardinality: 59
probe runtime filters:
- filter_id = 0, probe_expr = (22: dt)
column statistics:
* job_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* job_version–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* target_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* group_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* crowd_id–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* dt–>[1.6507296E9, 1.6546176E9, 0.0, 1.0, 1.0] UNKNOWN
* tenant_id–>[10000.0, 10000.0, 0.0, 1.0, 1.0] UNKNOWN
* cover_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* conv_num–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
* conv_amt–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN

PLAN FRAGMENT 3(F04)

Input Partition: UNPARTITIONED
OutPut Partition: UNPARTITIONED
OutPut Exchange Id: 11

10:AGGREGATE (merge finalize)
| aggregate: max[([49: max, DATE, true]); args: DATE; result: DATE; args nullable: true; result nullable: true]
| cardinality: 1
| column statistics:
| * max–>[-Infinity, Infinity, 0.0, 1.0, 1.0] UNKNOWN
|
9:EXCHANGE
cardinality: 1

PLAN FRAGMENT 4(F03)

Input Partition: RANDOM
OutPut Partition: UNPARTITIONED
OutPut Exchange Id: 09

他现在是稳定触发的吗

这个plan看上去不像是会触发这个问题的

直接执行sql查没问题,但是在代码里通过jdbc连接再执行查询时就会报上面的错误

你在JDBC里面explain一下看看呢

可以发一下建表语句,我这里复现一下看看

相关开发人员最开始在创建表的时候对分区副本概念不清晰,replication_num设置为1。不确定是不是这个原因影响。

表名:ma_dc_custom_crowd

CREATE TABLE ma_dc_custom_crowd (
job_id varchar(65533) NULL COMMENT “job_id”,
job_version varchar(65533) NULL COMMENT “版本”,
target_id varchar(65533) NULL COMMENT “转化目标”,
group_id varchar(65533) NULL COMMENT “group_id”,
crowd_id varchar(65533) NULL COMMENT "人群id - uuid,人群id会重复 ",
node_id varchar(65533) NULL COMMENT “节点id”,
branch_id varchar(65533) NULL COMMENT “分支id, PIN_TRUE/PIN_FALSE”,
dt date NOT NULL COMMENT “人群创建事件”,
crowd_name varchar(65533) NULL COMMENT “人群名称”,
crowd_desc varchar(65533) NULL COMMENT “人群描述”,
group_name varchar(65533) NULL COMMENT “分组名称”,
per_obs int(11) NULL COMMENT “观察期”,
tenant_id int(11) NULL COMMENT “租户ID”
) ENGINE=OLAP
DUPLICATE KEY(job_id, job_version, target_id, group_id, crowd_id, node_id, branch_id, dt)
COMMENT “任务信息维表”
DISTRIBUTED BY HASH(job_id) BUCKETS 3
PROPERTIES (
“replication_num” = “1”,
“in_memory” = “false”,
“storage_format” = “DEFAULT”,
“enable_persistent_index” = “false”
);

表名:ads_ma_crowd_statistics_1d
CREATE TABLE ads_ma_crowd_statistics_1d (
job_id varchar(65533) NULL COMMENT “job_id”,
job_version varchar(65533) NULL COMMENT “版本”,
target_id varchar(65533) NULL COMMENT “转化目标”,
group_id varchar(65533) NULL COMMENT “分组id”,
crowd_id varchar(65533) NULL COMMENT “人群id”,
dt date NOT NULL COMMENT “时间”,
job_name varchar(65533) NULL COMMENT “job_name”,
tenant_id int(11) NULL COMMENT “租户ID”,
group_name varchar(65533) NULL COMMENT “分组name”,
crowd_name varchar(65533) NULL COMMENT “人群name”,
crowd_ct varchar(65533) NULL COMMENT “人群创建时间”,
cover_num int(11) NULL COMMENT “覆盖人数”,
conv_num int(11) NULL COMMENT “转换人数”,
conv_amt decimal64(18, 4) NULL COMMENT “转换金额”,
crowd_desc varchar(65533) NULL COMMENT “”,
conv_freq int(11) NULL COMMENT “”
) ENGINE=OLAP
DUPLICATE KEY(job_id, job_version, target_id, group_id, crowd_id, dt)
COMMENT “任务信息维表”
PARTITION BY RANGE(dt)
(PARTITION job20220429 VALUES [(‘2022-04-29’), (‘2022-04-30’)),
PARTITION job20220430 VALUES [(‘2022-04-30’), (‘2022-05-01’)),
PARTITION job20220501 VALUES [(‘2022-05-01’), (‘2022-05-02’)),
PARTITION job20220502 VALUES [(‘2022-05-02’), (‘2022-05-03’)),
PARTITION job20220503 VALUES [(‘2022-05-03’), (‘2022-05-04’)),
PARTITION job20220504 VALUES [(‘2022-05-04’), (‘2022-05-05’)),
PARTITION job20220505 VALUES [(‘2022-05-05’), (‘2022-05-06’)),
PARTITION job20220506 VALUES [(‘2022-05-06’), (‘2022-05-07’)),
PARTITION job20220507 VALUES [(‘2022-05-07’), (‘2022-05-08’)),
PARTITION job20220508 VALUES [(‘2022-05-08’), (‘2022-05-09’)),
PARTITION job20220509 VALUES [(‘2022-05-09’), (‘2022-05-10’)),
PARTITION job20220510 VALUES [(‘2022-05-10’), (‘2022-05-11’)),
PARTITION job20220511 VALUES [(‘2022-05-11’), (‘2022-05-12’)),
PARTITION job20220512 VALUES [(‘2022-05-12’), (‘2022-05-13’)),
PARTITION job20220513 VALUES [(‘2022-05-13’), (‘2022-05-14’)),
PARTITION job20220514 VALUES [(‘2022-05-14’), (‘2022-05-15’)),
PARTITION job20220515 VALUES [(‘2022-05-15’), (‘2022-05-16’)),
PARTITION job20220516 VALUES [(‘2022-05-16’), (‘2022-05-17’)),
PARTITION job20220517 VALUES [(‘2022-05-17’), (‘2022-05-18’)),
PARTITION job20220518 VALUES [(‘2022-05-18’), (‘2022-05-19’)),
PARTITION job20220519 VALUES [(‘2022-05-19’), (‘2022-05-20’)),
PARTITION job20220520 VALUES [(‘2022-05-20’), (‘2022-05-21’)),
PARTITION job20220521 VALUES [(‘2022-05-21’), (‘2022-05-22’)),
PARTITION job20220522 VALUES [(‘2022-05-22’), (‘2022-05-23’)),
PARTITION job20220523 VALUES [(‘2022-05-23’), (‘2022-05-24’)),
PARTITION job20220524 VALUES [(‘2022-05-24’), (‘2022-05-25’)),
PARTITION job20220525 VALUES [(‘2022-05-25’), (‘2022-05-26’)),
PARTITION job20220526 VALUES [(‘2022-05-26’), (‘2022-05-27’)),
PARTITION job20220527 VALUES [(‘2022-05-27’), (‘2022-05-28’)),
PARTITION job20220528 VALUES [(‘2022-05-28’), (‘2022-05-29’)),
PARTITION job20220529 VALUES [(‘2022-05-29’), (‘2022-05-30’)),
PARTITION job20220530 VALUES [(‘2022-05-30’), (‘2022-05-31’)),
PARTITION job20220531 VALUES [(‘2022-05-31’), (‘2022-06-01’)),
PARTITION job20220601 VALUES [(‘2022-06-01’), (‘2022-06-02’)),
PARTITION job20220602 VALUES [(‘2022-06-02’), (‘2022-06-03’)),
PARTITION job20220603 VALUES [(‘2022-06-03’), (‘2022-06-04’)),
PARTITION job20220604 VALUES [(‘2022-06-04’), (‘2022-06-05’)),
PARTITION job20220605 VALUES [(‘2022-06-05’), (‘2022-06-06’)),
PARTITION job20220606 VALUES [(‘2022-06-06’), (‘2022-06-07’)),
PARTITION job20220607 VALUES [(‘2022-06-07’), (‘2022-06-08’)),
PARTITION job20220608 VALUES [(‘2022-06-08’), (‘2022-06-09’)),
PARTITION job20220609 VALUES [(‘2022-06-09’), (‘2022-06-10’)),
PARTITION job20220610 VALUES [(‘2022-06-10’), (‘2022-06-11’)),
PARTITION job20220611 VALUES [(‘2022-06-11’), (‘2022-06-12’)),
PARTITION job20220612 VALUES [(‘2022-06-12’), (‘2022-06-13’)),
PARTITION job20220613 VALUES [(‘2022-06-13’), (‘2022-06-14’)),
PARTITION job20220614 VALUES [(‘2022-06-14’), (‘2022-06-15’)),
PARTITION job20220615 VALUES [(‘2022-06-15’), (‘2022-06-16’)),
PARTITION job20220616 VALUES [(‘2022-06-16’), (‘2022-06-17’)),
PARTITION job20220617 VALUES [(‘2022-06-17’), (‘2022-06-18’)),
PARTITION job20220618 VALUES [(‘2022-06-18’), (‘2022-06-19’)),
PARTITION job20220619 VALUES [(‘2022-06-19’), (‘2022-06-20’)),
PARTITION job20220620 VALUES [(‘2022-06-20’), (‘2022-06-21’)),
PARTITION job20220621 VALUES [(‘2022-06-21’), (‘2022-06-22’)),
PARTITION job20220622 VALUES [(‘2022-06-22’), (‘2022-06-23’)),
PARTITION job20220623 VALUES [(‘2022-06-23’), (‘2022-06-24’)),
PARTITION job20220624 VALUES [(‘2022-06-24’), (‘2022-06-25’)),
PARTITION job20220625 VALUES [(‘2022-06-25’), (‘2022-06-26’)),
PARTITION job20220626 VALUES [(‘2022-06-26’), (‘2022-06-27’)),
PARTITION job20220627 VALUES [(‘2022-06-27’), (‘2022-06-28’)),
PARTITION job20220628 VALUES [(‘2022-06-28’), (‘2022-06-29’)),
PARTITION job20220629 VALUES [(‘2022-06-29’), (‘2022-06-30’)),
PARTITION job20220630 VALUES [(‘2022-06-30’), (‘2022-07-01’)),
PARTITION job20220701 VALUES [(‘2022-07-01’), (‘2022-07-02’)),
PARTITION job20220702 VALUES [(‘2022-07-02’), (‘2022-07-03’)),
PARTITION job20220703 VALUES [(‘2022-07-03’), (‘2022-07-04’)),
PARTITION job20220704 VALUES [(‘2022-07-04’), (‘2022-07-05’)),
PARTITION job20220705 VALUES [(‘2022-07-05’), (‘2022-07-06’)),
PARTITION job20220706 VALUES [(‘2022-07-06’), (‘2022-07-07’)),
PARTITION job20220707 VALUES [(‘2022-07-07’), (‘2022-07-08’)),
PARTITION job20220708 VALUES [(‘2022-07-08’), (‘2022-07-09’)),
PARTITION job20220709 VALUES [(‘2022-07-09’), (‘2022-07-10’)),
PARTITION job20220710 VALUES [(‘2022-07-10’), (‘2022-07-11’)),
PARTITION job20220711 VALUES [(‘2022-07-11’), (‘2022-07-12’)),
PARTITION job20220712 VALUES [(‘2022-07-12’), (‘2022-07-13’)),
PARTITION job20220713 VALUES [(‘2022-07-13’), (‘2022-07-14’)),
PARTITION job20220714 VALUES [(‘2022-07-14’), (‘2022-07-15’)),
PARTITION job20220715 VALUES [(‘2022-07-15’), (‘2022-07-16’)),
PARTITION job20220716 VALUES [(‘2022-07-16’), (‘2022-07-17’)),
PARTITION job20220717 VALUES [(‘2022-07-17’), (‘2022-07-18’)),
PARTITION job20220718 VALUES [(‘2022-07-18’), (‘2022-07-19’)),
PARTITION job20220719 VALUES [(‘2022-07-19’), (‘2022-07-20’)),
PARTITION job20220720 VALUES [(‘2022-07-20’), (‘2022-07-21’)),
PARTITION job20220721 VALUES [(‘2022-07-21’), (‘2022-07-22’)),
PARTITION job20220722 VALUES [(‘2022-07-22’), (‘2022-07-23’)),
PARTITION job20220723 VALUES [(‘2022-07-23’), (‘2022-07-24’)),
PARTITION job20220724 VALUES [(‘2022-07-24’), (‘2022-07-25’)),
PARTITION job20220725 VALUES [(‘2022-07-25’), (‘2022-07-26’)),
PARTITION job20220726 VALUES [(‘2022-07-26’), (‘2022-07-27’)),
PARTITION job20220727 VALUES [(‘2022-07-27’), (‘2022-07-28’)),
PARTITION job20220728 VALUES [(‘2022-07-28’), (‘2022-07-29’)),
PARTITION job20220729 VALUES [(‘2022-07-29’), (‘2022-07-30’)),
PARTITION job20220730 VALUES [(‘2022-07-30’), (‘2022-07-31’)),
PARTITION job20220731 VALUES [(‘2022-07-31’), (‘2022-08-01’)),
PARTITION job20220801 VALUES [(‘2022-08-01’), (‘2022-08-02’)),
PARTITION job20220802 VALUES [(‘2022-08-02’), (‘2022-08-03’)),
PARTITION job20220803 VALUES [(‘2022-08-03’), (‘2022-08-04’)),
PARTITION job20220804 VALUES [(‘2022-08-04’), (‘2022-08-05’)),
PARTITION job20220805 VALUES [(‘2022-08-05’), (‘2022-08-06’)),
PARTITION job20220806 VALUES [(‘2022-08-06’), (‘2022-08-07’)),
PARTITION job20220807 VALUES [(‘2022-08-07’), (‘2022-08-08’)),
PARTITION job20220808 VALUES [(‘2022-08-08’), (‘2022-08-09’)),
PARTITION job20220809 VALUES [(‘2022-08-09’), (‘2022-08-10’)),
PARTITION job20220810 VALUES [(‘2022-08-10’), (‘2022-08-11’)),
PARTITION job20220811 VALUES [(‘2022-08-11’), (‘2022-08-12’)),
PARTITION job20220812 VALUES [(‘2022-08-12’), (‘2022-08-13’)),
PARTITION job20220813 VALUES [(‘2022-08-13’), (‘2022-08-14’)),
PARTITION job20220814 VALUES [(‘2022-08-14’), (‘2022-08-15’)),
PARTITION job20220815 VALUES [(‘2022-08-15’), (‘2022-08-16’)),
PARTITION job20220816 VALUES [(‘2022-08-16’), (‘2022-08-17’)),
PARTITION job20220817 VALUES [(‘2022-08-17’), (‘2022-08-18’)),
PARTITION job20220818 VALUES [(‘2022-08-18’), (‘2022-08-19’)),
PARTITION job20220819 VALUES [(‘2022-08-19’), (‘2022-08-20’)),
PARTITION job20220820 VALUES [(‘2022-08-20’), (‘2022-08-21’)),
PARTITION job20220821 VALUES [(‘2022-08-21’), (‘2022-08-22’)),
PARTITION job20220822 VALUES [(‘2022-08-22’), (‘2022-08-23’)),
PARTITION job20220823 VALUES [(‘2022-08-23’), (‘2022-08-24’)),
PARTITION job20220824 VALUES [(‘2022-08-24’), (‘2022-08-25’)),
PARTITION job20220825 VALUES [(‘2022-08-25’), (‘2022-08-26’)),
PARTITION job20220826 VALUES [(‘2022-08-26’), (‘2022-08-27’)),
PARTITION job20220827 VALUES [(‘2022-08-27’), (‘2022-08-28’)),
PARTITION job20220828 VALUES [(‘2022-08-28’), (‘2022-08-29’)),
PARTITION job20220829 VALUES [(‘2022-08-29’), (‘2022-08-30’)),
PARTITION job20220830 VALUES [(‘2022-08-30’), (‘2022-08-31’)),
PARTITION job20220831 VALUES [(‘2022-08-31’), (‘2022-09-01’)),
PARTITION job20220901 VALUES [(‘2022-09-01’), (‘2022-09-02’)),
PARTITION job20220902 VALUES [(‘2022-09-02’), (‘2022-09-03’)),
PARTITION job20220903 VALUES [(‘2022-09-03’), (‘2022-09-04’)),
PARTITION job20220904 VALUES [(‘2022-09-04’), (‘2022-09-05’)),
PARTITION job20220905 VALUES [(‘2022-09-05’), (‘2022-09-06’)),
PARTITION job20220906 VALUES [(‘2022-09-06’), (‘2022-09-07’)),
PARTITION job20220907 VALUES [(‘2022-09-07’), (‘2022-09-08’)),
PARTITION job20220908 VALUES [(‘2022-09-08’), (‘2022-09-09’)),
PARTITION job20220909 VALUES [(‘2022-09-09’), (‘2022-09-10’)),
PARTITION job20220910 VALUES [(‘2022-09-10’), (‘2022-09-11’)),
PARTITION job20220911 VALUES [(‘2022-09-11’), (‘2022-09-12’)),
PARTITION job20220912 VALUES [(‘2022-09-12’), (‘2022-09-13’)),
PARTITION job20220913 VALUES [(‘2022-09-13’), (‘2022-09-14’)),
PARTITION job20220914 VALUES [(‘2022-09-14’), (‘2022-09-15’)),
PARTITION job20220915 VALUES [(‘2022-09-15’), (‘2022-09-16’)),
PARTITION job20220916 VALUES [(‘2022-09-16’), (‘2022-09-17’)),
PARTITION job20220917 VALUES [(‘2022-09-17’), (‘2022-09-18’)),
PARTITION job20220918 VALUES [(‘2022-09-18’), (‘2022-09-19’)),
PARTITION job20220919 VALUES [(‘2022-09-19’), (‘2022-09-20’)),
PARTITION job20220920 VALUES [(‘2022-09-20’), (‘2022-09-21’)),
PARTITION job20220921 VALUES [(‘2022-09-21’), (‘2022-09-22’)),
PARTITION job20220922 VALUES [(‘2022-09-22’), (‘2022-09-23’)),
PARTITION job20220923 VALUES [(‘2022-09-23’), (‘2022-09-24’)),
PARTITION job20220924 VALUES [(‘2022-09-24’), (‘2022-09-25’)),
PARTITION job20220925 VALUES [(‘2022-09-25’), (‘2022-09-26’)),
PARTITION job20220926 VALUES [(‘2022-09-26’), (‘2022-09-27’)),
PARTITION job20220927 VALUES [(‘2022-09-27’), (‘2022-09-28’)),
PARTITION job20220928 VALUES [(‘2022-09-28’), (‘2022-09-29’)),
PARTITION job20220929 VALUES [(‘2022-09-29’), (‘2022-09-30’)),
PARTITION job20220930 VALUES [(‘2022-09-30’), (‘2022-10-01’)),
PARTITION job20221001 VALUES [(‘2022-10-01’), (‘2022-10-02’)),
PARTITION job20221002 VALUES [(‘2022-10-02’), (‘2022-10-03’)),
PARTITION job20221003 VALUES [(‘2022-10-03’), (‘2022-10-04’)),
PARTITION job20221004 VALUES [(‘2022-10-04’), (‘2022-10-05’)),
PARTITION job20221005 VALUES [(‘2022-10-05’), (‘2022-10-06’)),
PARTITION job20221006 VALUES [(‘2022-10-06’), (‘2022-10-07’)),
PARTITION job20221007 VALUES [(‘2022-10-07’), (‘2022-10-08’)),
PARTITION job20221008 VALUES [(‘2022-10-08’), (‘2022-10-09’)),
PARTITION job20221009 VALUES [(‘2022-10-09’), (‘2022-10-10’)),
PARTITION job20221010 VALUES [(‘2022-10-10’), (‘2022-10-11’)),
PARTITION job20221011 VALUES [(‘2022-10-11’), (‘2022-10-12’)),
PARTITION job20221012 VALUES [(‘2022-10-12’), (‘2022-10-13’)),
PARTITION job20221013 VALUES [(‘2022-10-13’), (‘2022-10-14’)),
PARTITION job20221014 VALUES [(‘2022-10-14’), (‘2022-10-15’)),
PARTITION job20221015 VALUES [(‘2022-10-15’), (‘2022-10-16’)),
PARTITION job20221016 VALUES [(‘2022-10-16’), (‘2022-10-17’)),
PARTITION job20221017 VALUES [(‘2022-10-17’), (‘2022-10-18’)),
PARTITION job20221018 VALUES [(‘2022-10-18’), (‘2022-10-19’)),
PARTITION job20221019 VALUES [(‘2022-10-19’), (‘2022-10-20’)),
PARTITION job20221020 VALUES [(‘2022-10-20’), (‘2022-10-21’)),
PARTITION job20221021 VALUES [(‘2022-10-21’), (‘2022-10-22’)),
PARTITION job20221022 VALUES [(‘2022-10-22’), (‘2022-10-23’)),
PARTITION job20221023 VALUES [(‘2022-10-23’), (‘2022-10-24’)),
PARTITION job20221024 VALUES [(‘2022-10-24’), (‘2022-10-25’)),
PARTITION job20221025 VALUES [(‘2022-10-25’), (‘2022-10-26’)),
PARTITION job20221026 VALUES [(‘2022-10-26’), (‘2022-10-27’)),
PARTITION job20221027 VALUES [(‘2022-10-27’), (‘2022-10-28’)),
PARTITION job20221028 VALUES [(‘2022-10-28’), (‘2022-10-29’)),
PARTITION job20221029 VALUES [(‘2022-10-29’), (‘2022-10-30’)),
PARTITION job20221030 VALUES [(‘2022-10-30’), (‘2022-10-31’)),
PARTITION job20221031 VALUES [(‘2022-10-31’), (‘2022-11-01’)),
PARTITION job20221101 VALUES [(‘2022-11-01’), (‘2022-11-02’)),
PARTITION job20221102 VALUES [(‘2022-11-02’), (‘2022-11-03’)),
PARTITION job20221103 VALUES [(‘2022-11-03’), (‘2022-11-04’)))
DISTRIBUTED BY HASH(job_id) BUCKETS 3
PROPERTIES (
“replication_num” = “1”,
“dynamic_partition.enable” = “true”,
“dynamic_partition.time_unit” = “DAY”,
“dynamic_partition.time_zone” = “Asia/Shanghai”,
“dynamic_partition.start” = “-185”,
“dynamic_partition.end” = “3”,
“dynamic_partition.prefix” = “job”,
“dynamic_partition.buckets” = “3”,
“in_memory” = “false”,
“storage_format” = “DEFAULT”,
“enable_persistent_index” = “false”
);

没复现出来,提供一下query dump看看?

https://github.com/StarRocks/starrocks/pull/13185/files 这个PR是解决这个问题的。

我后来通过jdbc连接试了一下,也没有再复现出这个问题了 :sweat_smile: