from: flink-connectors
to: flink-runtime
evidence:
 - file: "flink-connectors/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSource.java"
   contains "import org.apache.flink.runtime.state.CheckpointListener;"

from: flink-connectors
to: flink-runtime
evidence:
 - file: "flink-connectors/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSink.java"
   contains "import org.apache.flink.runtime.state.FunctionInitializationContext;"

from: flink-connectors
to: flink-runtime
evidence:
 - file: "flink-connectors/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/common/AcknowledgeOnCheckpoint.java"
   contains "import org.apache.flink.runtime.state.CheckpointListener;"

from: flink-connectors
to: flink-runtime
evidence:
 - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/JdbcBatchingOutputFormat.java"
   contains "import org.apache.flink.runtime.util.ExecutorThreadFactory;"

from: flink-connectors
to: flink-runtime
evidence:
 - file: "flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/GenericJdbcSinkFunction.java"
   contains "import org.apache.flink.runtime.state.FunctionInitializationContext;"

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

from: flink-connectors
to: flink-runtime
evidence:
 - file: "flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveContinuousMonitoringFunction.java"
   contains "import org.apache.flink.runtime.state.FunctionInitializationContext;"

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

from: flink-connectors
to: flink-runtime
evidence:
 - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java"
   contains "import org.apache.flink.runtime.state.FunctionInitializationContext;"

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

from: flink-connectors
to: flink-runtime
evidence:
 - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/DynamoDBStreamsProxy.java"
   contains "import org.apache.flink.runtime.util.EnvironmentInformation;"

from: flink-connectors
to: flink-runtime
evidence:
 - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java"
   contains "import org.apache.flink.runtime.util.EnvironmentInformation;"

from: flink-connectors
to: flink-runtime
evidence:
 - file: "flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/JobManagerWatermarkTracker.java"
   contains "import org.apache.flink.runtime.taskexecutor.GlobalAggregateManager;"

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

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

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

from: flink-connectors
to: flink-runtime
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.runtime.state.FunctionInitializationContext;"

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

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

from: flink-connectors
to: flink-runtime
evidence:
 - file: "flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/sink/HBaseSinkFunction.java"
   contains "import org.apache.flink.runtime.util.ExecutorThreadFactory;"

from: flink-connectors
to: flink-runtime
evidence:
 - file: "flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java"
   contains "import org.apache.flink.runtime.state.CheckpointListener;"