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