from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/ForwardingOutputStream.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/NonClosingOutpusStreamDecorator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/NonClosingInputStreamDecorator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/ForwardingInputStream.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateMap.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateTableSnapshot.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateTable.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/AbstractStateTableSnapshot.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/InternalKeyContext.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/NestedMapsStateTable.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateMap.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/AbstractHeapState.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapPriorityQueueElement.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobResult.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerImpl.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotRequestBulkChecker.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SchedulerImpl.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SingleLogicalSlot.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManager.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/ActiveResourceManager.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/CheckpointCoordinatorConfiguration.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/InputSplitProvider.java" contains "import org.apache.flink.annotation.Public;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/IntermediateResultPartitionID.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/SavepointConfigOptions.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/ReporterSetup.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistryImpl.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/MetricUtils.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroup.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskMetricGroup.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/GenericValueMetricGroup.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/GenericKeyMetricGroup.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskManagerMetricGroup.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/ComponentMetricGroup.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskManagerJobMetricGroup.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/OperatorMetricGroup.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/JobManagerJobMetricGroup.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/JobMetricGroup.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/GenericMetricGroup.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/JobManagerProcessUtils.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/JobManagerProcessSpec.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/ScheduledUnit.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/CoLocationGroupDesc.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/PartitionDescriptor.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/NettyShuffleDescriptor.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ProducerDescriptor.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/TaskManagerLocation.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/messages/checkpoint/AcknowledgeCheckpoint.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRetentionPolicy.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointOptions.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorStateRepartitioner.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PrioritizedOperatorSubtaskState.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/RoundRobinOperatorStateRepartitioner.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ResultSubpartitionInfo.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateSerializer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateReader.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/InputChannelInfo.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateReaderImpl.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImpl.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriter.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV3Serializer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2Serializer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV1Serializer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/memory/SharedResources.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/RecreateOnResetOperatorCoordinator.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/jobmanager/JobManagerFlinkMemory.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/util/bash/BashJavaUtils.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/security/KerberosUtils.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/security/modules/HadoopModule.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/security/modules/JaasModule.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/IntermediateResult.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraphBuilder.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionVertex.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionAttemptID.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/RestartPipelinedRegionFailoverStrategy.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/ExecutionFailureHandler.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/TaskExecutorProcessSpec.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/SlotProfile.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SplitAssignmentTracker.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorContext.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/AbstractDispatcherBootstrap.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/FileArchivedExecutionGraphStore.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherBootstrap.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultDispatcherBootstrap.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/SessionDispatcherLeaderProcessFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/AbstractDispatcherLeaderProcess.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/DispatcherLeaderProcessFactoryFactory.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/DefaultDispatcherGatewayService.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NettyShuffleServiceFactory.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NettyShuffleEnvironment.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/AbstractBuffersUsageGauge.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedSequenceNumberingViewReader.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyServer.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/BroadcastRecordWriter.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionID.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionFactory.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResourceManagerPartitionTrackerImpl.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/DataSetMetaInfo.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateFactory.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferManager.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RecoveredInputChannel.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferOrEvent.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferDecompressor.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferBuilder.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/AvailabilityProvider.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/PullingAsyncDataInput.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/FileBasedBufferIterator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/AbstractExecutionSlotAllocator.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStore.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/SnappyStreamCompressionDecorator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSnapshotRestore.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/OwnedTaskLocalStateStore.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointListener.java" contains "import org.apache.flink.annotation.Public;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/IncrementalRemoteKeyedStateHandle.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java" contains "import org.apache.flink.annotation.Public;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStateCheckpointOutputStream.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateTransformationFunction.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSnapshotContextSynchronousImpl.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackendBuilder.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendFactory.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ManagedSnapshotContext.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/InputChannelStateHandle.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ResultSubpartitionStateHandle.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/DuplicatingCheckpointOutputStream.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorLocalStateStoresManager.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStoreImpl.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/AsyncSnapshotCallable.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/JavaSerializer.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/ConfigurableStateBackend.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/LocalRecoveryDirectoryProviderImpl.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotStrategy.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StatePartitionStreamProvider.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSnapshotContext.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSnapshot.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateCheckpointOutputStream.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/UncompressedStreamCompressionDecorator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/InternalPriorityQueue.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackend.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryKey.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StreamCompressionDecorator.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/FunctionInitializationContext.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateInitializationContext.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/FunctionSnapshotContext.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractStateBackend.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSerializerProvider.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSnapshotKeyGroupReader.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupStatePartitionStreamProvider.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractChannelStateHandle.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/MemoryStateBackendFactory.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/MemoryBackendCheckpointStorage.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/MemoryStateBackend.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackend.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackendFactory.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStorage.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/AbstractFsCheckpointStorage.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/AbstractFileStateBackend.java" contains "import org.apache.flink.annotation.PublicEvolving;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStorageLocation.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptorFactory.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/nonha/embedded/EmbeddedLeaderService.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/ScheduledFutureAdapter.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntryPointExceptionUtils.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/externalresource/StaticExternalResourceInfoProvider.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcService.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceUtils.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateEntry.java" contains "import org.apache.flink.annotation.Internal;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/PermanentBlobCache.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/VoidBlobWriter.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/PermanentBlobKey.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobKey.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobKey.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/blob/TransientBlobCache.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/CompletedOperationCache.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricStore.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/backpressure/BackPressureRequestCoordinator.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServices.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/DefaultJobLeaderService.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorResourceUtils.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTable.java" contains "import org.apache.flink.annotation.VisibleForTesting;" from: flink-runtime to: flink-annotations evidence: - file: "flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTableImpl.java" contains "import org.apache.flink.annotation.VisibleForTesting;"