【已解决】在使用ARRAY_AGG函数后be会挂掉

Viewed 36

建表语句

CREATE TABLE IF NOT EXISTS enterprise_tender_info
(

    `id`    VARCHAR(1024) NOT NULL",
    `bidId`     VARCHAR(64)",
    `projectType`  VARCHAR(64)",
    `recruitCompanyType`  VARCHAR(64)",
    `recruitCompanyName`  VARCHAR(1024)",
    `recruitCompany_ITCode`  VARCHAR(64)",
    `recruitCompany_ITCode2`  VARCHAR(64)",
    `publishDate`   DATE COMMENT",
    `bidAmount`    DOUBLE COMMENT",
    `bidCompanyProvinceCode`  VARCHAR(64)",
    `bidCompanyCityCode`  VARCHAR(64)",
    `bidCompanyCountyCode`  VARCHAR(64)",
    `bidCompanyIndustry_1`   VARCHAR(64)",
    `bidCompanyIndustry_2`    VARCHAR(64)",
    `bidCompanyIndustry_3`    VARCHAR(64)",
    `bidCompanyIndustry_4`    VARCHAR(64)",
    `bidCompanyType`    VARCHAR(64)",
    `bidCompanyScale`     VARCHAR(64)",
    `bidCompanyRegisteredCapital`  VARCHAR(64)",
    `bidCompany_ITCode`     VARCHAR(64)",
    `bidCompany_ITCode2`    VARCHAR(64)",
    `bidCompanyName`         VARCHAR(1024)",
    `updateAt`   DATE"
)
UNIQUE KEY(`id`)
DISTRIBUTED BY HASH(`id`) BUCKETS 10
PROPERTIES (
    "replication_allocation" = "tag.location.default: 1",
"enable_unique_key_merge_on_write" = "true"
)
;

查询语句

select *
from (select bidCompany_ITCode2,
             bidCompanyName,
             sum(bidAmount)                as amount,
             count(bidCompany_ITCode2)     as bidcnt,
             count(recruitCompany_ITCode2) as recnt,
             ARRAY_AGG(recruitCompanyName) as arr
      from enterprise_tender_info eti
      where recruitCompanyType = '12'
      group by bidCompany_ITCode2, bidCompanyName) A
order by A.recnt desc
limit 100;

[HY000][1105] RpcException, msg: io.grpc.StatusRuntimeException: UNAVAILABLE: Network closed for unknown reason

be会挂掉

2 Answers

已经本地复现,等 fix 后将 PR 同步到这个帖子下
image.png

你这个是稳定挂吗?数据有没有什么特殊的