from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/ConfigurationParserUtils.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/ClusterEntrypointUtils.java" contains "import org.apache.flink.configuration.ClusterOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/JvmShutdownSafeguard.java" contains "import org.apache.flink.util.ShutdownHookUtil;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/ReusingMutableToRegularIteratorWrapper.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/ReusingKeyGroupedIterator.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/ForwardingOutputStream.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/ClassLoaderUtil.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/ExecutorThreadFactory.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/OperatorSubtaskDescriptionText.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/SignalHandler.java" contains "import org.apache.flink.util.OperatingSystem;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/NonReusingKeyGroupedIterator.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/ResettableMutableObjectIterator.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/NonReusingMutableToRegularIteratorWrapper.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/EvictingBoundedList.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/Hardware.java" contains "import org.apache.flink.util.OperatingSystem;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/EmptyMutableObjectIterator.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/RegularToMutableObjectIterator.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/ForwardingInputStream.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/EnvironmentInformation.java" contains "import org.apache.flink.util.OperatingSystem;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/DualKeyLinkedMap.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoint.java" contains "import org.apache.flink.configuration.CheckpointingOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/RestfulGateway.java" contains "import org.apache.flink.util.SerializedValue;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorExtension.java" contains "import org.apache.flink.util.AutoCloseableAsync;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerUtils.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/history/ArchivedJson.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapSnapshotStrategy.java" contains "import org.apache.flink.core.memory.DataOutputViewStreamWrapper;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapListState.java" contains "import org.apache.flink.core.memory.DataOutputViewStreamWrapper;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateMapSnapshot.java" contains "import org.apache.flink.core.memory.DataOutputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/NestedStateMapSnapshot.java" contains "import org.apache.flink.core.memory.DataOutputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/AbstractStateTableSnapshot.java" contains "import org.apache.flink.core.memory.DataOutputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapRestoreOperation.java" contains "import org.apache.flink.core.memory.DataInputViewStreamWrapper;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateTableByKeyGroupReaders.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateMapSnapshot.java" contains "import org.apache.flink.core.memory.DataOutputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java" contains "import org.apache.flink.core.fs.CloseableRegistry;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackendBuilder.java" contains "import org.apache.flink.core.fs.CloseableRegistry;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateTable.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/KeyGroupPartitionedPriorityQueue.java" contains "import org.apache.flink.util.CloseableIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapAggregatingState.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/AbstractHeapPriorityQueue.java" contains "import org.apache.flink.util.CloseableIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapReducingState.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapFoldingState.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapMapState.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapPriorityQueueSet.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateMap.java" contains "import org.apache.flink.util.MathUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/AbstractHeapState.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateTableSnapshot.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/AbstractHeapMergingState.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/AsyncSnapshotStrategySynchronicityBehavior.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/SyncSnapshotStrategySynchronicityBehavior.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapPriorityQueueStateSnapshot.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapValueState.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapPriorityQueueSetFactory.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/NestedMapsStateTable.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/SnapshotStrategySynchronicityBehavior.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/AbstractHeapAppendingState.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapPriorityQueueSnapshotRestoreWrapper.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateTable.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerSharedServices.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterConfiguration.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/MiniDispatcherRestEndpoint.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/RpcTaskManagerGateway.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterService.java" contains "import org.apache.flink.util.AutoCloseableAsync;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/AllocatedSlotInfo.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunner.java" contains "import org.apache.flink.util.AutoCloseableAsync;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerException.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterException.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterId.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterRegistrationSuccess.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterOperatorEventGateway.java" contains "import org.apache.flink.util.SerializedValue;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobResult.java" contains "import org.apache.flink.util.OptionalFailure;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerImpl.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JMTMRegistrationSuccess.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/AllocatedSlotReport.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/SlotRequestId.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterGateway.java" contains "import org.apache.flink.util.SerializedValue;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/KvStateLocationOracle.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobNotFinishedException.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/KvStateRegistryGateway.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultSchedulerFactory.java" contains "import org.apache.flink.configuration.CheckpointingOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultSlotPoolFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/AllocatedSlot.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequestBulkChecker.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SchedulerImpl.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SingleLogicalSlot.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotProviderImpl.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/BulkSlotProviderImpl.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManager.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolFactory.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/ThrowingSlotProvider.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotProvider.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/BulkSlotProvider.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/WorkerResourceSpecFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ArbitraryWorkerResourceSpecFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/WorkerResourceSpec.java" contains "import org.apache.flink.configuration.MemorySize;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManagerFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/StandaloneResourceManagerFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManagerRuntimeServicesConfiguration.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/SlotRequest.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/JobLeaderIdService.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManagerId.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/StandaloneResourceManager.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/TaskExecutorRegistration.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManagerRuntimeServices.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManagerGateway.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/JobLeaderIdActions.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/registration/TaskExecutorConnection.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/registration/JobManagerRegistration.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/registration/WorkerRegistration.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/exceptions/ResourceManagerException.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/ActiveResourceManager.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/LegacyActiveResourceManagerFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/LegacyActiveResourceManager.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/PendingWorkerCounter.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerConfiguration.java" contains "import org.apache.flink.configuration.AkkaOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/LeastUtilizationSlotMatchingStrategy.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/TaskManagerRegistration.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/TaskManagerSlot.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/PendingTaskManagerSlot.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/TaskManagerSlotId.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/PendingSlotRequest.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/ResourceActions.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/topology/DefaultLogicalVertex.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/topology/DefaultLogicalTopology.java" contains "import org.apache.flink.util.IterableUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/topology/DefaultLogicalPipelinedRegion.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/topology/DefaultLogicalResult.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/AbstractInvokable.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/InputSplitProvider.java" contains "import org.apache.flink.core.io.InputSplit;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/JobCheckpointingSettings.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/CheckpointCoordinatorConfiguration.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/TaskOperatorEventGateway.java" contains "import org.apache.flink.util.SerializedValue;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/SavepointConfigOptions.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/InputOutputFormatContainer.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobVertex.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/SavepointRestoreSettings.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraphUtils.java" contains "import org.apache.flink.core.fs.FileSystem;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/InputOutputFormatVertex.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobVertexID.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/IntermediateDataSetID.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/OperatorID.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/IntermediateDataSet.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/ReporterSetup.java" contains "import org.apache.flink.configuration.ConfigConstants;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistryImpl.java" contains "import org.apache.flink.configuration.MetricOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistryConfiguration.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/NoOpMetricRegistry.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/dump/MetricDumpSerialization.java" contains "import org.apache.flink.core.memory.DataInputDeserializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/dump/MetricDump.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/dump/MetricQueryService.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/MetricUtils.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/SystemResourcesCounter.java" contains "import static org.apache.flink.util.Preconditions.checkState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/SystemResourcesMetricsInitializer.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroup.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskMetricGroup.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/ProxyMetricGroup.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskManagerMetricGroup.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskManagerJobMetricGroup.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/OperatorMetricGroup.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/JobManagerJobMetricGroup.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/ReporterScopedSettings.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/UnregisteredMetricGroups.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/JobManagerMetricGroup.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/JobMetricGroup.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/scope/ScopeFormats.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/scope/ScopeFormat.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/scope/TaskScopeFormat.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/scope/JobManagerJobScopeFormat.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/scope/TaskManagerJobScopeFormat.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/LeaderRetrievalException.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/StandaloneLeaderRetrievalService.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/registration/RetryingRegistrationConfiguration.java" contains "import org.apache.flink.configuration.ClusterOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/registration/RetryingRegistration.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/registration/RegisteredRpcConnection.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/HighAvailabilityMode.java" contains "import org.apache.flink.configuration.ConfigConstants;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/JobManagerProcessUtils.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/JobManagerProcessSpec.java" contains "import org.apache.flink.configuration.MemorySize;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/HaServicesJobGraphStoreFactory.java" contains "import org.apache.flink.util.FlinkRuntimeException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperJobGraphStore.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/JobGraphStore.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/JobGraphWriter.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/StandaloneJobGraphStore.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ThrowingJobGraphWriter.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/CoLocationConstraint.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/CoLocationConstraintDesc.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/ScheduledUnit.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/CoLocationGroup.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/CoLocationGroupDesc.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/SlotSharingGroup.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/slots/TaskManagerGateway.java" contains "import org.apache.flink.util.SerializedValue;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleServiceFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleServiceOptions.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleEnvironmentContext.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleServiceLoader.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/PartitionDescriptor.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ProducerDescriptor.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleIOOwnerContext.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/NettyShuffleEnvironmentConfiguration.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/TaskManagerRuntimeInfo.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/RuntimeEnvironment.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/MemoryLogger.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/InputGateWithMetrics.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/TaskExecutionState.java" contains "import org.apache.flink.util.SerializedThrowable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/TaskManagerLocation.java" contains "import org.apache.flink.util.NetUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/ConsumableNotifyingResultPartitionWriterDecorator.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/UnresolvedTaskManagerLocation.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/CheckpointResponder.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/messages/checkpoint/DeclineCheckpoint.java" contains "import org.apache.flink.util.SerializedThrowable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/messages/checkpoint/AbstractCheckpointMessage.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/messages/checkpoint/AcknowledgeCheckpoint.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobsOverview.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobIdsWithStatusOverview.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/MultipleJobsDetails.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobDetails.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/messages/TaskBackPressureResponse.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/messages/FlinkJobNotFoundException.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCheckpointRecoveryFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/Checkpoints.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/MasterTriggerRestoreHook.java" contains "import org.apache.flink.core.io.SimpleVersionedSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointMetrics.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/MasterState.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointException.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/AbstractCheckpointStats.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorDeActivator.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointOptions.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateSnapshot.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsCounts.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskState.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStatsSummary.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PendingCheckpoint.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorState.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsHistory.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/FailedCheckpointStats.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StandaloneCompletedCheckpointStore.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateStats.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsSnapshot.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PendingCheckpointStats.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureManager.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/RestoredCheckpointStats.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/RoundRobinOperatorStateRepartitioner.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCheckpointIDCounter.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStats.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SubtaskStateStats.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStore.java" contains "import org.apache.flink.api.common.JobStatus;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StandaloneCheckpointRecoveryFactory.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StandaloneCheckpointIDCounter.java" contains "import org.apache.flink.api.common.JobStatus;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorGateway.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointIDCounter.java" contains "import org.apache.flink.api.common.JobStatus;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRecoveryFactory.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/RefCountingFSDataInputStream.java" contains "import org.apache.flink.core.fs.FSDataInputStream;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequest.java" contains "import org.apache.flink.util.CloseableIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateCheckpointWriter.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateSerializer.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestDispatcherImpl.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateReaderImpl.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImpl.java" contains "import org.apache.flink.util.CloseableIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateStreamReader.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriter.java" contains "import org.apache.flink.util.CloseableIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/hooks/MasterHooks.java" contains "import org.apache.flink.core.io.SimpleVersionedSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataSerializer.java" contains "import org.apache.flink.core.io.Versioned;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java" contains "import org.apache.flink.core.fs.Path;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/CheckpointMetadata.java" contains "import org.apache.flink.util.Disposable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/ChannelStateHandleSerializer.java" contains "import org.apache.flink.util.function.BiConsumerWithException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV3Serializer.java" contains "import org.apache.flink.util.function.BiConsumerWithException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/memory/AbstractPagedInputView.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/memory/AbstractPagedOutputView.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/memory/ListMemorySegmentSource.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java" contains "import org.apache.flink.core.memory.HybridMemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/memory/OpaqueMemoryResource.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/memory/UnsafeMemoryBudget.java" contains "import org.apache.flink.util.JavaGcCleanerWrapper;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/memory/SharedResources.java" contains "import static org.apache.flink.util.Preconditions.checkState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/BatchTask.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/JoinDriver.java" contains "import org.apache.flink.configuration.AlgorithmOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/DataSourceTask.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/AbstractCachedBuildSideJoinDriver.java" contains "import org.apache.flink.configuration.AlgorithmOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/DataSinkTask.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/GroupReduceCombineDriver.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/ReduceCombineDriver.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/TempBarrier.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/FlatMapDriver.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/AbstractOuterJoinDriver.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/CoGroupDriver.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/CoGroupRawDriver.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/FullOuterJoinDriver.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/JoinWithSolutionSetSecondDriver.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/TaskContext.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/AllReduceDriver.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/AllGroupReduceDriver.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/JoinWithSolutionSetFirstDriver.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/RightOuterJoinDriver.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/MapPartitionDriver.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/ReduceDriver.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/NoOpDriver.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/UnionWithTempOperator.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/MapDriver.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/CoGroupWithSolutionSetSecondDriver.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/AllGroupCombineDriver.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/CrossDriver.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/GroupReduceDriver.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/LeftOuterJoinDriver.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/CoGroupWithSolutionSetFirstDriver.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/ResettableDriver.java" contains "import org.apache.flink.api.common.functions.Function;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/Driver.java" contains "import org.apache.flink.api.common.functions.Function;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/NoOpChainedDriver.java" contains "import org.apache.flink.api.common.functions.Function;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/TaskNotRunningException.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorEventValve.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/LargeRecordHandler.java" contains "import org.apache.flink.api.java.typeutils.TypeExtractor;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/CombiningUnilateralSortMerger.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/DefaultInMemorySorterFactory.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/UnilateralSortMerger.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/InMemorySorterFactory.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/FixedLengthRecordSorter.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/AbstractMergeIterator.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/NormalizedKeySorter.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/ReusingMergeOuterJoinIterator.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/NonReusingSortMergeCoGroupIterator.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/MergeIterator.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/AbstractMergeOuterJoinIterator.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/NonReusingMergeInnerJoinIterator.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/InMemorySorter.java" contains "import org.apache.flink.util.Disposable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/ReusingSortMergeCoGroupIterator.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/ReusingMergeInnerJoinIterator.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/Sorter.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/NonReusingMergeOuterJoinIterator.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/AbstractMergeInnerJoinIterator.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/metrics/CountingCollector.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/metrics/CountingMutableObjectIterator.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/TaskConfig.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/BitSet.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/BloomFilter.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/DistributedRuntimeUDFContext.java" contains "import org.apache.flink.core.fs.Path;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/SimpleCloseableInputProvider.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/CloseableInputProvider.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/JoinTaskIterator.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/ReaderIterator.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/HashPartition.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/AbstractMutableHashTable.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReOpenableHashPartition.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/MutableHashTable.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/CompactingHashTable.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/InPlaceMutableHashTable.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReusingBuildFirstReOpenableHashJoinIterator.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/NonReusingBuildSecondHashJoinIterator.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReusingBuildSecondHashJoinIterator.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/NonReusingBuildFirstHashJoinIterator.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReusingBuildSecondReOpenableHashJoinIterator.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/InMemoryPartition.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReOpenableMutableHashTable.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/NonReusingBuildSecondReOpenableHashJoinIterator.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/ReusingBuildFirstHashJoinIterator.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/NonReusingBuildFirstReOpenableHashJoinIterator.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/HashJoinIteratorBase.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/AbstractHashTableProber.java" contains "import org.apache.flink.api.common.typeutils.TypeComparator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/shipping/OutputEmitter.java" contains "import org.apache.flink.util.MathUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/shipping/OutputCollector.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/resettable/AbstractBlockResettableIterator.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/resettable/SpillingResettableIterator.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/resettable/SpillingResettableMutableObjectIterator.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/resettable/BlockResettableMutableObjectIterator.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/resettable/NonReusingBlockResettableIterator.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/resettable/ReusingBlockResettableIterator.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ChainedReduceCombineDriver.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ChainedMapDriver.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ChainedFlatMapDriver.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/SynchronousChainedCombineDriver.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ChainedAllReduceDriver.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ChainedDriver.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ChainedTerminationCriterionDriver.java" contains "import org.apache.flink.api.common.operators.base.BulkIterationBase;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/udf/AssignRangeIndex.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/udf/RangeBoundaryBuilder.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/udf/RemoveRangeIndex.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/jobmanager/JobManagerFlinkMemory.java" contains "import org.apache.flink.configuration.MemorySize;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/jobmanager/JobManagerFlinkMemoryUtils.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/ProcessMemoryUtils.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/CommonProcessMemorySpec.java" contains "import org.apache.flink.configuration.MemorySize;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/FlinkMemoryUtils.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/MemoryBackwardsCompatibilityUtils.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/LegacyMemoryOptions.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/JvmMetaspaceAndOverheadOptions.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/FlinkMemory.java" contains "import org.apache.flink.configuration.MemorySize;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/JvmMetaspaceAndOverhead.java" contains "import org.apache.flink.configuration.MemorySize;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/RangeFraction.java" contains "import org.apache.flink.configuration.MemorySize;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/ProcessMemoryOptions.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/ProcessMemorySpec.java" contains "import org.apache.flink.configuration.MemorySize;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/taskmanager/TaskExecutorFlinkMemory.java" contains "import org.apache.flink.configuration.MemorySize;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/taskmanager/TaskExecutorFlinkMemoryUtils.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/bash/FlinkConfigLoader.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/bash/BashJavaUtils.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/security/contexts/HadoopSecurityContext.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/security/ExitTrappingSecurityManager.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityConfiguration.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/security/KerberosUtils.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityFactoryServiceLoader.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/security/modules/JaasModule.java" contains "import org.apache.flink.configuration.CoreOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/security/modules/ZooKeeperModule.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/security/modules/HadoopModule.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/metrics/UpTimeGauge.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/metrics/DownTimeGauge.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/metrics/RestartTimeGauge.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/TaskInformation.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraphBuilder.java" contains "import org.apache.flink.configuration.CheckpointingOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionVertex.java" contains "import org.apache.flink.configuration.JobManagerOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java" contains "import org.apache.flink.configuration.JobManagerOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/JobInformation.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java" contains "import org.apache.flink.core.io.InputSplit;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/IntermediateResult.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/SchedulingUtils.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ArchivedExecution.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ErrorInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/AccessExecutionGraph.java" contains "import org.apache.flink.util.OptionalFailure;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraphResultPartitionAvailabilityChecker.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ArchivedExecutionGraph.java" contains "import org.apache.flink.util.OptionalFailure;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/SlotProviderStrategy.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionAttemptID.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/JobStatusListener.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/FixedDelayRestartStrategy.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/FailureRateRestartStrategy.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategyFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/NoRestartStrategy.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategyResolving.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/ExecutionGraphRestartCallback.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/FailoverStrategyFactoryLoader.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/FixedDelayRestartBackoffTimeStrategy.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/RestartBackoffTimeStrategyFactoryLoader.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/FailureRateRestartBackoffTimeStrategy.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/RestartPipelinedRegionFailoverStrategy.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/FailureHandlingResult.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/RestartAllFailoverStrategy.java" contains "import org.apache.flink.util.IterableUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/ExecutionFailureHandler.java" contains "import org.apache.flink.util.IterableUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/partitionrelease/PartitionReleaseStrategyFactoryLoader.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/partitionrelease/RegionPartitionReleaseStrategy.java" contains "import org.apache.flink.util.IterableUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/partitionrelease/PipelinedRegionExecutionView.java" contains "import org.apache.flink.util.IterableUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/FailoverStrategyLoader.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/RestartAllStrategy.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/plugable/ReusingDeserializationDelegate.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/plugable/NonReusingDeserializationDelegate.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/plugable/SerializationDelegate.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/plugable/DeserializationDelegate.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/ContainerSpecification.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/ContaineredTaskManagerParameters.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/TaskExecutorProcessSpec.java" contains "import org.apache.flink.configuration.MemorySize;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/TaskExecutorProcessSpecBuilder.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java" contains "import org.apache.flink.configuration.AkkaOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/TaskExecutorProcessUtils.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/ApplicationStatus.java" contains "import org.apache.flink.api.common.JobStatus;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java" contains "import org.apache.flink.configuration.MemorySize;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/AllocationID.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotID.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceID.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceBudgetManager.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotProfile.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/overlays/FlinkDistributionOverlay.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/overlays/HadoopConfOverlay.java" contains "import org.apache.flink.configuration.ConfigConstants;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/overlays/SSLStoreOverlay.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/overlays/HadoopUserOverlay.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/overlays/KeytabOverlay.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/overlays/UserLibOverlay.java" contains "import org.apache.flink.configuration.ConfigConstants;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/overlays/Krb5ConfOverlay.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/overlays/AbstractContainerOverlay.java" contains "import org.apache.flink.core.fs.Path;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java" contains "import org.apache.flink.core.memory.DataInputViewStreamWrapper;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorProvider.java" contains "import org.apache.flink.core.io.SimpleVersionedSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SplitAssignmentTracker.java" contains "import org.apache.flink.core.io.SimpleVersionedSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorSerdeUtils.java" contains "import org.apache.flink.core.io.SimpleVersionedSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorContext.java" contains "import org.apache.flink.core.io.SimpleVersionedSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/source/event/AddSplitEvent.java" contains "import org.apache.flink.core.io.SimpleVersionedSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/source/event/SourceEventWrapper.java" contains "import org.apache.flink.api.connector.source.SourceEvent;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/HistoryServerArchivist.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JobManagerRunnerFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/PartialDispatcherServicesWithJobGraphStore.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JobDispatcherFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/SchedulerNGFactoryFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherRestEndpoint.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/PartialDispatcherServices.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherServices.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JsonResponseHistoryServerArchivist.java" contains "import org.apache.flink.core.fs.Path;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/AbstractDispatcherBootstrap.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherId.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherException.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/FileArchivedExecutionGraphStore.java" contains "import org.apache.flink.util.FileUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/SingleJobJobGraphStore.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultDispatcherBootstrap.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/MiniDispatcher.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/MemoryArchivedExecutionGraphStore.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/ArchivedExecutionGraphStore.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherGateway.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/JobDispatcherLeaderProcessFactoryFactory.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/AbstractDispatcherLeaderProcess.java" contains "import org.apache.flink.util.AutoCloseableAsync;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/DefaultDispatcherRunner.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/DispatcherRunner.java" contains "import org.apache.flink.util.AutoCloseableAsync;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/SessionDispatcherLeaderProcess.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/DefaultDispatcherGatewayServiceFactory.java" contains "import org.apache.flink.util.FlinkRuntimeException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/DispatcherLeaderProcess.java" contains "import org.apache.flink.util.AutoCloseableAsync;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/DefaultDispatcherGatewayService.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NettyShuffleServiceFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/ConnectionID.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/TaskEventDispatcher.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NettyShuffleEnvironment.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/DataExchangeMode.java" contains "import org.apache.flink.api.common.ExecutionMode;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/NettyShuffleMetricFactory.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/ResultPartitionMetrics.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/ExclusiveBuffersUsageGauge.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/InputGateMetrics.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/FloatingBuffersUsageGauge.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/InputChannelMetrics.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/CreditBasedInputBuffersUsageGauge.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyConfig.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NetworkBufferAllocator.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyClient.java" contains "import static org.apache.flink.util.Preconditions.checkState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyConnectionManager.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyPartitionRequestClient.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/BufferResponseDecoder.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyBufferPool.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessageClientDecoderDelegate.java" contains "import org.apache.flink.util.IOUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyServer.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/reader/MutableRecordReader.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/reader/Reader.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/reader/AbstractRecordReader.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/reader/MutableReader.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/reader/RecordReader.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/reader/AbstractReader.java" contains "import static org.apache.flink.util.Preconditions.checkState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/EndOfPartitionEvent.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/CheckpointBarrier.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/EndOfSuperstepEvent.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/CancelCheckpointMarker.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/SpanningWrapper.java" contains "import org.apache.flink.core.memory.DataInputDeserializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/EventSerializer.java" contains "import org.apache.flink.core.memory.DataInputDeserializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/SpillingAdaptiveSpanningRecordDeserializer.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/SpanningRecordSerializer.java" contains "import org.apache.flink.core.memory.DataOutputSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/NonSpanningWrapper.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/RecordSerializer.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/RecordDeserializer.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/BroadcastRecordWriter.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/SingleRecordWriter.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/ChannelSelector.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/ChannelSelectorRecordWriter.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriterDelegate.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/NonRecordWriter.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RoundRobinChannelSelector.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/MultipleRecordWriters.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriterBuilder.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PartitionProducerStateProvider.java" contains "import org.apache.flink.types.Either;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/FileChannelBoundedData.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferReaderWriterUtil.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionView.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/FileChannelMemoryMappedBoundedData.java" contains "import org.apache.flink.util.IOUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BoundedBlockingSubpartitionReader.java" contains "import org.apache.flink.util.IOUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/JobMasterPartitionTrackerImpl.java" contains "import org.apache.flink.util.CollectionUtil;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BoundedBlockingSubpartition.java" contains "import org.apache.flink.util.FlinkRuntimeException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ProducerFailedException.java" contains "import org.apache.flink.util.SerializedThrowable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/TaskExecutorPartitionInfo.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/TaskExecutorPartitionTrackerImpl.java" contains "import org.apache.flink.util.CollectionUtil;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionID.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionFactory.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ReleaseOnConsumptionResultPartition.java" contains "import static org.apache.flink.util.Preconditions.checkState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResourceManagerPartitionTrackerImpl.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartition.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PageSizeUtil.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/AbstractPartitionTracker.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionManager.java" contains "import static org.apache.flink.util.Preconditions.checkState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/DataSetMetaInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/MemoryMappedBoundedData.java" contains "import org.apache.flink.util.IOUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/TaskExecutorPartitionTracker.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionConsumableNotifier.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteChannelStateChecker.java" contains "import org.apache.flink.types.Either;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java" contains "import org.apache.flink.core.memory.MemorySegmentProvider;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/EndOfChannelStateEvent.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferManager.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteRecoveredInputChannel.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/UnknownInputChannel.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputChannel.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/UnionInputGate.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RecoveredInputChannel.java" contains "import static org.apache.flink.util.Preconditions.checkState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalRecoveredInputChannel.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputChannelID.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferOrEvent.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java" contains "import org.apache.flink.util.CloseableIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputGate.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateFactory.java" contains "import org.apache.flink.util.function.SupplierWithException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java" contains "import org.apache.flink.configuration.NettyShuffleEnvironmentOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBuffer.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferConsumer.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferDecompressor.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferBuilder.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferCompressor.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferRecycler.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/ReadOnlySlicedNetworkBuffer.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/FreeingBufferRecycler.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/Buffer.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/compression/BlockCompressionFactory.java" contains "import org.apache.flink.configuration.IllegalConfigurationException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java" contains "import static org.apache.flink.core.memory.MemorySegmentFactory.wrap;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/ChannelReaderInputViewIterator.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/RandomAccessInputView.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileChannelInputView.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileChannelOutputView.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/InputViewIterator.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/SeekableFileChannelInputView.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/SpillingBuffer.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/SimpleCollectingOutputView.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/RandomAccessOutputView.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileChannelManagerImpl.java" contains "import org.apache.flink.util.FileUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/ChannelWriterOutputView.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/IOManagerAsync.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/AbstractChannelReaderInputView.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/AsynchronousBlockWriterWithCallback.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/AsynchronousFileIOChannel.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/BulkBlockChannelReader.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/AsynchronousBlockReader.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/AsynchronousBlockWriter.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/ChannelReaderInputView.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/AsynchronousBulkBlockReader.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/HeaderlessChannelReaderInputView.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/IOManager.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/FileIOChannel.java" contains "import org.apache.flink.util.StringUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/AsynchronousBufferFileWriter.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/AbstractFileIOChannel.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/BufferFileChannelReader.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/management/JMXService.java" contains "import org.apache.flink.util.NetUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionVertexSchedulingRequirementsMapper.java" contains "import org.apache.flink.configuration.MemorySize;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultSchedulerFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerNGFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java" contains "import org.apache.flink.configuration.CheckpointingOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/OneSlotPerExecutionSlotAllocator.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/AbstractExecutionSlotAllocator.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerNG.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotExecutionVertexAssignment.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocator.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/UpdateSchedulerNgOnInternalFailuresListener.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingExecutionSlotAllocator.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DeploymentHandle.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultPreferredLocationsRetriever.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionVertexSchedulingRequirements.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocatorFactory.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionVertexDeploymentOption.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/OneSlotPerExecutionSlotAllocatorFactory.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionVertexVersioner.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionGraphToInputsLocationsRetrieverAdapter.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/MergingSharedSlotProfileRetrieverFactory.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionVertex.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultSchedulingPipelinedRegion.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionTopology.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultResultPartition.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/EagerSchedulingStrategy.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/ExecutionVertexID.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/SchedulingStrategyUtils.java" contains "import org.apache.flink.util.IterableUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/PipelinedRegionSchedulingStrategy.java" contains "import org.apache.flink.util.IterableUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromSourcesSchedulingStrategy.java" contains "import org.apache.flink.util.IterableUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/SchedulingExecutionVertex.java" contains "import org.apache.flink.api.common.InputDependencyConstraint;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/InputDependencyConstraintChecker.java" contains "import org.apache.flink.api.common.InputDependencyConstraint;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java" contains "import org.apache.flink.configuration.ClusterOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterConfiguration.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/JobExecutorService.java" contains "import org.apache.flink.util.AutoCloseableAsync;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/JobExecutor.java" contains "import org.apache.flink.api.common.JobExecutionResult;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/JavaSerializer.java" contains "import org.apache.flink.api.java.typeutils.runtime.DataInputViewStream;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendFactory.java" contains "import org.apache.flink.configuration.IllegalConfigurationException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ConfigurableStateBackend.java" contains "import org.apache.flink.configuration.IllegalConfigurationException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendLoader.java" contains "import org.apache.flink.configuration.CheckpointingOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorBackendSerializationProxy.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/HeapBroadcastState.java" contains "import org.apache.flink.core.memory.DataOutputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStateRestoreOperation.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupPartitioner.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackendSnapshotStrategy.java" contains "import org.apache.flink.core.memory.DataOutputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedBackendSerializationProxy.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/PartitionableListState.java" contains "import org.apache.flink.core.memory.DataOutputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSnapshot.java" contains "import org.apache.flink.core.memory.DataOutputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceSerializer.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSnapshotKeyGroupReader.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ArrayListSerializer.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StreamStateHandle.java" contains "import org.apache.flink.core.fs.FSDataInputStream;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStateHandle.java" contains "import org.apache.flink.core.fs.FSDataInputStream;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java" contains "import org.apache.flink.core.fs.CloseableRegistry;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSnapshotContextSynchronousImpl.java" contains "import org.apache.flink.core.fs.CloseableRegistry;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/BackendWritableBroadcastState.java" contains "import org.apache.flink.core.fs.FSDataOutputStream;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackendBuilder.java" contains "import org.apache.flink.core.fs.CloseableRegistry;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStoreImpl.java" contains "import org.apache.flink.core.fs.FileSystem;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/AsyncSnapshotCallable.java" contains "import org.apache.flink.core.fs.CloseableRegistry;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackendBuilder.java" contains "import org.apache.flink.core.fs.CloseableRegistry;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/BoundedInputStream.java" contains "import org.apache.flink.core.fs.FSDataInputStream;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointMetadataOutputStream.java" contains "import org.apache.flink.core.fs.FSDataOutputStream;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStreamFactory.java" contains "import org.apache.flink.core.fs.FSDataOutputStream;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupsStateHandle.java" contains "import org.apache.flink.core.fs.FSDataInputStream;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackend.java" contains "import org.apache.flink.core.fs.CloseableRegistry;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/RetrievableStreamStateHandle.java" contains "import org.apache.flink.core.fs.FSDataInputStream;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStreamWithResultProvider.java" contains "import org.apache.flink.core.fs.Path;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java" contains "import org.apache.flink.core.fs.CloseableRegistry;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStreamStateHandle.java" contains "import org.apache.flink.core.fs.FSDataInputStream;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractStateBackend.java" contains "import org.apache.flink.core.fs.CloseableRegistry;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/PlaceholderStreamStateHandle.java" contains "import org.apache.flink.core.fs.FSDataInputStream;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStateBackend.java" contains "import org.apache.flink.util.Disposable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredKeyValueStateBackendMetaInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultKeyedStateStore.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupRangeAssignment.java" contains "import org.apache.flink.util.MathUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredOperatorStateBackendMetaInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalRemoteKeyedStateHandle.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotDirectory.java" contains "import org.apache.flink.util.FileUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistry.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateUtil.java" contains "import org.apache.flink.util.LambdaUtil;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/DirectoryStateHandle.java" contains "import org.apache.flink.util.FileUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStorageLocationReference.java" contains "import org.apache.flink.util.StringUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/DuplicatingCheckpointOutputStream.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorLocalStateStoresManager.java" contains "import org.apache.flink.util.FileUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupRangeOffsets.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateHandleID.java" contains "import org.apache.flink.util.StringBasedID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/LocalRecoveryDirectoryProviderImpl.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredBroadcastStateBackendMetaInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StatePartitionStreamProvider.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotResult.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateCheckpointOutputStream.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/InternalPriorityQueue.java" contains "import org.apache.flink.util.CloseableIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryKey.java" contains "import org.apache.flink.util.StringBasedID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredPriorityQueueStateBackendMetaInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalLocalKeyedStateHandle.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ChainedStateHandle.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupRange.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSerializerProvider.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateBackend.java" contains "import org.apache.flink.util.Disposable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/NonClosingCheckpointOutputStream.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractChannelStateHandle.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskStateManagerImpl.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ArrayListSerializerSnapshot.java" contains "import org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateFactory.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/PriorityQueueSetFactory.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateInitializationContextImpl.java" contains "import org.apache.flink.api.common.state.KeyedStateStore;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ManagedInitializationContext.java" contains "import org.apache.flink.api.common.state.KeyedStateStore;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateFunction.java" contains "import org.apache.flink.api.common.state.State;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/UserFacingMapState.java" contains "import org.apache.flink.api.common.state.MapState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/UserFacingListState.java" contains "import org.apache.flink.api.common.state.ListState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/MemoryStateBackendFactory.java" contains "import org.apache.flink.configuration.ReadableConfig;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/MemoryStateBackend.java" contains "import org.apache.flink.configuration.CheckpointingOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/NonPersistentMetadataCheckpointStorageLocation.java" contains "import org.apache.flink.core.memory.ByteArrayOutputStreamWithPos;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/MemCheckpointStreamFactory.java" contains "import org.apache.flink.core.memory.ByteArrayOutputStreamWithPos;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/ByteStreamStateHandle.java" contains "import org.apache.flink.core.fs.FSDataInputStream;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/PersistentMetadataCheckpointStorageLocation.java" contains "import org.apache.flink.core.fs.FileSystem;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/MemoryBackendCheckpointStorage.java" contains "import org.apache.flink.core.fs.FileSystem;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateSnapshotTransformer.java" contains "import org.apache.flink.core.memory.DataInputDeserializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlListState.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateFactory.java" contains "import org.apache.flink.util.FlinkRuntimeException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/AbstractTtlDecorator.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlAggregateFunction.java" contains "import org.apache.flink.util.FlinkRuntimeException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlMapState.java" contains "import org.apache.flink.util.FlinkRuntimeException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlIncrementalCleanup.java" contains "import org.apache.flink.util.FlinkRuntimeException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/AbstractTtlState.java" contains "import org.apache.flink.util.FlinkRuntimeException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateContext.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlReduceFunction.java" contains "import org.apache.flink.api.common.state.StateTtlConfig;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlFoldFunction.java" contains "import org.apache.flink.api.common.state.StateTtlConfig;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlFoldingState.java" contains "import org.apache.flink.api.common.state.AggregatingState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/internal/InternalKvState.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/internal/InternalValueState.java" contains "import org.apache.flink.api.common.state.ValueState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/internal/InternalFoldingState.java" contains "import org.apache.flink.api.common.state.FoldingState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/internal/InternalAppendingState.java" contains "import org.apache.flink.api.common.state.AppendingState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/internal/InternalMapState.java" contains "import org.apache.flink.api.common.state.MapState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/internal/InternalAggregatingState.java" contains "import org.apache.flink.api.common.state.AggregatingState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/internal/InternalReducingState.java" contains "import org.apache.flink.api.common.state.ReducingState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/internal/InternalMergingState.java" contains "import org.apache.flink.api.common.state.MergingState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/internal/InternalListState.java" contains "import org.apache.flink.api.common.state.ListState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackend.java" contains "import org.apache.flink.configuration.CheckpointingOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackendFactory.java" contains "import org.apache.flink.configuration.CheckpointingOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/AbstractFileStateBackend.java" contains "import org.apache.flink.configuration.CheckpointingOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FileBasedStateOutputStream.java" contains "import org.apache.flink.core.fs.FSDataOutputStream;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCompletedCheckpointStorageLocation.java" contains "import org.apache.flink.core.fs.FileSystem;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStorage.java" contains "import org.apache.flink.core.fs.FileSystem;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FileStateHandle.java" contains "import org.apache.flink.core.fs.FSDataInputStream;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/RelativeFileStateHandle.java" contains "import org.apache.flink.core.fs.Path;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointMetadataOutputStream.java" contains "import org.apache.flink.core.fs.FSDataOutputStream;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/AbstractFsCheckpointStorage.java" contains "import org.apache.flink.core.fs.FileStatus;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStorageLocation.java" contains "import org.apache.flink.core.fs.EntropyInjector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStreamFactory.java" contains "import org.apache.flink.core.fs.EntropyInjector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/metainfo/LegacyStateMetaInfoReaders.java" contains "import org.apache.flink.api.java.typeutils.runtime.DataInputViewStream;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/metainfo/StateMetaInfoReader.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/metainfo/StateMetaInfoSnapshotReadersWriters.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/metainfo/StateMetaInfoWriter.java" contains "import org.apache.flink.core.memory.DataOutputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/metainfo/StateMetaInfoSnapshot.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/retriever/impl/RpcGatewayRetriever.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/retriever/GatewayRetriever.java" contains "import org.apache.flink.util.FlinkRuntimeException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/retriever/LeaderGatewayRetriever.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/retriever/LeaderRetriever.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/retriever/MetricQueryServiceGateway.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperUtilityFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/FlinkZooKeeperQuorumPeer.java" contains "import org.apache.flink.configuration.IllegalConfigurationException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperSharedValue.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperVersionedValue.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperSharedCount.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/filesystem/FileSystemStateStorageHelper.java" contains "import org.apache.flink.core.fs.FSDataOutputStream;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java" contains "import org.apache.flink.core.fs.Path;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatServices.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatManagerImpl.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatMonitorImpl.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/io/WorksetUpdateOutputCollector.java" contains "import org.apache.flink.core.memory.DataOutputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/io/SerializedUpdateBuffer.java" contains "import org.apache.flink.core.memory.MemorySegment;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/io/SolutionSetObjectsUpdateOutputCollector.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/io/HashPartitionIterator.java" contains "import org.apache.flink.util.MutableObjectIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/io/SolutionSetUpdateOutputCollector.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/io/SolutionSetFastUpdateOutputCollector.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/convergence/WorksetEmptyConvergenceCriterion.java" contains "import org.apache.flink.types.LongValue;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/concurrent/SuperstepBarrier.java" contains "import org.apache.flink.types.Value;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/concurrent/BlockingBackChannel.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/SyncEventHandler.java" contains "import org.apache.flink.types.Value;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationSynchronizationSinkTask.java" contains "import org.apache.flink.types.IntValue;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/RuntimeAggregatorRegistry.java" contains "import org.apache.flink.types.Value;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/AbstractIterativeTask.java" contains "import org.apache.flink.types.Value;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationHeadTask.java" contains "import org.apache.flink.types.Value;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationTailTask.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationIntermediateTask.java" contains "import org.apache.flink.util.Collector;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/event/WorkerDoneEvent.java" contains "import org.apache.flink.types.Value;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/event/IterationEventWithAggregators.java" contains "import org.apache.flink.types.Value;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/event/TerminationEvent.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/iterative/event/AllWorkersDoneEvent.java" contains "import org.apache.flink.api.common.aggregators.Aggregator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionService.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/StandaloneLeaderElectionService.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/execution/Environment.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/FlinkUserCodeClassLoaders.java" contains "import org.apache.flink.configuration.CoreOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/BlobLibraryCacheManager.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/LibraryCacheManager.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptorFactory.java" contains "import org.apache.flink.types.Either;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptor.java" contains "import org.apache.flink.util.FileUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/deployment/ResultPartitionDeploymentDescriptor.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/deployment/InputGateDeploymentDescriptor.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/HighAvailabilityServicesFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/HighAvailabilityServicesUtils.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/RunningJobsRegistry.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/HighAvailabilityServices.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/nonha/AbstractNonHaServices.java" contains "import static org.apache.flink.util.Preconditions.checkState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/nonha/standalone/StandaloneClientHAServices.java" contains "import static org.apache.flink.util.Preconditions.checkState;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/nonha/standalone/StandaloneRunningJobsRegistry.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/nonha/standalone/StandaloneHaServices.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/nonha/embedded/EmbeddedLeaderService.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/nonha/embedded/EmbeddedHaServices.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperRunningJobsRegistry.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperClientHAServices.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperHaServices.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorSnapshot.java" contains "import org.apache.flink.util.SerializedValue;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/StringifiedAccumulatorResult.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorRegistry.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/ScheduledExecutorServiceAdapter.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureTaskWithException.java" contains "import org.apache.flink.util.function.RunnableWithException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/akka/ActorSystemScheduledExecutorAdapter.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/JobException.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/StandaloneSessionClusterEntrypoint.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java" contains "import org.apache.flink.configuration.ClusterOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntryPointExceptionUtils.java" contains "import org.apache.flink.configuration.JobManagerOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/JobClusterEntrypoint.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/SessionClusterEntrypoint.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypointException.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/FlinkParseException.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterInformation.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/DefaultDispatcherResourceManagerComponentFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/FileJobGraphRetriever.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/DispatcherResourceManagerComponentFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/JobGraphRetriever.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/AbstractUserClassPathJobGraphRetriever.java" contains "import org.apache.flink.util.FileUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/DispatcherResourceManagerComponent.java" contains "import org.apache.flink.util.AutoCloseableAsync;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/history/FsJobArchivist.java" contains "import org.apache.flink.configuration.JobManagerOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/instance/SlotSharingGroupId.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/instance/InstanceID.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/externalresource/ExternalResourceUtils.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/externalresource/ExternalResourceInfoProvider.java" contains "import org.apache.flink.api.common.externalresource.ExternalResourceInfo;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/externalresource/StaticExternalResourceInfoProvider.java" contains "import org.apache.flink.api.common.externalresource.ExternalResourceInfo;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcUtils.java" contains "import org.apache.flink.util.AutoCloseableAsync;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcEndpoint.java" contains "import org.apache.flink.util.AutoCloseableAsync;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/MainThreadValidatorUtil.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/FencedRpcEndpoint.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/PermanentlyFencedRpcEndpoint.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/MainThreadExecutable.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/FencedMainThreadExecutable.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/messages/RunAsync.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/messages/RemoteRpcInvocation.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/messages/LocalRpcInvocation.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/messages/UnfencedMessage.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/messages/LocalFencedMessage.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/messages/RemoteFencedMessage.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/messages/CallAsync.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceUtils.java" contains "import org.apache.flink.configuration.AkkaOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceConfiguration.java" contains "import org.apache.flink.configuration.AkkaOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActor.java" contains "import org.apache.flink.types.Either;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/FencedAkkaInvocationHandler.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaInvocationHandler.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcService.java" contains "import org.apache.flink.util.AutoCloseableAsync;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/SupervisorActor.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/exceptions/AkkaRpcInvalidStateException.java" contains "import org.apache.flink.util.FlinkRuntimeException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/query/QueryableStateUtils.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateLocationRegistry.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateLocation.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/query/TaskKvStateRegistry.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateEntry.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateRegistry.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateClientProxy.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateRegistryListener.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/PermanentBlobCache.java" contains "import org.apache.flink.configuration.BlobServerOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java" contains "import org.apache.flink.configuration.BlobServerOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java" contains "import org.apache.flink.configuration.BlobServerOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobCacheService.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/AbstractBlobCache.java" contains "import org.apache.flink.configuration.BlobServerOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobCache.java" contains "import org.apache.flink.configuration.BlobServerOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobClient.java" contains "import org.apache.flink.configuration.BlobServerOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobWriter.java" contains "import org.apache.flink.types.Either;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/FileSystemBlobStore.java" contains "import org.apache.flink.core.fs.FileSystem;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobKey.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServerConnection.java" contains "import org.apache.flink.util.InstantiationUtil;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobCleanupTask.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/VoidBlobWriter.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/PermanentBlobService.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/VoidBlobStore.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobStore.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobService.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobOutputStream.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobView.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/event/AbstractEvent.java" contains "import org.apache.flink.core.io.IOReadableWritable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/client/ClientUtils.java" contains "import org.apache.flink.core.fs.Path;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/client/SerializedJobExecutionResult.java" contains "import org.apache.flink.util.OptionalFailure;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/client/JobExecutionException.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/client/JobCancellationException.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/client/JobStatusMessage.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/client/JobSubmissionException.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/client/DuplicateJobSubmissionException.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/broadcast/BroadcastVariableMaterialization.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/broadcast/BroadcastVariableManager.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializerFactory;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/broadcast/InitializationTypeConflictException.java" contains "import org.apache.flink.api.common.functions.RuntimeContext;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/broadcast/DefaultBroadcastVariableInitializer.java" contains "import org.apache.flink.api.common.functions.BroadcastVariableInitializer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/resourcemanager/AbstractResourceManagerHandler.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/RestHandlerConfiguration.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java" contains "import org.apache.flink.util.AutoCloseableAsync;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/HandlerRequest.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/RestHandlerException.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/LeaderRetrievalHandler.java" contains "import org.apache.flink.util.OptionalConsumer;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/FileUploads.java" contains "import org.apache.flink.util.FileUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractRestHandler.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/HandlerRequestException.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/cluster/ClusterConfigHandler.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/cluster/AbstractJobManagerFileHandler.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/cluster/JobManagerLogFileHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/cluster/ClusterOverviewHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/cluster/JobManagerLogListHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/cluster/JobManagerCustomLogHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/cluster/DashboardConfigHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/cluster/ShutdownHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerDetailsHandler.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/taskmanager/AbstractTaskManagerFileHandler.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerLogListHandler.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerCustomLogHandler.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerLogFileHandler.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerStdoutFileHandler.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagersHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/taskmanager/TaskManagerThreadDumpHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/util/HandlerUtils.java" contains "import org.apache.flink.configuration.ConfigConstants;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/util/HandlerRedirectUtils.java" contains "import org.apache.flink.configuration.ConfigConstants;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/util/HandlerRequestUtils.java" contains "import org.apache.flink.util.function.SupplierWithException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/dataset/ClusterDataSetDeleteHandlers.java" contains "import org.apache.flink.util.SerializedThrowable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/dataset/ClusterDataSetListHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/CompletedOperationCache.java" contains "import org.apache.flink.types.Either;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/AbstractAsynchronousOperationHandlers.java" contains "import org.apache.flink.types.Either;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/TriggerResponse.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/AsynchronousOperationInfo.java" contains "import org.apache.flink.util.SerializedThrowable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/AsynchronousOperationResult.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/OperationKey.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/UnknownOperationKeyException.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricFetcherImpl.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricStore.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/messages/ClusterOverviewWithVersion.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/DefaultExecutionGraphCache.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/ExecutionGraphCache.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/backpressure/BackPressureStats.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/backpressure/BackPressureRequestCoordinator.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/backpressure/BackPressureStatsTracker.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/backpressure/BackPressureStatsTrackerImpl.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/backpressure/OperatorBackPressureStats.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/files/StaticFileServerHandler.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/AggregatingSubtasksMetricsHandler.java" contains "import org.apache.flink.util.UnionIterator;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/AbstractAggregatingMetricsHandler.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/JobVertexMetricsHandler.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/SubtaskMetricsHandler.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/JobVertexWatermarksHandler.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/AggregatingJobsMetricsHandler.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/TaskManagerMetricsHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/JobManagerMetricsHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/AggregatingTaskManagersMetricsHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/AbstractMetricsHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/metrics/JobMetricsHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobSubmitHandler.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobDetailsHandler.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobVertexTaskManagersHandler.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobExceptionsHandler.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobAccumulatorsHandler.java" contains "import org.apache.flink.util.OptionalFailure;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobCancellationHandler.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/SubtaskCurrentAttemptDetailsHandler.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AbstractExecutionGraphHandler.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/SubtaskExecutionAttemptDetailsHandler.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobExecutionResultHandler.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobConfigHandler.java" contains "import org.apache.flink.api.common.ArchivedExecutionConfig;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobVertexDetailsHandler.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobVertexBackPressureHandler.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AsynchronousJobOperationKey.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobVertexAccumulatorsHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobPlanHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AbstractJobVertexHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/SubtasksAllAccumulatorsHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AbstractSubtaskAttemptHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/SubtasksTimesHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/SubtaskExecutionAttemptAccumulatorsHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobsOverviewHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobIdsHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/AbstractSubtaskHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/coordination/ClientCoordinationHandler.java" contains "import org.apache.flink.util.SerializedValue;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/checkpoints/AbstractCheckpointHandler.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/checkpoints/CheckpointingStatisticsHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/checkpoints/TaskCheckpointStatisticDetailsHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/checkpoints/CheckpointConfigHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/checkpoints/CheckpointStatisticDetailsHandler.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/rescaling/RescalingHandlers.java" contains "import org.apache.flink.api.common.time.Time;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlers.java" contains "import org.apache.flink.configuration.CheckpointingOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointDisposalHandlers.java" contains "import org.apache.flink.util.SerializedThrowable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/router/PathPattern.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/router/RoutedRequest.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpointConfiguration.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/JobRestEndpointFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestEndpointFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java" contains "import org.apache.flink.configuration.IllegalConfigurationException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClientConfiguration.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/SessionRestEndpointFactory.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/FlinkHttpObjectAggregator.java" contains "import org.apache.flink.configuration.RestOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java" contains "import org.apache.flink.configuration.ConfigConstants;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/FileUploadHandler.java" contains "import org.apache.flink.util.FileUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ClusterConfigurationInfo.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobConfigInfo.java" contains "import org.apache.flink.configuration.ConfigurationUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexAccumulatorsInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobPlanInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/LogListInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/MessageParameters.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/OperatorIDPathParameter.java" contains "import org.apache.flink.util.StringUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ClusterConfigurationInfoEntry.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/MessageParameter.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexBackPressureInfo.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexTaskManagersInfo.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/SubtasksTimesInfo.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/TriggerId.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/DashboardConfiguration.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobAccumulatorsInfo.java" contains "import org.apache.flink.util.OptionalFailure;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ConversionException.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobVertexDetailsInfo.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/LogInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobExceptionsInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobIDPathParameter.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/ResourceProfileInfo.java" contains "import org.apache.flink.api.common.resources.Resource;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerDetailsInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagersInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerMetricsInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/TaskManagerInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/dataset/ClusterDataSetIdPathParameter.java" contains "import org.apache.flink.util.AbstractID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatisticsWithSubtaskDetails.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/TaskCheckpointStatistics.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/json/SerializedValueDeserializer.java" contains "import org.apache.flink.util.SerializedValue;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/json/SerializedThrowableSerializer.java" contains "import org.apache.flink.util.InstantiationUtil;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/json/SerializedValueSerializer.java" contains "import org.apache.flink.util.SerializedValue;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/json/JobResultDeserializer.java" contains "import org.apache.flink.util.OptionalFailure;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/json/JobResultSerializer.java" contains "import org.apache.flink.util.OptionalFailure;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/json/SerializedThrowableDeserializer.java" contains "import org.apache.flink.util.InstantiationUtil;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/json/JobIDDeserializer.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/json/JobIDSerializer.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/MetricsAggregationParameter.java" contains "import org.apache.flink.util.StringUtils;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/JobsFilterQueryParameter.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/UserAccumulator.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptDetailsInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtasksAllAccumulatorsInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/SubtaskExecutionAttemptAccumulatorsInfo.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/coordination/ClientCoordinationResponseBody.java" contains "import org.apache.flink.util.SerializedValue;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/coordination/ClientCoordinationRequestBody.java" contains "import org.apache.flink.util.SerializedValue;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/savepoints/SavepointInfo.java" contains "import org.apache.flink.util.SerializedThrowable;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/util/RestConstants.java" contains "import org.apache.flink.configuration.ConfigConstants;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/util/RestClientException.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServices.java" contains "import org.apache.flink.configuration.CoreOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServicesConfiguration.java" contains "import org.apache.flink.configuration.CheckpointingOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorResourceSpec.java" contains "import org.apache.flink.configuration.MemorySize;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/QueryableStateConfiguration.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorResourceUtils.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerConfiguration.java" contains "import org.apache.flink.configuration.AkkaOptions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorGateway.java" contains "import org.apache.flink.types.SerializableOptional;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java" contains "import org.apache.flink.types.SerializableOptional;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/KvStateService.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/SlotReport.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorToResourceManagerConnection.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/DefaultJobLeaderService.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorRegistrationSuccess.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/BackPressureSampleService.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorOperatorEventGateway.java" contains "import org.apache.flink.util.SerializedValue;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/SlotStatus.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/DefaultJobTable.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/JobTable.java" contains "import org.apache.flink.util.function.SupplierWithException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/JobLeaderListener.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/PartitionProducerStateChecker.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/JobLeaderService.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/GlobalAggregateManager.java" contains "import org.apache.flink.api.common.functions.AggregateFunction;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/exceptions/SlotOccupiedException.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/SlotOffer.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTable.java" contains "import org.apache.flink.util.AutoCloseableAsync;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TimerService.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTableImpl.java" contains "import org.apache.flink.util.FlinkException;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlot.java" contains "import org.apache.flink.util.AutoCloseableAsync;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotPayload.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/SlotNotActiveException.java" contains "import org.apache.flink.api.common.JobID;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/partition/PartitionTable.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/partition/ClusterPartitionReport.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/rpc/RpcInputSplitProvider.java" contains "import org.apache.flink.core.io.InputSplit;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/rpc/RpcGlobalAggregateManager.java" contains "import org.apache.flink.util.InstantiationUtil;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/rpc/RpcTaskOperatorEventGateway.java" contains "import org.apache.flink.util.SerializedValue;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/rpc/RpcPartitionStateChecker.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/rpc/RpcResultPartitionConsumableNotifier.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/rpc/RpcCheckpointResponder.java" contains "import org.apache.flink.util.Preconditions;" from: flink-runtime to: flink-core evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/rpc/RpcKvStateRegistryListener.java" contains "import org.apache.flink.util.Preconditions;"