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)

Reply via email to