Hi daviD, does it compile okay if you clone the https://github.com/ fhueske/flink-training-exercises/ directly without any changes? The repo contains the example you are referring to and seems to compile just fine on my machine both with Maven and IntelliJ.
In case it still doesn't work for you, would you mind sharing the output of "mvn compile"? Andrey On Fri, Nov 4, 2016 at 12:22 PM, daviD <duno...@yahoo.com.invalid> wrote: > Greetings, > First, thanks to DataArtisans for putting together Apache Flink® Training > documentation. Its proving to be a practical way to learn both Flink and > Scala. > In compiling our exercise writing to Kafka, I am getting following error > "missing parameter type" where the parameter 'r' seems not to be recognized > in filter method. Code snippet as follows: > val rides = env.addSource(new TaxiRideSource(input, maxEventsDelay, > streamServingSpeed)) > > val filteredRides = rides.filter(r => GeoUtils.isInNYC(r.startLon, > r.startLat) && GeoUtils.isInNYC(r.endLon, r.endLat))Any advice would be > appreciated. > Thanks > > >
