[
https://issues.apache.org/jira/browse/FLINK-6023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15905244#comment-15905244
]
ASF GitHub Bot commented on FLINK-6023:
---------------------------------------
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3510#discussion_r105417009
--- Diff: docs/dev/stream/process_function.md ---
@@ -176,56 +176,57 @@ public class CountWithTimeoutFunction extends
RichProcessFunction<Tuple2<String,
<div data-lang="scala" markdown="1">
{% highlight scala %}
-import org.apache.flink.api.common.state.ValueState;
-import org.apache.flink.api.common.state.ValueStateDescriptor;
-import org.apache.flink.streaming.api.functions.ProcessFunction;
-import org.apache.flink.streaming.api.functions.ProcessFunction.Context;
-import
org.apache.flink.streaming.api.functions.ProcessFunction.OnTimerContext;
-import org.apache.flink.util.Collector;
+import org.apache.flink.api.common.state.ValueState
+import org.apache.flink.api.common.state.ValueStateDescriptor
+import org.apache.flink.streaming.api.functions.RichProcessFunction
--- End diff --
RichProcessFunction no longer exists, can you change it back to
ProcessFunction? And there are some `RichProcessFunction`s in the java snippet,
can you try to fix that too?
> Fix Scala snippet into Process Function (Low-level Operations) Doc
> ------------------------------------------------------------------
>
> Key: FLINK-6023
> URL: https://issues.apache.org/jira/browse/FLINK-6023
> Project: Flink
> Issue Type: Bug
> Components: Documentation
> Reporter: Mauro Cortellazzi
> Assignee: Mauro Cortellazzi
> Priority: Trivial
> Fix For: 1.3.0, 1.2.1
>
>
> The current `/docs/dev/stream/process_function.md` has some errors in the
> Scala snippet
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
