You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/08/08 06:59:00 UTC
[jira] [Created] (FLINK-28860) CacheITCase.testBatchProduceCacheStreamConsume failed
Huang Xingbo created FLINK-28860:
------------------------------------
Summary: CacheITCase.testBatchProduceCacheStreamConsume failed
Key: FLINK-28860
URL: https://issues.apache.org/jira/browse/FLINK-28860
Project: Flink
Issue Type: Bug
Components: API / DataStream
Affects Versions: 1.16.0
Reporter: Huang Xingbo
Fix For: 1.16.0
{code:java}
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)
{code}
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
--
This message was sent by Atlassian Jira
(v8.20.10#820010)