insert into带上limit插入条数不正确

💬 StarRocks 用户问答
#1

【StarRocks版本】例如：2.2.2
【集群规模】例如：3fe（3follower）+8be（fe与be混部）
【机器信息】CPU虚拟核/内存/网卡，例如：40C/192G/千兆
先执行一段查询，限制查询结果2条，如下所示：

image
image1469×801 133 KB

然后再把上述的结果集插入另外一张表中：
image
image528×780 99.5 KB

显示更新了14条数据，再去count一下：
image
查询明细确实变成了14条数据，这是什么原因？
目标表表结构：
CREATE TABLE test_sy_data_12_test (
month date NOT NULL COMMENT “”,
platform_id int(11) NOT NULL COMMENT “”,
id varchar(2000) NOT NULL COMMENT “”,
title varchar(65533) NULL COMMENT “”,
content varchar(65533) NULL COMMENT “”,
content_type int(11) NULL COMMENT “”,
post_id varchar(2000) NULL COMMENT “”,
user_id varchar(2000) NULL COMMENT “”,
user_name varchar(2000) NULL COMMENT “”,
created_at datetime NULL COMMENT “”,
access_time datetime NULL COMMENT “”,
source_type int(11) NULL COMMENT “”,
busi_field varchar(2000) NULL COMMENT “行业标签”,
rule_flag varchar(2000) NULL COMMENT “需求/场景/品类/品牌标签”,
is_host int(11) NULL COMMENT “”,
access_date date NULL COMMENT “”,
inc_flag int(11) NULL COMMENT “0:初始值 1:日增量 2:规则增量”,
etl_load_dt datetime NULL COMMENT “”,
xuqiu varchar(65533) NULL COMMENT “”,
changjing varchar(65533) NULL COMMENT “”,
fangan varchar(65533) NULL COMMENT “”,
driver varchar(65533) NULL COMMENT “”,
barrier varchar(65533) NULL COMMENT “”,
question varchar(65533) NULL COMMENT “”,
cognition varchar(65533) NULL COMMENT “”
) ENGINE=OLAP
UNIQUE KEY(month, platform_id, id)
COMMENT “大健康集市需求时刻结果表”
PARTITION BY RANGE(month)
(PARTITION p201901 VALUES [(‘2019-01-01’), (‘2019-02-01’)),
PARTITION p201902 VALUES [(‘2019-02-01’), (‘2019-03-01’)),
PARTITION p201903 VALUES [(‘2019-03-01’), (‘2019-04-01’)),
PARTITION p201904 VALUES [(‘2019-04-01’), (‘2019-05-01’)),
PARTITION p201905 VALUES [(‘2019-05-01’), (‘2019-06-01’)),
PARTITION p201906 VALUES [(‘2019-06-01’), (‘2019-07-01’)),
PARTITION p201907 VALUES [(‘2019-07-01’), (‘2019-08-01’)),
PARTITION p201908 VALUES [(‘2019-08-01’), (‘2019-09-01’)),
PARTITION p201909 VALUES [(‘2019-09-01’), (‘2019-10-01’)),
PARTITION p201910 VALUES [(‘2019-10-01’), (‘2019-11-01’)),
PARTITION p201911 VALUES [(‘2019-11-01’), (‘2019-12-01’)),
PARTITION p201912 VALUES [(‘2019-12-01’), (‘2020-01-01’)),
PARTITION p202001 VALUES [(‘2020-01-01’), (‘2020-02-01’)),
PARTITION p202002 VALUES [(‘2020-02-01’), (‘2020-03-01’)),
PARTITION p202003 VALUES [(‘2020-03-01’), (‘2020-04-01’)),
PARTITION p202004 VALUES [(‘2020-04-01’), (‘2020-05-01’)),
PARTITION p202005 VALUES [(‘2020-05-01’), (‘2020-06-01’)),
PARTITION p202006 VALUES [(‘2020-06-01’), (‘2020-07-01’)),
PARTITION p202007 VALUES [(‘2020-07-01’), (‘2020-08-01’)),
PARTITION p202008 VALUES [(‘2020-08-01’), (‘2020-09-01’)),
PARTITION p202009 VALUES [(‘2020-09-01’), (‘2020-10-01’)),
PARTITION p202010 VALUES [(‘2020-10-01’), (‘2020-11-01’)),
PARTITION p202011 VALUES [(‘2020-11-01’), (‘2020-12-01’)),
PARTITION p202012 VALUES [(‘2020-12-01’), (‘2021-01-01’)),
PARTITION p202101 VALUES [(‘2021-01-01’), (‘2021-02-01’)),
PARTITION p202102 VALUES [(‘2021-02-01’), (‘2021-03-01’)),
PARTITION p202103 VALUES [(‘2021-03-01’), (‘2021-04-01’)),
PARTITION p202104 VALUES [(‘2021-04-01’), (‘2021-05-01’)),
PARTITION p202105 VALUES [(‘2021-05-01’), (‘2021-06-01’)),
PARTITION p202106 VALUES [(‘2021-06-01’), (‘2021-07-01’)),
PARTITION p202107 VALUES [(‘2021-07-01’), (‘2021-08-01’)),
PARTITION p202108 VALUES [(‘2021-08-01’), (‘2021-09-01’)),
PARTITION p202109 VALUES [(‘2021-09-01’), (‘2021-10-01’)),
PARTITION p202110 VALUES [(‘2021-10-01’), (‘2021-11-01’)),
PARTITION p202111 VALUES [(‘2021-11-01’), (‘2021-12-01’)),
PARTITION p202112 VALUES [(‘2021-12-01’), (‘2022-01-01’)),
PARTITION p202201 VALUES [(‘2022-01-01’), (‘2022-02-01’)),
PARTITION p202202 VALUES [(‘2022-02-01’), (‘2022-03-01’)),
PARTITION p202203 VALUES [(‘2022-03-01’), (‘2022-04-01’)),
PARTITION p202204 VALUES [(‘2022-04-01’), (‘2022-05-01’)),
PARTITION p202205 VALUES [(‘2022-05-01’), (‘2022-06-01’)),
PARTITION p202206 VALUES [(‘2022-06-01’), (‘2022-07-01’)),
PARTITION p202207 VALUES [(‘2022-07-01’), (‘2022-08-01’)),
PARTITION p202208 VALUES [(‘2022-08-01’), (‘2022-09-01’)),
PARTITION p202209 VALUES [(‘2022-09-01’), (‘2022-10-01’)),
PARTITION p202210 VALUES [(‘2022-10-01’), (‘2022-11-01’)),
PARTITION p202211 VALUES [(‘2022-11-01’), (‘2022-12-01’)))
DISTRIBUTED BY HASH(id) BUCKETS 32
PROPERTIES (
“replication_num” = “3”,
“colocate_with” = “cgs_industry_health”,
“dynamic_partition.enable” = “true”,
“dynamic_partition.time_unit” = “MONTH”,
“dynamic_partition.time_zone” = “Asia/Shanghai”,
“dynamic_partition.start” = “-2147483648”,
“dynamic_partition.end” = “1”,
“dynamic_partition.prefix” = “p”,
“dynamic_partition.buckets” = “32”,
“dynamic_partition.start_day_of_month” = “1”,
“in_memory” = “false”,
“storage_format” = “DEFAULT”
);

