This is an automated email from the ASF dual-hosted git repository. fpaul pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 0d42f22f6ed9a6a52379cd3aad44413493d05380 Author: Fabian Paul <[email protected]> AuthorDate: Mon Jan 10 14:23:42 2022 +0100 [FLINK-25569][core] Mark SimpleVersionedSerializer as PublicEvolving --- .../5b9eed8a-5fb6-4373-98ac-3be2a71941b8 | 28 ---------------------- .../flink/core/io/SimpleVersionedSerializer.java | 4 ++-- 2 files changed, 2 insertions(+), 30 deletions(-) diff --git a/flink-architecture-tests/violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8 b/flink-architecture-tests/violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8 index c0e15af..f494fcd 100644 --- a/flink-architecture-tests/violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8 +++ b/flink-architecture-tests/violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8 @@ -58,8 +58,6 @@ org.apache.flink.configuration.MemorySize.parse(java.lang.String, org.apache.fli org.apache.flink.connector.base.DeliveryGuarantee.getDescription(): Returned leaf type org.apache.flink.configuration.description.InlineElement does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.base.sink.AsyncSinkBase.createCommitter(): Returned leaf type org.apache.flink.api.connector.sink.Committer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.base.sink.AsyncSinkBase.createGlobalCommitter(): Returned leaf type org.apache.flink.api.connector.sink.GlobalCommitter does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.connector.base.sink.AsyncSinkBase.getCommittableSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.connector.base.sink.AsyncSinkBase.getGlobalCommittableSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.base.sink.writer.AsyncSinkWriter.write(java.lang.Object, org.apache.flink.api.connector.sink.SinkWriter$Context): Argument leaf type org.apache.flink.api.connector.sink.SinkWriter$Context does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.base.sink.writer.ElementConverter.apply(java.lang.Object, org.apache.flink.api.connector.sink.SinkWriter$Context): Argument leaf type org.apache.flink.api.connector.sink.SinkWriter$Context does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.base.source.hybrid.HybridSource.builder(org.apache.flink.api.connector.source.Source): Returned leaf type org.apache.flink.connector.base.source.hybrid.HybridSource$HybridSourceBuilder does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated @@ -68,9 +66,7 @@ org.apache.flink.connector.base.source.hybrid.HybridSource.createEnumerator(org. org.apache.flink.connector.base.source.hybrid.HybridSource.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext): Returned leaf type org.apache.flink.connector.base.source.hybrid.HybridSourceSplit does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.base.source.hybrid.HybridSource.createReader(org.apache.flink.api.connector.source.SourceReaderContext): Returned leaf type org.apache.flink.connector.base.source.hybrid.HybridSourceSplit does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.base.source.hybrid.HybridSource.getEnumeratorCheckpointSerializer(): Returned leaf type org.apache.flink.connector.base.source.hybrid.HybridSourceEnumeratorState does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.connector.base.source.hybrid.HybridSource.getEnumeratorCheckpointSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.base.source.hybrid.HybridSource.getSplitSerializer(): Returned leaf type org.apache.flink.connector.base.source.hybrid.HybridSourceSplit does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.connector.base.source.hybrid.HybridSource.getSplitSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.base.source.hybrid.HybridSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext, org.apache.flink.connector.base.source.hybrid.HybridSourceEnumeratorState): Argument leaf type org.apache.flink.connector.base.source.hybrid.HybridSourceEnumeratorState does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.base.source.hybrid.HybridSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext, org.apache.flink.connector.base.source.hybrid.HybridSourceEnumeratorState): Argument leaf type org.apache.flink.connector.base.source.hybrid.HybridSourceSplit does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.base.source.hybrid.HybridSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext, org.apache.flink.connector.base.source.hybrid.HybridSourceEnumeratorState): Returned leaf type org.apache.flink.connector.base.source.hybrid.HybridSourceEnumeratorState does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated @@ -81,18 +77,12 @@ org.apache.flink.connector.elasticsearch.sink.ElasticsearchSink.createCommitter( org.apache.flink.connector.elasticsearch.sink.ElasticsearchSink.createGlobalCommitter(): Returned leaf type org.apache.flink.api.connector.sink.GlobalCommitter does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.elasticsearch.sink.ElasticsearchSink.createWriter(org.apache.flink.api.connector.sink.Sink$InitContext, java.util.List): Argument leaf type org.apache.flink.api.connector.sink.Sink$InitContext does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.elasticsearch.sink.ElasticsearchSink.createWriter(org.apache.flink.api.connector.sink.Sink$InitContext, java.util.List): Returned leaf type org.apache.flink.api.connector.sink.SinkWriter does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.connector.elasticsearch.sink.ElasticsearchSink.getCommittableSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.connector.elasticsearch.sink.ElasticsearchSink.getGlobalCommittableSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.connector.elasticsearch.sink.ElasticsearchSink.getWriterStateSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.build(): Returned leaf type org.apache.flink.connector.file.sink.FileSink does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.file.sink.FileSink$BulkFormatBuilder.withOutputFileConfig(org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig): Argument leaf type org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.file.src.AbstractFileSource.getAssignerFactory(): Returned leaf type org.apache.flink.connector.file.src.assigners.FileSplitAssigner$Provider does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.file.src.AbstractFileSource.getContinuousEnumerationSettings(): Returned leaf type org.apache.flink.connector.file.src.ContinuousEnumerationSettings does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.connector.file.src.AbstractFileSource.getEnumeratorCheckpointSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.connector.file.src.AbstractFileSource.getSplitSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.file.src.FileSource.forBulkFileFormat(org.apache.flink.connector.file.src.reader.BulkFormat, [Lorg.apache.flink.core.fs.Path;): Returned leaf type org.apache.flink.connector.file.src.FileSource$FileSourceBuilder does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.file.src.FileSource.forRecordStreamFormat(org.apache.flink.connector.file.src.reader.StreamFormat, [Lorg.apache.flink.core.fs.Path;): Returned leaf type org.apache.flink.connector.file.src.FileSource$FileSourceBuilder does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.connector.file.src.FileSource.getSplitSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.file.src.compression.StandardDeCompressors.getDecompressorForExtension(java.lang.String): Returned leaf type org.apache.flink.api.common.io.compression.InflaterInputStreamFactory does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.file.src.compression.StandardDeCompressors.getDecompressorForFileName(java.lang.String): Returned leaf type org.apache.flink.api.common.io.compression.InflaterInputStreamFactory does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.file.src.reader.BulkFormat.createReader(org.apache.flink.configuration.Configuration, org.apache.flink.connector.file.src.FileSourceSplit): Returned leaf type org.apache.flink.connector.file.src.reader.BulkFormat$Reader does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated @@ -122,44 +112,29 @@ org.apache.flink.connector.kafka.sink.KafkaSink.createWriter(org.apache.flink.ap org.apache.flink.connector.kafka.sink.KafkaSink.createWriter(org.apache.flink.api.connector.sink.Sink$InitContext, java.util.List): Returned leaf type org.apache.flink.connector.kafka.sink.KafkaCommittable does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.kafka.sink.KafkaSink.createWriter(org.apache.flink.api.connector.sink.Sink$InitContext, java.util.List): Returned leaf type org.apache.flink.connector.kafka.sink.KafkaWriterState does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.kafka.sink.KafkaSink.getCommittableSerializer(): Returned leaf type org.apache.flink.connector.kafka.sink.KafkaCommittable does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.connector.kafka.sink.KafkaSink.getCommittableSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.connector.kafka.sink.KafkaSink.getGlobalCommittableSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.kafka.sink.KafkaSink.getWriterStateSerializer(): Returned leaf type org.apache.flink.connector.kafka.sink.KafkaWriterState does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.connector.kafka.sink.KafkaSink.getWriterStateSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.kafka.source.enumerator.initializer.OffsetsInitializer.getPartitionOffsets(java.util.Collection, org.apache.flink.connector.kafka.source.enumerator.initializer.OffsetsInitializer$PartitionOffsetsRetriever): Argument leaf type org.apache.flink.connector.kafka.source.enumerator.initializer.OffsetsInitializer$PartitionOffsetsRetriever does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or ann [...] org.apache.flink.connector.pulsar.source.PulsarSource.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext): Argument leaf type org.apache.flink.connector.pulsar.source.split.PulsarPartitionSplit does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.pulsar.source.PulsarSource.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext): Returned leaf type org.apache.flink.connector.pulsar.source.enumerator.PulsarSourceEnumState does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.pulsar.source.PulsarSource.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext): Returned leaf type org.apache.flink.connector.pulsar.source.split.PulsarPartitionSplit does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.pulsar.source.PulsarSource.createReader(org.apache.flink.api.connector.source.SourceReaderContext): Returned leaf type org.apache.flink.connector.pulsar.source.split.PulsarPartitionSplit does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.pulsar.source.PulsarSource.getEnumeratorCheckpointSerializer(): Returned leaf type org.apache.flink.connector.pulsar.source.enumerator.PulsarSourceEnumState does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.connector.pulsar.source.PulsarSource.getEnumeratorCheckpointSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.pulsar.source.PulsarSource.getSplitSerializer(): Returned leaf type org.apache.flink.connector.pulsar.source.split.PulsarPartitionSplit does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.connector.pulsar.source.PulsarSource.getSplitSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.pulsar.source.PulsarSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext, org.apache.flink.connector.pulsar.source.enumerator.PulsarSourceEnumState): Argument leaf type org.apache.flink.connector.pulsar.source.enumerator.PulsarSourceEnumState does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.pulsar.source.PulsarSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext, org.apache.flink.connector.pulsar.source.enumerator.PulsarSourceEnumState): Argument leaf type org.apache.flink.connector.pulsar.source.split.PulsarPartitionSplit does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.pulsar.source.PulsarSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext, org.apache.flink.connector.pulsar.source.enumerator.PulsarSourceEnumState): Returned leaf type org.apache.flink.connector.pulsar.source.enumerator.PulsarSourceEnumState does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.pulsar.source.PulsarSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext, org.apache.flink.connector.pulsar.source.enumerator.PulsarSourceEnumState): Returned leaf type org.apache.flink.connector.pulsar.source.split.PulsarPartitionSplit does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.connector.pulsar.source.enumerator.cursor.StopCursor.open(org.apache.pulsar.client.admin.PulsarAdmin, org.apache.flink.connector.pulsar.source.enumerator.topic.TopicPartition): Argument leaf type org.apache.flink.connector.pulsar.source.enumerator.topic.TopicPartition does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.connectors.hive.HiveSource.getEnumeratorCheckpointSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.connectors.hive.HiveSource.getSplitSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.core.fs.EntropyInjector.createEntropyAware(org.apache.flink.core.fs.FileSystem, org.apache.flink.core.fs.Path, org.apache.flink.core.fs.FileSystem$WriteMode): Argument leaf type org.apache.flink.core.fs.FileSystem$WriteMode does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.core.fs.EntropyInjector.createEntropyAware(org.apache.flink.core.fs.FileSystem, org.apache.flink.core.fs.Path, org.apache.flink.core.fs.FileSystem$WriteMode): Returned leaf type org.apache.flink.core.fs.OutputStreamAndPath does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.core.fs.RecoverableFsDataOutputStream.closeForCommit(): Returned leaf type org.apache.flink.core.fs.RecoverableFsDataOutputStream$Committer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.core.fs.RecoverableFsDataOutputStream.persist(): Returned leaf type org.apache.flink.core.fs.RecoverableWriter$ResumeRecoverable does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.core.fs.RecoverableWriter.cleanupRecoverableState(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 annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.core.fs.RecoverableWriter.getCommitRecoverableSerializer(): Returned leaf type org.apache.flink.core.fs.RecoverableWriter$CommitRecoverable does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.core.fs.RecoverableWriter.getCommitRecoverableSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.core.fs.RecoverableWriter.getResumeRecoverableSerializer(): Returned leaf type org.apache.flink.core.fs.RecoverableWriter$ResumeRecoverable does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.core.fs.RecoverableWriter.getResumeRecoverableSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated 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 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 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 annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.core.io.SimpleVersionedSerialization.readVersionAndDeSerialize(org.apache.flink.core.io.SimpleVersionedSerializer, [B): Argument leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.core.io.SimpleVersionedSerialization.readVersionAndDeSerialize(org.apache.flink.core.io.SimpleVersionedSerializer, org.apache.flink.core.memory.DataInputView): Argument leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.core.io.SimpleVersionedSerialization.readVersionAndDeserializeList(org.apache.flink.core.io.SimpleVersionedSerializer, org.apache.flink.core.memory.DataInputView): Argument leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.core.io.SimpleVersionedSerialization.writeVersionAndSerialize(org.apache.flink.core.io.SimpleVersionedSerializer, java.lang.Object): Argument leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.core.io.SimpleVersionedSerialization.writeVersionAndSerialize(org.apache.flink.core.io.SimpleVersionedSerializer, java.lang.Object, org.apache.flink.core.memory.DataOutputView): Argument leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.core.io.SimpleVersionedSerialization.writeVersionAndSerializeList(org.apache.flink.core.io.SimpleVersionedSerializer, java.util.List, org.apache.flink.core.memory.DataOutputView): Argument leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' 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 [...] @@ -287,15 +262,12 @@ org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction.onTimer(long, org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction.processElement1(java.lang.Object, org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction$Context, org.apache.flink.util.Collector): Argument leaf type org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction$Context does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction.processElement2(java.lang.Object, org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction$Context, org.apache.flink.util.Collector): Argument leaf type org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction$Context does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.streaming.api.functions.co.ProcessJoinFunction.processElement(java.lang.Object, java.lang.Object, org.apache.flink.streaming.api.functions.co.ProcessJoinFunction$Context, org.apache.flink.util.Collector): Argument leaf type org.apache.flink.streaming.api.functions.co.ProcessJoinFunction$Context does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner.getSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig$OutputFileConfigBuilder.build(): Returned leaf type org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink$BulkFormatBuilder.withOutputFileConfig(org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig): Argument leaf type org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink$RowFormatBuilder.withOutputFileConfig(org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig): Argument leaf type org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.forBulkFormat(org.apache.flink.core.fs.Path, org.apache.flink.api.common.serialization.BulkWriter$Factory): Argument leaf type org.apache.flink.api.common.serialization.BulkWriter$Factory does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.forBulkFormat(org.apache.flink.core.fs.Path, org.apache.flink.api.common.serialization.BulkWriter$Factory): Returned leaf type org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink$DefaultBulkFormatBuilder does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.forRowFormat(org.apache.flink.core.fs.Path, org.apache.flink.api.common.serialization.Encoder): Returned leaf type org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink$DefaultRowFormatBuilder does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.streaming.api.functions.sink.filesystem.bucketassigners.BasePathBucketAssigner.getSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated -org.apache.flink.streaming.api.functions.sink.filesystem.bucketassigners.DateTimeBucketAssigner.getSerializer(): Returned leaf type org.apache.flink.core.io.SimpleVersionedSerializer does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor.withViolationHandler(org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor$MonotonyViolationHandler): Argument leaf type org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor$MonotonyViolationHandler does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.streaming.api.functions.windowing.ProcessAllWindowFunction.clear(org.apache.flink.streaming.api.functions.windowing.ProcessAllWindowFunction$Context): Argument leaf type org.apache.flink.streaming.api.functions.windowing.ProcessAllWindowFunction$Context does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated org.apache.flink.streaming.api.functions.windowing.ProcessAllWindowFunction.process(org.apache.flink.streaming.api.functions.windowing.ProcessAllWindowFunction$Context, java.lang.Iterable, org.apache.flink.util.Collector): Argument leaf type org.apache.flink.streaming.api.functions.windowing.ProcessAllWindowFunction$Context does not satisfy: reside outside of package 'org.apache.flink..' or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated diff --git a/flink-core/src/main/java/org/apache/flink/core/io/SimpleVersionedSerializer.java b/flink-core/src/main/java/org/apache/flink/core/io/SimpleVersionedSerializer.java index 9914897..80f8cf4 100644 --- a/flink-core/src/main/java/org/apache/flink/core/io/SimpleVersionedSerializer.java +++ b/flink-core/src/main/java/org/apache/flink/core/io/SimpleVersionedSerializer.java @@ -18,7 +18,7 @@ package org.apache.flink.core.io; -import org.apache.flink.annotation.Internal; +import org.apache.flink.annotation.PublicEvolving; import java.io.IOException; @@ -46,7 +46,7 @@ import java.io.IOException; * * @param <E> The data type serialized / deserialized by this serializer. */ -@Internal +@PublicEvolving public interface SimpleVersionedSerializer<E> extends Versioned { /**
