xiaojin.wy created FLINK-23077:
----------------------------------
Summary: Running nexmark q5 with 1.13.1 of
pipeline.object-reuse=true, the taskmanager will be killed and produce failover.
Key: FLINK-23077
URL: https://issues.apache.org/jira/browse/FLINK-23077
Project: Flink
Issue Type: Bug
Components: Table SQL / Runtime
Affects Versions: 1.13.1, 1.13.0
Reporter: xiaojin.wy
Running nexmark with flink 1.13.0, 1.13.1, q5 can`t success.
*The conf is: *
pipeline.object-reuse=true
*The sql is:*
CREATE TABLE discard_sink (
auction BIGINT,
num BIGINT
) WITH (
'connector' = 'blackhole'
);
INSERT INTO discard_sink
SELECT AuctionBids.auction, AuctionBids.num
FROM (
SELECT
B1.auction,
count(*) AS num,
HOP_START(B1.dateTime, INTERVAL '2' SECOND, INTERVAL '10' SECOND) AS
starttime,
HOP_END(B1.dateTime, INTERVAL '2' SECOND, INTERVAL '10' SECOND) AS endtime
FROM bid B1
GROUP BY
B1.auction,
HOP(B1.dateTime, INTERVAL '2' SECOND, INTERVAL '10' SECOND)
) AS AuctionBids
JOIN (
SELECT
max(CountBids.num) AS maxn,
CountBids.starttime,
CountBids.endtime
FROM (
SELECT
count(*) AS num,
HOP_START(B2.dateTime, INTERVAL '2' SECOND, INTERVAL '10' SECOND) AS
starttime,
HOP_END(B2.dateTime, INTERVAL '2' SECOND, INTERVAL '10' SECOND) AS
endtime
FROM bid B2
GROUP BY
B2.auction,
HOP(B2.dateTime, INTERVAL '2' SECOND, INTERVAL '10' SECOND)
) AS CountBids
GROUP BY CountBids.starttime, CountBids.endtime
) AS MaxBids
ON AuctionBids.starttime = MaxBids.starttime AND
AuctionBids.endtime = MaxBids.endtime AND
AuctionBids.num >= MaxBids.maxn;%
*The error is:*
!image-2021-06-22-11-30-58-022.png!
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