StarRocks 2.2.2使用问题
#2

您好，请问下您的source table是什么模型呢？

#3

你好，是更新模型

#4

你好，这是个bug吗？

#6

嗯嗯，好的，知道了。

#7

是有什么新发现吗？

#8

咱们sink表是什么类型的呢？我再check下

#9

你好，是更新模型。

#10

方便提供下问题数据么？我check下。

#11

原表数据3亿5千万，我导出了1万条，你看看能否复现
query-mysql-322.csv (10.3 MB)
另外，原表的表结构我也贴一下：
CREATE TABLE dm_health (
month date NOT NULL COMMENT “”,
platform_id int(11) NOT NULL COMMENT “”,
id varchar(2000) NOT NULL COMMENT “”,
title varchar(65533) NULL COMMENT “”,
content varchar(65533) NULL COMMENT “”,
content_type int(11) NULL COMMENT “”,
post_id varchar(2000) NULL COMMENT “”,
user_id varchar(2000) NULL COMMENT “”,
user_name varchar(2000) NULL COMMENT “”,
created_at datetime NULL COMMENT “”,
access_time datetime NULL COMMENT “”,
source_type int(11) NULL COMMENT “”,
busi_field varchar(2000) NULL COMMENT “行业标签”,
rule_flag varchar(2000) NULL COMMENT “需求/场景/品类/品牌标签”,
is_host int(11) NULL COMMENT “”,
access_date date NULL COMMENT “”,
inc_flag int(11) NULL COMMENT “0:初始值 1:日增量 2:规则增量”,
etl_load_dt datetime NULL COMMENT “”,
xuqiu varchar(65533) NULL COMMENT “”,
changjing varchar(65533) NULL COMMENT “”,
fangan varchar(65533) NULL COMMENT “”,
driver varchar(65533) NULL COMMENT “”,
barrier varchar(65533) NULL COMMENT “”,
question varchar(65533) NULL COMMENT “”,
cognition varchar(65533) NULL COMMENT “”
) ENGINE=OLAP
UNIQUE KEY(month, platform_id, id)
COMMENT “大健康集市需求时刻结果表”
PARTITION BY RANGE(month)
(PARTITION p201901 VALUES [(‘2019-01-01’), (‘2019-02-01’)),
PARTITION p201902 VALUES [(‘2019-02-01’), (‘2019-03-01’)),
PARTITION p201903 VALUES [(‘2019-03-01’), (‘2019-04-01’)),
PARTITION p201904 VALUES [(‘2019-04-01’), (‘2019-05-01’)),
PARTITION p201905 VALUES [(‘2019-05-01’), (‘2019-06-01’)),
PARTITION p201906 VALUES [(‘2019-06-01’), (‘2019-07-01’)),
PARTITION p201907 VALUES [(‘2019-07-01’), (‘2019-08-01’)),
PARTITION p201908 VALUES [(‘2019-08-01’), (‘2019-09-01’)),
PARTITION p201909 VALUES [(‘2019-09-01’), (‘2019-10-01’)),
PARTITION p201910 VALUES [(‘2019-10-01’), (‘2019-11-01’)),
PARTITION p201911 VALUES [(‘2019-11-01’), (‘2019-12-01’)),
PARTITION p201912 VALUES [(‘2019-12-01’), (‘2020-01-01’)),
PARTITION p202001 VALUES [(‘2020-01-01’), (‘2020-02-01’)),
PARTITION p202002 VALUES [(‘2020-02-01’), (‘2020-03-01’)),
PARTITION p202003 VALUES [(‘2020-03-01’), (‘2020-04-01’)),
PARTITION p202004 VALUES [(‘2020-04-01’), (‘2020-05-01’)),
PARTITION p202005 VALUES [(‘2020-05-01’), (‘2020-06-01’)),
PARTITION p202006 VALUES [(‘2020-06-01’), (‘2020-07-01’)),
PARTITION p202007 VALUES [(‘2020-07-01’), (‘2020-08-01’)),
PARTITION p202008 VALUES [(‘2020-08-01’), (‘2020-09-01’)),
PARTITION p202009 VALUES [(‘2020-09-01’), (‘2020-10-01’)),
PARTITION p202010 VALUES [(‘2020-10-01’), (‘2020-11-01’)),
PARTITION p202011 VALUES [(‘2020-11-01’), (‘2020-12-01’)),
PARTITION p202012 VALUES [(‘2020-12-01’), (‘2021-01-01’)),
PARTITION p202101 VALUES [(‘2021-01-01’), (‘2021-02-01’)),
PARTITION p202102 VALUES [(‘2021-02-01’), (‘2021-03-01’)),
PARTITION p202103 VALUES [(‘2021-03-01’), (‘2021-04-01’)),
PARTITION p202104 VALUES [(‘2021-04-01’), (‘2021-05-01’)),
PARTITION p202105 VALUES [(‘2021-05-01’), (‘2021-06-01’)),
PARTITION p202106 VALUES [(‘2021-06-01’), (‘2021-07-01’)),
PARTITION p202107 VALUES [(‘2021-07-01’), (‘2021-08-01’)),
PARTITION p202108 VALUES [(‘2021-08-01’), (‘2021-09-01’)),
PARTITION p202109 VALUES [(‘2021-09-01’), (‘2021-10-01’)),
PARTITION p202110 VALUES [(‘2021-10-01’), (‘2021-11-01’)),
PARTITION p202111 VALUES [(‘2021-11-01’), (‘2021-12-01’)),
PARTITION p202112 VALUES [(‘2021-12-01’), (‘2022-01-01’)),
PARTITION p202201 VALUES [(‘2022-01-01’), (‘2022-02-01’)),
PARTITION p202202 VALUES [(‘2022-02-01’), (‘2022-03-01’)),
PARTITION p202203 VALUES [(‘2022-03-01’), (‘2022-04-01’)),
PARTITION p202204 VALUES [(‘2022-04-01’), (‘2022-05-01’)),
PARTITION p202205 VALUES [(‘2022-05-01’), (‘2022-06-01’)),
PARTITION p202206 VALUES [(‘2022-06-01’), (‘2022-07-01’)),
PARTITION p202207 VALUES [(‘2022-07-01’), (‘2022-08-01’)),
PARTITION p202208 VALUES [(‘2022-08-01’), (‘2022-09-01’)),
PARTITION p202209 VALUES [(‘2022-09-01’), (‘2022-10-01’)),
PARTITION p202210 VALUES [(‘2022-10-01’), (‘2022-11-01’)),
PARTITION p202211 VALUES [(‘2022-11-01’), (‘2022-12-01’)))
DISTRIBUTED BY HASH(id) BUCKETS 32
PROPERTIES (
“replication_num” = “3”,
“colocate_with” = “cgs_industry_health”,
“dynamic_partition.enable” = “true”,
“dynamic_partition.time_unit” = “MONTH”,
“dynamic_partition.time_zone” = “Asia/Shanghai”,
“dynamic_partition.start” = “-2147483648”,
“dynamic_partition.end” = “1”,
“dynamic_partition.prefix” = “p”,
“dynamic_partition.buckets” = “32”,
“dynamic_partition.start_day_of_month” = “1”,
“in_memory” = “false”,
“storage_format” = “DEFAULT”
);

#12

这个定位是bug，会在后续版本修复，目前建议是使用pk模型吧。

#13

好的，了解了（凑够8个字）。

京ICP备2022026421号-1