【详述】执行insert into xxxx select xxx from xxx 语句插入数据到目标表,没有报错。
【背景】
【业务影响】
【StarRocks版本】例如:1.18.1
【集群规模】例如:3fe(3 follower)+8be(fe与be混部)
【机器信息】64C/192G/千兆
【附件】
但是select部分是有数据的
【详述】执行insert into xxxx select xxx from xxx 语句插入数据到目标表,没有报错。
【背景】
【业务影响】
【StarRocks版本】例如:1.18.1
【集群规模】例如:3fe(3 follower)+8be(fe与be混部)
【机器信息】64C/192G/千兆
【附件】
语句explain的结果:
PLAN FRAGMENT 0
OUTPUT EXPRS:1: month | 2: access_date | 3: platform_id | 4: id | 5: content | 6: content_type | 7: post_id | 8: user_id | 9: user_name | 10: noise | 11: created_at | 12: access_time | 13: source_type | 14: busi_field | 15: rule_flag | 16: is_host | 17: etl_load_dt
PARTITION: UNPARTITIONED
OLAP TABLE SINK
TUPLE ID: 3
RANDOM
5:EXCHANGE
use vectorized: true
PLAN FRAGMENT 1
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 05
UNPARTITIONED
4:Project
| <slot 1> : 1: month
| <slot 2> : 2: access_date
| <slot 3> : 3: platform_id
| <slot 4> : 4: id
| <slot 5> : 5: content
| <slot 6> : 6: content_type
| <slot 7> : 7: post_id
| <slot 8> : 8: user_id
| <slot 9> : 9: user_name
| <slot 10> : 10: noise
| <slot 11> : 11: created_at
| <slot 12> : 12: access_time
| <slot 13> : 13: source_type
| <slot 14> : 14: busi_field
| <slot 15> : 15: rule_flag
| <slot 16> : 16: is_host
| <slot 17> : 17: etl_load_dt
| use vectorized: true
|
3:HASH JOIN
| join op: LEFT OUTER JOIN (BUCKET_SHUFFLE)
| hash predicates:
| colocate: false, reason:
| equal join conjunct: 4: id = 18: id
| other predicates: 18: id IS NULL
| use vectorized: true
|
|----2:EXCHANGE
| use vectorized: true
|
0:OlapScanNode
TABLE: dm_shoes_clothes_origin1
PREAGGREGATION: ON
PREDICATES: 2: access_date = ‘2021-11-14’
partitions=1/1
rollup: dm_shoes_clothes_origin1
tabletRatio=16/16
tabletList=6385177,6385181,6385185,6385189,6385193,6385197,6385201,6385205,6385209,6385213 …
cardinality=11121
avgRowSize=17.0
numNodes=0
use vectorized: true
PLAN FRAGMENT 2
OUTPUT EXPRS:
PARTITION: RANDOM
STREAM DATA SINK
EXCHANGE ID: 02
BUCKET_SHFFULE_HASH_PARTITIONED: 18: id
1:OlapScanNode
TABLE: dm_shoes_clothes_id
PREAGGREGATION: OFF. Reason: Has Join
partitions=1/1
rollup: dm_shoes_clothes_id
tabletRatio=32/32
tabletList=6377398,6377402,6377406,6377410,6377414,6377418,6377422,6377426,6377430,6377434 …
cardinality=39031
avgRowSize=1.0
numNodes=0
use vectorized: true
这个问题是什么呢?看图写入成功了啊,写入失败的话贴下报错信息呢
是的,看图写入成功了,但是就是没有数据。没有任何报错信息,很奇怪。
您的问题解决了么?没有复现出来
你好,确实不好复现,我删除了原来的表,重新建表就好了。
您好,下次可以注意观察下insert into执行后的输出提示,看下txn state是visible还是committed
嗯,如果status是VISIBLE就是可见的,如果是committed,可能要等一会儿才能看见
能麻烦修改下帖子标题为 “数据导入成功后SELECT不到”吗?
你好,我好像不能修改帖子的标题,刚发布没多久可以修改,现在好像不行了。