You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Jakes John <ja...@gmail.com> on 2017/08/28 22:58:08 UTC
Example build error
When I am trying to build and run streaming wordcount example(example in
the flink github), I am getting the following error
StreamingWordCount.java:[56,59] incompatible types:
org.apache.flink.api.java.operators.DataSource<java.lang.String> cannot be
converted to
org.apache.flink.streaming.api.datastream.DataStream<java.lang.String>
Did any of the apis change? I am building with latest flink
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<flink.version>1.3.2</flink.version>
<slf4j.version>1.7.7</slf4j.version>
<log4j.version>1.2.17</log4j.version>
<scala.binary.version>2.10</scala.binary.version>
</properties>
Thanks,
Johnu
Re: Example build error
Posted by Ted Yu <yu...@gmail.com>.
Looking at:
https://github.com/kl0u/flink-examples/blob/master/src/main/java/com/dataartisans/flinksolo/simple/StreamingWordCount.java
there is no line 56.
Which repo do you get StreamingWordCount from ?
On Mon, Aug 28, 2017 at 3:58 PM, Jakes John <ja...@gmail.com>
wrote:
> When I am trying to build and run streaming wordcount example(example in
> the flink github), I am getting the following error
>
> StreamingWordCount.java:[56,59] incompatible types:
> org.apache.flink.api.java.operators.DataSource<java.lang.String> cannot
> be converted to org.apache.flink.streaming.api.datastream.DataStream<
> java.lang.String>
>
>
> Did any of the apis change? I am building with latest flink
>
>
> <properties>
>
> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
>
> <flink.version>1.3.2</flink.version>
>
> <slf4j.version>1.7.7</slf4j.version>
>
> <log4j.version>1.2.17</log4j.version>
>
> <scala.binary.version>2.10</scala.binary.version>
>
> </properties>
>
>
> Thanks,
>
> Johnu
>