Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
Description
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;