from: flink-connectors
to: flink-scala-shell
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-scala-shell
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-scala-shell
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-scala-shell
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-scala-shell
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-scala-shell
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-scala-shell
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-scala-shell
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-scala-shell
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-scala-shell
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-scala-shell
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;"