from: flink-connectors
to: flink-java
evidence:
 - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java"
   contains "import org.apache.flink.api.java.ClosureCleaner;"

from: flink-connectors
to: flink-java
evidence:
 - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleWriteAheadSink.java"
   contains "import org.apache.flink.api.java.ClosureCleaner;"

from: flink-connectors
to: flink-java
evidence:
 - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraRowWriteAheadSink.java"
   contains "import org.apache.flink.api.java.ClosureCleaner;"

from: flink-connectors
to: flink-java
evidence:
 - file: "flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSinkBase.java"
   contains "import org.apache.flink.api.java.ClosureCleaner;"

from: flink-connectors
to: flink-java
evidence:
 - file: "flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java"
   contains "import org.apache.flink.api.java.utils.ParameterTool;"

from: flink-connectors
to: flink-java
evidence:
 - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java"
   contains "import org.apache.flink.api.java.ClosureCleaner;"

from: flink-connectors
to: flink-java
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java"
   contains "import org.apache.flink.api.java.ClosureCleaner;"

from: flink-connectors
to: flink-java
evidence:
 - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java"
   contains "import org.apache.flink.api.java.ClosureCleaner;"

from: flink-connectors
to: flink-java
evidence:
 - file: "flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java"
   contains "import org.apache.flink.api.java.ClosureCleaner;"

from: flink-connectors
to: flink-java
evidence:
 - file: "flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java"
   contains "import org.apache.flink.api.java.ClosureCleaner;"

from: flink-connectors
to: flink-java
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleProducer.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-connectors
to: flink-java
evidence:
 - file: "flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffle.java"
   contains "import org.apache.flink.api.java.functions.KeySelector;"

from: flink-connectors
to: flink-java
evidence:
 - file: "flink-connectors/flink-connector-twitter/src/main/java/org/apache/flink/streaming/connectors/twitter/TwitterSource.java"
   contains "import org.apache.flink.api.java.ClosureCleaner;"

from: flink-connectors
to: flink-java
evidence:
 - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/HadoopUtils.java"
   contains "import org.apache.flink.api.java.utils.ParameterTool;"

from: flink-connectors
to: flink-java
evidence:
 - file: "flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/hadoopcompatibility/mapred/wrapper/HadoopTupleUnwrappingIterator.java"
   contains "import org.apache.flink.api.java.operators.translation.TupleUnwrappingIterator;"

from: flink-connectors
to: flink-java
evidence:
 - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/HBaseTableSource.java"
   contains "import org.apache.flink.api.java.DataSet;"