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)