Thanks, good catch. Could you open the JIRA please and assign it to me? Fixing it asap as we would like to cut a release candidate today. :)
On Fri, May 29, 2015 at 11:31 AM, Matthias J. Sax < mj...@informatik.hu-berlin.de> wrote: > Hi, > > the classes KafkaITCase.java and KafkaLocalSystemTime.java have an wrong > package statement. > > They are in package "org.apache.flink.streaming.kafka" and > "org.apache.flink.streaming.kafka.util" respectily, but the package > statements are > > package org.apache.flink.streaming.connectors.kafka; > and > > package org.apache.flink.streaming.connectors.kafka.util; > > Not sure why the build succeeds. However, I remember a similar issues > that was resolved a few weeks ago > https://github.com/apache/flink/pull/437 > > I guess, that breaking up the connector module into sub-modules > introduces this bug. > > Shall I open an JIRA for it or just open a pull request with a fix for > it? Or is anyone else taking care of it? > > > -Matthias > > > >
