This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit e6556fa898dc7aa3448c6052d29a78ff6e327547 Author: Piotr Nowojski <[email protected]> AuthorDate: Tue Jan 9 16:30:37 2024 +0100 [FLINK-33697][state] Allow incorrect public evolving API violation The test complains about bunch of classes returned by newly added KeyedStateBackendParameters and OperatorStateBackendParameters being not marked as @PublicEvolving. However, this is a pre-existing issue, as those parameters were already used in the @PublicEvolving API. --- .../18509c9e-3250-4c52-91b9-11ccefc85db1 | 2 +- .../5b9eed8a-5fb6-4373-98ac-3be2a71941b8 | 121 +++++---------------- .../7602816f-5c01-4b7a-9e3e-235dfedec245 | 7 +- .../e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5 | 13 +-- .../e577412e-8d38-496c-a680-b842112e4b94 | 2 +- .../f7a4e6fa-e7de-48c9-a61e-c13e83f0c72e | 22 ++-- 6 files changed, 50 insertions(+), 117 deletions(-) diff --git a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/18509c9e-3250-4c52-91b9-11ccefc85db1 b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/18509c9e-3250-4c52-91b9-11ccefc85db1 index e2812cfad3a..a0aacccbc7f 100644 --- a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/18509c9e-3250-4c52-91b9-11ccefc85db1 +++ b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/18509c9e-3250-4c52-91b9-11ccefc85db1 @@ -108,4 +108,4 @@ org.apache.flink.types.LongValue.copyNormalizedKey(org.apache.flink.core.memory. org.apache.flink.types.NormalizableKey.copyNormalizedKey(org.apache.flink.core.memory.MemorySegment, int, int): Argument leaf type org.apache.flink.core.memory.MemorySegment does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated org.apache.flink.types.NullValue.copyNormalizedKey(org.apache.flink.core.memory.MemorySegment, int, int): Argument leaf type org.apache.flink.core.memory.MemorySegment does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated org.apache.flink.types.ShortValue.copyNormalizedKey(org.apache.flink.core.memory.MemorySegment, int, int): Argument leaf type org.apache.flink.core.memory.MemorySegment does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated -org.apache.flink.types.StringValue.copyNormalizedKey(org.apache.flink.core.memory.MemorySegment, int, int): Argument leaf type org.apache.flink.core.memory.MemorySegment does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated \ No newline at end of file +org.apache.flink.types.StringValue.copyNormalizedKey(org.apache.flink.core.memory.MemorySegment, int, int): Argument leaf type org.apache.flink.core.memory.MemorySegment does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated diff --git a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8 b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8 index 8fa69ca0639..c47f4c3b8ce 100644 --- a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8 +++ b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8 @@ -60,105 +60,44 @@ org.apache.flink.core.fs.RecoverableWriter.getResumeRecoverableSerializer(): Ret org.apache.flink.core.fs.RecoverableWriter.recover(org.apache.flink.core.fs.RecoverableWriter$ResumeRecoverable): Argument leaf type org.apache.flink.core.fs.RecoverableWriter$ResumeRecoverable does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.core.fs.RecoverableWriter.recoverForCommit(org.apache.flink.core.fs.RecoverableWriter$CommitRecoverable): Argument leaf type org.apache.flink.core.fs.RecoverableWriter$CommitRecoverable does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.core.fs.RecoverableWriter.recoverForCommit(org.apache.flink.core.fs.RecoverableWriter$CommitRecoverable): Returned leaf type org.apache.flink.core.fs.RecoverableFsDataOutputStream$Committer does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.AbstractStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): A [...] -org.apache.flink.runtime.state.AbstractStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): A [...] -org.apache.flink.runtime.state.AbstractStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): A [...] -org.apache.flink.runtime.state.AbstractStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): A [...] -org.apache.flink.runtime.state.AbstractStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): A [...] -org.apache.flink.runtime.state.AbstractStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): A [...] -org.apache.flink.runtime.state.AbstractStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): A [...] -org.apache.flink.runtime.state.AbstractStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): A [...] -org.apache.flink.runtime.state.AbstractStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): A [...] -org.apache.flink.runtime.state.AbstractStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): A [...] -org.apache.flink.runtime.state.AbstractStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): A [...] -org.apache.flink.runtime.state.AbstractStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): R [...] -org.apache.flink.runtime.state.AbstractStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): R [...] -org.apache.flink.runtime.state.AbstractStateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument leaf type org.apache.flink.core.fs.CloseableRegistry does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.AbstractStateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument leaf type org.apache.flink.runtime.execution.Environment does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.AbstractStateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument leaf type org.apache.flink.runtime.state.OperatorStateHandle does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.AbstractStateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Returned leaf type org.apache.flink.runtime.state.OperatorStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.AbstractStateBackend.createKeyedStateBackend(org.apache.flink.runtime.state.StateBackend$KeyedStateBackendParameters): Returned leaf type org.apache.flink.runtime.state.AbstractKeyedStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.AbstractStateBackend.createKeyedStateBackend(org.apache.flink.runtime.state.StateBackend$KeyedStateBackendParameters): Returned leaf type org.apache.flink.runtime.state.CheckpointableKeyedStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.AbstractStateBackend.createOperatorStateBackend(org.apache.flink.runtime.state.StateBackend$OperatorStateBackendParameters): Returned leaf type org.apache.flink.runtime.state.OperatorStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.runtime.state.AbstractStateBackend.getCompressionDecorator(org.apache.flink.api.common.ExecutionConfig): Returned leaf type org.apache.flink.runtime.state.StreamCompressionDecorator does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.runtime.state.CheckpointStorage.createCheckpointStorage(org.apache.flink.api.common.JobID): Returned leaf type org.apache.flink.runtime.state.CheckpointStorageAccess does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.runtime.state.CheckpointStorage.resolveCheckpoint(java.lang.String): Returned leaf type org.apache.flink.runtime.state.CompletedCheckpointStorageLocation does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.runtime.state.KeyedStateCheckpointOutputStream.getKeyGroupList(): Returned leaf type org.apache.flink.runtime.state.KeyGroupsList does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.StateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument [...] -org.apache.flink.runtime.state.StateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument [...] -org.apache.flink.runtime.state.StateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument [...] -org.apache.flink.runtime.state.StateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument [...] -org.apache.flink.runtime.state.StateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument [...] -org.apache.flink.runtime.state.StateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument [...] -org.apache.flink.runtime.state.StateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Returned [...] -org.apache.flink.runtime.state.StateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry, double): A [...] -org.apache.flink.runtime.state.StateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry, double): A [...] -org.apache.flink.runtime.state.StateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry, double): A [...] -org.apache.flink.runtime.state.StateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry, double): A [...] -org.apache.flink.runtime.state.StateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry, double): A [...] -org.apache.flink.runtime.state.StateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry, double): A [...] -org.apache.flink.runtime.state.StateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry, double): R [...] -org.apache.flink.runtime.state.StateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument leaf type org.apache.flink.core.fs.CloseableRegistry does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.StateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument leaf type org.apache.flink.runtime.execution.Environment does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.StateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument leaf type org.apache.flink.runtime.state.OperatorStateHandle does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.StateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Returned leaf type org.apache.flink.runtime.state.OperatorStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.StateBackend$KeyedStateBackendParameters.getCancelStreamRegistry(): Returned leaf type org.apache.flink.core.fs.CloseableRegistry does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.StateBackend$KeyedStateBackendParameters.getCustomInitializationMetrics(): Returned leaf type org.apache.flink.runtime.state.StateBackend$CustomInitializationMetrics does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.StateBackend$KeyedStateBackendParameters.getEnv(): Returned leaf type org.apache.flink.runtime.execution.Environment does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.StateBackend$KeyedStateBackendParameters.getKeyGroupRange(): Returned leaf type org.apache.flink.runtime.state.KeyGroupRange does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.StateBackend$KeyedStateBackendParameters.getKvStateRegistry(): Returned leaf type org.apache.flink.runtime.query.TaskKvStateRegistry does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.StateBackend$KeyedStateBackendParameters.getStateHandles(): Returned leaf type org.apache.flink.runtime.state.KeyedStateHandle does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.StateBackend$KeyedStateBackendParameters.getTtlTimeProvider(): Returned leaf type org.apache.flink.runtime.state.ttl.TtlTimeProvider does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.StateBackend$OperatorStateBackendParameters.getCancelStreamRegistry(): Returned leaf type org.apache.flink.core.fs.CloseableRegistry does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.StateBackend$OperatorStateBackendParameters.getCustomInitializationMetrics(): Returned leaf type org.apache.flink.runtime.state.StateBackend$CustomInitializationMetrics does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.StateBackend$OperatorStateBackendParameters.getEnv(): Returned leaf type org.apache.flink.runtime.execution.Environment does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.StateBackend$OperatorStateBackendParameters.getStateHandles(): Returned leaf type org.apache.flink.runtime.state.OperatorStateHandle does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.StateBackend.createKeyedStateBackend(org.apache.flink.runtime.state.StateBackend$KeyedStateBackendParameters): Returned leaf type org.apache.flink.runtime.state.CheckpointableKeyedStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.StateBackend.createOperatorStateBackend(org.apache.flink.runtime.state.StateBackend$OperatorStateBackendParameters): Returned leaf type org.apache.flink.runtime.state.OperatorStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.runtime.state.VoidNamespaceTypeInfo.createSerializer(org.apache.flink.api.common.ExecutionConfig): Returned leaf type org.apache.flink.runtime.state.VoidNamespace does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.runtime.state.VoidNamespaceTypeInfo.getTypeClass(): Returned leaf type org.apache.flink.runtime.state.VoidNamespace does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.runtime.state.filesystem.AbstractFileStateBackend.resolveCheckpoint(java.lang.String): Returned leaf type org.apache.flink.runtime.state.CompletedCheckpointStorageLocation does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.runtime.state.filesystem.FsStateBackend.createCheckpointStorage(org.apache.flink.api.common.JobID): Returned leaf type org.apache.flink.runtime.state.CheckpointStorageAccess does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.filesystem.FsStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.filesystem.FsStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.filesystem.FsStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.filesystem.FsStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.filesystem.FsStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.filesystem.FsStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.filesystem.FsStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.filesystem.FsStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.filesystem.FsStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.filesystem.FsStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.filesystem.FsStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.filesystem.FsStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.filesystem.FsStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.filesystem.FsStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.filesystem.FsStateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument leaf type org.apache.flink.core.fs.CloseableRegistry does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.filesystem.FsStateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument leaf type org.apache.flink.runtime.execution.Environment does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.filesystem.FsStateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument leaf type org.apache.flink.runtime.state.OperatorStateHandle does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.filesystem.FsStateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Exception leaf type org.apache.flink.runtime.state.BackendBuildingException does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.filesystem.FsStateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Returned leaf type org.apache.flink.runtime.state.OperatorStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegis [...] -org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegis [...] -org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegis [...] -org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegis [...] -org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegis [...] -org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegis [...] -org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegis [...] -org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegis [...] -org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegis [...] -org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegis [...] -org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegis [...] -org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegis [...] -org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegis [...] -org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument leaf type org.apache.flink.core.fs.CloseableRegistry does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument leaf type org.apache.flink.runtime.execution.Environment does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument leaf type org.apache.flink.runtime.state.OperatorStateHandle does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Exception leaf type org.apache.flink.runtime.state.BackendBuildingException does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Returned leaf type org.apache.flink.runtime.state.OperatorStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.filesystem.FsStateBackend.createKeyedStateBackend(org.apache.flink.runtime.state.StateBackend$KeyedStateBackendParameters): Exception leaf type org.apache.flink.runtime.state.BackendBuildingException does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.filesystem.FsStateBackend.createKeyedStateBackend(org.apache.flink.runtime.state.StateBackend$KeyedStateBackendParameters): Returned leaf type org.apache.flink.runtime.state.AbstractKeyedStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.filesystem.FsStateBackend.createKeyedStateBackend(org.apache.flink.runtime.state.StateBackend$KeyedStateBackendParameters): Returned leaf type org.apache.flink.runtime.state.CheckpointableKeyedStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.filesystem.FsStateBackend.createOperatorStateBackend(org.apache.flink.runtime.state.StateBackend$OperatorStateBackendParameters): Exception leaf type org.apache.flink.runtime.state.BackendBuildingException does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.filesystem.FsStateBackend.createOperatorStateBackend(org.apache.flink.runtime.state.StateBackend$OperatorStateBackendParameters): Returned leaf type org.apache.flink.runtime.state.OperatorStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createKeyedStateBackend(org.apache.flink.runtime.state.StateBackend$KeyedStateBackendParameters): Returned leaf type org.apache.flink.runtime.state.AbstractKeyedStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createKeyedStateBackend(org.apache.flink.runtime.state.StateBackend$KeyedStateBackendParameters): Returned leaf type org.apache.flink.runtime.state.CheckpointableKeyedStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createOperatorStateBackend(org.apache.flink.runtime.state.StateBackend$OperatorStateBackendParameters): Exception leaf type org.apache.flink.runtime.state.BackendBuildingException does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.hashmap.HashMapStateBackend.createOperatorStateBackend(org.apache.flink.runtime.state.StateBackend$OperatorStateBackendParameters): Returned leaf type org.apache.flink.runtime.state.OperatorStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.runtime.state.memory.MemoryStateBackend.createCheckpointStorage(org.apache.flink.api.common.JobID): Returned leaf type org.apache.flink.runtime.state.CheckpointStorageAccess does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.memory.MemoryStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.memory.MemoryStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.memory.MemoryStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.memory.MemoryStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.memory.MemoryStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.memory.MemoryStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.memory.MemoryStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.memory.MemoryStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.memory.MemoryStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.memory.MemoryStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.memory.MemoryStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.memory.MemoryStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.memory.MemoryStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.memory.MemoryStateBackend.createKeyedStateBackend(org.apache.flink.runtime.execution.Environment, org.apache.flink.api.common.JobID, java.lang.String, org.apache.flink.api.common.typeutils.TypeSerializer, int, org.apache.flink.runtime.state.KeyGroupRange, org.apache.flink.runtime.query.TaskKvStateRegistry, org.apache.flink.runtime.state.ttl.TtlTimeProvider, org.apache.flink.metrics.MetricGroup, java.util.Collection, org.apache.flink.core.fs.CloseableRegistr [...] -org.apache.flink.runtime.state.memory.MemoryStateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument leaf type org.apache.flink.core.fs.CloseableRegistry does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.memory.MemoryStateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument leaf type org.apache.flink.runtime.execution.Environment does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.memory.MemoryStateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Argument leaf type org.apache.flink.runtime.state.OperatorStateHandle does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.runtime.state.memory.MemoryStateBackend.createOperatorStateBackend(org.apache.flink.runtime.execution.Environment, java.lang.String, java.util.Collection, org.apache.flink.core.fs.CloseableRegistry): Returned leaf type org.apache.flink.runtime.state.OperatorStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.memory.MemoryStateBackend.createKeyedStateBackend(org.apache.flink.runtime.state.StateBackend$KeyedStateBackendParameters): Exception leaf type org.apache.flink.runtime.state.BackendBuildingException does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.memory.MemoryStateBackend.createKeyedStateBackend(org.apache.flink.runtime.state.StateBackend$KeyedStateBackendParameters): Returned leaf type org.apache.flink.runtime.state.AbstractKeyedStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.memory.MemoryStateBackend.createKeyedStateBackend(org.apache.flink.runtime.state.StateBackend$KeyedStateBackendParameters): Returned leaf type org.apache.flink.runtime.state.CheckpointableKeyedStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated +org.apache.flink.runtime.state.memory.MemoryStateBackend.createOperatorStateBackend(org.apache.flink.runtime.state.StateBackend$OperatorStateBackendParameters): Returned leaf type org.apache.flink.runtime.state.OperatorStateBackend does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.runtime.state.storage.FileSystemCheckpointStorage.createCheckpointStorage(org.apache.flink.api.common.JobID): Returned leaf type org.apache.flink.runtime.state.CheckpointStorageAccess does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.runtime.state.storage.FileSystemCheckpointStorage.resolveCheckpoint(java.lang.String): Returned leaf type org.apache.flink.runtime.state.CompletedCheckpointStorageLocation does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.runtime.state.storage.JobManagerCheckpointStorage.createCheckpointStorage(org.apache.flink.api.common.JobID): Returned leaf type org.apache.flink.runtime.state.CheckpointStorageAccess does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated @@ -341,4 +280,4 @@ org.apache.flink.streaming.runtime.streamrecord.LatencyMarker.getOperatorId(): R org.apache.flink.streaming.runtime.tasks.ProcessingTimeServiceAware.setProcessingTimeService(org.apache.flink.streaming.runtime.tasks.ProcessingTimeService): Argument leaf type org.apache.flink.streaming.runtime.tasks.ProcessingTimeService does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.table.functions.SpecializedFunction$ExpressionEvaluatorFactory.createEvaluator(org.apache.flink.table.functions.BuiltInFunctionDefinition, org.apache.flink.table.types.DataType, [Lorg.apache.flink.table.types.DataType;): Argument leaf type org.apache.flink.table.functions.BuiltInFunctionDefinition does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotate [...] org.apache.flink.table.operations.QueryOperation.accept(org.apache.flink.table.operations.QueryOperationVisitor): Argument leaf type org.apache.flink.table.operations.QueryOperationVisitor does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.types.parser.FieldParser.getErrorState(): Returned leaf type org.apache.flink.types.parser.FieldParser$ParseErrorState does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated \ No newline at end of file +org.apache.flink.types.parser.FieldParser.getErrorState(): Returned leaf type org.apache.flink.types.parser.FieldParser$ParseErrorState does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated diff --git a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/7602816f-5c01-4b7a-9e3e-235dfedec245 b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/7602816f-5c01-4b7a-9e3e-235dfedec245 index 154f0160136..4ff32ba018f 100644 --- a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/7602816f-5c01-4b7a-9e3e-235dfedec245 +++ b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/7602816f-5c01-4b7a-9e3e-235dfedec245 @@ -100,7 +100,6 @@ org.apache.flink.api.java.functions.FunctionAnnotation$ForwardedFieldsSecond doe org.apache.flink.api.java.functions.FunctionAnnotation$NonForwardedFields does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.api.java.functions.FunctionAnnotation$NonForwardedFieldsFirst does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.api.java.functions.FunctionAnnotation$NonForwardedFieldsSecond does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated -org.apache.flink.api.java.hadoop.mapreduce.wrapper.HadoopInputSplit does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.api.java.io.SplitDataProperties$SourcePartitionerMarker does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.api.java.io.TextOutputFormat$TextFormatter does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.api.java.operators.CoGroupOperator$CoGroupOperatorSets does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated @@ -144,8 +143,6 @@ org.apache.flink.api.java.typeutils.runtime.NullableSerializer$NullableSerialize org.apache.flink.api.java.typeutils.runtime.RowSerializer$RowSerializerSnapshot does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.api.java.typeutils.runtime.Tuple0SerializerSnapshot does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.api.java.typeutils.runtime.ValueSerializer$ValueSerializerSnapshot does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated -org.apache.flink.api.java.typeutils.runtime.WritableComparator does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated -org.apache.flink.api.java.typeutils.runtime.WritableSerializer$WritableSerializerSnapshot does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.api.java.typeutils.runtime.kryo.ChillSerializerRegistrar does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.api.java.typeutils.runtime.kryo.FlinkChillPackageRegistrar does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.api.java.typeutils.runtime.kryo.JavaSerializer does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated @@ -207,7 +204,6 @@ org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction$OnTimerContex org.apache.flink.streaming.api.functions.co.ProcessJoinFunction$Context does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.streaming.api.functions.sink.filesystem.AbstractPartFileWriter does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter$PendingFile does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated -org.apache.flink.streaming.api.functions.sink.filesystem.HadoopPathBasedBulkFormatBuilder does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$InProgressFileRecoverable does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated @@ -216,7 +212,6 @@ org.apache.flink.streaming.api.functions.sink.filesystem.OutputStreamBasedPartFi org.apache.flink.streaming.api.functions.sink.filesystem.OutputStreamBasedPartFileWriter$OutputStreamBasedInProgressFileRecoverableSerializer does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.streaming.api.functions.sink.filesystem.OutputStreamBasedPartFileWriter$OutputStreamBasedPendingFileRecoverable does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.streaming.api.functions.sink.filesystem.OutputStreamBasedPartFileWriter$OutputStreamBasedPendingFileRecoverableSerializer does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated -org.apache.flink.streaming.api.functions.sink.filesystem.SerializableConfiguration does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink$DefaultBulkFormatBuilder does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink$DefaultRowFormatBuilder does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy$PolicyBuilder does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated @@ -288,4 +283,4 @@ org.apache.flink.streaming.api.windowing.triggers.TriggerResult does not satisfy org.apache.flink.streaming.api.windowing.windows.GlobalWindow$Serializer does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.streaming.api.windowing.windows.GlobalWindow$Serializer$GlobalWindowSerializerSnapshot does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated org.apache.flink.streaming.api.windowing.windows.TimeWindow$Serializer does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated -org.apache.flink.streaming.api.windowing.windows.TimeWindow$Serializer$TimeWindowSerializerSnapshot does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated \ No newline at end of file +org.apache.flink.streaming.api.windowing.windows.TimeWindow$Serializer$TimeWindowSerializerSnapshot does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated diff --git a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5 b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5 index dbca0076986..34ac49f8993 100644 --- a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5 +++ b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5 @@ -2,7 +2,6 @@ Constructor <org.apache.flink.runtime.state.heap.CopyOnWriteStateMapSnapshot.<in Constructor <org.apache.flink.streaming.runtime.io.StreamTaskExternallyInducedSourceInput.<init>(org.apache.flink.streaming.api.operators.SourceOperator, java.util.function.Consumer, int, int)> calls method <org.apache.flink.streaming.api.operators.SourceOperator.getSourceReader()> in (StreamTaskExternallyInducedSourceInput.java:41) Method <org.apache.flink.api.java.typeutils.runtime.TupleSerializerSnapshot.getNestedSerializers(org.apache.flink.api.java.typeutils.runtime.TupleSerializer)> calls method <org.apache.flink.api.java.typeutils.runtime.TupleSerializer.getFieldSerializers()> in (TupleSerializerSnapshot.java:70) Method <org.apache.flink.cep.nfa.sharedbuffer.LockableTypeSerializerSnapshot.getNestedSerializers(org.apache.flink.cep.nfa.sharedbuffer.Lockable$LockableTypeSerializer)> calls method <org.apache.flink.cep.nfa.sharedbuffer.Lockable$LockableTypeSerializer.getElementSerializer()> in (LockableTypeSerializerSnapshot.java:60) -Method <org.apache.flink.orc.nohive.shim.OrcNoHiveShim.createRecordReader(org.apache.hadoop.conf.Configuration, org.apache.orc.TypeDescription, [I, java.util.List, org.apache.flink.core.fs.Path, long, long)> calls method <org.apache.flink.orc.shim.OrcShimV200.getOffsetAndLengthForSplit(long, long, java.util.List)> in (OrcNoHiveShim.java:62) Method <org.apache.flink.runtime.blob.BlobInputStream.read()> calls method <org.apache.flink.runtime.blob.BlobKey.getHash()> in (BlobInputStream.java:127) Method <org.apache.flink.runtime.blob.BlobInputStream.read([B, int, int)> calls method <org.apache.flink.runtime.blob.BlobKey.getHash()> in (BlobInputStream.java:163) Method <org.apache.flink.runtime.blob.BlobOutputStream.receiveAndCheckPutResponse(java.io.InputStream, java.security.MessageDigest, org.apache.flink.runtime.blob.BlobKey$BlobType)> calls method <org.apache.flink.runtime.blob.BlobKey.getHash()> in (BlobOutputStream.java:155) @@ -19,9 +18,9 @@ Method <org.apache.flink.runtime.io.network.partition.ResourceManagerPartitionTr Method <org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator$DeferrableCoordinator.closeAsync(long)> calls method <org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator$QuiesceableContext.quiesce()> in (RecreateOnResetOperatorCoordinator.java:361) Method <org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration.fromConfiguration(org.apache.flink.configuration.Configuration, org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, java.lang.String, java.io.File)> calls method <org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils.generateDefaultSlotResourceProfile(org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, int)> in (TaskManagerConfiguration.java:241) Method <org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration.fromConfiguration(org.apache.flink.configuration.Configuration, org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, java.lang.String, java.io.File)> calls method <org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils.generateTotalAvailableResourceProfile(org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec)> in (TaskManagerConfiguration.java:243) -Method <org.apache.flink.runtime.taskexecutor.TaskManagerServices.createTaskSlotTable(int, org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, long, int, java.util.concurrent.Executor)> calls method <org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils.generateDefaultSlotResourceProfile(org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, int)> in (TaskManagerServices.java:450) -Method <org.apache.flink.runtime.taskexecutor.TaskManagerServices.createTaskSlotTable(int, org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, long, int, java.util.concurrent.Executor)> calls method <org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils.generateTotalAvailableResourceProfile(org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec)> in (TaskManagerServices.java:448) -Method <org.apache.flink.streaming.api.operators.SourceOperator$1$1.asClassLoader()> calls method <org.apache.flink.streaming.api.operators.SourceOperator.getRuntimeContext()> in (SourceOperator.java:295) -Method <org.apache.flink.streaming.api.operators.SourceOperator$1$1.registerReleaseHookIfAbsent(java.lang.String, java.lang.Runnable)> calls method <org.apache.flink.streaming.api.operators.SourceOperator.getRuntimeContext()> in (SourceOperator.java:301) -Method <org.apache.flink.streaming.runtime.tasks.SourceOperatorStreamTask.init()> calls method <org.apache.flink.streaming.api.operators.SourceOperator.getSourceReader()> in (SourceOperatorStreamTask.java:95) -Method <org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorImpl.isIdle()> calls method <org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.isDefaultActionAvailable()> in (MailboxExecutorImpl.java:63) \ No newline at end of file +Method <org.apache.flink.runtime.taskexecutor.TaskManagerServices.createTaskSlotTable(int, org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, long, int, java.util.concurrent.Executor)> calls method <org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils.generateDefaultSlotResourceProfile(org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, int)> in (TaskManagerServices.java:480) +Method <org.apache.flink.runtime.taskexecutor.TaskManagerServices.createTaskSlotTable(int, org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec, long, int, java.util.concurrent.Executor)> calls method <org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils.generateTotalAvailableResourceProfile(org.apache.flink.runtime.taskexecutor.TaskExecutorResourceSpec)> in (TaskManagerServices.java:478) +Method <org.apache.flink.streaming.api.operators.SourceOperator$1$1.asClassLoader()> calls method <org.apache.flink.streaming.api.operators.SourceOperator.getRuntimeContext()> in (SourceOperator.java:297) +Method <org.apache.flink.streaming.api.operators.SourceOperator$1$1.registerReleaseHookIfAbsent(java.lang.String, java.lang.Runnable)> calls method <org.apache.flink.streaming.api.operators.SourceOperator.getRuntimeContext()> in (SourceOperator.java:303) +Method <org.apache.flink.streaming.runtime.tasks.SourceOperatorStreamTask.init()> calls method <org.apache.flink.streaming.api.operators.SourceOperator.getSourceReader()> in (SourceOperatorStreamTask.java:96) +Method <org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorImpl.isIdle()> calls method <org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.isDefaultActionAvailable()> in (MailboxExecutorImpl.java:63) diff --git a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/e577412e-8d38-496c-a680-b842112e4b94 b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/e577412e-8d38-496c-a680-b842112e4b94 index 3274a36584a..37662503dee 100644 --- a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/e577412e-8d38-496c-a680-b842112e4b94 +++ b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/e577412e-8d38-496c-a680-b842112e4b94 @@ -1 +1 @@ -Class <org.apache.flink.formats.raw.RawFormatOptions> does not reside in a package 'org.apache.flink..table' in (RawFormatOptions.java:0) \ No newline at end of file +Class <org.apache.flink.formats.raw.RawFormatOptions> does not reside in a package 'org.apache.flink..table' in (RawFormatOptions.java:0) diff --git a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/f7a4e6fa-e7de-48c9-a61e-c13e83f0c72e b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/f7a4e6fa-e7de-48c9-a61e-c13e83f0c72e index 8a67c876d70..e2d6482ff0e 100644 --- a/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/f7a4e6fa-e7de-48c9-a61e-c13e83f0c72e +++ b/flink-architecture-tests/flink-architecture-tests-production/archunit-violations/f7a4e6fa-e7de-48c9-a61e-c13e83f0c72e @@ -51,7 +51,7 @@ Constructor <org.apache.flink.connector.base.sink.writer.strategy.CongestionCont Constructor <org.apache.flink.connector.base.source.hybrid.HybridSource$SourceListEntry.<init>(org.apache.flink.connector.base.source.hybrid.HybridSource$SourceFactory, org.apache.flink.api.connector.source.Boundedness)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (HybridSource.java:211) Constructor <org.apache.flink.connector.base.source.hybrid.HybridSource$SourceListEntry.<init>(org.apache.flink.connector.base.source.hybrid.HybridSource$SourceFactory, org.apache.flink.api.connector.source.Boundedness)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (HybridSource.java:212) Constructor <org.apache.flink.connector.base.source.hybrid.HybridSource.<init>(java.util.List)> calls method <org.apache.flink.util.Preconditions.checkArgument(boolean)> in (HybridSource.java:96) -Constructor <org.apache.flink.connector.base.source.hybrid.HybridSourceSplitEnumerator.<init>(org.apache.flink.api.connector.source.SplitEnumeratorContext, java.util.List, int, org.apache.flink.connector.base.source.hybrid.HybridSourceEnumeratorState)> calls method <org.apache.flink.util.Preconditions.checkArgument(boolean)> in (HybridSourceSplitEnumerator.java:88) +Constructor <org.apache.flink.connector.base.source.hybrid.HybridSourceSplitEnumerator.<init>(org.apache.flink.api.connector.source.SplitEnumeratorContext, java.util.List, int, org.apache.flink.connector.base.source.hybrid.HybridSourceEnumeratorState)> calls method <org.apache.flink.util.Preconditions.checkArgument(boolean)> in (HybridSourceSplitEnumerator.java:89) Constructor <org.apache.flink.connector.base.source.reader.RecordsBySplits.<init>(java.util.Map, java.util.Set)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, java.lang.String)> in (RecordsBySplits.java:50) Constructor <org.apache.flink.connector.base.source.reader.RecordsBySplits.<init>(java.util.Map, java.util.Set)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, java.lang.String)> in (RecordsBySplits.java:51) Constructor <org.apache.flink.connector.base.source.reader.fetcher.PauseOrResumeSplitsTask.<init>(org.apache.flink.connector.base.source.reader.splitreader.SplitReader, java.util.Collection, java.util.Collection, boolean)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (PauseOrResumeSplitsTask.java:54) @@ -64,8 +64,8 @@ Constructor <org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher. Constructor <org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.<init>(int, org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue, org.apache.flink.connector.base.source.reader.splitreader.SplitReader, java.util.function.Consumer, java.lang.Runnable, java.util.function.Consumer, boolean)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (SplitFetcher.java:97) Constructor <org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.<init>(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue, java.util.function.Supplier, org.apache.flink.configuration.Configuration, java.util.function.Consumer)> is annotated with <org.apache.flink.annotation.VisibleForTesting> in (SplitFetcherManager.java:0) Constructor <org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue.<init>(int)> calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> in (FutureCompletingBlockingQueue.java:114) -Constructor <org.apache.flink.connector.datagen.source.DataGeneratorSource.<init>(org.apache.flink.api.connector.source.SourceReaderFactory, org.apache.flink.connector.datagen.source.GeneratorFunction, long, org.apache.flink.api.common.typeinfo.TypeInformation)> calls method <org.apache.flink.api.java.ClosureCleaner.clean(java.lang.Object, org.apache.flink.api.common.ExecutionConfig$ClosureCleanerLevel, boolean)> in (DataGeneratorSource.java:154) -Constructor <org.apache.flink.connector.datagen.source.DataGeneratorSource.<init>(org.apache.flink.api.connector.source.SourceReaderFactory, org.apache.flink.connector.datagen.source.GeneratorFunction, long, org.apache.flink.api.common.typeinfo.TypeInformation)> calls method <org.apache.flink.api.java.ClosureCleaner.clean(java.lang.Object, org.apache.flink.api.common.ExecutionConfig$ClosureCleanerLevel, boolean)> in (DataGeneratorSource.java:156) +Constructor <org.apache.flink.connector.datagen.source.DataGeneratorSource.<init>(org.apache.flink.api.connector.source.SourceReaderFactory, org.apache.flink.connector.datagen.source.GeneratorFunction, long, org.apache.flink.api.common.typeinfo.TypeInformation)> calls method <org.apache.flink.api.java.ClosureCleaner.clean(java.lang.Object, org.apache.flink.api.common.ExecutionConfig$ClosureCleanerLevel, boolean)> in (DataGeneratorSource.java:155) +Constructor <org.apache.flink.connector.datagen.source.DataGeneratorSource.<init>(org.apache.flink.api.connector.source.SourceReaderFactory, org.apache.flink.connector.datagen.source.GeneratorFunction, long, org.apache.flink.api.common.typeinfo.TypeInformation)> calls method <org.apache.flink.api.java.ClosureCleaner.clean(java.lang.Object, org.apache.flink.api.common.ExecutionConfig$ClosureCleanerLevel, boolean)> in (DataGeneratorSource.java:157) Constructor <org.apache.flink.connector.datagen.source.DataGeneratorSource.<init>(org.apache.flink.api.connector.source.SourceReaderFactory, org.apache.flink.connector.datagen.source.GeneratorFunction, long, org.apache.flink.api.common.typeinfo.TypeInformation)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (DataGeneratorSource.java:150) Constructor <org.apache.flink.connector.datagen.source.DataGeneratorSource.<init>(org.apache.flink.api.connector.source.SourceReaderFactory, org.apache.flink.connector.datagen.source.GeneratorFunction, long, org.apache.flink.api.common.typeinfo.TypeInformation)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (DataGeneratorSource.java:151) Constructor <org.apache.flink.connector.datagen.source.DataGeneratorSource.<init>(org.apache.flink.api.connector.source.SourceReaderFactory, org.apache.flink.connector.datagen.source.GeneratorFunction, long, org.apache.flink.api.common.typeinfo.TypeInformation)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (DataGeneratorSource.java:152) @@ -80,9 +80,9 @@ Constructor <org.apache.flink.connector.datagen.table.DataGenTableSource.<init>( Constructor <org.apache.flink.connector.datagen.table.DataGenTableSource.<init>([Lorg.apache.flink.streaming.api.functions.source.datagen.DataGenerator;, java.lang.String, org.apache.flink.table.types.DataType, long, java.lang.Long)> has parameter of type <[Lorg.apache.flink.streaming.api.functions.source.datagen.DataGenerator;> in (DataGenTableSource.java:0) Constructor <org.apache.flink.connector.datagen.table.DataGenVisitorBase.<init>(java.lang.String, org.apache.flink.configuration.ReadableConfig)> calls constructor <org.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor.<init>()> in (DataGenVisitorBase.java:49) Constructor <org.apache.flink.connector.datagen.table.DataGeneratorContainer.<init>(org.apache.flink.streaming.api.functions.source.datagen.DataGenerator, java.util.Set)> has parameter of type <org.apache.flink.streaming.api.functions.source.datagen.DataGenerator> in (DataGeneratorContainer.java:0) -Constructor <org.apache.flink.connector.datagen.table.RandomGeneratorVisitor$1.<init>(int)> calls constructor <org.apache.flink.streaming.api.functions.source.datagen.RandomGenerator.<init>()> in (RandomGeneratorVisitor.java:474) -Constructor <org.apache.flink.connector.datagen.table.RandomGeneratorVisitor$2.<init>(java.time.Duration)> calls constructor <org.apache.flink.streaming.api.functions.source.datagen.RandomGenerator.<init>()> in (RandomGeneratorVisitor.java:488) -Constructor <org.apache.flink.connector.datagen.table.RandomGeneratorVisitor$3.<init>(int)> calls constructor <org.apache.flink.streaming.api.functions.source.datagen.RandomGenerator.<init>()> in (RandomGeneratorVisitor.java:503) +Constructor <org.apache.flink.connector.datagen.table.RandomGeneratorVisitor$1.<init>(int)> calls constructor <org.apache.flink.streaming.api.functions.source.datagen.RandomGenerator.<init>()> in (RandomGeneratorVisitor.java:458) +Constructor <org.apache.flink.connector.datagen.table.RandomGeneratorVisitor$2.<init>(java.time.Duration)> calls constructor <org.apache.flink.streaming.api.functions.source.datagen.RandomGenerator.<init>()> in (RandomGeneratorVisitor.java:473) +Constructor <org.apache.flink.connector.datagen.table.RandomGeneratorVisitor$3.<init>(int)> calls constructor <org.apache.flink.streaming.api.functions.source.datagen.RandomGenerator.<init>()> in (RandomGeneratorVisitor.java:488) Constructor <org.apache.flink.connector.datagen.table.SequenceGeneratorVisitor$1.<init>(long, long)> calls constructor <org.apache.flink.streaming.api.functions.source.datagen.SequenceGenerator.<init>(long, long)> in (SequenceGeneratorVisitor.java:207) Constructor <org.apache.flink.connector.datagen.table.SequenceGeneratorVisitor$2.<init>(long, long)> calls constructor <org.apache.flink.streaming.api.functions.source.datagen.SequenceGenerator.<init>(long, long)> in (SequenceGeneratorVisitor.java:216) Constructor <org.apache.flink.connector.datagen.table.types.DataGeneratorMapper.<init>(org.apache.flink.streaming.api.functions.source.datagen.DataGenerator, org.apache.flink.util.function.SerializableFunction, float)> has generic parameter type <org.apache.flink.streaming.api.functions.source.datagen.DataGenerator<A>> with type argument depending on <org.apache.flink.streaming.api.functions.source.datagen.DataGenerator> in (DataGeneratorMapper.java:0) @@ -287,10 +287,10 @@ Method <org.apache.flink.connector.base.source.hybrid.HybridSource$HybridSourceB Method <org.apache.flink.connector.base.source.hybrid.HybridSource$HybridSourceBuilder.addSource(org.apache.flink.connector.base.source.hybrid.HybridSource$SourceFactory, org.apache.flink.api.connector.source.Boundedness)> calls method <org.apache.flink.util.Preconditions.checkArgument(boolean, java.lang.Object)> in (HybridSource.java:242) Method <org.apache.flink.connector.base.source.hybrid.HybridSourceReader.addSplits(java.util.List)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.String, [Ljava.lang.Object;)> in (HybridSourceReader.java:153) Method <org.apache.flink.connector.base.source.hybrid.HybridSourceReader.setCurrentReader(int)> calls method <org.apache.flink.util.Preconditions.checkArgument(boolean)> in (HybridSourceReader.java:206) -Method <org.apache.flink.connector.base.source.hybrid.HybridSourceSplitEnumerator.checkAndSignalNoMoreSplits(org.apache.flink.api.connector.source.SplitEnumeratorContext, int, int, int)> calls method <org.apache.flink.api.connector.source.SupportsIntermediateNoMoreSplits.signalIntermediateNoMoreSplits(int)> in (HybridSourceSplitEnumerator.java:447) -Method <org.apache.flink.connector.base.source.hybrid.HybridSourceSplitEnumerator.checkAndSignalNoMoreSplits(org.apache.flink.api.connector.source.SplitEnumeratorContext, int, int, int)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.String, [Ljava.lang.Object;)> in (HybridSourceSplitEnumerator.java:439) -Method <org.apache.flink.connector.base.source.hybrid.HybridSourceSplitEnumerator.checkAndSignalNoMoreSplits(org.apache.flink.api.connector.source.SplitEnumeratorContext, int, int, int)> checks instanceof <org.apache.flink.api.connector.source.SupportsIntermediateNoMoreSplits> in (HybridSourceSplitEnumerator.java:439) -Method <org.apache.flink.connector.base.source.hybrid.HybridSourceSplitEnumerator.handleSplitRequest(int, java.lang.String)> calls method <org.apache.flink.util.Preconditions.checkState(boolean)> in (HybridSourceSplitEnumerator.java:110) +Method <org.apache.flink.connector.base.source.hybrid.HybridSourceSplitEnumerator.checkAndSignalNoMoreSplits(org.apache.flink.api.connector.source.SplitEnumeratorContext, int, int, int)> calls method <org.apache.flink.api.connector.source.SupportsIntermediateNoMoreSplits.signalIntermediateNoMoreSplits(int)> in (HybridSourceSplitEnumerator.java:448) +Method <org.apache.flink.connector.base.source.hybrid.HybridSourceSplitEnumerator.checkAndSignalNoMoreSplits(org.apache.flink.api.connector.source.SplitEnumeratorContext, int, int, int)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.String, [Ljava.lang.Object;)> in (HybridSourceSplitEnumerator.java:440) +Method <org.apache.flink.connector.base.source.hybrid.HybridSourceSplitEnumerator.checkAndSignalNoMoreSplits(org.apache.flink.api.connector.source.SplitEnumeratorContext, int, int, int)> checks instanceof <org.apache.flink.api.connector.source.SupportsIntermediateNoMoreSplits> in (HybridSourceSplitEnumerator.java:440) +Method <org.apache.flink.connector.base.source.hybrid.HybridSourceSplitEnumerator.handleSplitRequest(int, java.lang.String)> calls method <org.apache.flink.util.Preconditions.checkState(boolean)> in (HybridSourceSplitEnumerator.java:111) Method <org.apache.flink.connector.base.source.hybrid.SwitchedSources.put(int, org.apache.flink.api.connector.source.Source)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (SwitchedSources.java:48) Method <org.apache.flink.connector.base.source.hybrid.SwitchedSources.sourceOf(int)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object, java.lang.String, [Ljava.lang.Object;)> in (SwitchedSources.java:38) Method <org.apache.flink.connector.base.source.reader.SourceReaderBase.moveToNextSplit(org.apache.flink.connector.base.source.reader.RecordsWithSplitIds, org.apache.flink.api.connector.source.ReaderOutput)> calls method <org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in (SourceReaderBase.java:229) @@ -456,7 +456,7 @@ Method <org.apache.flink.connector.file.sink.compactor.operator.CompactService.c Method <org.apache.flink.connector.file.sink.compactor.operator.CompactService.compact(org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest)> calls method <org.apache.flink.streaming.api.functions.sink.filesystem.OutputStreamBasedCompactingFileWriter.asOutputStream()> in (CompactService.java:120) Method <org.apache.flink.connector.file.sink.compactor.operator.CompactService.compact(org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest)> gets field <org.apache.flink.streaming.api.functions.sink.filesystem.CompactingFileWriter$Type.OUTPUT_STREAM> in (CompactService.java:115) Method <org.apache.flink.connector.file.sink.compactor.operator.CompactService.compact(org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest)> gets field <org.apache.flink.streaming.api.functions.sink.filesystem.CompactingFileWriter$Type.RECORD_WISE> in (CompactService.java:110) -Method <org.apache.flink.connector.file.sink.compactor.operator.CompactService.compact(org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest)> references method <org.apache.flink.streaming.api.functions.sink.filesystem.RecordWiseCompactingFileWriter.write(java.lang.Object)> in (CompactService.java:111) +Method <org.apache.flink.connector.file.sink.compactor.operator.CompactService.compact(org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest)> references method <org.apache.flink.streaming.api.functions.sink.filesystem.RecordWiseCompactingFileWriter.write(java.lang.Object)> in (CompactService.java:114) Method <org.apache.flink.connector.file.sink.compactor.operator.CompactService.getCompactingPath(org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest)> calls method <org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter$PendingFile.commitAfterRecovery()> in (CompactService.java:151) Method <org.apache.flink.connector.file.sink.compactor.operator.CompactService.getCompactingPath(org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest)> calls method <org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter.recoverPendingFile(org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable)> in (CompactService.java:151) Method <org.apache.flink.connector.file.sink.compactor.operator.CompactService.getCompactingPath(org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest)> calls method <org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter$PendingFileRecoverable.getPath()> in (CompactService.java:144)
