建表语句
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会挂掉