Prabhu Joseph created FLINK-30097:
-------------------------------------
Summary: CachedDataStream java example in the document is not
correct
Key: FLINK-30097
URL: https://issues.apache.org/jira/browse/FLINK-30097
Project: Flink
Issue Type: Bug
Components: Documentation
Affects Versions: 1.16.0
Reporter: Prabhu Joseph
CachedDataStream java example in the document is not correct -
[https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/operators/overview/#datastream-rarr-cacheddatastream]
{code:java}
DataStream<Integer> dataStream = //...
CachedDataStream<Integer> cachedDataStream = dataStream.cache();{code}
The example shows to invoke cache() on a DataStream instance but DataStream
class does not have cache() method. The right usage is to call cache() on an
instance of DataStreamSource/SideOutputDataStream/SingleOutputStreamOperator.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)