from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/util/LatencyStats.java" contains "import org.apache.flink.runtime.jobgraph.OperatorID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/util/functions/StreamingFunctionUtils.java" contains "import org.apache.flink.runtime.state.DefaultOperatorStateBackend;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java" contains "import org.apache.flink.runtime.util.FatalExitExceptionHandler;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java" contains "import org.apache.flink.runtime.util.ExecutorThreadFactory;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorEventDispatcherImpl.java" contains "import org.apache.flink.runtime.jobgraph.tasks.TaskOperatorEventGateway;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java" contains "import org.apache.flink.runtime.jobgraph.OperatorID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java" contains "import org.apache.flink.runtime.jobgraph.OperatorID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java" contains "import org.apache.flink.runtime.jobgraph.OperatorID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AbstractTwoInputStreamTask.java" contains "import org.apache.flink.runtime.metrics.MetricNames;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTask.java" contains "import org.apache.flink.runtime.metrics.MetricNames;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTask.java" contains "import org.apache.flink.runtime.metrics.MetricNames;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinator.java" contains "import org.apache.flink.runtime.checkpoint.CheckpointMetaData;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTask.java" contains "import org.apache.flink.runtime.io.network.partition.consumer.IndexedInputGate;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationHead.java" contains "import org.apache.flink.runtime.execution.Environment;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationTail.java" contains "import org.apache.flink.runtime.execution.Environment;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceOperatorStreamTask.java" contains "import org.apache.flink.runtime.execution.Environment;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.java" contains "import org.apache.flink.runtime.metrics.groups.TaskMetricGroup;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java" contains "import org.apache.flink.runtime.util.ReusingMutableToRegularIteratorWrapper;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java" contains "import org.apache.flink.runtime.state.DefaultKeyedStateStore;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/EvictingWindowOperator.java" contains "import org.apache.flink.runtime.state.internal.InternalListState;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/RescalePartitioner.java" contains "import org.apache.flink.runtime.jobgraph.DistributionPattern;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/ShufflePartitioner.java" contains "import org.apache.flink.runtime.plugable.SerializationDelegate;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/KeyGroupStreamPartitioner.java" contains "import org.apache.flink.runtime.plugable.SerializationDelegate;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/GlobalPartitioner.java" contains "import org.apache.flink.runtime.plugable.SerializationDelegate;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/StreamPartitioner.java" contains "import org.apache.flink.runtime.plugable.SerializationDelegate;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/RebalancePartitioner.java" contains "import org.apache.flink.runtime.plugable.SerializationDelegate;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/CustomPartitionerWrapper.java" contains "import org.apache.flink.runtime.plugable.SerializationDelegate;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/ForwardPartitioner.java" contains "import org.apache.flink.runtime.plugable.SerializationDelegate;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/BroadcastPartitioner.java" contains "import org.apache.flink.runtime.plugable.SerializationDelegate;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierUnaligner.java" contains "import org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierHandler.java" contains "import org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/InputProcessorUtil.java" contains "import org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierTracker.java" contains "import org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/AlternatingCheckpointBarrierHandler.java" contains "import org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierAligner.java" contains "import org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTwoInputProcessor.java" contains "import org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTaskInput.java" contains "import org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTaskSourceInput.java" contains "import org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamMultipleInputProcessor.java" contains "import org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamInputProcessor.java" contains "import org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointedInputGate.java" contains "import org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTaskNetworkInput.java" contains "import org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamOneInputProcessor.java" contains "import org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/RecordWriterOutput.java" contains "import org.apache.flink.runtime.plugable.SerializationDelegate;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/InputGateUtil.java" contains "import org.apache.flink.runtime.io.network.partition.consumer.IndexedInputGate;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/PushingAsyncDataInput.java" contains "import org.apache.flink.runtime.io.AvailabilityProvider;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BlockingQueueBroker.java" contains "import org.apache.flink.runtime.iterative.concurrent.Broker;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamrecord/LatencyMarker.java" contains "import org.apache.flink.runtime.jobgraph.OperatorID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.java" contains "import org.apache.flink.runtime.jobgraph.OperatorID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/WithMasterCheckpointHook.java" contains "import org.apache.flink.runtime.checkpoint.MasterTriggerRestoreHook;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedFunction.java" contains "import org.apache.flink.runtime.state.FunctionInitializationContext;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamTaskStateInitializerImpl.java" contains "import org.apache.flink.runtime.util.OperatorSubtaskDescriptionText;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerHeapInternalTimer.java" contains "import org.apache.flink.runtime.state.heap.HeapPriorityQueueElement;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java" contains "import org.apache.flink.runtime.jobgraph.tasks.InputSplitProvider;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperator.java" contains "import org.apache.flink.runtime.jobgraph.OperatorID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorV2.java" contains "import org.apache.flink.runtime.jobgraph.OperatorID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSource.java" contains "import org.apache.flink.runtime.jobgraph.OperatorID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java" contains "import org.apache.flink.runtime.jobgraph.OperatorID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/CoordinatedOperatorFactory.java" contains "import org.apache.flink.runtime.jobgraph.OperatorID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperatorFactory.java" contains "import org.apache.flink.runtime.jobgraph.OperatorID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamTaskStateInitializer.java" contains "import org.apache.flink.runtime.jobgraph.OperatorID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/OperatorSnapshotFinalizer.java" contains "import org.apache.flink.runtime.checkpoint.OperatorSubtaskState;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/OperatorSnapshotFutures.java" contains "import org.apache.flink.runtime.checkpoint.StateObjectCollection;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorStateHandler.java" contains "import org.apache.flink.runtime.checkpoint.CheckpointException;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorParameters.java" contains "import org.apache.flink.runtime.operators.coordination.OperatorEventDispatcher;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java" contains "import org.apache.flink.runtime.operators.coordination.OperatorEvent;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorFactoryUtil.java" contains "import org.apache.flink.runtime.operators.coordination.OperatorEventDispatcher;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceImpl.java" contains "import org.apache.flink.runtime.state.InternalPriorityQueue;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/BackendRestorerProcedure.java" contains "import org.apache.flink.runtime.state.StateObject;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimer.java" contains "import org.apache.flink.runtime.state.KeyExtractorFunction;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/LegacyKeyedProcessOperator.java" contains "import org.apache.flink.runtime.state.VoidNamespace;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimeServiceManager.java" contains "import org.apache.flink.runtime.state.AbstractKeyedStateBackend;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java" contains "import org.apache.flink.runtime.state.VoidNamespace;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorStateContext.java" contains "import org.apache.flink.runtime.state.AbstractKeyedStateBackend;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractUdfStreamOperator.java" contains "import org.apache.flink.runtime.state.CheckpointListener;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/MailboxExecutor.java" contains "import org.apache.flink.runtime.concurrent.FutureTaskWithException;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinator.java" contains "import org.apache.flink.runtime.util.ExecutorThreadFactory;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorFactory.java" contains "import org.apache.flink.runtime.jobgraph.OperatorID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultIterator.java" contains "import org.apache.flink.runtime.jobgraph.OperatorID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperator.java" contains "import org.apache.flink.runtime.jobgraph.OperatorID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultFetcher.java" contains "import org.apache.flink.runtime.jobgraph.OperatorID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunction.java" contains "import org.apache.flink.runtime.operators.coordination.OperatorEventGateway;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectCoordinationRequest.java" contains "import org.apache.flink.runtime.operators.coordination.CoordinationRequest;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectCoordinationResponse.java" contains "import org.apache.flink.runtime.operators.coordination.CoordinationResponse;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkAddressEvent.java" contains "import org.apache.flink.runtime.operators.coordination.OperatorEvent;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java" contains "import org.apache.flink.runtime.state.StateInitializationContext;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/KeyedCoProcessOperator.java" contains "import org.apache.flink.runtime.state.VoidNamespace;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithKeyedOperator.java" contains "import org.apache.flink.runtime.state.KeyedStateBackend;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/LegacyKeyedCoProcessOperator.java" contains "import org.apache.flink.runtime.state.VoidNamespace;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java" contains "import org.apache.flink.runtime.state.StateInitializationContext;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/SimpleTimerService.java" contains "import org.apache.flink.runtime.state.VoidNamespace;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java" contains "import org.apache.flink.runtime.util.ClassLoaderUtil;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java" contains "import org.apache.flink.runtime.jobgraph.topology.DefaultLogicalPipelinedRegion;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java" contains "import org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java" contains "import org.apache.flink.runtime.jobgraph.tasks.AbstractInvokable;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java" contains "import org.apache.flink.runtime.jobgraph.SavepointRestoreSettings;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphHasherV2.java" contains "import org.apache.flink.runtime.jobgraph.JobVertexID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphHasher.java" contains "import org.apache.flink.runtime.jobgraph.JobVertexID;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/FunctionMasterCheckpointHookFactory.java" contains "import org.apache.flink.runtime.checkpoint.MasterTriggerRestoreHook;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/GlobalDataExchangeMode.java" contains "import org.apache.flink.runtime.io.network.partition.ResultPartitionType;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java" contains "import static org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration.MINIMAL_CHECKPOINT_TIME;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/RemoteStreamEnvironment.java" contains "import org.apache.flink.runtime.jobgraph.SavepointRestoreSettings;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java" contains "import org.apache.flink.runtime.state.AbstractStateBackend;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/KeyedBroadcastProcessFunction.java" contains "import org.apache.flink.runtime.state.KeyedStateFunction;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/InputFormatSourceFunction.java" contains "import org.apache.flink.runtime.jobgraph.tasks.InputSplitProvider;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/MessageAcknowledgingSourceBase.java" contains "import org.apache.flink.runtime.state.CheckpointListener;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/MultipleIdsMessageAcknowledgingSourceBase.java" contains "import org.apache.flink.runtime.state.FunctionSnapshotContext;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java" contains "import org.apache.flink.runtime.state.JavaSerializer;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java" contains "import org.apache.flink.runtime.state.FunctionInitializationContext;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java" contains "import org.apache.flink.runtime.state.FunctionInitializationContext;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromElementsFunction.java" contains "import org.apache.flink.runtime.state.FunctionInitializationContext;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/RandomGenerator.java" contains "import org.apache.flink.runtime.state.FunctionInitializationContext;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/DataGeneratorSource.java" contains "import org.apache.flink.runtime.state.FunctionInitializationContext;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java" contains "import org.apache.flink.runtime.state.FunctionInitializationContext;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/DataGenerator.java" contains "import org.apache.flink.runtime.state.FunctionInitializationContext;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java" contains "import org.apache.flink.runtime.state.CheckpointListener;" from: flink-streaming-java to: flink-runtime evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java" contains "import org.apache.flink.runtime.state.CheckpointListener;"