[FLINK-30097] CachedDataStream java example in the document is not correct

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.16.0
• Component/s: Documentation
• Labels: pull-request-available stale-assigned
• Assignee: Xuannan Su
• Reporter: Prabhu Joseph
• Created: 19/Nov/22 13:44
• Updated: 14/Aug/23 22:35

Description

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

 

DataStream<Integer> dataStream = //...
CachedDataStream<Integer> cachedDataStream = dataStream.cache();

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.
 

Issue Links

• links to: GitHub Pull Request #21506