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 <jakesjohn12...@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 >
