Re: Problem with KeyedStream 1.0-SNAPSHOT

Hi Fabian, Thanks a lot, it worked. On 15 February 2016 at 12:42, Fabian Hueske wrote: > Hi Javier, > > Keys is an internal class and was recently moved to a different package. > So it appears like your Flink dependencies are not aligned to the same > version. > > We also

Re: Problem with KeyedStream 1.0-SNAPSHOT

Hi Javier, Keys is an internal class and was recently moved to a different package. So it appears like your Flink dependencies are not aligned to the same version. We also added Scala version identifiers to all our dependencies which depend on Scala 2.10. For instance, flink-scala became

Problem with KeyedStream 1.0-SNAPSHOT

Hi guys, I'm running a small test with the SNAPSHOT version in order to be able to use Kafka 0.9 and I'm getting the following error: *cannot access org.apache.flink.api.java.operators.Keys* *[ERROR] class file for org.apache.flink.api.java.operators.Keys not found* The code I'm using is as