[FLINK-28860] CacheITCase.testBatchProduceCacheStreamConsume failed

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.16.0
• Fix Version/s: 1.16.0
• Component/s: API / DataStream
• Labels: pull-request-available test-stability
• Assignee: Xuannan Su
• Reporter: Huang Xingbo
• Created: 08/Aug/22 06:58
• Updated: 08/Sep/22 03:26
• Resolved: 08/Sep/22 03:26

Description

2022-08-08T03:27:22.1988575Z Aug 08 03:27:22 [ERROR] org.apache.flink.test.streaming.runtime.CacheITCase.testBatchProduceCacheStreamConsume(Path)  Time elapsed: 0.593 s  <<< ERROR!
2022-08-08T03:27:22.1989338Z Aug 08 03:27:22 java.lang.RuntimeException: Producing cache IntermediateResult is not supported in streaming mode
2022-08-08T03:27:22.1990401Z Aug 08 03:27:22 	at org.apache.flink.streaming.runtime.translators.CacheTransformationTranslator.translateForStreamingInternal(CacheTransformationTranslator.java:75)
2022-08-08T03:27:22.1991511Z Aug 08 03:27:22 	at org.apache.flink.streaming.runtime.translators.CacheTransformationTranslator.translateForStreamingInternal(CacheTransformationTranslator.java:42)
2022-08-08T03:27:22.1993671Z Aug 08 03:27:22 	at org.apache.flink.streaming.api.graph.SimpleTransformationTranslator.translateForStreaming(SimpleTransformationTranslator.java:62)
2022-08-08T03:27:22.1994900Z Aug 08 03:27:22 	at org.apache.flink.streaming.api.graph.StreamGraphGenerator.translate(StreamGraphGenerator.java:830)
2022-08-08T03:27:22.1995748Z Aug 08 03:27:22 	at org.apache.flink.streaming.api.graph.StreamGraphGenerator.transform(StreamGraphGenerator.java:560)
2022-08-08T03:27:22.1996932Z Aug 08 03:27:22 	at org.apache.flink.streaming.api.graph.StreamGraphGenerator.getParentInputIds(StreamGraphGenerator.java:851)
2022-08-08T03:27:22.1998562Z Aug 08 03:27:22 	at org.apache.flink.streaming.api.graph.StreamGraphGenerator.translate(StreamGraphGenerator.java:809)
2022-08-08T03:27:22.1999581Z Aug 08 03:27:22 	at org.apache.flink.streaming.api.graph.StreamGraphGenerator.transform(StreamGraphGenerator.java:560)
2022-08-08T03:27:22.2000376Z Aug 08 03:27:22 	at org.apache.flink.streaming.api.graph.StreamGraphGenerator.generate(StreamGraphGenerator.java:319)
2022-08-08T03:27:22.2001359Z Aug 08 03:27:22 	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getStreamGraph(StreamExecutionEnvironment.java:2250)
2022-08-08T03:27:22.2002767Z Aug 08 03:27:22 	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getStreamGraph(StreamExecutionEnvironment.java:2241)
2022-08-08T03:27:22.2004121Z Aug 08 03:27:22 	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getStreamGraph(StreamExecutionEnvironment.java:2227)
2022-08-08T03:27:22.2005059Z Aug 08 03:27:22 	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2178)
2022-08-08T03:27:22.2005939Z Aug 08 03:27:22 	at org.apache.flink.streaming.api.datastream.DataStream.executeAndCollectWithClient(DataStream.java:1469)
2022-08-08T03:27:22.2006735Z Aug 08 03:27:22 	at org.apache.flink.streaming.api.datastream.DataStream.executeAndCollect(DataStream.java:1334)
2022-08-08T03:27:22.2007500Z Aug 08 03:27:22 	at org.apache.flink.streaming.api.datastream.DataStream.executeAndCollect(DataStream.java:1320)
2022-08-08T03:27:22.2008315Z Aug 08 03:27:22 	at org.apache.flink.test.streaming.runtime.CacheITCase.testBatchProduceCacheStreamConsume(CacheITCase.java:190)

https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=39518&view=logs&j=a57e0635-3fad-5b08-57c7-a4142d7d6fa9&t=2ef0effc-1da1-50e5-c2bd-aab434b1c5b7

Issue Links

• links to: GitHub Pull Request #20512
• links to: GitHub Pull Request #20534