flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Hequn Cheng <chenghe...@gmail.com>
Subject Re: FoldFunction accumulator checkpointing
Date Mon, 03 Sep 2018 01:39:40 GMT
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 <m.marzieh.ghasemi@gmail.com> 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/
>

Mime
View raw message