(DEPRECATED) Apache Flink User Mailing List archive.

Re: FoldFunction accumulator checkpointing

Posted by Hequn Cheng on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/FoldFunction-accumulator-checkpointing-tp6068p22781.html

Hi Marzieh,

Have you ever imported `org.apache.flink.api.java.tuple.Tuple2`? It seems that you imported the wrong class. You can copy the code from here[1].

Best, Hequn

[1] https://ci.apache.org/projects/flink/flink-docs-master/tutorials/datastream_api.html

On Sun, Sep 2, 2018 at 1:56 PM Mar_zieh <[hidden email]> wrote:

Hello

I wrote example of "Monitoring the Wikipedia Edit Stream" in Intellij Idea,
but I got errors on "acc.f0 , acc.f1" which was like this:

Error:(39, 28) java: cannot find symbol
symbol: variable f0
location: variable acc of type
scala.Tuple2<java.lang.String,java.lang.Long>

Would you please tell me how to solve this problem?

Thank you in advance.

--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/