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
signature.asc
Description: OpenPGP digital signature
