[jira] [Created] (FLINK-9225) Minor code comments fix in RuntimeContext

[Shang Yuanchun (Jira)]

binlijin created FLINK-9225:
-------------------------------

             Summary: Minor code comments fix in RuntimeContext
                 Key: FLINK-9225
                 URL: https://issues.apache.org/jira/browse/FLINK-9225
             Project: Flink
          Issue Type: Bug
            Reporter: binlijin


* <pre>{@code

* DataStream<MyType> stream = ...;

* KeyedStream<MyType> keyedStream = stream.keyBy("id");

*

* keyedStream.map(new RichMapFunction<MyType, Tuple2<MyType, Long>>() {

*

*     private ValueState<Long> count;

*

*     public void open(Configuration cfg) {

*         state = getRuntimeContext().getState(

*                 new ValueStateDescriptor<Long>("count", LongSerializer.INSTANCE, 0L));

*     }

*

*     public Tuple2<MyType, Long> map(MyType value) {

*         long count = state.value() + 1;

*         state.update(value);

*         return new Tuple2<>(value, count);

*     }

* });

 * }</pre>

 

"private ValueState<Long> count;"  should be "private ValueState<Long> state;"



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)