Deprecated List (Flink : 1.19-SNAPSHOT API)

Deprecated Interfaces
Interface and Description
org.apache.flink.table.sinks.AppendStreamTableSink This interface has been replaced by `DynamicTableSink`. The new interface consumes internal data structures. See FLIP-95 for more information.
org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks
org.apache.flink.streaming.api.functions.AssignerWithPunctuatedWatermarks
org.apache.flink.table.connector.source.AsyncTableFunctionProvider Please use `AsyncLookupFunctionProvider` to implement asynchronous lookup table.
org.apache.flink.table.catalog.CatalogLock This interface will be removed soon. Please see FLIP-346 for more details.
org.apache.flink.table.catalog.CatalogLock.Factory This interface will be removed soon. Please see FLIP-346 for more details.
org.apache.flink.runtime.state.CheckpointListener This interface has been moved to `CheckpointListener`. This class is kept to maintain backwards compatibility and will be removed in future releases.
org.apache.flink.api.connector.sink.Committer Please use `Committer`.
org.apache.flink.table.api.constraints.Constraint See `ResolvedSchema` and `Constraint`.
org.apache.flink.api.java.operators.CustomUnaryOperation All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.table.sources.DefinedFieldMapping This interface will not be supported in the new source design around `DynamicTableSource`. See FLIP-95 for more information.
org.apache.flink.table.sources.DefinedProctimeAttribute This interface will not be supported in the new source design around `DynamicTableSource`. Use the concept of computed columns instead. See FLIP-95 for more information.
org.apache.flink.table.sources.DefinedRowtimeAttributes This interface will not be supported in the new source design around `DynamicTableSource`. Use the concept of computed columns instead. See FLIP-95 for more information.
org.apache.flink.table.descriptors.Descriptor `Descriptor` was primarily used for the legacy connector stack and have been deprecated. Use `TableDescriptor` for creating sources and sinks from the Table API.
org.apache.flink.table.descriptors.DescriptorValidator See `Descriptor` for details.
org.apache.flink.streaming.util.serialization.DeserializationSchema Use `DeserializationSchema` instead.
org.apache.flink.api.java.ExecutionEnvironmentFactory All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.streaming.api.checkpoint.ExternallyInducedSource This interface is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.table.sources.FieldComputer This interface will not be supported in the new source design around `DynamicTableSource`. Use the concept of computed columns instead. See FLIP-95 for more information.
org.apache.flink.connector.file.src.reader.FileRecordFormat Please use `StreamFormat` instead. The main motivation for removing it is the inherent design flaw in the batching of FileRecordFormat: StreamFormat can guarantee that only a certain amount of memory is being used (unless a single record exceeds that already), but FileRecordFormat can only batch by the number of records. By removing FileRecordFormat, we relay the responsibility of implementing the batching to the format developer; they need to use BulkFormat and find a better way than batch by number of records.
org.apache.flink.table.sources.FilterableTableSource This interface will not be supported in the new source design around `DynamicTableSource`. Use `SupportsFilterPushDown` instead. See FLIP-95 for more information.
org.apache.flink.api.connector.sink.GlobalCommitter Please use `WithPostCommitTopology` with `StandardSinkTopologies#addGlobalCommitter`.
org.apache.flink.api.java.operators.join.JoinFunctionAssigner All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.types.Key The Key type is a relict of a deprecated and removed API and will be removed in future (2.0) versions as well.
org.apache.flink.table.sources.LimitableTableSource This interface will not be supported in the new source design around `DynamicTableSource`. Use `SupportsLimitPushDown` instead. See FLIP-95 for more information.
org.apache.flink.streaming.api.checkpoint.ListCheckpointed If you need to do non-keyed state snapshots of your operator, use `CheckpointedFunction`. This should only be needed in rare cases, though.
org.apache.flink.table.sources.LookupableTableSource This interface will not be supported in the new source design around `DynamicTableSource`. Use `LookupTableSource` instead. See FLIP-95 for more information.
org.apache.flink.table.factories.ManagedTableFactory This interface will be removed soon. Please see FLIP-346 for more details.
org.apache.flink.table.sources.NestedFieldsProjectableTableSource This interface will not be supported in the new source design around `DynamicTableSource`. Use `SupportsProjectionPushDown` instead. See FLIP-95 for more information.
org.apache.flink.table.sinks.OverwritableTableSink This interface will not be supported in the new sink design around `DynamicTableSink`. Use `SupportsOverwrite` instead. See FLIP-95 for more information.
org.apache.flink.streaming.api.functions.source.ParallelSourceFunction This interface is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.table.sinks.PartitionableTableSink This interface will not be supported in the new sink design around `DynamicTableSink`. Use `SupportsPartitioning` instead. See FLIP-95 for more information.
org.apache.flink.table.sources.PartitionableTableSource This interface will not be supported in the new source design around `DynamicTableSource`. Use `SupportsPartitionPushDown` instead. See FLIP-95 for more information.
org.apache.flink.table.sources.ProjectableTableSource This interface will not be supported in the new source design around `DynamicTableSource`. Use `SupportsProjectionPushDown` instead. See FLIP-95 for more information.
org.apache.flink.table.connector.RequireCatalogLock This interface will be removed soon. Please see FLIP-346 for more details.
org.apache.flink.table.sinks.RetractStreamTableSink This interface has been replaced by `DynamicTableSink`. The new interface consumes internal data structures. See FLIP-95 for more information.
org.apache.flink.streaming.util.serialization.SerializationSchema Use `SerializationSchema` instead.
org.apache.flink.streaming.api.operators.SetupableStreamOperator This class is deprecated in favour of using `StreamOperatorFactory` and it's `StreamOperatorFactory.createStreamOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<OUT>)` and passing the required parameters to the Operator's constructor in create method.
org.apache.flink.api.connector.sink.Sink Please use `Sink` or a derivative.
org.apache.flink.api.connector.sink2.Sink.InitContext
org.apache.flink.api.connector.sink.Sink.InitContext Please migrate to `Sink` and use `Sink.InitContext`.
org.apache.flink.api.connector.sink.Sink.ProcessingTimeService Please migrate to `Sink` and use `ProcessingTimeService`.
org.apache.flink.api.connector.sink.Sink.ProcessingTimeService.ProcessingTimeCallback Please migrate to `Sink` and use `ProcessingTimeService.ProcessingTimeCallback`.
org.apache.flink.table.connector.sink.SinkProvider Please convert your sink to `Sink` and use `SinkV2Provider`.
org.apache.flink.api.connector.sink.SinkWriter Please use `SinkWriter` or a derivative.
org.apache.flink.api.connector.sink.SinkWriter.Context Please migrate to `SinkWriter` and use `SinkWriter.Context`.
org.apache.flink.streaming.api.functions.source.SourceFunction This interface will be removed in future versions. Use the new `Source` interface instead. NOTE: All sub-tasks from FLINK-28045 must be closed before this API can be completely removed.
org.apache.flink.table.connector.source.SourceFunctionProvider This interface is based on the `SourceFunction` API, which is due to be removed. Use `SourceProvider` instead.
org.apache.flink.api.connector.sink2.StatefulSink Please implement `Sink` and `SupportsWriterState` instead.
org.apache.flink.table.sinks.StreamTableSink This interface has been replaced by `DynamicTableSink`. The new interface consumes internal data structures. See FLIP-95 for more information.
org.apache.flink.table.factories.StreamTableSinkFactory This interface has been replaced by `DynamicTableSinkFactory`. The new interface creates instances of `DynamicTableSink`. See FLIP-95 for more information.
org.apache.flink.table.sources.StreamTableSource This interface has been replaced by `DynamicTableSource`. The new interface produces internal data structures. See FLIP-95 for more information.
org.apache.flink.table.factories.StreamTableSourceFactory This interface has been replaced by `DynamicTableSourceFactory`. The new interface creates instances of `DynamicTableSource`. See FLIP-95 for more information.
org.apache.flink.table.factories.TableFactory This interface has been replaced by `Factory`.
org.apache.flink.table.connector.source.TableFunctionProvider Please use `LookupFunctionProvider` to implement synchronous lookup table.
org.apache.flink.table.sinks.TableSink This interface has been replaced by `DynamicTableSink`. The new interface consumes internal data structures. See FLIP-95 for more information.
org.apache.flink.table.factories.TableSinkFactory This interface has been replaced by `DynamicTableSinkFactory`. The new interface consumes internal data structures. See FLIP-95 for more information.
org.apache.flink.table.sources.TableSource This interface has been replaced by `DynamicTableSource`. The new interface produces internal data structures. See FLIP-95 for more information.
org.apache.flink.table.factories.TableSourceFactory This interface has been replaced by `DynamicTableSourceFactory`. The new interface produces internal data structures. See FLIP-95 for more information.
org.apache.flink.streaming.api.functions.TimestampAssigner use `TimestampAssigner`
org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink Please implement `Sink` `SupportsCommitter` instead.
org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink.PrecommittingSinkWriter
org.apache.flink.api.java.operators.UdfOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.table.sinks.UpsertStreamTableSink This interface has been replaced by `DynamicTableSink`. The new interface consumes internal data structures. See FLIP-95 for more information.
org.apache.flink.table.runtime.groupwindow.WindowProperty The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they also used to configure Python operators.
org.apache.flink.streaming.api.connector.sink2.WithPostCommitTopology Please implement `Sink`, `SupportsCommitter` and `SupportsPostCommitTopology` instead.
org.apache.flink.streaming.api.connector.sink2.WithPreCommitTopology Please implement `Sink`, `SupportsCommitter` and `SupportsPreCommitTopology` instead.
org.apache.flink.streaming.api.connector.sink2.WithPreWriteTopology Please implement `Sink` and `SupportsPreWriteTopology` instead.

Deprecated Classes
Class and Description
org.apache.flink.streaming.util.serialization.AbstractDeserializationSchema Use `AbstractDeserializationSchema` instead.
org.apache.flink.runtime.state.filesystem.AbstractFileStateBackend State backends should no longer implement `CheckpointStorage` functionality. Please inherit `AbstractStateBackend` instead. Custom checkpoint storage can be additionally implemented as a separate class.
org.apache.flink.client.deployment.executors.AbstractJobClusterExecutor
org.apache.flink.table.runtime.groupwindow.AbstractWindowProperty The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they also used to configure Python operators.
org.apache.flink.table.functions.AggregateFunctionDefinition Non-legacy functions can simply omit this wrapper for declarations.
org.apache.flink.api.java.operators.AggregateOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.configuration.AkkaOptions Use `RpcOptions` instead.
org.apache.flink.table.operations.ddl.AlterTableOptionsOperation Please use `AlterTableChangeOperation` instead.
org.apache.flink.cep.pattern.conditions.AndCondition Please use `RichAndCondition` instead. This class exists just for backwards compatibility and will be removed in FLINK-10113.
org.apache.flink.table.runtime.arrow.sources.ArrowSourceFunction This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.streaming.api.functions.AscendingTimestampExtractor Extend `AscendingTimestampExtractor` instead.
org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor
org.apache.flink.formats.avro.AvroRowDeserializationSchema The format was developed for the Table API users and will not be maintained for DataStream API users anymore. Either use Table API or switch to Data Stream, defining your own `DeserializationSchema`.
org.apache.flink.formats.avro.AvroRowSerializationSchema The format was developed for the Table API users and will not be maintained for DataStream API users anymore. Either use Table API or switch to Data Stream, defining your own `SerializationSchema`.
org.apache.flink.formats.avro.typeutils.AvroSerializer.AvroSchemaSerializerConfigSnapshot
org.apache.flink.api.java.summarize.BooleanColumnSummary All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.state.api.BootstrapTransformation Use `StateBootstrapTransformation` instead.
org.apache.flink.state.api.runtime.BootstrapTransformationWithID
org.apache.flink.state.api.output.BoundedOneInputStreamTaskRunner
org.apache.flink.table.catalog.CatalogTableImpl Use `CatalogTable.of(Schema, String, List, Map)` or a custom implementation instead. Don't implement against this internal class. It can lead to unintended side effects if code checks against this class instead of the common interface.
org.apache.flink.table.catalog.CatalogViewImpl Use `CatalogView.of(Schema, String, String, String, Map)` or a custom implementation instead. Don't implement against this internal class. It can lead to unintended side effects if code checks against this class instead of the common interface.
org.apache.flink.api.java.operators.CoGroupOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.CollectionEnvironment All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.io.CollectionInputFormat All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.summarize.ColumnSummary All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.table.descriptors.ConnectorDescriptorValidator
org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.api.java.operators.CrossOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.table.sinks.CsvAppendTableSinkFactory The legacy CSV connector has been replaced by `FileSink`. It is kept only to support tests for the legacy connector stack.
org.apache.flink.table.sources.CsvAppendTableSourceFactory The legacy CSV connector has been replaced by `FileSource`. It is kept only to support tests for the legacy connector stack.
org.apache.flink.table.sinks.CsvBatchTableSinkFactory The legacy CSV connector has been replaced by `FileSink`. It is kept only to support tests for the legacy connector stack.
org.apache.flink.table.sources.CsvBatchTableSourceFactory The legacy CSV connector has been replaced by `FileSource`. It is kept only to support tests for the legacy connector stack.
org.apache.flink.api.java.io.CsvOutputFormat All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.io.CsvReader All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.formats.csv.CsvRowDeserializationSchema The format was developed for the Table API users and will not be maintained for DataStream API users anymore. Either use Table API or switch to Data Stream, defining your own `DeserializationSchema`.
org.apache.flink.formats.csv.CsvRowSerializationSchema The format was developed for the Table API users and will not be maintained for DataStream API users anymore. Either use Table API or switch to Data Stream, defining your own `SerializationSchema`.
org.apache.flink.table.sinks.CsvTableSink The legacy CSV connector has been replaced by `FileSink`. It is kept only to support tests for the legacy connector stack.
org.apache.flink.table.sinks.CsvTableSinkFactoryBase The legacy CSV connector has been replaced by `FileSink`. It is kept only to support tests for the legacy connector stack.
org.apache.flink.table.sources.CsvTableSource The legacy CSV connector has been replaced by `FileSource`. It is kept only to support tests for the legacy connector stack.
org.apache.flink.table.sources.CsvTableSourceFactoryBase The legacy CSV connector has been replaced by `FileSource`. It is kept only to support tests for the legacy connector stack.
org.apache.flink.streaming.api.functions.source.datagen.DataGeneratorSource Use `org.apache.flink.connector.datagen.source.DataGeneratorSource` instead.
org.apache.flink.api.java.DataSet All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.utils.DataSetUtils All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.operators.DataSink All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.operators.DataSource All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.table.operations.DataStreamQueryOperation
org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory
org.apache.flink.streaming.util.typeutils.DefaultScalaProductFieldAccessorFactory All Flink Scala APIs are deprecated and will be removed in a future Flink major version. You can still build your application in Scala, but you should move to the Java version of either the DataStream and/or Table API.
org.apache.flink.api.java.operators.DeltaIteration All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.operators.DeltaIterationResultSet All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.table.descriptors.DescriptorProperties This utility will be dropped soon. `DynamicTableFactory` is based on `ConfigOption` and catalogs use `CatalogPropertiesUtil`.
org.apache.flink.api.java.io.DiscardingOutputFormat All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.operators.DistinctOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.typeutils.runtime.EitherSerializerSnapshot this snapshot class is no longer used by any serializers. Instead, `JavaEitherSerializerSnapshot` is used.
org.apache.flink.state.api.EvictingWindowReader
org.apache.flink.api.common.ExecutionConfig.SerializableSerializer The class is deprecated because instance-type serializer definition where serializers are serialized and written into the snapshot and deserialized for use is deprecated. Use class-type serializer definition instead, where only the class name is written into the snapshot and new instance of the serializer is created for use. This is a breaking change, and it will be removed in Flink 2.0.
org.apache.flink.api.java.ExecutionEnvironment All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.table.sources.tsextractors.ExistingField This class will not be supported in the new source design around `DynamicTableSource`. See FLIP-95 for more information.
org.apache.flink.state.api.ExistingSavepoint For creating a new savepoint, use `SavepointWriter` and the data stream api under batch execution. For reading a savepoint, use `SavepointReader` and the data stream api under batch execution.
org.apache.flink.streaming.api.functions.source.FileMonitoringFunction Internal class deprecated in favour of `ContinuousFileMonitoringFunction`.
org.apache.flink.streaming.api.functions.source.FileReadFunction Internal class deprecated in favour of `ContinuousFileMonitoringFunction`.
org.apache.flink.connector.file.src.impl.FileRecordFormatAdapter Please use `StreamFormatAdapter` instead.
org.apache.flink.connector.file.sink.FileSinkProgram.Generator This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.table.descriptors.FileSystemValidator The legacy CSV connector has been replaced by `FileSource` / `FileSink`. It is kept only to support tests for the legacy connector stack.
org.apache.flink.api.java.operators.FilterOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.streaming.util.FiniteTestSource This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.api.java.functions.FlatMapIterator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.operators.FlatMapOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.core.testutils.FlinkMatchers You should assertj assertions, which have built-in assertions for `CompletableFuture`. To check chains of `Throwable` causes, use `FlinkAssertions.anyCauseMatches(String)` or `FlinkAssertions.anyCauseMatches(Class, String)`
org.apache.flink.streaming.api.functions.source.FromElementsFunction This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.streaming.api.functions.source.FromIteratorFunction This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.streaming.api.functions.source.FromSplittableIteratorFunction This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.runtime.state.filesystem.FsStateBackend
org.apache.flink.api.java.functions.FunctionAnnotation All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.common.typeutils.base.GenericArraySerializerConfigSnapshot this is deprecated and no longer used by the `GenericArraySerializer`. It has been replaced by `GenericArraySerializerSnapshot`.
org.apache.flink.api.java.operators.GroupCombineOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.operators.Grouping All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.functions.GroupReduceIterator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.operators.GroupReduceOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.state.api.output.partitioner.HashSelector
org.apache.flink.connectors.hive.read.HiveBulkFormatAdapter Please use `HiveInputFormat`.
org.apache.flink.table.catalog.hive.HiveCatalogLock This class will be removed soon. Please see FLIP-346 for more details.
org.apache.flink.streaming.api.functions.IngestionTimeExtractor
org.apache.flink.streaming.api.functions.source.InputFormatSourceFunction This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.table.sources.InputFormatTableSource This interface has been replaced by `DynamicTableSource`. The new interface produces internal data structures. See FLIP-95 for more information.
org.apache.flink.table.planner.operations.InternalDataStreamQueryOperation
org.apache.flink.api.java.operators.IterativeDataSet All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.streaming.api.datastream.IterativeStream This method is deprecated since Flink 1.19. The only known use case of this Iteration API comes from Flink ML, which already has its own implementation of iteration and no longer uses this API. If there's any use cases other than Flink ML that needs iteration support, please reach out to dev@flink.apache.org and we can consider making the Flink ML iteration implementation a separate common library.
org.apache.flink.streaming.api.datastream.IterativeStream.ConnectedIterativeStreams This method is deprecated since Flink 1.19. The only known use case of this Iteration API comes from Flink ML, which already has its own implementation of iteration and no longer uses this API. If there's any use cases other than Flink ML that needs iteration support, please reach out to dev@flink.apache.org and we can consider making the Flink ML iteration implementation a separate common library.
org.apache.flink.api.java.io.IteratorInputFormat All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.runtime.entrypoint.JobClusterEntrypoint Per-job mode has been deprecated in Flink 1.15 and will be removed in the future. Please use application mode instead.
org.apache.flink.runtime.rest.messages.JobExceptionsInfo.ExecutionExceptionInfo `ExecutionExceptionInfo` will be replaced by `JobExceptionsInfoWithHistory.ExceptionInfo` as part of the effort of deprecating `JobExceptionsInfo.allExceptions`.
org.apache.flink.runtime.rest.handler.job.metrics.JobVertexMetricsHandler This class is subsumed by `SubtaskMetricsHandler` and is only kept for backwards-compatibility.
org.apache.flink.api.java.operators.JoinOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.operators.join.JoinOperatorSetsBase All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.formats.json.JsonNodeDeserializationSchema Use `new JsonDeserializationSchema(ObjectNode.class)` instead
org.apache.flink.formats.json.JsonRowDeserializationSchema The format was developed for the Table API users and will not be maintained for DataStream API users anymore. Either use Table API or switch to Data Stream, defining your own `DeserializationSchema`.
org.apache.flink.formats.json.JsonRowSerializationSchema The format was developed for the Table API users and will not be maintained for DataStream API users anymore. Either use Table API or switch to Data Stream, defining your own `SerializationSchema`.
org.apache.flink.state.api.KeyedOperatorTransformation
org.apache.flink.state.api.output.partitioner.KeyGroupRangePartitioner
org.apache.flink.streaming.api.operators.co.LegacyKeyedCoProcessOperator Replaced by `KeyedCoProcessOperator` which takes `KeyedCoProcessFunction`
org.apache.flink.streaming.api.operators.LegacyKeyedProcessOperator Replaced by `KeyedProcessOperator` which takes `KeyedProcessFunction`
org.apache.flink.table.types.utils.LegacyTypeInfoDataTypeConverter Use `DataTypeFactory.createDataType(TypeInformation)` instead. Note that this method will not create legacy types anymore. It fully uses the new type system available only in the planner.
org.apache.flink.table.functions.LegacyUserDefinedFunctionInference
org.apache.flink.table.dataview.ListViewSerializer
org.apache.flink.table.dataview.ListViewSerializerSnapshot
org.apache.flink.table.dataview.ListViewTypeInfo
org.apache.flink.table.dataview.ListViewTypeInfoFactory
org.apache.flink.api.java.io.LocalCollectionOutputFormat All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.LocalEnvironment All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.table.runtime.types.LogicalTypeDataTypeConverter
org.apache.flink.table.catalog.ManagedTableListener This interface will be removed soon. Please see FLIP-346 for more details.
org.apache.flink.api.java.operators.MapOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.operators.MapPartitionOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.table.dataview.MapViewSerializer
org.apache.flink.table.dataview.MapViewSerializerSnapshot
org.apache.flink.table.dataview.MapViewTypeInfo
org.apache.flink.table.dataview.MapViewTypeInfoFactory
org.apache.flink.runtime.state.memory.MemoryStateBackend
org.apache.flink.streaming.api.functions.source.MessageAcknowledgingSourceBase This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.streaming.api.functions.source.MultipleIdsMessageAcknowledgingSourceBase This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.table.runtime.groupwindow.NamedWindowProperty The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they also used to configure Python operators.
org.apache.flink.state.api.NewSavepoint For creating a new savepoint, use `SavepointWriter` and the data stream api under batch execution.
org.apache.flink.cep.nfa.NFA.NFASerializer
org.apache.flink.cep.pattern.conditions.NotCondition Please use `RichNotCondition` instead. This class exists just for backwards compatibility and will be removed in FLINK-10113.
org.apache.flink.table.dataview.NullAwareMapSerializer
org.apache.flink.table.dataview.NullAwareMapSerializerSnapshot
org.apache.flink.api.java.summarize.NumericColumnSummary All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.summarize.ObjectColumnSummary All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.table.descriptors.OldCsvValidator Use the RFC-compliant `Csv` format in the dedicated flink-formats/flink-csv module instead.
org.apache.flink.state.api.OneInputOperatorTransformation Use `OneInputStateTransformation` instead.
org.apache.flink.api.java.operators.Operator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.orc.OrcColumnarRowFileInputFormat Please use `OrcColumnarRowInputFormat`.
org.apache.flink.cep.pattern.conditions.OrCondition Please use `RichOrCondition` instead. This class exists just for backwards compatibility and will be removed in FLINK-10113.
org.apache.flink.streaming.api.functions.sink.OutputFormatSinkFunction Please use the `StreamingFileSink` for writing to files from a streaming program.
org.apache.flink.table.sinks.OutputFormatTableSink This interface has been replaced by `DynamicTableSink`. The new interface consumes internal data structures. See FLIP-95 for more information.
org.apache.flink.api.java.io.ParallelIteratorInputFormat All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.formats.parquet.avro.ParquetAvroWriters use `AvroParquetWriters` instead.
org.apache.flink.api.java.operators.PartitionOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.streaming.tests.PeriodicStreamingJob.PeriodicSourceGenerator This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.api.java.io.PrimitiveInputFormat All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.io.PrintingOutputFormat All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.table.runtime.groupwindow.ProctimeAttribute The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they also used to configure Python operators.
org.apache.flink.runtime.webmonitor.handlers.ProgramArgsQueryParameter please, use `JarRequestBody.FIELD_NAME_PROGRAM_ARGUMENTS_LIST`
org.apache.flink.api.java.operators.ProjectOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.queryablestate.client.QueryableStateClient The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.
org.apache.flink.configuration.QueryableStateOptions The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.
org.apache.flink.streaming.api.datastream.QueryableStateStream The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.
org.apache.flink.api.java.operators.ReduceOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.RemoteEnvironment All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.common.restartstrategy.RestartStrategies The `RestartStrategies` class is marked as deprecated because starting from Flink 1.19, all complex Java objects related to configuration should be replaced by ConfigOption. In a future major version of Flink, this class will be removed entirely. It is recommended to switch to using the ConfigOptions provided by `RestartStrategyOptions` for configuring restart strategies like the following code snippet: `Configuration config = new Configuration(); config.set(RestartStrategyOptions.RESTART_STRATEGY, "fixed-delay"); config.set(RestartStrategyOptions.RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS, 3); config.set(RestartStrategyOptions.RESTART_STRATEGY_FIXED_DELAY_DELAY, Duration.ofMinutes(1)); StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(config);` For more details on using ConfigOption for restart strategies, please refer to the Flink documentation: restart-strategies
org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.streaming.api.functions.windowing.RichProcessAllWindowFunction use `ProcessAllWindowFunction` instead
org.apache.flink.streaming.api.functions.windowing.RichProcessWindowFunction use `ProcessWindowFunction` instead
org.apache.flink.streaming.api.functions.source.RichSourceFunction This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.contrib.streaming.state.RocksDBStateBackend
org.apache.flink.api.java.io.RowCsvInputFormat All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.table.descriptors.Rowtime This class was used for legacy connectors using `Descriptor`.
org.apache.flink.table.runtime.groupwindow.RowtimeAttribute The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they also used to configure Python operators.
org.apache.flink.table.sources.RowtimeAttributeDescriptor This interface will not be supported in the new source design around `DynamicTableSource`. Use the concept of computed columns instead. See FLIP-95 for more information.
org.apache.flink.table.descriptors.RowtimeValidator See `Rowtime` for details.
org.apache.flink.state.api.Savepoint For creating a new savepoint, use `SavepointWriter` and the data stream api under batch execution. For reading a savepoint, use `SavepointReader` and the data stream api under batch execution.
org.apache.flink.state.api.runtime.metadata.SavepointMetadata
org.apache.flink.api.scala.operators.ScalaAggregateOperator All Flink Scala APIs are deprecated and will be removed in a future Flink major version. You can still build your application in Scala, but you should move to the Java version of either the DataStream and/or Table API.
org.apache.flink.api.scala.operators.ScalaCsvOutputFormat All Flink Scala APIs are deprecated and will be removed in a future Flink major version. You can still build your application in Scala, but you should move to the Java version of either the DataStream and/or Table API.
org.apache.flink.table.functions.ScalarFunctionDefinition Non-legacy functions can simply omit this wrapper for declarations.
org.apache.flink.table.descriptors.Schema This class was used for legacy connectors using `Descriptor`.
org.apache.flink.table.descriptors.SchemaValidator See `Schema` for details.
org.apache.flink.streaming.tests.SequenceGeneratorSource This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.cep.nfa.SharedBuffer everything in this class is deprecated. Those are only migration procedures from older versions.
org.apache.flink.cep.nfa.sharedbuffer.SharedBufferNode.SharedBufferNodeSerializer was used in <= 1.12, use `SharedBufferNodeSerializer` instead.
org.apache.flink.streaming.util.serialization.SimpleStringSchema Use `SimpleStringSchema` instead.
org.apache.flink.api.java.operators.SingleInputOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.operators.SingleInputUdfOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.connector.sink2.Sink.InitContextWrapper Internal, do not use it.
org.apache.flink.table.runtime.groupwindow.SliceEnd The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they also used to configure Python operators.
org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.api.java.operators.SortedGrouping All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.operators.SortPartitionOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.streaming.runtime.tasks.SourceStreamTask This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.api.java.io.SplitDataProperties All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.streaming.api.functions.source.StatefulSequenceSource This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.test.StatefulStreamingJob.MySource This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink Use `FileSink` instead.
org.apache.flink.table.sources.tsextractors.StreamRecordTimestamp This class will not be supported in the new source design around `DynamicTableSource`. See FLIP-95 for more information.
org.apache.flink.streaming.api.operators.StreamSource This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.streaming.api.operators.StreamSourceContexts This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.sql.tests.StreamSQLTestProgram.Generator This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor.SynchronizedStreamTaskActionExecutor this class should only be used in `SourceStreamTask` which exposes the checkpoint lock as part of Public API.
org.apache.flink.api.java.summarize.StringColumnSummary All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.runtime.checkpoint.SubtaskState Internal class for savepoint backwards compatibility. Don't use for other purposes.
org.apache.flink.table.functions.TableAggregateFunctionDefinition Non-legacy functions can simply omit this wrapper for declarations.
org.apache.flink.table.api.TableColumn See `ResolvedSchema` and `Column`.
org.apache.flink.table.factories.TableFactoryService
org.apache.flink.table.functions.TableFunctionDefinition Non-legacy functions can simply omit this wrapper for declarations.
org.apache.flink.table.api.TableSchema This class has been deprecated as part of FLIP-164. It has been replaced by two more dedicated classes `Schema` and `ResolvedSchema`. Use `Schema` for declaration in APIs. `ResolvedSchema` is offered by the framework after resolution and validation.
org.apache.flink.table.sinks.TableSinkBase This class is implementing the deprecated `TableSink` interface. Implement `DynamicTableSink` directly instead.
org.apache.flink.table.factories.TableSinkFactoryContextImpl
org.apache.flink.table.factories.TableSourceFactoryContextImpl
org.apache.flink.runtime.checkpoint.TaskState Internal class for savepoint backwards compatibility. Don't use for other purposes.
org.apache.flink.api.java.io.TextInputFormat All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.connector.file.src.reader.TextLineFormat Please use `TextLineInputFormat`.
org.apache.flink.api.java.io.TextOutputFormat All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.io.TextValueInputFormat All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.common.time.Time Use `Duration`
org.apache.flink.streaming.api.windowing.time.Time Use `Duration`
org.apache.flink.table.typeutils.TimeIndicatorTypeInfo This class will be removed in future versions as it is used for the old type system. It is recommended to use `DataTypes` instead. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.typeutils.TimeIntervalTypeInfo This class will be removed in future versions as it is used for the old type system. It is recommended to use `DataTypes` instead. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.state.api.output.TimestampAssignerWrapper
org.apache.flink.table.sources.tsextractors.TimestampExtractor This interface will not be supported in the new source design around `DynamicTableSource`. Use the concept of computed columns instead. See FLIP-95 for more information.
org.apache.flink.walkthrough.common.source.TransactionSource This class is based on the `SourceFunction` API, which is due to be removed. Use the new `Source` API instead.
org.apache.flink.api.java.operators.TwoInputOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.operators.TwoInputUdfOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.table.runtime.types.TypeInfoDataTypeConverter Use `InternalTypeInfo.of(LogicalType)` instead if `TypeInformation` is really required. In many cases, `InternalSerializers.create(LogicalType)` should be sufficient.
org.apache.flink.table.runtime.types.TypeInfoLogicalTypeConverter
org.apache.flink.table.types.logical.TypeInformationRawType Use `RawType` instead.
org.apache.flink.streaming.util.serialization.TypeInformationSerializationSchema Use `TypeInformationSerializationSchema` instead.
org.apache.flink.table.api.Types This class will be removed in future versions as it uses the old type system. It is recommended to use `DataTypes` instead which uses the new type system based on instances of `DataType`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.api.java.io.TypeSerializerInputFormat All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.java.io.TypeSerializerOutputFormat All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.table.utils.TypeStringUtils This utility is based on `TypeInformation`. However, the Table & SQL API is currently updated to use `DataType`s based on `LogicalType`s. Use `LogicalTypeParser` instead.
org.apache.flink.api.java.operators.UnionOperator All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.table.api.constraints.UniqueConstraint See `ResolvedSchema` and `UniqueConstraint`.
org.apache.flink.api.java.operators.UnsortedGrouping All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.table.api.WatermarkSpec See `ResolvedSchema` and `WatermarkSpec`.
org.apache.flink.table.runtime.groupwindow.WindowEnd The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they also used to configure Python operators.
org.apache.flink.state.api.WindowReader
org.apache.flink.table.runtime.groupwindow.WindowReference The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they are also used to configure Python operators.
org.apache.flink.table.runtime.groupwindow.WindowStart The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they also used to configure Python operators.
org.apache.flink.state.api.WritableSavepoint
org.apache.flink.streaming.api.functions.sink.WriteFormat Please use the `StreamingFileSink` for writing to files from a streaming program.
org.apache.flink.streaming.api.functions.sink.WriteFormatAsCsv Please use the `StreamingFileSink` for writing to files from a streaming program.
org.apache.flink.streaming.api.functions.sink.WriteFormatAsText Please use the `StreamingFileSink` for writing to files from a streaming program.
org.apache.flink.streaming.api.functions.sink.WriteSinkFunction Please use the `StreamingFileSink` for writing to files from a streaming program.
org.apache.flink.streaming.api.functions.sink.WriteSinkFunctionByMillis Please use the `StreamingFileSink` for writing to files from a streaming program.
org.apache.flink.runtime.rest.messages.YarnCancelJobTerminationHeaders This should be removed once we can send arbitrary REST calls via the Yarn proxy.
org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint Per-mode has been deprecated in Flink 1.15 and will be removed in the future. Please use application mode instead.
org.apache.flink.yarn.executors.YarnJobClusterExecutor
org.apache.flink.yarn.executors.YarnJobClusterExecutorFactory
org.apache.flink.runtime.rest.messages.YarnStopJobTerminationHeaders This should be removed once we can send arbitrary REST calls via the Yarn proxy.

Deprecated Enums
Enum and Description
org.apache.flink.api.java.aggregation.Aggregations All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.table.api.config.ExecutionConfigOptions.LegacyCastBehaviour
org.apache.flink.api.common.ExecutionMode The `ExecutionMode` is deprecated because it's only used in DataSet APIs. All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.common.InputDependencyConstraint `InputDependencyConstraint` is not used anymore and will be deleted in one of the future versions. It was previously used in the scheduler implementations that were removed as part of FLINK-20589.
org.apache.flink.api.java.operators.join.JoinType All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.contrib.streaming.state.RocksDBStateBackend.PriorityQueueStateType
org.apache.flink.streaming.api.TimeCharacteristic In Flink 1.12 the default stream time characteristic has been changed to `TimeCharacteristic.EventTime`, thus you don't need to call this method for enabling event-time support anymore. Explicitly using processing-time windows and timers works in event-time mode. If you need to disable watermarks, please use `ExecutionConfig.setAutoWatermarkInterval(long)`. If you are using `TimeCharacteristic.IngestionTime`, please manually set an appropriate `WatermarkStrategy`. If you are using generic "time window" operations (for example `KeyedStream.timeWindow(org.apache.flink.streaming.api.windowing.time.Time)` that change behaviour based on the time characteristic, please use equivalent operations that explicitly specify processing time or event time.

Deprecated Exceptions
Exceptions and Description
org.apache.flink.table.api.AmbiguousTableFactoryException This exception is considered internal and has been erroneously placed in the *.api package. It is replaced by `AmbiguousTableFactoryException` and should not be used directly anymore.
org.apache.flink.table.api.ExpressionParserException This exception is considered internal and has been erroneously placed in the *.api package. It is replaced by `ExpressionParserException` and should not be used directly anymore.
org.apache.flink.table.api.NoMatchingTableFactoryException This exception is considered internal and has been erroneously placed in the *.api package. It is replaced by `NoMatchingTableFactoryException` and should not be used directly anymore.
org.apache.flink.api.java.aggregation.UnsupportedAggregationTypeException All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.

Deprecated Annotation Types
Annotation Type and Description
org.apache.flink.metrics.reporter.InstantiateViaFactory Will be removed in a future version. Users should use all reporters as plugins.
org.apache.flink.metrics.reporter.InterceptInstantiationViaReflection Will be removed in a future version. Users should use all reporters as plugins.

Deprecated Fields
Field and Description
org.apache.flink.configuration.JobManagerOptions.ADAPTIVE_BATCH_SCHEDULER_AVG_DATA_VOLUME_PER_TASK Use `BatchExecutionOptions.ADAPTIVE_AUTO_PARALLELISM_AVG_DATA_VOLUME_PER_TASK`.
org.apache.flink.configuration.JobManagerOptions.ADAPTIVE_BATCH_SCHEDULER_DEFAULT_SOURCE_PARALLELISM Use `BatchExecutionOptions.ADAPTIVE_AUTO_PARALLELISM_DEFAULT_SOURCE_PARALLELISM`.
org.apache.flink.configuration.JobManagerOptions.ADAPTIVE_BATCH_SCHEDULER_MAX_PARALLELISM Use `BatchExecutionOptions.ADAPTIVE_AUTO_PARALLELISM_MAX_PARALLELISM`.
org.apache.flink.configuration.JobManagerOptions.ADAPTIVE_BATCH_SCHEDULER_MIN_PARALLELISM Use `BatchExecutionOptions.ADAPTIVE_AUTO_PARALLELISM_MIN_PARALLELISM`.
org.apache.flink.configuration.WebOptions.ADDRESS
org.apache.flink.configuration.ConfigConstants.AKKA_ASK_TIMEOUT Use `RpcOptions.ASK_TIMEOUT_DURATION` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_CLIENT_TIMEOUT Use `ClientOptions#CLIENT_TIMEOUT` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_DISPATCHER_THROUGHPUT Use `RpcOptions.DISPATCHER_THROUGHPUT` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_FRAMESIZE Use `RpcOptions.FRAMESIZE` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_JVM_EXIT_ON_FATAL_ERROR Use `RpcOptions.JVM_EXIT_ON_FATAL_ERROR` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_LOG_LIFECYCLE_EVENTS Use `RpcOptions.LOG_LIFECYCLE_EVENTS` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_LOOKUP_TIMEOUT Use `RpcOptions.LOOKUP_TIMEOUT_DURATION` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_SSL_ENABLED Use `RpcOptions.SSL_ENABLED` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_STARTUP_TIMEOUT Use `RpcOptions.STARTUP_TIMEOUT` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_TCP_TIMEOUT Use `RpcOptions.TCP_TIMEOUT` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_TRANSPORT_HEARTBEAT_INTERVAL Use `RpcOptions#TRANSPORT_HEARTBEAT_INTERVAL` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_TRANSPORT_HEARTBEAT_PAUSE Use `RpcOptions#TRANSPORT_HEARTBEAT_PAUSE` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_TRANSPORT_THRESHOLD Use `RpcOptions#TRANSPORT_THRESHOLD` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_WATCH_HEARTBEAT_INTERVAL This option is no longer used and has no effect on Flink.
org.apache.flink.configuration.ConfigConstants.AKKA_WATCH_HEARTBEAT_PAUSE This option is no longer used and has no effect on Flink.
org.apache.flink.configuration.ConfigConstants.AKKA_WATCH_THRESHOLD This option is no longer used and has no effect on Flink.
org.apache.flink.streaming.api.environment.ExecutionCheckpointingOptions.ALIGNMENT_TIMEOUT Use `ExecutionCheckpointingOptions.ALIGNED_CHECKPOINT_TIMEOUT` instead.
org.apache.flink.configuration.AkkaOptions.ASK_TIMEOUT Use `RpcOptions.ASK_TIMEOUT_DURATION`
org.apache.flink.configuration.CheckpointingOptions.ASYNC_SNAPSHOTS Checkpoints are always asynchronous.
org.apache.flink.configuration.PipelineOptions.AUTO_TYPE_REGISTRATION The config is deprecated because it's only used in DataSet API. All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.configuration.WebOptions.BACKPRESSURE_CLEANUP_INTERVAL - no longer used.
org.apache.flink.configuration.WebOptions.BACKPRESSURE_DELAY - no longer used.
org.apache.flink.configuration.WebOptions.BACKPRESSURE_NUM_SAMPLES - no longer used.
org.apache.flink.configuration.WebOptions.BACKPRESSURE_REFRESH_INTERVAL - no longer used.
org.apache.flink.configuration.ConfigConstants.BLOB_FETCH_BACKLOG_KEY use `BlobServerOptions.FETCH_BACKLOG` instead
org.apache.flink.configuration.ConfigConstants.BLOB_FETCH_CONCURRENT_KEY use `BlobServerOptions.FETCH_CONCURRENT` instead
org.apache.flink.configuration.ConfigConstants.BLOB_FETCH_RETRIES_KEY use `BlobServerOptions.FETCH_RETRIES` instead
org.apache.flink.configuration.ConfigConstants.BLOB_SERVER_PORT use `BlobServerOptions.PORT` instead
org.apache.flink.configuration.ConfigConstants.BLOB_SERVICE_SSL_ENABLED use `BlobServerOptions.SSL_ENABLED` instead
org.apache.flink.configuration.ConfigConstants.BLOB_STORAGE_DIRECTORY_KEY use `BlobServerOptions.STORAGE_DIRECTORY` instead
org.apache.flink.api.common.io.BinaryInputFormat.BLOCK_SIZE_PARAMETER_KEY
org.apache.flink.api.common.io.BinaryOutputFormat.BLOCK_SIZE_PARAMETER_KEY
org.apache.flink.configuration.JobManagerOptions.BLOCK_SLOW_NODE_DURATION Use `BatchExecutionOptions.BLOCK_SLOW_NODE_DURATION`.
org.apache.flink.configuration.ConfigConstants.CHECKPOINTS_DIRECTORY_KEY Use `CheckpointingOptions.CHECKPOINTS_DIRECTORY` instead.
org.apache.flink.configuration.AkkaOptions.CLIENT_TIMEOUT Use the `ClientOptions.CLIENT_TIMEOUT` instead.
org.apache.flink.configuration.ConfigConstants.CONTAINERIZED_HEAP_CUTOFF_MIN Not used anymore, but remain here until Flink 2.0
org.apache.flink.configuration.ConfigConstants.CONTAINERIZED_HEAP_CUTOFF_RATIO Not used anymore, but remain here until Flink 2.0
org.apache.flink.configuration.ConfigConstants.CONTAINERIZED_MASTER_ENV_PREFIX Use `ResourceManagerOptions.CONTAINERIZED_MASTER_ENV_PREFIX` instead.
org.apache.flink.configuration.ConfigConstants.CONTAINERIZED_TASK_MANAGER_ENV_PREFIX Use `ResourceManagerOptions.CONTAINERIZED_TASK_MANAGER_ENV_PREFIX` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_AKKA_ASK_TIMEOUT Use `RpcOptions.ASK_TIMEOUT_DURATION` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_AKKA_CLIENT_TIMEOUT Use `ClientOptions#CLIENT_TIMEOUT` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_AKKA_DISPATCHER_THROUGHPUT Use `RpcOptions.DISPATCHER_THROUGHPUT` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_AKKA_FRAMESIZE Use `RpcOptions.FRAMESIZE` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_AKKA_LOG_LIFECYCLE_EVENTS Use `RpcOptions.LOG_LIFECYCLE_EVENTS` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_AKKA_LOOKUP_TIMEOUT Use `RpcOptions.LOOKUP_TIMEOUT_DURATION` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_AKKA_SSL_ENABLED Use `RpcOptions.SSL_ENABLED` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_AKKA_TRANSPORT_HEARTBEAT_INTERVAL Use `RpcOptions#TRANSPORT_HEARTBEAT_INTERVAL` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_AKKA_TRANSPORT_HEARTBEAT_PAUSE Use `RpcOptions#TRANSPORT_HEARTBEAT_PAUSE` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_AKKA_TRANSPORT_THRESHOLD Use `RpcOptions#TRANSPORT_THRESHOLD` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_AKKA_WATCH_THRESHOLD This default value is no longer used and has no effect on Flink.
org.apache.flink.configuration.ConfigConstants.DEFAULT_BLOB_FETCH_BACKLOG use `BlobServerOptions.FETCH_BACKLOG` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_BLOB_FETCH_CONCURRENT use `BlobServerOptions.FETCH_CONCURRENT` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_BLOB_FETCH_RETRIES use `BlobServerOptions.FETCH_RETRIES` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_BLOB_SERVER_PORT use `BlobServerOptions.PORT` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_BLOB_SERVICE_SSL_ENABLED use `BlobServerOptions.SSL_ENABLED` instead
org.apache.flink.streaming.api.environment.CheckpointConfig.DEFAULT_CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA This field is no longer used. Please use `ExecutionCheckpointingOptions.CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_DELIMITED_FORMAT_MAX_LINE_SAMPLES use `OptimizerOptions.DELIMITED_FORMAT_MAX_LINE_SAMPLES` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_DELIMITED_FORMAT_MAX_SAMPLE_LEN use `OptimizerOptions.DELIMITED_FORMAT_MAX_SAMPLE_LEN` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_DELIMITED_FORMAT_MIN_LINE_SAMPLES use `OptimizerOptions.DELIMITED_FORMAT_MIN_LINE_SAMPLES` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_EXECUTION_RETRIES
org.apache.flink.configuration.ConfigConstants.DEFAULT_FILESYSTEM_ALWAYS_CREATE_DIRECTORY Use `CoreOptions.FILESYSTEM_OUTPUT_ALWAYS_CREATE_DIRECTORY` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_FILESYSTEM_OVERWRITE
org.apache.flink.configuration.ConfigConstants.DEFAULT_FILESYSTEM_SCHEME
org.apache.flink.configuration.ConfigConstants.DEFAULT_FS_STREAM_OPENING_TIMEOUT
org.apache.flink.configuration.ConfigConstants.DEFAULT_HA_JOB_MANAGER_PORT No longer used.
org.apache.flink.configuration.ConfigConstants.DEFAULT_HA_MODE Deprecated in favour of `HighAvailabilityOptions.HA_MODE`
org.apache.flink.configuration.ConfigConstants.DEFAULT_HA_ZOOKEEPER_CLIENT_ACL in favor of `HighAvailabilityOptions.ZOOKEEPER_CLIENT_ACL`.
org.apache.calcite.sql2rel.SqlToRelConverter.DEFAULT_IN_SUBQUERY_THRESHOLD
org.apache.flink.configuration.ConfigConstants.DEFAULT_JOB_MANAGER_IPC_PORT use `JobManagerOptions.PORT` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_JOB_MANAGER_WEB_ARCHIVE_COUNT use `WebOptions.ARCHIVE_COUNT` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_CLEAN_UP_INTERVAL use `WebOptions.BACKPRESSURE_CLEANUP_INTERVAL` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_DELAY use `WebOptions.BACKPRESSURE_DELAY` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_NUM_SAMPLES use `WebOptions.BACKPRESSURE_NUM_SAMPLES` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_REFRESH_INTERVAL use `WebOptions.BACKPRESSURE_REFRESH_INTERVAL` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_JOB_MANAGER_WEB_CHECKPOINTS_DISABLE Config key has been deprecated. Therefore, no default value required.
org.apache.flink.configuration.ConfigConstants.DEFAULT_JOB_MANAGER_WEB_CHECKPOINTS_HISTORY_SIZE use `WebOptions.CHECKPOINTS_HISTORY_SIZE` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_JOB_MANAGER_WEB_FRONTEND_ADDRESS use `WebOptions.ADDRESS` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_JOB_MANAGER_WEB_FRONTEND_PORT use `WebOptions.PORT` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_JOB_MANAGER_WEB_SSL_ENABLED use `WebOptions.SSL_ENABLED` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_JOB_MANAGER_WEB_SUBMIT_ENABLED use `WebOptions.SUBMIT_ENABLE` instead
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.DEFAULT_JOB_NAME This constant does not fit well to batch runtime mode.
org.apache.flink.configuration.ConfigConstants.DEFAULT_LIBRARY_CACHE_MANAGER_CLEANUP_INTERVAL use `BlobServerOptions.CLEANUP_INTERVAL` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_LOCAL_NUMBER_JOB_MANAGER
org.apache.flink.configuration.ConfigConstants.DEFAULT_LOCAL_NUMBER_RESOURCE_MANAGER Use `ResourceManagerOptions.LOCAL_NUMBER_RESOURCE_MANAGER` instead.
org.apache.flink.streaming.api.environment.CheckpointConfig.DEFAULT_MAX_CONCURRENT_CHECKPOINTS This field is no longer used. Please use `ExecutionCheckpointingOptions.MAX_CONCURRENT_CHECKPOINTS` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_MEMORY_MANAGER_MEMORY_FRACTION has no effect
org.apache.flink.configuration.ConfigConstants.DEFAULT_MESOS_ARTIFACT_SERVER_PORT has no effect
org.apache.flink.configuration.ConfigConstants.DEFAULT_MESOS_ARTIFACT_SERVER_SSL_ENABLED has no effect
org.apache.flink.configuration.ConfigConstants.DEFAULT_MESOS_FAILOVER_TIMEOUT_SECS has no effect
org.apache.flink.configuration.ConfigConstants.DEFAULT_MESOS_RESOURCEMANAGER_FRAMEWORK_NAME has no effect
org.apache.flink.configuration.ConfigConstants.DEFAULT_MESOS_RESOURCEMANAGER_FRAMEWORK_ROLE has no effect
org.apache.flink.configuration.ConfigConstants.DEFAULT_MESOS_RESOURCEMANAGER_FRAMEWORK_USER has no effect
org.apache.flink.configuration.ConfigConstants.DEFAULT_METRICS_LATENCY_HISTORY_SIZE Use `MetricOptions.LATENCY_HISTORY_SIZE` instead.
org.apache.flink.streaming.api.environment.CheckpointConfig.DEFAULT_MIN_PAUSE_BETWEEN_CHECKPOINTS This field is no longer used. Please use `ExecutionCheckpointingOptions.MIN_PAUSE_BETWEEN_CHECKPOINTS` instead.
org.apache.flink.streaming.api.environment.CheckpointConfig.DEFAULT_MODE
org.apache.flink.configuration.ConfigConstants.DEFAULT_PARALLELISM use `CoreOptions.DEFAULT_PARALLELISM` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_PARALLELISM_KEY use `CoreOptions.DEFAULT_PARALLELISM` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_RECOVERY_JOB_MANAGER_PORT Deprecated in favour of `ConfigConstants.DEFAULT_HA_JOB_MANAGER_PORT`
org.apache.flink.configuration.ConfigConstants.DEFAULT_RECOVERY_MODE Deprecated in favour of `ConfigConstants.DEFAULT_HA_MODE`
org.apache.flink.configuration.ConfigConstants.DEFAULT_RESOURCE_MANAGER_IPC_PORT Use `ResourceManagerOptions.IPC_PORT` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_RUNTIME_HASH_JOIN_BLOOM_FILTERS use `AlgorithmOptions.HASH_JOIN_BLOOM_FILTERS` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_SECURITY_SSL_ALGORITHMS use `SecurityOptions.SSL_ALGORITHMS` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_SECURITY_SSL_ENABLED use `SecurityOptions.SSL_ENABLED` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_SECURITY_SSL_PROTOCOL use `SecurityOptions.SSL_PROTOCOL` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_SECURITY_SSL_VERIFY_HOSTNAME use `SecurityOptions.SSL_VERIFY_HOSTNAME` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_SORT_SPILLING_THRESHOLD use `AlgorithmOptions.SORT_SPILLING_THRESHOLD` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_SORT_SPILLING_THRESHOLD_KEY use `instead`
org.apache.flink.configuration.ConfigConstants.DEFAULT_SPILLING_MAX_FAN use `AlgorithmOptions.SPILLING_MAX_FAN` insstead
org.apache.flink.configuration.ConfigConstants.DEFAULT_SPILLING_MAX_FAN_KEY use `AlgorithmOptions.SPILLING_MAX_FAN` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_STATE_BACKEND
org.apache.flink.configuration.ConfigConstants.DEFAULT_TASK_CANCELLATION_INTERVAL_MILLIS Please use `TaskManagerOptions.TASK_CANCELLATION_INTERVAL`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_TASK_MANAGER_DATA_PORT use `NettyShuffleEnvironmentOptions.DATA_PORT` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_TASK_MANAGER_DATA_SSL_ENABLED use `NettyShuffleEnvironmentOptions.DATA_SSL_ENABLED` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_TASK_MANAGER_DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS use `TaskManagerOptions.DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD use `TaskManagerOptions.DEBUG_MEMORY_LOG` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_TASK_MANAGER_INITIAL_REGISTRATION_PAUSE use `ClusterOptions.INITIAL_REGISTRATION_TIMEOUT` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_TASK_MANAGER_IPC_PORT use `TaskManagerOptions.RPC_PORT` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_TASK_MANAGER_MAX_REGISTRATION_DURATION use `TaskManagerOptions.REGISTRATION_TIMEOUT` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_TASK_MANAGER_MAX_REGISTRATION_PAUSE use `ClusterOptions.MAX_REGISTRATION_TIMEOUT` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_TASK_MANAGER_MEMORY_PRE_ALLOCATE has no effect
org.apache.flink.configuration.ConfigConstants.DEFAULT_TASK_MANAGER_MEMORY_SEGMENT_SIZE `TaskManagerOptions.MEMORY_SEGMENT_SIZE` provides the default value now
org.apache.flink.configuration.ConfigConstants.DEFAULT_TASK_MANAGER_NETWORK_DEFAULT_IO_MODE Not used anymore
org.apache.flink.configuration.ConfigConstants.DEFAULT_TASK_MANAGER_NETWORK_NUM_BUFFERS `NettyShuffleEnvironmentOptions.NETWORK_NUM_BUFFERS` provides the default value now
org.apache.flink.configuration.ConfigConstants.DEFAULT_TASK_MANAGER_REFUSED_REGISTRATION_PAUSE use `ClusterOptions.REFUSED_REGISTRATION_DELAY` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_TASK_MANAGER_TMP_PATH `CoreOptions.TMP_DIRS` provides the default value now
org.apache.flink.streaming.api.environment.CheckpointConfig.DEFAULT_TIMEOUT This field is no longer used. Please use `ExecutionCheckpointingOptions.CHECKPOINTING_TIMEOUT` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_USE_LARGE_RECORD_HANDLER use `AlgorithmOptions.USE_LARGE_RECORDS_HANDLER` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_YARN_APPLICATION_MASTER_PORT Not used anymore, but remain here until Flink 2.0
org.apache.flink.configuration.ConfigConstants.DEFAULT_YARN_HEAP_CUTOFF Not used anymore, but remain here until Flink 2.0
org.apache.flink.configuration.ConfigConstants.DEFAULT_YARN_HEAP_CUTOFF_RATIO Not used anymore, but remain here until Flink 2.0
org.apache.flink.configuration.ConfigConstants.DEFAULT_YARN_JOB_MANAGER_PORT in favor of `YarnConfigOptions#APPLICATION_MASTER_PORT`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_YARN_MIN_HEAP_CUTOFF Not used anymore, but remain here until Flink 2.0
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_CHECKPOINT_COUNTER_PATH no longer used.
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_CHECKPOINTS_PATH no longer used.
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_CLIENT_PORT in favor of `FlinkZookeeperQuorumPeer#DEFAULT_ZOOKEEPER_CLIENT_PORT`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_CONNECTION_TIMEOUT in favor of `HighAvailabilityOptions.ZOOKEEPER_CONNECTION_TIMEOUT`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_DIR_KEY in favor of `HighAvailabilityOptions.HA_ZOOKEEPER_ROOT`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_INIT_LIMIT in favor of `FlinkZookeeperQuorumPeer#DEFAULT_ZOOKEEPER_INIT_LIMIT`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_JOBGRAPHS_PATH in favor of `HighAvailabilityOptions.HA_ZOOKEEPER_JOBGRAPHS_PATH`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_LATCH_PATH no longer used.
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_LEADER_PATH no longer used.
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_LEADER_PORT in favor of `FlinkZookeeperQuorumPeer#DEFAULT_ZOOKEEPER_LEADER_PORT`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_MAX_RETRY_ATTEMPTS in favor of `HighAvailabilityOptions.ZOOKEEPER_MAX_RETRY_ATTEMPTS`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_MESOS_WORKERS_PATH has no effect
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_NAMESPACE_KEY in favor of `HighAvailabilityOptions.HA_CLUSTER_ID`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_PEER_PORT in favor of `FlinkZookeeperQuorumPeer#DEFAULT_ZOOKEEPER_PEER_PORT`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_RETRY_WAIT in favor of `HighAvailabilityOptions.ZOOKEEPER_RETRY_WAIT`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_SASL_DISABLE in favor of `SecurityOptions.ZOOKEEPER_SASL_DISABLE`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_SESSION_TIMEOUT in favor of `HighAvailabilityOptions.ZOOKEEPER_SESSION_TIMEOUT`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_SYNC_LIMIT in favor of `FlinkZookeeperQuorumPeer#DEFAULT_ZOOKEEPER_SYNC_LIMIT`.
org.apache.flink.api.common.state.StateDescriptor.defaultValue To make the semantics more clear, user should manually manage the default value if the contents of the state is `null`
org.apache.flink.configuration.ConfigConstants.DELIMITED_FORMAT_MAX_LINE_SAMPLES_KEY use `OptimizerOptions.DELIMITED_FORMAT_MAX_LINE_SAMPLES` instead
org.apache.flink.configuration.ConfigConstants.DELIMITED_FORMAT_MAX_SAMPLE_LENGTH_KEY use `OptimizerOptions.DELIMITED_FORMAT_MAX_SAMPLE_LEN` instead
org.apache.flink.configuration.ConfigConstants.DELIMITED_FORMAT_MIN_LINE_SAMPLES_KEY use `OptimizerOptions.DELIMITED_FORMAT_MIN_LINE_SAMPLES` instead
org.apache.flink.table.api.dataview.ListView.elementType
org.apache.flink.api.common.io.FileInputFormat.ENUMERATE_NESTED_FILES_FLAG
org.apache.flink.configuration.ConfigConstants.ENV_FLINK_BIN_DIR
org.apache.flink.configuration.ClusterOptions.EVENLY_SPREAD_OUT_SLOTS_STRATEGY Please use `TaskManagerOptions.TASK_MANAGER_LOAD_BALANCE_MODE` instead. Note: The 'taskmanager.load-balance.mode: SLOTS' is equal to 'cluster.evenly-spread-out-slots: true'. The 'taskmanager.load-balance.mode: NONE' is equal to 'cluster.evenly-spread-out-slots: false'.
org.apache.flink.runtime.entrypoint.parser.CommandLineOptions.EXECUTION_MODE_OPTION exists only for compatibility with legacy mode. Remove once legacy mode and execution mode option has been removed.
org.apache.flink.configuration.ConfigConstants.EXECUTION_RETRIES_KEY The configuration value will be replaced by `ConfigConstants.RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS` and the corresponding FixedDelayRestartStrategy.
org.apache.flink.configuration.ConfigConstants.EXECUTION_RETRY_DELAY_KEY The configuration value will be replaced by `ConfigConstants.RESTART_STRATEGY_FIXED_DELAY_DELAY` and the corresponding FixedDelayRestartStrategy.
org.apache.flink.configuration.TaskManagerOptions.EXIT_ON_FATAL_AKKA_ERROR
org.apache.flink.runtime.rest.messages.SubtasksTimesInfo.SubtaskTimeInfo.FIELD_NAME_HOST
org.apache.flink.runtime.rest.messages.job.SubtasksAllAccumulatorsInfo.SubtaskAccumulatorsInfo.FIELD_NAME_HOST
org.apache.flink.runtime.rest.messages.job.SubtaskExecutionAttemptDetailsInfo.FIELD_NAME_HOST
org.apache.flink.runtime.rest.messages.JobExceptionsInfo.ExecutionExceptionInfo.FIELD_NAME_LOCATION
org.apache.flink.runtime.rest.messages.JobExceptionsInfoWithHistory.ExceptionInfo.FIELD_NAME_LOCATION
org.apache.flink.runtime.rest.messages.taskmanager.TaskManagerMetricsInfo.FIELD_NAME_NETWORK_MEMORY_SEGMENTS_AVAILABLE
org.apache.flink.runtime.rest.messages.taskmanager.TaskManagerMetricsInfo.FIELD_NAME_NETWORK_MEMORY_SEGMENTS_TOTAL
org.apache.flink.api.common.io.FileOutputFormat.FILE_PARAMETER_KEY
org.apache.flink.api.common.io.FileInputFormat.filePath Please override `FileInputFormat.supportsMultiPaths()` and use `FileInputFormat.getFilePaths()` and `FileInputFormat.setFilePaths(Path...)`.
org.apache.flink.configuration.ConfigConstants.FILESYSTEM_DEFAULT_OVERWRITE_KEY Use `CoreOptions.FILESYTEM_DEFAULT_OVERRIDE` instead.
org.apache.flink.configuration.ConfigConstants.FILESYSTEM_OUTPUT_ALWAYS_CREATE_DIRECTORY_KEY Use `CoreOptions.FILESYSTEM_OUTPUT_ALWAYS_CREATE_DIRECTORY` instead.
org.apache.flink.configuration.ConfigConstants.FILESYSTEM_SCHEME Use `CoreOptions.DEFAULT_FILESYSTEM_SCHEME` instead.
org.apache.flink.configuration.ConfigConstants.FLINK_BASE_DIR_PATH_KEY This parameter should not be used any more. A running Flink cluster should make no assumption about its location.
org.apache.flink.configuration.ConfigConstants.FLINK_JVM_OPTIONS Use `CoreOptions.FLINK_JVM_OPTIONS` instead.
org.apache.flink.streaming.api.environment.ExecutionCheckpointingOptions.FORCE_CHECKPOINTING This will be removed once iterations properly participate in checkpointing.
org.apache.flink.runtime.state.StateBackendLoader.FS_STATE_BACKEND_NAME
org.apache.flink.configuration.ConfigConstants.FS_STREAM_OPENING_TIMEOUT_KEY use `TaskManagerOptions.FS_STREAM_OPENING_TIME_OUT` instead.
org.apache.flink.runtime.metrics.MetricNames.FULL_RESTARTS
org.apache.flink.configuration.HighAvailabilityOptions.HA_JOB_DELAY Don't use this option anymore. It has no effect on Flink.
org.apache.flink.configuration.ConfigConstants.HA_JOB_MANAGER_PORT
org.apache.flink.configuration.ConfigConstants.HA_MODE Deprecated in favour of `HighAvailabilityOptions.HA_MODE`
org.apache.flink.configuration.ConfigConstants.HA_ZOOKEEPER_CHECKPOINT_COUNTER_PATH no longer used.
org.apache.flink.configuration.ConfigConstants.HA_ZOOKEEPER_CHECKPOINTS_PATH no longer used.
org.apache.flink.configuration.ConfigConstants.HA_ZOOKEEPER_CLIENT_ACL in favor of `HighAvailabilityOptions.ZOOKEEPER_CLIENT_ACL`.
org.apache.flink.configuration.ConfigConstants.HA_ZOOKEEPER_CONNECTION_TIMEOUT in favor of `HighAvailabilityOptions.ZOOKEEPER_CONNECTION_TIMEOUT`.
org.apache.flink.configuration.ConfigConstants.HA_ZOOKEEPER_DIR_KEY in favor of `HighAvailabilityOptions.HA_ZOOKEEPER_ROOT`.
org.apache.flink.configuration.ConfigConstants.HA_ZOOKEEPER_JOBGRAPHS_PATH in favor of `HighAvailabilityOptions.HA_ZOOKEEPER_JOBGRAPHS_PATH`.
org.apache.flink.configuration.ConfigConstants.HA_ZOOKEEPER_LATCH_PATH no longer used.
org.apache.flink.configuration.ConfigConstants.HA_ZOOKEEPER_LEADER_PATH no longer used.
org.apache.flink.configuration.ConfigConstants.HA_ZOOKEEPER_MAX_RETRY_ATTEMPTS in favor of `HighAvailabilityOptions.ZOOKEEPER_MAX_RETRY_ATTEMPTS`.
org.apache.flink.configuration.ConfigConstants.HA_ZOOKEEPER_MESOS_WORKERS_PATH has no effect
org.apache.flink.configuration.ConfigConstants.HA_ZOOKEEPER_NAMESPACE_KEY in favor of `HighAvailabilityOptions.HA_CLUSTER_ID`.
org.apache.flink.configuration.ConfigConstants.HA_ZOOKEEPER_QUORUM_KEY in favor of `HighAvailabilityOptions.HA_ZOOKEEPER_QUORUM`.
org.apache.flink.configuration.ConfigConstants.HA_ZOOKEEPER_RETRY_WAIT in favor of `HighAvailabilityOptions.ZOOKEEPER_RETRY_WAIT`
org.apache.flink.configuration.ConfigConstants.HA_ZOOKEEPER_SESSION_TIMEOUT in favor of `HighAvailabilityOptions.ZOOKEEPER_SESSION_TIMEOUT`.
org.apache.flink.configuration.ConfigConstants.HA_ZOOKEEPER_STORAGE_PATH in favor of `HighAvailabilityOptions.HA_STORAGE_PATH`.
org.apache.flink.configuration.ConfigConstants.HDFS_DEFAULT_CONFIG Use environment variable HADOOP_CONF_DIR instead.
org.apache.flink.configuration.ConfigConstants.HDFS_SITE_CONFIG Use environment variable HADOOP_CONF_DIR instead.
org.apache.flink.metrics.prometheus.PrometheusPushGatewayReporterOptions.HOST
org.apache.flink.runtime.entrypoint.parser.CommandLineOptions.HOST_OPTION subsumed by dynamic properties
org.apache.flink.configuration.TaskManagerOptions.INITIAL_REGISTRATION_BACKOFF use `ClusterOptions.INITIAL_REGISTRATION_TIMEOUT` instead
org.apache.flink.runtime.metrics.MetricNames.IO_CURRENT_INPUT_1_WATERMARK
org.apache.flink.runtime.metrics.MetricNames.IO_CURRENT_INPUT_2_WATERMARK
org.apache.flink.configuration.JobManagerOptions.JOB_MANAGER_HEAP_MEMORY use `JobManagerOptions.TOTAL_FLINK_MEMORY` for standalone setups and `JobManagerOptions.TOTAL_PROCESS_MEMORY` for containerized setups.
org.apache.flink.configuration.JobManagerOptions.JOB_MANAGER_HEAP_MEMORY_MB use `JobManagerOptions.TOTAL_FLINK_MEMORY` for standalone setups and `JobManagerOptions.TOTAL_PROCESS_MEMORY` for containerized setups.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_IPC_ADDRESS_KEY Use `JobManagerOptions.ADDRESS` instead
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_IPC_PORT_KEY Use `JobManagerOptions.PORT` instead
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_ARCHIVE_COUNT Use `WebOptions.ARCHIVE_COUNT` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_BACK_PRESSURE_CLEAN_UP_INTERVAL - no longer used.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_BACK_PRESSURE_DELAY - no longer used.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_BACK_PRESSURE_NUM_SAMPLES - no longer used.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_BACK_PRESSURE_REFRESH_INTERVAL - no longer used.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_CHECKPOINTS_DISABLE Not possible to disable any longer. Use history size of 0.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_CHECKPOINTS_HISTORY_SIZE Use `WebOptions.CHECKPOINTS_HISTORY_SIZE` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_LOG_PATH_KEY Use `WebOptions.LOG_PATH` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_PORT_KEY Use `WebOptions.PORT` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_SSL_ENABLED Use `WebOptions.SSL_ENABLED` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_SUBMIT_ENABLED_KEY Use `WebOptions.SUBMIT_ENABLE` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_TMPDIR_KEY Use `WebOptions.TMP_DIR` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_UPLOAD_DIR_KEY Use `WebOptions.UPLOAD_DIR` instead.
org.apache.flink.configuration.SecurityOptions.KERBEROS_FETCH_DELEGATION_TOKEN Use `SecurityOptions.DELEGATION_TOKENS_ENABLED`.
org.apache.flink.configuration.SecurityOptions.KERBEROS_TOKENS_RENEWAL_RETRY_BACKOFF Use `SecurityOptions.DELEGATION_TOKENS_RENEWAL_RETRY_BACKOFF`.
org.apache.flink.configuration.SecurityOptions.KERBEROS_TOKENS_RENEWAL_TIME_RATIO Use `SecurityOptions.DELEGATION_TOKENS_RENEWAL_TIME_RATIO`.
org.apache.flink.table.api.dataview.MapView.keyType
org.apache.flink.configuration.PipelineOptions.KRYO_DEFAULT_SERIALIZERS The config is subsumed by `PipelineOptions.SERIALIZATION_CONFIG`.
org.apache.flink.configuration.PipelineOptions.KRYO_REGISTERED_CLASSES The config is subsumed by `PipelineOptions.SERIALIZATION_CONFIG`.
org.apache.flink.kubernetes.utils.Constants.LABEL_CONFIGMAP_TYPE_HIGH_AVAILABILITY
org.apache.flink.kubernetes.utils.Constants.LABEL_CONFIGMAP_TYPE_KEY
org.apache.flink.configuration.ConfigConstants.LIBRARY_CACHE_MANAGER_CLEANUP_INTERVAL use `BlobServerOptions.CLEANUP_INTERVAL` instead
org.apache.flink.configuration.ConfigConstants.LOCAL_NUMBER_JOB_MANAGER
org.apache.flink.configuration.ConfigConstants.LOCAL_NUMBER_RESOURCE_MANAGER Use `ResourceManagerOptions.LOCAL_NUMBER_RESOURCE_MANAGER` instead.
org.apache.flink.configuration.ResourceManagerOptions.LOCAL_NUMBER_RESOURCE_MANAGER
org.apache.flink.configuration.ConfigConstants.LOCAL_NUMBER_TASK_MANAGER use `TaskManagerOptions.MINI_CLUSTER_NUM_TASK_MANAGERS` instead
org.apache.flink.configuration.ConfigConstants.LOCAL_START_WEBSERVER Has no effect; the web-server is always started. Will be removed in 2.0.
org.apache.flink.configuration.AkkaOptions.LOOKUP_TIMEOUT use `RpcOptions.LOOKUP_TIMEOUT_DURATION`
org.apache.flink.configuration.TaskManagerOptions.MANAGED_MEMORY_CONSUMER_NAME_DATAPROC use `TaskManagerOptions.MANAGED_MEMORY_CONSUMER_NAME_OPERATOR` and `TaskManagerOptions.MANAGED_MEMORY_CONSUMER_NAME_STATE_BACKEND` instead
org.apache.flink.runtime.state.StateBackendLoader.MEMORY_STATE_BACKEND_NAME
org.apache.flink.configuration.ConfigConstants.MESOS_ARTIFACT_SERVER_PORT_KEY has no effect
org.apache.flink.configuration.ConfigConstants.MESOS_ARTIFACT_SERVER_SSL_ENABLED has no effect
org.apache.flink.configuration.ConfigConstants.MESOS_FAILOVER_TIMEOUT_SECONDS has no effect
org.apache.flink.configuration.ConfigConstants.MESOS_INITIAL_TASKS has no effect
org.apache.flink.configuration.ConfigConstants.MESOS_MASTER_URL has no effect
org.apache.flink.configuration.ConfigConstants.MESOS_MAX_FAILED_TASKS has no effect
org.apache.flink.configuration.ConfigConstants.MESOS_RESOURCEMANAGER_FRAMEWORK_NAME has no effect
org.apache.flink.configuration.ConfigConstants.MESOS_RESOURCEMANAGER_FRAMEWORK_PRINCIPAL has no effect
org.apache.flink.configuration.ConfigConstants.MESOS_RESOURCEMANAGER_FRAMEWORK_ROLE has no effect
org.apache.flink.configuration.ConfigConstants.MESOS_RESOURCEMANAGER_FRAMEWORK_SECRET has no effect
org.apache.flink.configuration.ConfigConstants.MESOS_RESOURCEMANAGER_FRAMEWORK_USER has no effect
org.apache.flink.configuration.ConfigConstants.METRICS_LATENCY_HISTORY_SIZE Use `MetricOptions.LATENCY_HISTORY_SIZE` instead.
org.apache.flink.configuration.ConfigConstants.METRICS_REPORTER_ADDITIONAL_VARIABLES use `MetricOptions.REPORTER_ADDITIONAL_VARIABLES`
org.apache.flink.configuration.ConfigConstants.METRICS_REPORTER_CLASS_SUFFIX use `MetricOptions.REPORTER_CLASS`
org.apache.flink.configuration.ConfigConstants.METRICS_REPORTER_EXCLUDED_VARIABLES use `MetricOptions.REPORTER_EXCLUDED_VARIABLES`
org.apache.flink.configuration.ConfigConstants.METRICS_REPORTER_FACTORY_CLASS_SUFFIX use `MetricOptions.REPORTER_FACTORY_CLASS`
org.apache.flink.configuration.ConfigConstants.METRICS_REPORTER_INTERVAL_SUFFIX use `MetricOptions.REPORTER_INTERVAL`
org.apache.flink.configuration.ConfigConstants.METRICS_REPORTER_SCOPE_DELIMITER use `MetricOptions.REPORTER_SCOPE_DELIMITER`
org.apache.flink.configuration.ConfigConstants.METRICS_REPORTERS_LIST Use `MetricOptions.REPORTERS_LIST` instead.
org.apache.flink.configuration.ConfigConstants.METRICS_SCOPE_DELIMITER Use `MetricOptions.SCOPE_DELIMITER` instead.
org.apache.flink.configuration.ConfigConstants.METRICS_SCOPE_NAMING_JM Use `MetricOptions.SCOPE_NAMING_JM` instead.
org.apache.flink.configuration.ConfigConstants.METRICS_SCOPE_NAMING_JM_JOB Use `MetricOptions.SCOPE_NAMING_JM_JOB` instead.
org.apache.flink.configuration.ConfigConstants.METRICS_SCOPE_NAMING_OPERATOR Use `MetricOptions.SCOPE_NAMING_OPERATOR` instead.
org.apache.flink.configuration.ConfigConstants.METRICS_SCOPE_NAMING_TASK Use `MetricOptions.SCOPE_NAMING_TASK` instead.
org.apache.flink.configuration.ConfigConstants.METRICS_SCOPE_NAMING_TM Use `MetricOptions.SCOPE_NAMING_TM` instead.
org.apache.flink.configuration.ConfigConstants.METRICS_SCOPE_NAMING_TM_JOB Use `MetricOptions.SCOPE_NAMING_TM_JOB` instead.
org.apache.flink.table.module.CommonModuleOptions.MODULE_TYPE This is only required for the legacy factory stack
org.apache.flink.configuration.NettyShuffleEnvironmentOptions.NETWORK_BUFFERS_MEMORY_FRACTION use `TaskManagerOptions.NETWORK_MEMORY_FRACTION` instead
org.apache.flink.configuration.NettyShuffleEnvironmentOptions.NETWORK_BUFFERS_MEMORY_MAX use `TaskManagerOptions.NETWORK_MEMORY_MAX` instead
org.apache.flink.configuration.NettyShuffleEnvironmentOptions.NETWORK_BUFFERS_MEMORY_MIN use `TaskManagerOptions.NETWORK_MEMORY_MIN` instead
org.apache.flink.configuration.NettyShuffleEnvironmentOptions.NETWORK_NUM_BUFFERS use `TaskManagerOptions.NETWORK_MEMORY_FRACTION`, `TaskManagerOptions.NETWORK_MEMORY_MIN`, and `TaskManagerOptions.NETWORK_MEMORY_MAX` instead
org.apache.flink.table.client.cli.CliOptionsParser.OPTION_UPDATE
org.apache.flink.api.common.ExecutionConfig.PARALLELISM_AUTO_MAX
org.apache.flink.configuration.ConfigConstants.PATH_HADOOP_CONFIG Use environment variable HADOOP_CONF_DIR instead.
org.apache.flink.configuration.PipelineOptions.POJO_REGISTERED_CLASSES The config is subsumed by `PipelineOptions.SERIALIZATION_CONFIG`.
org.apache.flink.configuration.WebOptions.PORT Use `RestOptions.PORT` instead
org.apache.flink.metrics.prometheus.PrometheusPushGatewayReporterOptions.PORT
org.apache.flink.configuration.ConfigConstants.RECOVERY_JOB_DELAY This option is no longer used and has no effect on Flink.
org.apache.flink.configuration.ConfigConstants.RECOVERY_JOB_MANAGER_PORT Deprecated in favour of `ConfigConstants.HA_JOB_MANAGER_PORT`.
org.apache.flink.configuration.ConfigConstants.RECOVERY_MODE Deprecated in favour of `ConfigConstants.HA_MODE`.
org.apache.flink.configuration.TaskManagerOptions.REFUSED_REGISTRATION_BACKOFF use `ClusterOptions.REFUSED_REGISTRATION_DELAY` instead
org.apache.flink.configuration.TaskManagerOptions.REGISTRATION_MAX_BACKOFF use `ClusterOptions.MAX_REGISTRATION_TIMEOUT` instead
org.apache.flink.configuration.MetricOptions.REPORTER_CLASS use `MetricOptions.REPORTER_FACTORY_CLASS` instead.
org.apache.flink.configuration.ConfigConstants.RESOURCE_MANAGER_IPC_PORT_KEY Use `ResourceManagerOptions.IPC_PORT` instead.
org.apache.flink.runtime.entrypoint.parser.CommandLineOptions.REST_PORT_OPTION subsumed by dynamic properties
org.apache.flink.configuration.ConfigConstants.RESTART_STRATEGY use `RestartStrategyOptions.RESTART_STRATEGY` instead.
org.apache.flink.configuration.ConfigConstants.RESTART_STRATEGY_FAILURE_RATE_DELAY use `RestartStrategyOptions.RESTART_STRATEGY_FAILURE_RATE_DELAY` instead.
org.apache.flink.configuration.ConfigConstants.RESTART_STRATEGY_FAILURE_RATE_FAILURE_RATE_INTERVAL use `RestartStrategyOptions.RESTART_STRATEGY_FAILURE_RATE_FAILURE_RATE_INTERVAL`
org.apache.flink.configuration.ConfigConstants.RESTART_STRATEGY_FAILURE_RATE_MAX_FAILURES_PER_INTERVAL use `RestartStrategyOptions.RESTART_STRATEGY_FAILURE_RATE_MAX_FAILURES_PER_INTERVAL` instead.
org.apache.flink.configuration.ConfigConstants.RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS use `RestartStrategyOptions.RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS` instead.
org.apache.flink.configuration.ConfigConstants.RESTART_STRATEGY_FIXED_DELAY_DELAY use `RestartStrategyOptions.RESTART_STRATEGY_FIXED_DELAY_DELAY` instead.
org.apache.flink.configuration.ConfigConstants.RUNTIME_HASH_JOIN_BLOOM_FILTERS_KEY use `AlgorithmOptions.HASH_JOIN_BLOOM_FILTERS` instead
org.apache.flink.configuration.ConfigConstants.SAVEPOINT_DIRECTORY_KEY Use `CheckpointingOptions.SAVEPOINT_DIRECTORY` instead.
org.apache.flink.configuration.ConfigConstants.SAVEPOINT_FS_DIRECTORY_KEY This key was used in Flink versions <= 1.1.X with the savepoint backend configuration. We now always use the FileSystem for savepoints. For this, the only relevant config key is `CheckpointingOptions.SAVEPOINT_DIRECTORY`.
org.apache.flink.table.descriptors.Schema.SCHEMA_TYPE `Schema` uses the legacy type key (e.g. schema.0.type = LONG) to store type information in prior v1.9. Since v1.10, `Schema` uses data type key (e.g. schema.0.data-type = BIGINT) to store types.
org.apache.flink.configuration.ConfigConstants.SECURITY_SSL_ALGORITHMS use `SecurityOptions.SSL_ALGORITHMS` instead
org.apache.flink.configuration.ConfigConstants.SECURITY_SSL_ENABLED use `SecurityOptions.SSL_ENABLED` instead
org.apache.flink.configuration.ConfigConstants.SECURITY_SSL_KEY_PASSWORD use `SecurityOptions.SSL_KEY_PASSWORD` instead
org.apache.flink.configuration.ConfigConstants.SECURITY_SSL_KEYSTORE use `SecurityOptions.SSL_KEYSTORE` instead
org.apache.flink.configuration.ConfigConstants.SECURITY_SSL_KEYSTORE_PASSWORD use `SecurityOptions.SSL_KEYSTORE_PASSWORD` instead
org.apache.flink.configuration.ConfigConstants.SECURITY_SSL_PROTOCOL use `SecurityOptions.SSL_PROTOCOL` instead
org.apache.flink.configuration.ConfigConstants.SECURITY_SSL_TRUSTSTORE use `SecurityOptions.SSL_TRUSTSTORE` instead
org.apache.flink.configuration.ConfigConstants.SECURITY_SSL_TRUSTSTORE_PASSWORD use `SecurityOptions.SSL_TRUSTSTORE_PASSWORD` instead
org.apache.flink.configuration.ConfigConstants.SECURITY_SSL_VERIFY_HOSTNAME use `SecurityOptions.SSL_VERIFY_HOSTNAME` instead
org.apache.flink.configuration.ResourceManagerOptions.SLOT_MANAGER_TASK_MANAGER_TIMEOUT Use `ResourceManagerOptions.TASK_MANAGER_TIMEOUT`.
org.apache.flink.configuration.JobManagerOptions.SPECULATIVE_ENABLED Use `BatchExecutionOptions.SPECULATIVE_ENABLED`.
org.apache.flink.configuration.JobManagerOptions.SPECULATIVE_MAX_CONCURRENT_EXECUTIONS Use `BatchExecutionOptions.SPECULATIVE_MAX_CONCURRENT_EXECUTIONS`.
org.apache.flink.configuration.WebOptions.SSL_ENABLED
org.apache.flink.configuration.SecurityOptions.SSL_ENABLED Use `SecurityOptions.SSL_INTERNAL_ENABLED` and `SecurityOptions.SSL_REST_ENABLED` instead.
org.apache.flink.configuration.ConfigConstants.STATE_BACKEND Use `CheckpointingOptions.STATE_BACKEND` instead.
org.apache.flink.configuration.CheckpointingOptions.STATE_BACKEND Use `StateBackendOptions.STATE_BACKEND`.
org.apache.flink.table.api.config.ExecutionConfigOptions.TABLE_EXEC_LEGACY_TRANSFORMATION_UIDS Use `ExecutionConfigOptions.TABLE_EXEC_UID_GENERATION` instead.
org.apache.flink.table.api.config.ExecutionConfigOptions.TABLE_EXEC_SHUFFLE_MODE Use `ExecutionOptions.BATCH_SHUFFLE_MODE` instead.
org.apache.flink.configuration.ConfigConstants.TASK_CANCELLATION_INTERVAL_MILLIS Deprecated. Please use `TaskManagerOptions.TASK_CANCELLATION_INTERVAL`.
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_DATA_PORT_KEY use `NettyShuffleEnvironmentOptions.DATA_PORT` instead
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_DATA_SSL_ENABLED use `NettyShuffleEnvironmentOptions.DATA_SSL_ENABLED` instead
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS use `TaskManagerOptions.DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS` instead
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD use `TaskManagerOptions.DEBUG_MEMORY_LOG` instead
org.apache.flink.configuration.TaskManagerOptions.TASK_MANAGER_HEAP_MEMORY use `TaskManagerOptions.TOTAL_FLINK_MEMORY` for standalone setups and `TaskManagerOptions.TOTAL_PROCESS_MEMORY` for containerized setups.
org.apache.flink.configuration.TaskManagerOptions.TASK_MANAGER_HEAP_MEMORY_MB use `TaskManagerOptions.TOTAL_FLINK_MEMORY` for standalone setups and `TaskManagerOptions.TOTAL_PROCESS_MEMORY` for containerized setups.
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_HOSTNAME_KEY use `TaskManagerOptions.HOST` instead
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_INITIAL_REGISTRATION_PAUSE use `ClusterOptions.INITIAL_REGISTRATION_TIMEOUT` instead
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_IPC_PORT_KEY use `TaskManagerOptions.RPC_PORT` instead
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_LOG_PATH_KEY Use `TaskManagerOptions.TASK_MANAGER_LOG_PATH` instead.
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_MAX_REGISTARTION_PAUSE use `ClusterOptions.MAX_REGISTRATION_TIMEOUT` instead
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_MAX_REGISTRATION_DURATION use `TaskManagerOptions.REGISTRATION_TIMEOUT` instead
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_MEMORY_FRACTION_KEY has no effect
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_MEMORY_OFF_HEAP_KEY has no effect
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_MEMORY_PRE_ALLOCATE_KEY has no effect
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_MEMORY_SEGMENT_SIZE_KEY Use `TaskManagerOptions.MEMORY_SEGMENT_SIZE` instead
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_MEMORY_SIZE_KEY Use `TaskManagerOptions.MANAGED_MEMORY_SIZE` instead
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_NETWORK_DEFAULT_IO_MODE Not used anymore
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_NETWORK_NUM_BUFFERS_KEY Use `NettyShuffleEnvironmentOptions.NETWORK_NUM_BUFFERS` instead
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_NUM_TASK_SLOTS use `TaskManagerOptions.NUM_TASK_SLOTS` instead
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_REFUSED_REGISTRATION_PAUSE use `ClusterOptions.REFUSED_REGISTRATION_DELAY` instead
org.apache.flink.configuration.ResourceManagerOptions.TASK_MANAGER_RELEASE_WHEN_RESULT_CONSUMED The default value should be reasonable enough in all cases, this option is to fallback to older behaviour which will be removed or refactored in future.
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_TMP_DIR_KEY Use `CoreOptions.TMP_DIRS` instead
org.apache.flink.runtime.rest.messages.JobVertexTaskManagersInfo.TaskManagersInfo.TASK_MANAGERS_FIELD_HOST
org.apache.flink.streaming.api.environment.StreamPipelineOptions.TIME_CHARACTERISTIC In Flink 1.12 the default stream time characteristic has been changed to `TimeCharacteristic.EventTime`, thus you don't need to set this option for enabling event-time support anymore. Explicitly using processing-time windows and timers works in event-time mode. If you need to disable watermarks, please set `PipelineOptions.AUTO_WATERMARK_INTERVAL` to 0. If you are using `TimeCharacteristic.IngestionTime`, please manually set an appropriate `WatermarkStrategy`. If you are using generic "time window" operations (for example `KeyedStream.timeWindow(org.apache.flink.streaming.api.windowing.time.Time)` that change behaviour based on the time characteristic, please use equivalent operations that explicitly specify processing time or event time.
org.apache.flink.table.codesplit.JavaParser.tokenNames Use `JavaParser.VOCABULARY` instead.
org.apache.flink.table.codesplit.JavaLexer.tokenNames Use `JavaLexer.VOCABULARY` instead.
org.apache.flink.table.codesplit.JavaLexer.tokenNames Use `JavaLexer.VOCABULARY` instead.
org.apache.flink.table.codesplit.JavaParser.tokenNames Use `JavaParser.VOCABULARY` instead.
org.apache.flink.streaming.api.environment.CheckpointConfig.UNDEFINED_TOLERABLE_CHECKPOINT_NUMBER This field is no longer used.
org.apache.flink.configuration.ConfigConstants.USE_LARGE_RECORD_HANDLER_KEY use `AlgorithmOptions.USE_LARGE_RECORDS_HANDLER`
org.apache.flink.table.api.dataview.MapView.valueType
org.apache.flink.configuration.AkkaOptions.WATCH_HEARTBEAT_INTERVAL Don't use this option anymore. It has no effect on Flink.
org.apache.flink.configuration.AkkaOptions.WATCH_HEARTBEAT_PAUSE Don't use this option anymore. It has no effect on Flink.
org.apache.flink.configuration.AkkaOptions.WATCH_THRESHOLD Don't use this option anymore. It has no effect on Flink.
org.apache.flink.configuration.ConfigConstants.YARN_APPLICATION_ATTEMPTS in favor of `YarnConfigOptions#APPLICATION_ATTEMPTS`.
org.apache.flink.configuration.ConfigConstants.YARN_APPLICATION_MASTER_ENV_PREFIX Please use `CONTAINERIZED_MASTER_ENV_PREFIX`.
org.apache.flink.configuration.ConfigConstants.YARN_APPLICATION_MASTER_PORT in favor of `YarnConfigOptions#APPLICATION_MASTER_PORT`.
org.apache.flink.configuration.ConfigConstants.YARN_APPLICATION_TAGS in favor of `YarnConfigOptions#APPLICATION_TAGS`.
org.apache.flink.configuration.ConfigConstants.YARN_CONTAINER_START_COMMAND_TEMPLATE in favor of `YarnConfigOptions#YARN_CONTAINER_START_COMMAND_TEMPLATE`.
org.apache.flink.client.cli.CliFrontendParser.YARN_DETACHED_OPTION use non-prefixed variant `CliFrontendParser.DETACHED_OPTION` for both YARN and non-YARN deployments
org.apache.flink.configuration.ConfigConstants.YARN_HEAP_CUTOFF_MIN Not used anymore, but remain here until Flink 2.0
org.apache.flink.configuration.ConfigConstants.YARN_HEAP_CUTOFF_RATIO Not used anymore, but remain here until Flink 2.0
org.apache.flink.configuration.ConfigConstants.YARN_HEARTBEAT_DELAY_SECONDS in favor of `YarnConfigOptions#HEARTBEAT_DELAY_SECONDS`.
org.apache.flink.configuration.ConfigConstants.YARN_MAX_FAILED_CONTAINERS in favor of `YarnConfigOptions#MAX_FAILED_CONTAINERS`.
org.apache.flink.configuration.ConfigConstants.YARN_PROPERTIES_FILE_LOCATION in favor of `YarnConfigOptions#PROPERTIES_FILE_LOCATION`.
org.apache.flink.configuration.ConfigConstants.YARN_REALLOCATE_FAILED_CONTAINERS Not used anymore
org.apache.flink.configuration.ConfigConstants.YARN_TASK_MANAGER_ENV_PREFIX Please use `CONTAINERIZED_TASK_MANAGER_ENV_PREFIX`.
org.apache.flink.configuration.ConfigConstants.YARN_VCORES in favor of `YarnConfigOptions#VCORES`.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_CHECKPOINT_COUNTER_PATH Deprecated in favour of `ConfigConstants.HA_ZOOKEEPER_CHECKPOINT_COUNTER_PATH`.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_CHECKPOINTS_PATH Deprecated in favour of `ConfigConstants.HA_ZOOKEEPER_CHECKPOINTS_PATH`.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_CONNECTION_TIMEOUT Deprecated in favour of `ConfigConstants.HA_ZOOKEEPER_CONNECTION_TIMEOUT`.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_DIR_KEY Deprecated in favour of `ConfigConstants.HA_ZOOKEEPER_DIR_KEY`.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_JOBGRAPHS_PATH Deprecated in favour of `ConfigConstants.HA_ZOOKEEPER_JOBGRAPHS_PATH`.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_LATCH_PATH Deprecated in favour of `ConfigConstants.HA_ZOOKEEPER_LATCH_PATH`.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_LEADER_PATH Deprecated in favour of `ConfigConstants.HA_ZOOKEEPER_LEADER_PATH`.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_MAX_RETRY_ATTEMPTS Deprecated in favour of `ConfigConstants.HA_ZOOKEEPER_MAX_RETRY_ATTEMPTS`.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_MESOS_WORKERS_PATH has no effect
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_NAMESPACE_KEY Deprecated in favour of `ConfigConstants.HA_ZOOKEEPER_NAMESPACE_KEY`.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_QUORUM_KEY Deprecated in favour of `ConfigConstants.HA_ZOOKEEPER_QUORUM_KEY`.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_RECOVERY_PATH Deprecated in favour of `ConfigConstants.HA_ZOOKEEPER_STORAGE_PATH`.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_RETRY_WAIT Deprecated in favour of `ConfigConstants.HA_ZOOKEEPER_RETRY_WAIT`.
org.apache.flink.configuration.HighAvailabilityOptions.ZOOKEEPER_RUNNING_JOB_REGISTRY_PATH Don't use this option anymore. It has no effect on Flink.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_SASL_DISABLE in favor of `SecurityOptions.ZOOKEEPER_SASL_DISABLE`.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_SASL_SERVICE_NAME in favor of `SecurityOptions.ZOOKEEPER_SASL_SERVICE_NAME`.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_SESSION_TIMEOUT Deprecated in favour of `ConfigConstants.HA_ZOOKEEPER_SESSION_TIMEOUT`.

Deprecated Methods
Method and Description
org.apache.flink.api.common.ExecutionConfig.addDefaultKryoSerializer(Class<?>, Class<? extends Serializer<?>>) Register data types and serializers through hard codes is deprecated, because you need to modify the codes when upgrading job version. You should configure this by config option `PipelineOptions.SERIALIZATION_CONFIG`.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addDefaultKryoSerializer(Class<?>, Class<? extends Serializer<?>>) Register data types and serializers through hard codes is deprecated, because you need to modify the codes when upgrading job version. You should configure this by config option `PipelineOptions.SERIALIZATION_CONFIG`.
org.apache.flink.api.common.ExecutionConfig.addDefaultKryoSerializer(Class<?>, T) Register data types and serializers through hard codes is deprecated, because you need to modify the codes when upgrading job version. You should configure this by config option `PipelineOptions.SERIALIZATION_CONFIG`.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addDefaultKryoSerializer(Class<?>, T) Register data types and serializers through hard codes is deprecated, because you need to modify the codes when upgrading job version. Instance-type serializer definition where serializers are serialized and written into the snapshot and deserialized for use is deprecated as well. Use class-type serializer definition by `PipelineOptions.SERIALIZATION_CONFIG` instead, where only the class name is written into the snapshot and new instance of the serializer is created for use. This is a breaking change, and it will be removed in Flink 2.0.
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.addDynamicPartitions(long, long, String, String, List<String>)
org.apache.flink.api.common.operators.DualInputOperator.addFirstInput(Operator<IN1>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.DualInputOperator.addFirstInputs(List<Operator<IN1>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.SingleInputOperator.addInput(List<Operator<IN>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.addInput(Operator<IN>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.SingleInputOperator.addInput(Operator<IN>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.addInputs(List<? extends Operator<IN>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.DualInputOperator.addSecondInput(Operator<IN2>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.DualInputOperator.addSecondInputs(List<Operator<IN2>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addSource(SourceFunction<OUT>) This method relies on the `SourceFunction` API, which is due to be removed. Use the `StreamExecutionEnvironment.fromSource(Source, WatermarkStrategy, String)` method based on the new `Source` API instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addSource(SourceFunction<OUT>, String) This method relies on the `SourceFunction` API, which is due to be removed. Use the `StreamExecutionEnvironment.fromSource(Source, WatermarkStrategy, String)` method based on the new `Source` API instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addSource(SourceFunction<OUT>, String, TypeInformation<OUT>) This method relies on the `SourceFunction` API, which is due to be removed. Use the `StreamExecutionEnvironment.fromSource(Source, WatermarkStrategy, String, TypeInformation)` method based on the new `Source` API instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addSource(SourceFunction<OUT>, TypeInformation<OUT>) This method relies on the `SourceFunction` API, which is due to be removed. Use the `StreamExecutionEnvironment.fromSource(Source, WatermarkStrategy, String, TypeInformation)` method based on the new `Source` API instead.
org.apache.calcite.tools.RelBuilder.aggregateCall(SqlAggFunction, boolean, boolean, RexNode, String, Iterable<? extends RexNode>)
org.apache.calcite.tools.RelBuilder.aggregateCall(SqlAggFunction, boolean, boolean, RexNode, String, RexNode...)
org.apache.calcite.tools.RelBuilder.aggregateCall(SqlAggFunction, boolean, RexNode, String, Iterable<? extends RexNode>)
org.apache.calcite.tools.RelBuilder.aggregateCall(SqlAggFunction, boolean, RexNode, String, RexNode...)
org.apache.flink.streaming.api.datastream.AllWindowedStream.allowedLateness(Time) Use `AllWindowedStream.allowedLateness(Duration)`, instead.
org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow.allowedLateness(Time) Use `JoinedStreams.WithWindow.allowedLateness(Duration)`.
org.apache.flink.streaming.api.datastream.WindowedStream.allowedLateness(Time) Use `WindowedStream.allowedLateness(Duration)`
org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithWindow.allowedLateness(Time) Use `CoGroupedStreams.WithWindow.allowedLateness(Duration)`
org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorBuilder.allowedLateness(Time) Use `WindowOperatorBuilder.allowedLateness(Duration)`.
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.appendPartition(String, String, List<String>, EnvironmentContext)
org.apache.flink.streaming.api.datastream.AllWindowedStream.apply(ReduceFunction<T>, AllWindowFunction<T, R, W>) Use `AllWindowedStream.reduce(ReduceFunction, AllWindowFunction)` instead.
org.apache.flink.streaming.api.datastream.AllWindowedStream.apply(ReduceFunction<T>, AllWindowFunction<T, R, W>, TypeInformation<R>) Use `AllWindowedStream.reduce(ReduceFunction, AllWindowFunction, TypeInformation)` instead.
org.apache.flink.streaming.api.datastream.WindowedStream.apply(ReduceFunction<T>, WindowFunction<T, R, K, W>) Use `WindowedStream.reduce(ReduceFunction, WindowFunction)` instead.
org.apache.flink.streaming.api.datastream.WindowedStream.apply(ReduceFunction<T>, WindowFunction<T, R, K, W>, TypeInformation<R>) Use `WindowedStream.reduce(ReduceFunction, WindowFunction, TypeInformation)` instead.
org.apache.flink.table.connector.source.abilities.SupportsProjectionPushDown.applyProjection(int[][]) Please implement `SupportsProjectionPushDown.applyProjection(int[][], DataType)`
org.apache.flink.table.api.Table.as(Expression...) use `Table.as(String, String...)`
org.apache.flink.streaming.api.datastream.KeyedStream.asQueryableState(String) The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.
org.apache.flink.streaming.api.datastream.KeyedStream.asQueryableState(String, ReducingStateDescriptor<T>) The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.
org.apache.flink.streaming.api.datastream.KeyedStream.asQueryableState(String, ValueStateDescriptor<T>) The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.
org.apache.flink.streaming.api.datastream.DataStream.assignTimestampsAndWatermarks(AssignerWithPeriodicWatermarks<T>) Please use `DataStream.assignTimestampsAndWatermarks(WatermarkStrategy)` instead.
org.apache.flink.streaming.api.datastream.DataStream.assignTimestampsAndWatermarks(AssignerWithPunctuatedWatermarks<T>) Please use `DataStream.assignTimestampsAndWatermarks(WatermarkStrategy)` instead.
org.apache.flink.streaming.api.datastream.KeyedStream.IntervalJoin.between(Time, Time) Use `KeyedStream.IntervalJoin.between(Duration, Duration)`
org.apache.flink.state.api.OperatorTransformation.bootstrapWith(DataSet<T>) use `OperatorTransformation.bootstrapWith(DataStream)` to bootstrap a savepoint using the data stream api under batch execution.
org.apache.flink.api.common.ExecutionConfig.canEqual(Object) It is not intended to be used by users.
org.apache.flink.table.api.internal.BaseExpressions.cast(TypeInformation<?>) This method will be removed in future versions as it uses the old type system. It is recommended to use `BaseExpressions.cast(DataType)` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.api.java.utils.DataSetUtils.checksumHashCode(DataSet<T>) This method will be removed at some point.
org.apache.flink.streaming.api.datastream.DataStreamUtils.collect(DataStream<OUT>) Please use `DataStream.executeAndCollect()`.
org.apache.flink.streaming.api.datastream.DataStreamUtils.collect(DataStream<OUT>, String) Please use `DataStream.executeAndCollect()`.
org.apache.flink.streaming.api.datastream.DataStreamUtils.collectBoundedStream(DataStream<E>, String) Please use `DataStream.executeAndCollect()`.
org.apache.flink.streaming.api.datastream.DataStreamUtils.collectRecordsFromUnboundedStream(ClientAndIterator<E>, int) Please use `DataStream.executeAndCollect()`.
org.apache.flink.streaming.api.datastream.DataStreamUtils.collectUnboundedStream(DataStream<E>, int, String) Please use `DataStream.executeAndCollect()`.
org.apache.flink.streaming.api.datastream.DataStreamUtils.collectWithClient(DataStream<OUT>, String) Please use `DataStream.executeAndCollect()`.
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.compact(String, String, String, CompactionType)
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.compact(String, String, String, CompactionType, Map<String, String>)
org.apache.flink.table.sinks.TableSink.configure(String[], TypeInformation<?>[]) This method will be dropped in future versions. It is recommended to pass a static schema when instantiating the sink instead.
org.apache.flink.table.connector.sink.DataStreamSinkProvider.consumeDataStream(DataStream<RowData>) Use `DataStreamSinkProvider.consumeDataStream(ProviderContext, DataStream)` and correctly set a unique identifier for each data stream transformation.
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.DefaultRollingPolicy.create()
org.apache.flink.core.fs.FileSystem.create(Path, boolean) Use `FileSystem.create(Path, WriteMode)` instead.
org.apache.flink.core.fs.LimitedConnectionsFileSystem.create(Path, boolean, int, short, long)
org.apache.flink.core.fs.FileSystem.create(Path, boolean, int, short, long) Deprecated because not well supported across types of file systems. Control the behavior of specific file systems via configurations instead.
org.apache.flink.table.factories.CatalogFactory.createCatalog(String, Map<String, String>) Use `this#createCatalog(Context)` instead and implement `Factory` instead of `TableFactory`.
org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink.createCommitter() Please use `TwoPhaseCommittingSink.createCommitter(CommitterInitContext)`
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(DynamicTableSinkFactory, ObjectIdentifier, ResolvedCatalogTable, ReadableConfig, ClassLoader, boolean) Use `FactoryUtil.createDynamicTableSink(DynamicTableSinkFactory, ObjectIdentifier, ResolvedCatalogTable, Map, ReadableConfig, ClassLoader, boolean)`
org.apache.flink.table.factories.FactoryUtil.createDynamicTableSource(DynamicTableSourceFactory, ObjectIdentifier, ResolvedCatalogTable, ReadableConfig, ClassLoader, boolean) Use `FactoryUtil.createDynamicTableSource(DynamicTableSourceFactory, ObjectIdentifier, ResolvedCatalogTable, Map, ReadableConfig, ClassLoader, boolean)`
org.apache.flink.table.factories.FunctionDefinitionFactory.createFunctionDefinition(String, CatalogFunction) Please implement `FunctionDefinitionFactory.createFunctionDefinition(String, CatalogFunction, Context)` instead.
org.apache.flink.api.java.typeutils.RowTypeInfo.createLegacySerializer(SerializerConfig)
org.apache.flink.table.factories.ModuleFactory.createModule(Map<String, String>) Use `ModuleFactory.createModule(Context)` instead and implement `Factory` instead of `TableFactory`.
org.apache.flink.api.java.typeutils.PojoTypeInfo.createPojoSerializer(ExecutionConfig)
org.apache.flink.api.common.typeinfo.NothingTypeInfo.createSerializer(ExecutionConfig)
org.apache.flink.api.common.typeinfo.TypeInformation.createSerializer(ExecutionConfig) This method is deprecated since Flink 1.19 and will be removed in Flink 1.20. The users are recommended to implement `TypeInformation.createSerializer(SerializerConfig config)`. If you implement `TypeInformation.createSerializer(SerializerConfig)`, this method will never be invoked. If you don't implement `TypeInformation.createSerializer(SerializerConfig)`, this method will be invoked in the default implementation of `TypeInformation.createSerializer(SerializerConfig)`.
org.apache.flink.api.common.typeinfo.BasicTypeInfo.createSerializer(ExecutionConfig)
org.apache.flink.api.common.typeinfo.BasicArrayTypeInfo.createSerializer(ExecutionConfig)
org.apache.flink.api.java.typeutils.WritableTypeInfo.createSerializer(ExecutionConfig)
org.apache.flink.api.java.typeutils.ValueTypeInfo.createSerializer(ExecutionConfig)
org.apache.flink.api.java.typeutils.ObjectArrayTypeInfo.createSerializer(ExecutionConfig)
org.apache.flink.api.java.typeutils.PojoTypeInfo.createSerializer(ExecutionConfig)
org.apache.flink.api.java.typeutils.TupleTypeInfo.createSerializer(ExecutionConfig)
org.apache.flink.api.java.typeutils.EitherTypeInfo.createSerializer(ExecutionConfig)
org.apache.flink.api.java.typeutils.GenericTypeInfo.createSerializer(ExecutionConfig)
org.apache.flink.api.java.typeutils.EnumTypeInfo.createSerializer(ExecutionConfig)
org.apache.flink.runtime.state.VoidNamespaceTypeInfo.createSerializer(ExecutionConfig)
org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecTableSourceScan.createSourceFunctionTransformation(StreamExecutionEnvironment, SourceFunction<RowData>, boolean, String, TypeInformation<RowData>, int, boolean) This method relies on the `SourceFunction` API, which is due to be removed.
org.apache.flink.table.factories.StreamTableSinkFactory.createStreamTableSink(Map<String, String>) `Context` contains more information, and already contains table schema too. Please use `TableSinkFactory.createTableSink(Context)` instead.
org.apache.flink.table.factories.StreamTableSourceFactory.createStreamTableSource(Map<String, String>) `Context` contains more information, and already contains table schema too. Please use `TableSourceFactory.createTableSource(Context)` instead.
org.apache.flink.table.factories.FactoryUtil.createTableSink(Catalog, ObjectIdentifier, ResolvedCatalogTable, ReadableConfig, ClassLoader, boolean) Use `FactoryUtil.createDynamicTableSink(DynamicTableSinkFactory, ObjectIdentifier, ResolvedCatalogTable, Map, ReadableConfig, ClassLoader, boolean)` instead.
org.apache.flink.table.factories.TableSinkFactory.createTableSink(Map<String, String>) `TableSinkFactory.Context` contains more information, and already contains table schema too. Please use `TableSinkFactory.createTableSink(Context)` instead.
org.apache.flink.table.factories.TableSinkFactory.createTableSink(ObjectPath, CatalogTable) `TableSinkFactory.Context` contains more information, and already contains table schema too. Please use `TableSinkFactory.createTableSink(Context)` instead.
org.apache.flink.table.factories.FactoryUtil.createTableSource(Catalog, ObjectIdentifier, ResolvedCatalogTable, ReadableConfig, ClassLoader, boolean) Use `FactoryUtil.createDynamicTableSource(DynamicTableSourceFactory, ObjectIdentifier, ResolvedCatalogTable, Map, ReadableConfig, ClassLoader, boolean)` instead.
org.apache.flink.table.factories.TableSourceFactory.createTableSource(Map<String, String>) `TableSourceFactory.Context` contains more information, and already contains table schema too. Please use `TableSourceFactory.createTableSource(Context)` instead.
org.apache.flink.table.factories.TableSourceFactory.createTableSource(ObjectPath, CatalogTable) `TableSourceFactory.Context` contains more information, and already contains table schema too. Please use `TableSourceFactory.createTableSource(Context)` instead.
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.createTemporaryView(String, DataStream<T>, Expression...) Use `StreamTableEnvironment.createTemporaryView(String, DataStream, Schema)` instead. In most cases, `StreamTableEnvironment.createTemporaryView(String, DataStream)` should already be sufficient. It integrates with the new type system and supports all kinds of `DataTypes` that the table runtime can consume. The semantics might be slightly different for raw and structured types.
org.apache.flink.api.connector.sink2.Sink.createWriter(Sink.InitContext) Please implement `Sink.createWriter(WriterInitContext)`. For backward compatibility reasons - to keep `Sink` a functional interface - Flink did not provide a default implementation. New `Sink` implementations should implement this method, but it will not be used, and it will be removed in 1.20.0 release. Do not use `Override` annotation when implementing this method, to prevent compilation errors when migrating to 1.20.x release.
org.apache.calcite.sql2rel.RelDecorrelator.decorrelateQuery(RelNode)
org.apache.flink.configuration.ConfigOptions.OptionBuilder.defaultValue(T) define the type explicitly first with one of the intType(), stringType(), etc.
org.apache.flink.client.deployment.ClusterDescriptor.deployJobCluster(ClusterSpecification, JobGraph, boolean) Per-job mode has been deprecated in Flink 1.15 and will be removed in the future. Please use application mode instead.
org.apache.flink.configuration.ConfigOption.deprecatedKeys() Replaced by `ConfigOption.fallbackKeys()`
org.apache.flink.table.descriptors.SchemaValidator.deriveTableSinkSchema(DescriptorProperties) This method combines two separate concepts of table schema and field mapping. This should be split into two methods once we have support for the corresponding interfaces (see FLINK-9870).
org.apache.flink.api.common.ExecutionConfig.disableAutoTypeRegistration() The method is deprecated because it's only used in DataSet API. All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.common.ExecutionConfig.disableForceAvro() Configure serialization behavior through hard codes is deprecated, because you need to modify the codes when upgrading job version. You should configure this by config option `PipelineOptions.FORCE_AVRO`.
org.apache.flink.api.common.ExecutionConfig.disableForceKryo() Configure serialization behavior through hard codes is deprecated, because you need to modify the codes when upgrading job version. You should configure this by config option `PipelineOptions.FORCE_KRYO`.
org.apache.flink.api.common.ExecutionConfig.disableGenericTypes() Configure serialization behavior through hard codes is deprecated, because you need to modify the codes when upgrading job version. You should configure this by config option `PipelineOptions.GENERIC_TYPES`.
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.dropPartition(String, String, List<String>)
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.dropPartition(String, String, List<String>, EnvironmentContext)
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.dropPartition(String, String, String, boolean, EnvironmentContext)
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.enableCheckpointing() Use `StreamExecutionEnvironment.enableCheckpointing(long)` instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.enableCheckpointing(long, CheckpointingMode, boolean) Use `StreamExecutionEnvironment.enableCheckpointing(long, CheckpointingMode)` instead. Forcing checkpoints will be removed in the future.
org.apache.calcite.sql2rel.SqlToRelConverter.enableDecorrelation()
org.apache.flink.streaming.api.environment.CheckpointConfig.enableExternalizedCheckpoints(CheckpointConfig.ExternalizedCheckpointCleanup) use `CheckpointConfig.setExternalizedCheckpointCleanup(ExternalizedCheckpointCleanup)` instead.
org.apache.flink.api.common.ExecutionConfig.enableForceAvro() Configure serialization behavior through hard codes is deprecated, because you need to modify the codes when upgrading job version. You should configure this by config option `PipelineOptions.FORCE_AVRO`.
org.apache.flink.api.common.ExecutionConfig.enableForceKryo() Configure serialization behavior through hard codes is deprecated, because you need to modify the codes when upgrading job version. You should configure this by config option `PipelineOptions.FORCE_KRYO`.
org.apache.flink.api.common.ExecutionConfig.enableGenericTypes() Configure serialization behavior through hard codes is deprecated, because you need to modify the codes when upgrading job version. You should configure this by config option `PipelineOptions.GENERIC_TYPES`.
org.apache.flink.api.common.restartstrategy.RestartStrategies.exponentialDelayRestart(Time, Time, double, Time, double) Use `RestartStrategies.exponentialDelayRestart(Duration, Duration, double, Duration, double)`
org.apache.flink.api.common.restartstrategy.RestartStrategies.failureRateRestart(int, Time, Time) Use `RestartStrategies.failureRateRestart(int, Duration, Duration)`
org.apache.flink.table.sources.CsvTableSource.Builder.field(String, TypeInformation<?>) This method will be removed in future versions as it uses the old type system. It is recommended to use `CsvTableSource.Builder.field(String, DataType)` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.api.TableSchema.Builder.field(String, TypeInformation<?>) This method will be removed in future versions as it uses the old type system. It is recommended to use `TableSchema.Builder.field(String, DataType)` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.descriptors.Schema.field(String, TypeInformation<?>) This method will be removed in future versions as it uses the old type system. Please use `Schema.field(String, DataType)` instead.
org.apache.flink.api.java.io.CsvReader.fieldDelimiter(char) Please use `CsvReader.fieldDelimiter(String)`.
org.apache.flink.api.common.io.FinalizeOnMaster.finalizeGlobal(int) Use `FinalizeOnMaster.finalizeGlobal(FinalizationContext)` instead.
org.apache.flink.api.common.restartstrategy.RestartStrategies.fixedDelayRestart(int, Time) Use `RestartStrategies.fixedDelayRestart(int, Duration)`
org.apache.flink.cep.PatternStream.flatSelect(PatternFlatTimeoutFunction<T, L>, PatternFlatSelectFunction<T, R>) Use `PatternStream.flatSelect(OutputTag, PatternFlatTimeoutFunction, PatternFlatSelectFunction)` that returns timed out events as a side-output
org.apache.flink.table.api.TableDescriptor.forManaged() This method will be removed soon. Please see FLIP-346 for more details.
org.apache.flink.connector.file.src.FileSource.forRecordFileFormat(FileRecordFormat<T>, Path...) Please use `FileSource.forRecordStreamFormat(StreamFormat, Path...)` instead.
org.apache.flink.formats.csv.CsvReaderFormat.forSchema(CsvMapper, CsvSchema, TypeInformation<T>) This method is limited to serializable `CsvMappers`, preventing the usage of certain Jackson modules (like the `Java 8 Date/Time Serializers`). Use `#forSchema(Supplier, Function, TypeInformation)` instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.fromCollection(Collection<OUT>) This method will be removed a future release, possibly as early as version 2.0. Use `StreamExecutionEnvironment.fromData(Collection)` instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.fromCollection(Collection<OUT>, TypeInformation<OUT>) This method will be removed a future release, possibly as early as version 2.0. Use `StreamExecutionEnvironment.fromData(Collection, TypeInformation)` instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.fromCollection(Iterator<OUT>, Class<OUT>) This method will be removed a future release, possibly as early as version 2.0. Use `StreamExecutionEnvironment.fromData(Collection, TypeInformation)` instead. For rate-limited data generation, use `DataGeneratorSource` with `RateLimiterStrategy`. If you need to use a fixed set of elements in such scenario, combine it with `FromElementsGeneratorFunction`.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.fromCollection(Iterator<OUT>, TypeInformation<OUT>) This method will be removed a future release, possibly as early as version 2.0. Use `StreamExecutionEnvironment.fromData(Collection, TypeInformation)` instead. For rate-limited data generation, use `DataGeneratorSource` with `RateLimiterStrategy`. If you need to use a fixed set of elements in such scenario, combine it with `FromElementsGeneratorFunction`.
org.apache.flink.table.api.EnvironmentSettings.fromConfiguration(ReadableConfig) use `EnvironmentSettings.Builder.withConfiguration(Configuration)` instead.
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.fromDataStream(DataStream<T>, Expression...) Use `StreamTableEnvironment.fromDataStream(DataStream, Schema)` instead. In most cases, `StreamTableEnvironment.fromDataStream(DataStream)` should already be sufficient. It integrates with the new type system and supports all kinds of `DataTypes` that the table runtime can consume. The semantics might be slightly different for raw and structured types.
org.apache.flink.table.types.utils.TypeConversions.fromDataTypeToLegacyInfo(DataType) Please don't use this method anymore. It will be removed soon and we should not make the removal more painful. Sources and sinks should use the method available in context to convert, within the planner you should use either `InternalTypeInfo` or `ExternalTypeInfo` depending on the use case.
org.apache.flink.table.types.utils.TypeConversions.fromDataTypeToLegacyInfo(DataType[]) Please don't use this method anymore. It will be removed soon and we should not make the removal more painful. Sources and sinks should use the method available in context to convert, within the planner you should use either `InternalTypeInfo` or `ExternalTypeInfo` depending on the use case.
org.apache.flink.table.runtime.types.LogicalTypeDataTypeConverter.fromDataTypeToLogicalType(DataType)
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.fromElements(Class<OUT>, OUT...) This method will be removed a future release, possibly as early as version 2.0. Use `#fromData(OUT...)` instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.fromElements(OUT...) This method will be removed a future release, possibly as early as version 2.0. Use `#fromData(OUT...)` instead.
org.apache.flink.state.api.SavepointWriter.fromExistingSavepoint(String) use `SavepointWriter.fromExistingSavepoint(StreamExecutionEnvironment, String)`
org.apache.flink.state.api.SavepointWriter.fromExistingSavepoint(String, StateBackend) use `SavepointWriter.fromExistingSavepoint(StreamExecutionEnvironment, String, StateBackend)`
org.apache.flink.api.common.JobExecutionResult.fromJobSubmissionResult(JobSubmissionResult) Will be removed in future versions.
org.apache.flink.table.types.utils.TypeConversions.fromLegacyInfoToDataType(TypeInformation<?>) Please don't use this method anymore. It will be removed soon and we should not make the removal more painful. Sources and sinks should use the method available in context to convert, within the planner you should use either `InternalTypeInfo` or `ExternalTypeInfo` depending on the use case.
org.apache.flink.table.types.utils.TypeConversions.fromLegacyInfoToDataType(TypeInformation<?>[]) Please don't use this method anymore. It will be removed soon and we should not make the removal more painful. Sources and sinks should use the method available in context to convert, within the planner you should use either `InternalTypeInfo` or `ExternalTypeInfo` depending on the use case.
org.apache.flink.table.runtime.types.LogicalTypeDataTypeConverter.fromLogicalTypeToDataType(LogicalType)
org.apache.flink.table.api.internal.TableEnvironmentInternal.fromTableSource(TableSource<?>)
org.apache.flink.table.api.TableSchema.fromTypeInfo(TypeInformation<?>) This method will be removed soon. Use `DataTypes` to declare types.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.generateSequence(long, long) Use `StreamExecutionEnvironment.fromSequence(long, long)` instead to create a new data stream that contains `NumberSequenceSource`.
org.apache.flink.table.functions.ImperativeAggregateFunction.getAccumulatorType() This method uses the old type system and is based on the old reflective extraction logic. The method will be removed in future versions and is only called when using the deprecated `TableEnvironment.registerFunction(...)` method. The new reflective extraction logic (possibly enriched with `DataTypeHint` and `FunctionHint`) should be powerful enough to cover most use cases. For advanced users, it is possible to override `UserDefinedFunction.getTypeInference(DataTypeFactory)`.
org.apache.flink.streaming.api.environment.CheckpointConfig.getAlignmentTimeout() User `CheckpointConfig.getAlignedCheckpointTimeout()` instead.
org.apache.flink.api.common.functions.RuntimeContext.getAttemptNumber() This method is deprecated since Flink 1.19. All metadata about the task should be provided uniformly by `RuntimeContext.getTaskInfo()`.
org.apache.flink.api.connector.sink2.InitContext.getAttemptNumber() This method is deprecated since Flink 1.19. All metadata about the task should be provided uniformly by `InitContext.getTaskInfo()`.
org.apache.flink.runtime.state.filesystem.FsStateBackend.getBasePath() Deprecated in favor of `FsStateBackend.getCheckpointPath()`.
org.apache.flink.configuration.Configuration.getBoolean(ConfigOption<Boolean>) use `Configuration.get(ConfigOption)` or `Configuration.getOptional(ConfigOption)`
org.apache.flink.configuration.Configuration.getBoolean(ConfigOption<Boolean>, boolean) use `Configuration.get(ConfigOption, Object)`
org.apache.flink.configuration.Configuration.getBoolean(String, boolean) use `Configuration.get(ConfigOption)`, `Configuration.get(ConfigOption, Object)` or `Configuration.getOptional(ConfigOption)`
org.apache.flink.core.memory.DataOutputSerializer.getByteArray() Replaced by `DataOutputSerializer.getSharedBuffer()` for a better, safer name.
org.apache.flink.streaming.api.connector.sink2.CommittableMessage.getCheckpointId()
org.apache.flink.streaming.api.environment.CheckpointConfig.getCheckpointStorage() The method is marked as deprecated because starting from Flink 1.19, the usage of all complex Java objects related to configuration, including their getter and setter methods, should be replaced by ConfigOption. In a future major version of Flink, this method will be removed entirely. It is recommended to find which checkpoint storage is used by checkpoint storage ConfigOption. For more details on using ConfigOption for checkpoint storage configuration, please refer to the Flink documentation: Checkpoints
org.apache.flink.configuration.Configuration.getClass(String, Class<? extends T>, ClassLoader)
org.apache.flink.streaming.api.environment.RemoteStreamEnvironment.getClientConfiguration() This method is going to be removed in the next releases.
org.apache.flink.sql.parser.impl.SimpleCharStream.getColumn()
org.apache.flink.table.api.TableEnvironment.getCompletionHints(String, int) Will be removed in the next release
org.apache.flink.core.fs.LimitedConnectionsFileSystem.getDefaultBlockSize()
org.apache.flink.core.fs.FileSystem.getDefaultBlockSize() This value is no longer used and is meaningless.
org.apache.flink.table.runtime.types.ClassLogicalTypeConverter.getDefaultExternalClassForType(LogicalType)
org.apache.flink.api.common.ExecutionConfig.getDefaultInputDependencyConstraint() due to the deprecation of `InputDependencyConstraint`.
org.apache.flink.api.common.ExecutionConfig.getDefaultKryoSerializerClasses() Use `SerializerConfig.getDefaultKryoSerializerClasses()`.
org.apache.flink.api.common.ExecutionConfig.getDefaultKryoSerializers() Use `SerializerConfig.getDefaultKryoSerializers()`.
org.apache.flink.api.common.serialization.SerializerConfig.getDefaultKryoSerializers() The method is deprecated because `ExecutionConfig.SerializableSerializer` is deprecated.
org.apache.flink.streaming.api.windowing.assigners.WindowAssigner.getDefaultTrigger(StreamExecutionEnvironment) the method is deprecated since Flink 1.19 because `StreamExecutionEnvironment` is unused. Please use `getDefaultTrigger` and override this method with an empty body instead. 1. If you override `getDefaultTrigger()`, the `getDefaultTrigger()` will be invoked and the `getDefaultTrigger(StreamExecutionEnvironment env)` won't be invoked. 2. If you don't override `getDefaultTrigger()`, the `getDefaultTrigger(StreamExecutionEnvironment env)` will be invoked in the default implementation of the `getDefaultTrigger()`.
org.apache.flink.api.common.restartstrategy.RestartStrategies.FixedDelayRestartStrategyConfiguration.getDelayBetweenAttemptsInterval() Use `RestartStrategies.FixedDelayRestartStrategyConfiguration.getDurationBetweenAttempts()`
org.apache.flink.api.common.restartstrategy.RestartStrategies.FailureRateRestartStrategyConfiguration.getDelayBetweenAttemptsInterval() Use `RestartStrategies.FailureRateRestartStrategyConfiguration.getDurationBetweenAttempts()`
org.apache.flink.configuration.Configuration.getDouble(ConfigOption<Double>) use `Configuration.get(ConfigOption)` or `Configuration.getOptional(ConfigOption)`
org.apache.flink.configuration.Configuration.getDouble(ConfigOption<Double>, double) use `Configuration.get(ConfigOption, Object)`
org.apache.flink.configuration.Configuration.getDouble(String, double) use `Configuration.get(ConfigOption)`, `Configuration.get(ConfigOption, Object)` or `Configuration.getOptional(ConfigOption)`
org.apache.flink.api.common.functions.RuntimeContext.getExecutionConfig() This method has been deprecated and will be removed in the upcoming FLINK major version FLINK-2.0. Users relying on this method should migrate to alternative getter methods, such as `RuntimeContext.getGlobalJobParameters()` or `RuntimeContext.isObjectReuseEnabled()`.
org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext.getExecutionConfig()
org.apache.flink.state.api.runtime.SavepointRuntimeContext.getExecutionConfig()
org.apache.flink.api.common.ExecutionConfig.getExecutionMode() The `ExecutionMode` is deprecated because it's only used in DataSet APIs. All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.common.ExecutionConfig.getExecutionRetryDelay() Should no longer be used because it is subsumed by RestartStrategyConfiguration
org.apache.flink.api.common.restartstrategy.RestartStrategies.FailureRateRestartStrategyConfiguration.getFailureInterval() Use `RestartStrategies.FailureRateRestartStrategyConfiguration.getFailureIntervalDuration()`
org.apache.flink.table.sinks.TableSink.getFieldNames() Use the field names of `TableSink.getTableSchema()` instead.
org.apache.flink.table.api.TableSchema.getFieldType(int) This method will be removed in future versions as it uses the old type system. It is recommended to use `TableSchema.getFieldDataType(int)` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.api.TableSchema.getFieldType(String) This method will be removed in future versions as it uses the old type system. It is recommended to use `TableSchema.getFieldDataType(String)` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.sinks.TableSink.getFieldTypes() Use the field types of `TableSink.getTableSchema()` instead.
org.apache.flink.table.api.TableSchema.getFieldTypes() This method will be removed in future versions as it uses the old type system. It is recommended to use `TableSchema.getFieldDataTypes()` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.api.common.io.FileInputFormat.getFilePath() Please use getFilePaths() instead.
org.apache.flink.configuration.Configuration.getFloat(ConfigOption<Float>) use `Configuration.get(ConfigOption)` or `Configuration.getOptional(ConfigOption)`
org.apache.flink.configuration.Configuration.getFloat(ConfigOption<Float>, float) use `Configuration.get(ConfigOption, Object)`
org.apache.flink.configuration.Configuration.getFloat(String, float) use `Configuration.get(ConfigOption)`, `Configuration.get(ConfigOption, Object)` or `Configuration.getOptional(ConfigOption)`
org.apache.flink.runtime.rest.messages.job.SubtaskExecutionAttemptDetailsInfo.getHost()
org.apache.flink.api.common.functions.RuntimeContext.getIndexOfThisSubtask() This method is deprecated since Flink 1.19. All metadata about the task should be provided uniformly by `RuntimeContext.getTaskInfo()`.
org.apache.flink.api.common.restartstrategy.RestartStrategies.ExponentialDelayRestartStrategyConfiguration.getInitialBackoff() Use `RestartStrategies.ExponentialDelayRestartStrategyConfiguration.getInitialBackoffDuration()`
org.apache.calcite.sql2rel.SqlToRelConverter.getInSubqueryThreshold()
org.apache.flink.api.common.JobExecutionResult.getIntCounterResult(String) Will be removed in future versions. Use `JobExecutionResult.getAccumulatorResult(java.lang.String)` instead.
org.apache.flink.configuration.Configuration.getInteger(ConfigOption<Integer>) use `Configuration.get(ConfigOption)` or `Configuration.getOptional(ConfigOption)`
org.apache.flink.configuration.Configuration.getInteger(ConfigOption<Integer>, int) use `Configuration.get(ConfigOption, Object)`
org.apache.flink.configuration.Configuration.getInteger(String, int) use `Configuration.get(ConfigOption)`, `Configuration.get(ConfigOption, Object)` or `Configuration.getOptional(ConfigOption)`
org.apache.flink.api.common.functions.RuntimeContext.getJobId() This method is deprecated since Flink 1.19. All metadata about the job should be provided uniformly by `RuntimeContext.getJobInfo()`.
org.apache.flink.api.connector.sink2.InitContext.getJobId() This method is deprecated since Flink 1.19. All metadata about the job should be provided uniformly by `InitContext.getJobInfo()`.
org.apache.flink.core.failure.FailureEnricher.Context.getJobId() This method is deprecated since Flink 1.19. All metadata about the job should be provided uniformly by `FailureEnricher.Context.getJobInfo()`.
org.apache.flink.runtime.rest.handler.legacy.metrics.MetricStore.getJobManager() Use semantically equivalent `MetricStore.getJobManagerMetricStore()`.
org.apache.flink.runtime.highavailability.HighAvailabilityServices.getJobManagerLeaderRetriever(JobID) This method should only be used by the legacy code where the JobManager acts as the master.
org.apache.flink.core.failure.FailureEnricher.Context.getJobName() This method is deprecated since Flink 1.19. All metadata about the job should be provided uniformly by `FailureEnricher.Context.getJobInfo()`.
org.apache.flink.streaming.api.windowing.triggers.Trigger.TriggerContext.getKeyValueState(String, Class<S>, S) Use `Trigger.TriggerContext.getPartitionedState(StateDescriptor)`.
org.apache.flink.streaming.api.windowing.triggers.Trigger.TriggerContext.getKeyValueState(String, TypeInformation<S>, S) Use `Trigger.TriggerContext.getPartitionedState(StateDescriptor)`.
org.apache.flink.core.fs.FileSystem.getKind() this method is not used anymore.
org.apache.flink.sql.parser.impl.SimpleCharStream.getLine()
org.apache.flink.runtime.rest.messages.JobExceptionsInfoWithHistory.ExceptionInfo.getLocation()
org.apache.flink.connector.file.table.TableMetaStoreFactory.TableMetaStore.getLocationPath()
org.apache.flink.runtime.metrics.groups.FrontMetricGroup.getLogicalScope(CharacterFilter) work against the LogicalScopeProvider interface instead.
org.apache.flink.runtime.metrics.groups.FrontMetricGroup.getLogicalScope(CharacterFilter, char) work against the LogicalScopeProvider interface instead.
org.apache.flink.configuration.Configuration.getLong(ConfigOption<Long>) use `Configuration.get(ConfigOption)` or `Configuration.getOptional(ConfigOption)`
org.apache.flink.configuration.Configuration.getLong(ConfigOption<Long>, long) use `Configuration.get(ConfigOption, Object)`
org.apache.flink.configuration.Configuration.getLong(String, long) use `Configuration.get(ConfigOption)`, `Configuration.get(ConfigOption, Object)` or `Configuration.getOptional(ConfigOption)`
org.apache.flink.api.common.restartstrategy.RestartStrategies.ExponentialDelayRestartStrategyConfiguration.getMaxBackoff() Use `RestartStrategies.ExponentialDelayRestartStrategyConfiguration.getMaxBackoffDuration()`
org.apache.flink.table.api.TableConfig.getMaxIdleStateRetentionTime() use`getIdleStateRetention` instead.
org.apache.flink.table.planner.utils.TableConfigUtils.getMaxIdleStateRetentionTime(ReadableConfig)
org.apache.flink.api.common.functions.RuntimeContext.getMaxNumberOfParallelSubtasks() This method is deprecated since Flink 1.19. All metadata about the task should be provided uniformly by `RuntimeContext.getTaskInfo()`.
org.apache.flink.table.plan.stats.ColumnStats.getMaxValue()
org.apache.flink.runtime.io.network.buffer.Buffer.getMemorySegment()
org.apache.flink.runtime.io.network.buffer.Buffer.getMemorySegmentOffset()
org.apache.flink.table.api.TableConfig.getMinIdleStateRetentionTime() use`getIdleStateRetention` instead.
org.apache.flink.table.plan.stats.ColumnStats.getMinValue()
org.apache.flink.test.util.TestUtils.getMostRecentCompletedCheckpoint(File) please use `org.apache.flink.runtime.testutils.CommonTestUtils#getLatestCompletedCheckpointPath(JobID, MiniCluster)` which is less prone to `NoSuchFileException` and IO-intensive.
org.apache.flink.test.util.TestUtils.getMostRecentCompletedCheckpointMaybe(File) please use `org.apache.flink.runtime.testutils.CommonTestUtils#getLatestCompletedCheckpointPath(JobID, MiniCluster)` which is less prone to `NoSuchFileException` and IO-intensive.
org.apache.flink.api.common.ExecutionConfig.getNumberOfExecutionRetries() Should no longer be used because it is subsumed by RestartStrategyConfiguration
org.apache.flink.api.java.ExecutionEnvironment.getNumberOfExecutionRetries() This method will be replaced by `ExecutionEnvironment.getRestartStrategy()`. The `RestartStrategies.FixedDelayRestartStrategyConfiguration` contains the number of execution retries.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getNumberOfExecutionRetries() This method will be replaced by `StreamExecutionEnvironment.getRestartStrategy()`.
org.apache.flink.api.common.functions.RuntimeContext.getNumberOfParallelSubtasks() This method is deprecated since Flink 1.19. All metadata about the task should be provided uniformly by `RuntimeContext.getTaskInfo()`.
org.apache.flink.api.connector.sink2.InitContext.getNumberOfParallelSubtasks() This method is deprecated since Flink 1.19. All metadata about the task should be provided uniformly by `InitContext.getTaskInfo()`.
org.apache.flink.contrib.streaming.state.RocksDBStateBackend.getNumberOfTransferingThreads() Typo in method name. Use `RocksDBStateBackend.getNumberOfTransferThreads()` instead.
org.apache.flink.table.sinks.TableSink.getOutputType() This method will be removed in future versions as it uses the old type system. It is recommended to use `TableSink.getConsumedDataType()` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.functions.ScalarFunction.getParameterTypes(Class<?>[]) This method uses the old type system and is based on the old reflective extraction logic. The method will be removed in future versions and is only called when using the deprecated `TableEnvironment.registerFunction(...)` method. The new reflective extraction logic (possibly enriched with `DataTypeHint` and `FunctionHint`) should be powerful enough to cover most use cases. For advanced users, it is possible to override `UserDefinedFunction.getTypeInference(DataTypeFactory)`.
org.apache.flink.table.functions.TableFunction.getParameterTypes(Class<?>[]) This method uses the old type system and is based on the old reflective extraction logic. The method will be removed in future versions and is only called when using the deprecated `TableEnvironment.registerFunction(...)` method. The new reflective extraction logic (possibly enriched with `DataTypeHint` and `FunctionHint`) should be powerful enough to cover most use cases. For advanced users, it is possible to override `UserDefinedFunction.getTypeInference(DataTypeFactory)`.
org.apache.flink.api.common.state.StateDescriptor.getQueryableStateName() The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.
org.apache.flink.api.common.ExecutionConfig.getRegisteredKryoTypes() Use `SerializerConfig.getRegisteredKryoTypes()`.
org.apache.flink.api.common.ExecutionConfig.getRegisteredPojoTypes() Use `SerializerConfig.getRegisteredPojoTypes()`.
org.apache.flink.api.common.ExecutionConfig.getRegisteredTypesWithKryoSerializerClasses() Use `SerializerConfig.getRegisteredTypesWithKryoSerializerClasses()`.
org.apache.flink.api.common.ExecutionConfig.getRegisteredTypesWithKryoSerializers() Use `SerializerConfig.getRegisteredTypesWithKryoSerializers()`.
org.apache.flink.api.common.serialization.SerializerConfig.getRegisteredTypesWithKryoSerializers() The method is deprecated because instance-type Kryo serializer definition based on `ExecutionConfig.SerializableSerializer` is deprecated. Use class-type Kryo serializers instead.
org.apache.flink.api.common.restartstrategy.RestartStrategies.ExponentialDelayRestartStrategyConfiguration.getResetBackoffThreshold() Use `RestartStrategies.ExponentialDelayRestartStrategyConfiguration.getResetBackoffDurationThreshold()`
org.apache.flink.api.common.ExecutionConfig.getRestartStrategy() The method is marked as deprecated because starting from Flink 1.19, the usage of all complex Java objects related to configuration, including their getter and setter methods, should be replaced by ConfigOption. In a future major version of Flink, this method will be removed entirely. It is recommended to switch to using the ConfigOptions provided by `RestartStrategyOptions` for configuring restart strategies.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getRestartStrategy() The method is marked as deprecated because starting from Flink 1.19, the usage of all complex Java objects related to configuration, including their getter and setter methods, should be replaced by ConfigOption. In a future major version of Flink, this method will be removed entirely. It is recommended to switch to using the ConfigOptions provided by `RestartStrategyOptions` for configuring restart strategies.
org.apache.flink.table.functions.TableFunction.getResultType() This method uses the old type system and is based on the old reflective extraction logic. The method will be removed in future versions and is only called when using the deprecated `TableEnvironment.registerFunction(...)` method. The new reflective extraction logic (possibly enriched with `DataTypeHint` and `FunctionHint`) should be powerful enough to cover most use cases. For advanced users, it is possible to override `UserDefinedFunction.getTypeInference(DataTypeFactory)`.
org.apache.flink.table.functions.ImperativeAggregateFunction.getResultType() This method uses the old type system and is based on the old reflective extraction logic. The method will be removed in future versions and is only called when using the deprecated `TableEnvironment.registerFunction(...)` method. The new reflective extraction logic (possibly enriched with `DataTypeHint` and `FunctionHint`) should be powerful enough to cover most use cases. For advanced users, it is possible to override `UserDefinedFunction.getTypeInference(DataTypeFactory)`.
org.apache.flink.table.functions.ScalarFunction.getResultType(Class<?>[]) This method uses the old type system and is based on the old reflective extraction logic. The method will be removed in future versions and is only called when using the deprecated `TableEnvironment.registerFunction(...)` method. The new reflective extraction logic (possibly enriched with `DataTypeHint` and `FunctionHint`) should be powerful enough to cover most use cases. For advanced users, it is possible to override `UserDefinedFunction.getTypeInference(DataTypeFactory)`.
org.apache.flink.table.sources.TableSource.getReturnType() This method will be removed in future versions as it uses the old type system. It is recommended to use `TableSource.getProducedDataType()` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.api.Table.getSchema() This method has been deprecated as part of FLIP-164. `TableSchema` has been replaced by two more dedicated classes `Schema` and `ResolvedSchema`. Use `Schema` for declaration in APIs. `ResolvedSchema` is offered by the framework after resolution and validation.
org.apache.flink.table.catalog.CatalogBaseTable.getSchema() This method returns the deprecated `TableSchema` class. The old class was a hybrid of resolved and unresolved schema information. It has been replaced by the new `Schema` which is always unresolved and will be resolved by the framework later.
org.apache.flink.table.catalog.ResolvedCatalogBaseTable.getSchema() This method returns the deprecated `TableSchema` class. The old class was a hybrid of resolved and unresolved schema information. It has been replaced by the new `ResolvedSchema` which is resolved by the framework and accessible via `ResolvedCatalogBaseTable.getResolvedSchema()`.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getStateBackend() The method is marked as deprecated because starting from Flink 1.19, the usage of all complex Java objects related to configuration, including their getter and setter methods, should be replaced by ConfigOption. In a future major version of Flink, this method will be removed entirely. It is recommended to find which state backend is used by state backend ConfigOption. For more details on using ConfigOption for state backend configuration, please refer to the Flink documentation: state-backends
org.apache.flink.streaming.api.graph.StreamGraph.getStreamEdgesOrThrow(int, int)
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getStreamTimeCharacteristic() See `StreamExecutionEnvironment.setStreamTimeCharacteristic(TimeCharacteristic)` for deprecation notice.
org.apache.flink.configuration.Configuration.getString(ConfigOption<String>) use `Configuration.get(ConfigOption)` or `Configuration.getOptional(ConfigOption)`
org.apache.flink.configuration.Configuration.getString(ConfigOption<String>, String) use `Configuration.get(ConfigOption, Object)`
org.apache.flink.api.connector.sink2.InitContext.getSubtaskId() This method is deprecated since Flink 1.19. All metadata about the task should be provided uniformly by `InitContext.getTaskInfo()`.
org.apache.flink.table.catalog.Catalog.getTableFactory() Use `Catalog.getFactory()` for the new factory stack. The new factory stack uses the new table sources and sinks defined in FLIP-95 and a slightly different discovery mechanism.
org.apache.flink.table.sources.TableSource.getTableSchema() Table schema is a logical description of a table and should not be part of the physical TableSource. Define schema when registering a Table either in DDL or in `TableEnvironment#connect(...)`.
org.apache.flink.table.api.TableResult.getTableSchema() This method has been deprecated as part of FLIP-164. `TableSchema` has been replaced by two more dedicated classes `Schema` and `ResolvedSchema`. Use `Schema` for declaration in APIs. `ResolvedSchema` is offered by the framework after resolution and validation.
org.apache.flink.api.common.functions.RuntimeContext.getTaskName() This method is deprecated since Flink 1.19. All metadata about the task should be provided uniformly by `RuntimeContext.getTaskInfo()`.
org.apache.flink.api.common.functions.RuntimeContext.getTaskNameWithSubtasks() This method is deprecated since Flink 1.19. All metadata about the task should be provided uniformly by `RuntimeContext.getTaskInfo()`.
org.apache.flink.table.codesplit.JavaParser.getTokenNames()
org.apache.flink.table.codesplit.JavaLexer.getTokenNames()
org.apache.flink.table.codesplit.JavaLexer.getTokenNames()
org.apache.flink.table.codesplit.JavaParser.getTokenNames()
org.apache.flink.api.common.state.StateTtlConfig.getTtl() Use `StateTtlConfig.getTimeToLive()`
org.apache.flink.streaming.api.graph.StreamConfig.getTypeSerializerIn1(ClassLoader)
org.apache.flink.streaming.api.graph.StreamConfig.getTypeSerializerIn2(ClassLoader)
org.apache.flink.runtime.highavailability.HighAvailabilityServices.getWebMonitorLeaderElection() Use `HighAvailabilityServices.getClusterRestEndpointLeaderElection()` instead.
org.apache.flink.runtime.highavailability.HighAvailabilityServices.getWebMonitorLeaderRetriever() just use `HighAvailabilityServices.getClusterRestEndpointLeaderRetriever()` instead of this method.
org.apache.flink.cep.pattern.Quantifier.Times.getWindowTime() Use `Quantifier.Times.getWindowSize()`.
org.apache.flink.cep.pattern.Pattern.getWindowTime() Use `Pattern.getWindowSize()`
org.apache.flink.cep.pattern.Pattern.getWindowTime(WithinType) Use `Pattern.getWindowSize(WithinType)`.
org.apache.calcite.tools.RelBuilder.groupKey(ImmutableBitSet, boolean, ImmutableList<ImmutableBitSet>) Use `RelBuilder.groupKey(ImmutableBitSet, Iterable)`.
org.apache.calcite.tools.RelBuilder.groupKey(Iterable<? extends RexNode>, boolean, Iterable<? extends Iterable<? extends RexNode>>) Now that indicator is deprecated, use `RelBuilder.groupKey(Iterable, Iterable)`, which has the same behavior as calling this method with `indicator = false`.
org.apache.flink.configuration.ConfigOption.hasDeprecatedKeys() Replaced by `ConfigOption.hasFallbackKeys()`
org.apache.flink.api.common.ExecutionConfig.hasGenericTypesDisabled() Use `SerializerConfig.hasGenericTypesDisabled()`.
org.apache.flink.core.fs.FileSystem.initialize(Configuration) use `FileSystem.initialize(Configuration, PluginManager)` instead.
org.apache.flink.streaming.api.functions.sink.SinkFunction.invoke(IN) Use `SinkFunction.invoke(Object, Context)`.
org.apache.calcite.sql.validate.SqlValidatorImpl.isAggregate(SqlNode)
org.apache.flink.api.common.ExecutionConfig.isAutoTypeRegistrationDisabled() The method is deprecated because it's only used in DataSet API. All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.streaming.api.environment.CheckpointConfig.isFailOnCheckpointingErrors() Use `CheckpointConfig.getTolerableCheckpointFailureNumber()`.
org.apache.flink.api.common.ExecutionConfig.isForceAvroEnabled() Use `SerializerConfig.isForceAvroEnabled()`.
org.apache.flink.streaming.api.environment.CheckpointConfig.isForceCheckpointing() This will be removed once iterations properly participate in checkpointing.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.isForceCheckpointing() Forcing checkpoints will be removed in future version.
org.apache.flink.api.common.ExecutionConfig.isForceKryoEnabled() Use `SerializerConfig.isForceKryoEnabled()`.
org.apache.flink.table.catalog.CatalogFunction.isGeneric() There is no replacement for this function, as now functions have type inference strategies
org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot.isOuterSnapshotCompatible(S) this method is deprecated, and will be removed in the future. Please implement `CompositeTypeSerializerSnapshot.resolveOuterSchemaCompatibility(TypeSerializerSnapshot)` instead.
org.apache.flink.api.common.state.StateDescriptor.isQueryable() The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.
org.apache.flink.runtime.state.KeyedStateBackend.isStateImmutableInStateBackend(CheckpointType)
org.apache.calcite.sql2rel.SqlToRelConverter.isTrimUnusedFields()
org.apache.flink.streaming.api.datastream.DataStream.iterate() This method is deprecated since Flink 1.19. The only known use case of this Iteration API comes from Flink ML, which already has its own implementation of iteration and no longer uses this API. If there's any use cases other than Flink ML that needs iteration support, please reach out to dev@flink.apache.org and we can consider making the Flink ML iteration implementation a separate common library.
org.apache.flink.streaming.api.datastream.DataStream.iterate(long) This method is deprecated since Flink 1.19. The only known use case of this Iteration API comes from Flink ML, which already has its own implementation of iteration and no longer uses this API. If there's any use cases other than Flink ML that needs iteration support, please reach out to dev@flink.apache.org and we can consider making the Flink ML iteration implementation a separate common library.
org.apache.flink.streaming.api.datastream.DataStream.keyBy(int...) Use `DataStream.keyBy(KeySelector)`.
org.apache.flink.streaming.api.datastream.DataStream.keyBy(String...) Use `DataStream.keyBy(KeySelector)`.
org.apache.flink.table.planner.functions.casting.CodeGeneratorCastRule.Context.legacyBehaviour()
org.apache.flink.table.planner.functions.casting.CastRule.Context.legacyBehaviour()
org.apache.flink.table.utils.EncodingUtils.loadClass(String) Use `EncodingUtils.loadClass(String, ClassLoader)` instead, in order to explicitly provide the correct classloader.
org.apache.flink.api.common.io.DelimitedInputFormat.loadGlobalConfigParams() Please use `loadConfigParameters(Configuration config`
org.apache.flink.api.common.state.StateTtlConfig.newBuilder(Time) Use `StateTtlConfig.newBuilder(Duration)`
org.apache.flink.state.api.SavepointWriter.newSavepoint(int) use `SavepointWriter.newSavepoint(StreamExecutionEnvironment, int)`
org.apache.flink.state.api.SavepointWriter.newSavepoint(StateBackend, int) use `SavepointWriter.newSavepoint(StreamExecutionEnvironment, StateBackend, int)`
org.apache.flink.configuration.ConfigOptions.OptionBuilder.noDefaultValue() define the type explicitly first with one of the intType(), stringType(), etc.
org.apache.flink.table.api.Expressions.nullOf(TypeInformation<?>) This method will be removed in future versions as it uses the old type system. It is recommended to use `Expressions.nullOf(DataType)` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.cep.pattern.Quantifier.Times.of(int, int, Time) Use `Quantifier.Times.of(int, int, Duration)`
org.apache.flink.cep.pattern.Quantifier.Times.of(int, Time) Use `Quantifier.Times.of(int, Duration)`
org.apache.flink.table.api.TableColumn.of(String, DataType) Use `TableColumn.physical(String, DataType)` instead.
org.apache.flink.table.api.TableColumn.of(String, DataType, String) Use `TableColumn.computed(String, DataType, String)` instead.
org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows.of(Time) Use `TumblingEventTimeWindows.of(Duration)`
org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows.of(Time) Use `TumblingProcessingTimeWindows.of(Duration)`
org.apache.flink.streaming.api.windowing.evictors.TimeEvictor.of(Time) Use `TimeEvictor.of(Duration)`
org.apache.flink.streaming.api.windowing.triggers.ContinuousProcessingTimeTrigger.of(Time) Use `ContinuousProcessingTimeTrigger.of(Duration)`
org.apache.flink.streaming.api.windowing.triggers.ContinuousEventTimeTrigger.of(Time) Use `ContinuousEventTimeTrigger.of(Duration)`
org.apache.flink.streaming.api.windowing.evictors.TimeEvictor.of(Time, boolean) Use `TimeEvictor.of(Duration, boolean)`
org.apache.flink.streaming.api.windowing.assigners.SlidingEventTimeWindows.of(Time, Time) Use `SlidingEventTimeWindows.of(Duration, Duration)`
org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows.of(Time, Time) Use `TumblingEventTimeWindows.of(Duration, Duration)`
org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows.of(Time, Time) Use `TumblingProcessingTimeWindows.of(Duration, Duration)`
org.apache.flink.streaming.api.windowing.assigners.SlidingProcessingTimeWindows.of(Time, Time) `SlidingProcessingTimeWindows.of(Duration, Duration)`
org.apache.flink.streaming.api.windowing.assigners.SlidingEventTimeWindows.of(Time, Time, Time) Use `SlidingEventTimeWindows.of(Duration, Duration, Duration)`
org.apache.flink.streaming.api.windowing.assigners.SlidingProcessingTimeWindows.of(Time, Time, Time) Use `SlidingProcessingTimeWindows.of(Duration, Duration, Duration)`
org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows.of(Time, Time, WindowStagger) Use `TumblingEventTimeWindows.of(Duration, Duration, WindowStagger)`
org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows.of(Time, Time, WindowStagger) Use `TumblingProcessingTimeWindows.of(Duration, Duration, WindowStagger)`
org.apache.flink.cep.pattern.Pattern.oneOrMore(Time) Use `Pattern.oneOrMore(Duration)`
org.apache.flink.api.common.functions.RichFunction.open(Configuration) This method is deprecated since Flink 1.19. The users are recommended to implement `open(OpenContext openContext)` and implement `open(Configuration parameters)` with an empty body instead. 1. If you implement `open(OpenContext openContext)`, the `open(OpenContext openContext)` will be invoked and the `open(Configuration parameters)` won't be invoked. 2. If you don't implement `open(OpenContext openContext)`, the `open(Configuration parameters)` will be invoked in the default implementation of the `open(OpenContext openContext)`.
org.apache.flink.streaming.api.functions.source.MultipleIdsMessageAcknowledgingSourceBase.open(Configuration) This method is deprecated since Flink 1.19. The users are recommended to implement `open(OpenContext openContext)` and override `open(Configuration parameters)` with an empty body instead. 1. If you implement `open(OpenContext openContext)`, the `open(OpenContext openContext)` will be invoked and the `open(Configuration parameters)` won't be invoked. 2. If you don't implement `open(OpenContext openContext)`, the `open(Configuration parameters)` will be invoked in the default implementation of the `open(OpenContext openContext)`.
org.apache.flink.streaming.api.functions.source.FromSplittableIteratorFunction.open(Configuration) This method is deprecated since Flink 1.19. The users are recommended to implement `open(OpenContext openContext)` and override `open(Configuration parameters)` with an empty body instead. 1. If you implement `open(OpenContext openContext)`, the `open(OpenContext openContext)` will be invoked and the `open(Configuration parameters)` won't be invoked. 2. If you don't implement `open(OpenContext openContext)`, the `open(Configuration parameters)` will be invoked in the default implementation of the `open(OpenContext openContext)`.
org.apache.flink.streaming.api.functions.sink.SocketClientSink.open(Configuration) This method is deprecated since Flink 1.19. The users are recommended to implement `open(OpenContext openContext)` and override `open(Configuration parameters)` with an empty body instead. 1. If you implement `open(OpenContext openContext)`, the `open(OpenContext openContext)` will be invoked and the `open(Configuration parameters)` won't be invoked. 2. If you don't implement `open(OpenContext openContext)`, the `open(Configuration parameters)` will be invoked in the default implementation of the `open(OpenContext openContext)`.
org.apache.flink.streaming.api.functions.sink.PrintSinkFunction.open(Configuration) This method is deprecated since Flink 1.19. The users are recommended to implement `open(OpenContext openContext)` and override `open(Configuration parameters)` with an empty body instead. 1. If you implement `open(OpenContext openContext)`, the `open(OpenContext openContext)` will be invoked and the `open(Configuration parameters)` won't be invoked. 2. If you don't implement `open(OpenContext openContext)`, the `open(Configuration parameters)` will be invoked in the default implementation of the `open(OpenContext openContext)`.
org.apache.flink.streaming.api.functions.sink.OutputFormatSinkFunction.open(Configuration) This method is deprecated since Flink 1.19. The users are recommended to implement `open(OpenContext openContext)` and override `open(Configuration parameters)` with an empty body instead. 1. If you implement `open(OpenContext openContext)`, the `open(OpenContext openContext)` will be invoked and the `open(Configuration parameters)` won't be invoked. 2. If you don't implement `open(OpenContext openContext)`, the `open(Configuration parameters)` will be invoked in the default implementation of the `open(OpenContext openContext)`.
org.apache.flink.api.common.io.OutputFormat.open(int, int) Use `OutputFormat.open(InitializationContext)` instead
org.apache.flink.runtime.operators.hash.InMemoryPartition.overwriteRecordAt(long, T) Don't use this, overwrites record and causes inconsistency or data loss for overwriting everything but records of the exact same size
org.apache.flink.table.types.logical.utils.LogicalTypeParser.parse(String) You should use `LogicalTypeParser.parse(String, ClassLoader)` to correctly load user types
org.apache.flink.streaming.api.datastream.DataStream.partitionCustom(Partitioner<K>, int) use `DataStream.partitionCustom(Partitioner, KeySelector)`.
org.apache.flink.streaming.api.datastream.DataStream.partitionCustom(Partitioner<K>, String) use `DataStream.partitionCustom(Partitioner, KeySelector)`.
org.apache.flink.api.java.DataSet.print(String) Use `DataSet.printOnTaskManager(String)` instead.
org.apache.flink.api.java.DataSet.printToErr(String) Use `DataSet.printOnTaskManager(String)` instead, or the `PrintingOutputFormat`.
org.apache.flink.streaming.api.datastream.KeyedStream.process(ProcessFunction<T, R>) Use `KeyedStream.process(KeyedProcessFunction)`
org.apache.flink.streaming.api.datastream.KeyedStream.process(ProcessFunction<T, R>, TypeInformation<R>) Use `KeyedStream.process(KeyedProcessFunction, TypeInformation)`
org.apache.flink.table.connector.source.DataStreamScanProvider.produceDataStream(StreamExecutionEnvironment)
org.apache.flink.table.types.utils.DataTypeUtils.projectRow(DataType, int[]) Use the `Projection` type
org.apache.flink.table.types.utils.DataTypeUtils.projectRow(DataType, int[][]) Use the `Projection` type
org.apache.flink.core.fs.Path.read(DataInputView) the method is deprecated since Flink 1.19 because Path will no longer implement `IOReadableWritable` in future versions. Please use `deserializeFromDataInputView` instead.
org.apache.flink.state.api.SavepointReader.readBroadcastState(String, String, TypeInformation<K>, TypeInformation<V>) use `SavepointReader.readBroadcastState(OperatorIdentifier, String, TypeInformation, TypeInformation)`
org.apache.flink.state.api.SavepointReader.readBroadcastState(String, String, TypeInformation<K>, TypeInformation<V>, TypeSerializer<K>, TypeSerializer<V>) use `SavepointReader.readBroadcastState(OperatorIdentifier, String, TypeInformation, TypeInformation, TypeSerializer, TypeSerializer)`
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.readFile(FileInputFormat<OUT>, String) Use `FileSource#forRecordStreamFormat()/forBulkFileFormat()/forRecordFileFormat() instead`. An example of reading a file using a simple `TextLineInputFormat`: `FileSource<String> source = FileSource.forRecordStreamFormat( new TextLineInputFormat(), new Path("/foo/bar")) .build();`
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.readFile(FileInputFormat<OUT>, String, FileProcessingMode, long) Use `FileSource#forRecordStreamFormat()/forBulkFileFormat()/forRecordFileFormat() instead`. An example of reading a file using a simple `TextLineInputFormat`: `FileSource<String> source = FileSource.forRecordStreamFormat( new TextLineInputFormat(), new Path("/foo/bar")) .monitorContinuously(Duration.of(10, SECONDS)) .build();`
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.readFile(FileInputFormat<OUT>, String, FileProcessingMode, long, FilePathFilter) Use `FileInputFormat.setFilesFilter(FilePathFilter)` to set a filter and `StreamExecutionEnvironment.readFile(FileInputFormat, String, FileProcessingMode, long)`
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.readFile(FileInputFormat<OUT>, String, FileProcessingMode, long, TypeInformation<OUT>) Use `FileSource#forRecordStreamFormat()/forBulkFileFormat()/forRecordFileFormat() instead`. An example of reading a file using a simple `TextLineInputFormat`: `FileSource<String> source = FileSource.forRecordStreamFormat( new TextLineInputFormat(), new Path("/foo/bar")) .monitorContinuously(Duration.of(10, SECONDS)) .build();`
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.readFileStream(String, long, FileMonitoringFunction.WatchType) Use `StreamExecutionEnvironment.readFile(FileInputFormat, String, FileProcessingMode, long)` instead.
org.apache.flink.state.api.SavepointReader.readKeyedState(String, KeyedStateReaderFunction<K, OUT>) use `SavepointReader.readKeyedState(OperatorIdentifier, KeyedStateReaderFunction)`
org.apache.flink.state.api.SavepointReader.readKeyedState(String, KeyedStateReaderFunction<K, OUT>, TypeInformation<K>, TypeInformation<OUT>) use `SavepointReader.readKeyedState(OperatorIdentifier, KeyedStateReaderFunction, TypeInformation, TypeInformation)`
org.apache.flink.state.api.SavepointReader.readListState(String, String, TypeInformation<T>) use `SavepointReader.readListState(OperatorIdentifier, String, TypeInformation)`
org.apache.flink.state.api.SavepointReader.readListState(String, String, TypeInformation<T>, TypeSerializer<T>) use `SavepointReader.readListState(OperatorIdentifier, String, TypeInformation, TypeSerializer)`
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.readTextFile(String) Use `FileSource#forRecordStreamFormat()/forBulkFileFormat()/forRecordFileFormat() instead`. An example of reading a file using a simple `TextLineInputFormat`: `FileSource<String> source = FileSource.forRecordStreamFormat( new TextLineInputFormat(), new Path("/foo/bar")) .build();`
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.readTextFile(String, String) Use `FileSource#forRecordStreamFormat()/forBulkFileFormat()/forRecordFileFormat() instead`. An example of reading a file using a simple `TextLineInputFormat`: `FileSource<String> source = FileSource.forRecordStreamFormat( new TextLineInputFormat("UTF-8"), new Path("/foo/bar")) .build();`
org.apache.flink.state.api.SavepointReader.readUnionState(String, String, TypeInformation<T>) use `SavepointReader.readUnionState(OperatorIdentifier, String, TypeInformation)`
org.apache.flink.state.api.SavepointReader.readUnionState(String, String, TypeInformation<T>, TypeSerializer<T>) use `SavepointReader.readUnionState(OperatorIdentifier, String, TypeInformation, TypeSerializer)`
org.apache.flink.table.api.TableEnvironment.registerCatalog(String, Catalog) Use `TableEnvironment.createCatalog(String, CatalogDescriptor)` instead. The new method uses a `CatalogDescriptor` to initialize the catalog instance and store the `CatalogDescriptor` to the `CatalogStore`.
org.apache.flink.table.catalog.CatalogManager.registerCatalog(String, Catalog) This method is deprecated and will be removed in a future release. Use `createCatalog` instead to create a catalog using `CatalogDescriptor` and store it in the `CatalogStore`.
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.registerDataStream(String, DataStream<T>) use `StreamTableEnvironment.createTemporaryView(String, DataStream)`
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.registerFunction(String, AggregateFunction<T, ACC>) Use `TableEnvironment.createTemporarySystemFunction(String, UserDefinedFunction)` instead. Please note that the new method also uses the new type system and reflective extraction logic. It might be necessary to update the function implementation as well. See the documentation of `AggregateFunction` for more information on the new function design.
org.apache.flink.table.api.TableEnvironment.registerFunction(String, ScalarFunction) Use `TableEnvironment.createTemporarySystemFunction(String, UserDefinedFunction)` instead. Please note that the new method also uses the new type system and reflective extraction logic. It might be necessary to update the function implementation as well. See the documentation of `ScalarFunction` for more information on the new function design.
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.registerFunction(String, TableAggregateFunction<T, ACC>) Use `TableEnvironment.createTemporarySystemFunction(String, UserDefinedFunction)` instead. Please note that the new method also uses the new type system and reflective extraction logic. It might be necessary to update the function implementation as well. See the documentation of `TableAggregateFunction` for more information on the new function design.
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.registerFunction(String, TableFunction<T>) Use `TableEnvironment.createTemporarySystemFunction(String, UserDefinedFunction)` instead. Please note that the new method also uses the new type system and reflective extraction logic. It might be necessary to update the function implementation as well. See the documentation of `TableFunction` for more information on the new function design.
org.apache.flink.api.common.ExecutionConfig.registerKryoType(Class<?>) Register data types and serializers through hard codes is deprecated, because you need to modify the codes when upgrading job version. You should configure this by config option `PipelineOptions.SERIALIZATION_CONFIG`.
org.apache.flink.runtime.io.network.metrics.NettyShuffleMetricFactory.registerLegacyNetworkMetrics(boolean, MetricGroup, ResultPartitionWriter[], InputGate[]) should be removed in future
org.apache.flink.runtime.io.network.NettyShuffleEnvironment.registerLegacyNetworkMetrics(MetricGroup, ResultPartitionWriter[], InputGate[]) should be removed in future
org.apache.flink.api.common.ExecutionConfig.registerPojoType(Class<?>) Register data types and serializers through hard codes is deprecated, because you need to modify the codes when upgrading job version. You should configure this by config option `PipelineOptions.SERIALIZATION_CONFIG`.
org.apache.flink.table.api.TableEnvironment.registerTable(String, Table) use `TableEnvironment.createTemporaryView(String, Table)`
org.apache.flink.table.catalog.FunctionCatalog.registerTempCatalogScalarFunction(ObjectIdentifier, ScalarFunction) Use `FunctionCatalog.registerTemporaryCatalogFunction(UnresolvedIdentifier, FunctionDefinition, boolean)` instead.
org.apache.flink.table.catalog.FunctionCatalog.registerTempSystemAggregateFunction(String, ImperativeAggregateFunction<T, ACC>, TypeInformation<T>, TypeInformation<ACC>) Use `FunctionCatalog.registerTemporarySystemFunction(String, FunctionDefinition, boolean)` instead.
org.apache.flink.table.catalog.FunctionCatalog.registerTempSystemScalarFunction(String, ScalarFunction) Use `FunctionCatalog.registerTemporarySystemFunction(String, FunctionDefinition, boolean)` instead.
org.apache.flink.table.catalog.FunctionCatalog.registerTempSystemTableFunction(String, TableFunction<T>, TypeInformation<T>) Use `FunctionCatalog.registerTemporarySystemFunction(String, FunctionDefinition, boolean)` instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.registerType(Class<?>) Register data types and serializers through hard codes is deprecated, because you need to modify the codes when upgrading job version. You should configure this by config option `PipelineOptions.SERIALIZATION_CONFIG`.
org.apache.flink.api.common.ExecutionConfig.registerTypeWithKryoSerializer(Class<?>, Class<? extends Serializer>) Register data types and serializers through hard codes is deprecated, because you need to modify the codes when upgrading job version. You should configure this by config option `PipelineOptions.SERIALIZATION_CONFIG`.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.registerTypeWithKryoSerializer(Class<?>, Class<? extends Serializer>) Register data types and serializers through hard codes is deprecated, because you need to modify the codes when upgrading job version. You should configure this by config option `PipelineOptions.SERIALIZATION_CONFIG`.
org.apache.flink.api.common.ExecutionConfig.registerTypeWithKryoSerializer(Class<?>, T) Register data types and serializers through hard codes is deprecated, because you need to modify the codes when upgrading job version. You should configure this by config option `PipelineOptions.SERIALIZATION_CONFIG`.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.registerTypeWithKryoSerializer(Class<?>, T) Register data types and serializers through hard codes is deprecated, because you need to modify the codes when upgrading job version. Instance-type serializer definition where serializers are serialized and written into the snapshot and deserialized for use is deprecated as well. Use class-type serializer definition by `PipelineOptions.SERIALIZATION_CONFIG` instead, where only the class name is written into the snapshot and new instance of the serializer is created for use. This is a breaking change, and it will be removed in Flink 2.0.
org.apache.flink.runtime.jobmaster.LogicalSlot.releaseSlot() Added because extended the actual releaseSlot method with cause parameter.
org.apache.flink.state.api.SavepointWriter.removeOperator(String) use `SavepointWriter.removeOperator(OperatorIdentifier)`
org.apache.flink.runtime.resourcemanager.ResourceManagerGateway.requestTaskManagerFileUploadByName(ResourceID, String, Time) use `ResourceManagerGateway.requestTaskManagerFileUploadByNameAndType(ResourceID, String, FileType, Duration)` as instead.
org.apache.flink.table.factories.ModuleFactory.requiredContext() Implement the `Factory` based stack instead.
org.apache.flink.table.factories.CatalogFactory.requiredContext() Implement the `Factory` based stack instead.
org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot.resolveOuterSchemaCompatibility(S) this method is deprecated, and will be removed in the future. Please implement `CompositeTypeSerializerSnapshot.resolveOuterSchemaCompatibility(TypeSerializerSnapshot)` instead.
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<T>) This method has been replaced by `#resolveSchemaCompatibility(TypeSerializerSnapshot)` and will be removed in the future release. It's strongly recommended to migrate from old method to the new one, see the doc section "Migrating from deprecated `TypeSerializerSnapshot#resolveSchemaCompatibility(TypeSerializer newSerializer)`" for more details.
org.apache.flink.table.api.TableEnvironment.scan(String...) use `TableEnvironment.from(String)`
org.apache.flink.cep.PatternStream.select(PatternTimeoutFunction<T, L>, PatternSelectFunction<T, R>) Use `PatternStream.select(OutputTag, PatternTimeoutFunction, PatternSelectFunction)` that returns timed out events as a side-output
org.apache.flink.streaming.api.environment.CheckpointConfig.setAlignmentTimeout(Duration) Use `CheckpointConfig.setAlignedCheckpointTimeout(Duration)` instead.
org.apache.flink.configuration.Configuration.setBoolean(ConfigOption<Boolean>, boolean) use `Configuration.set(ConfigOption, Object)`
org.apache.flink.configuration.Configuration.setBoolean(String, boolean) use `Configuration.set(ConfigOption, Object)`
org.apache.flink.streaming.api.environment.CheckpointConfig.setCheckpointStorage(CheckpointStorage) The method is marked as deprecated because starting from Flink 1.19, the usage of all complex Java objects related to configuration, including their getter and setter methods, should be replaced by ConfigOption. In a future major version of Flink, this method will be removed entirely. It is recommended to switch to using the ConfigOptions provided for configuring checkpoint storage like the following code snippet: `Configuration config = new Configuration(); config.set(CheckpointingOptions.CHECKPOINT_STORAGE, "filesystem"); config.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, "file:///flink/checkpoints"); StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(config);` For more details on using ConfigOption for checkpoint storage configuration, please refer to the Flink documentation: Checkpoints
org.apache.flink.streaming.api.environment.CheckpointConfig.setCheckpointStorage(Path) The method is marked as deprecated because starting from Flink 1.19, the usage of all complex Java objects related to configuration, including their getter and setter methods, should be replaced by ConfigOption. In a future major version of Flink, this method will be removed entirely. It is recommended to switch to using the ConfigOptions provided for configuring checkpoint storage like the following code snippet: `Configuration config = new Configuration(); config.set(CheckpointingOptions.CHECKPOINT_STORAGE, "filesystem"); config.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, "file:///flink/checkpoints"); StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(config);` For more details on using ConfigOption for checkpoint storage configuration, please refer to the Flink documentation: Checkpoints
org.apache.flink.streaming.api.environment.CheckpointConfig.setCheckpointStorage(String) The method is marked as deprecated because starting from Flink 1.19, the usage of all complex Java objects related to configuration, including their getter and setter methods, should be replaced by ConfigOption. In a future major version of Flink, this method will be removed entirely. It is recommended to switch to using the ConfigOptions provided for configuring checkpoint storage like the following code snippet: `Configuration config = new Configuration(); config.set(CheckpointingOptions.CHECKPOINT_STORAGE, "filesystem"); config.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, "file:///flink/checkpoints"); StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(config);` For more details on using ConfigOption for checkpoint storage configuration, please refer to the Flink documentation: Checkpoints
org.apache.flink.streaming.api.environment.CheckpointConfig.setCheckpointStorage(URI) The method is marked as deprecated because starting from Flink 1.19, the usage of all complex Java objects related to configuration, including their getter and setter methods, should be replaced by ConfigOption. In a future major version of Flink, this method will be removed entirely. It is recommended to switch to using the ConfigOptions provided for configuring checkpoint storage like the following code snippet: `Configuration config = new Configuration(); config.set(CheckpointingOptions.CHECKPOINT_STORAGE, "filesystem"); config.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, "file:///flink/checkpoints"); StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(config);` For more details on using ConfigOption for checkpoint storage configuration, please refer to the Flink documentation: Checkpoints
org.apache.flink.configuration.Configuration.setClass(String, Class<?>)
org.apache.flink.api.common.ExecutionConfig.setDefaultInputDependencyConstraint(InputDependencyConstraint) due to the deprecation of `InputDependencyConstraint`.
org.apache.flink.configuration.Configuration.setDouble(ConfigOption<Double>, double) use `Configuration.set(ConfigOption, Object)`
org.apache.flink.configuration.Configuration.setDouble(String, double) use `Configuration.set(ConfigOption, Object)`
org.apache.flink.api.common.ExecutionConfig.setExecutionMode(ExecutionMode) The `ExecutionMode` is deprecated because it's only used in DataSet APIs. All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.api.common.ExecutionConfig.setExecutionRetryDelay(long) This method will be replaced by `ExecutionConfig.setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration)`. The `RestartStrategies.FixedDelayRestartStrategyConfiguration` contains the delay between successive execution attempts.
org.apache.flink.streaming.api.environment.CheckpointConfig.setFailOnCheckpointingErrors(boolean) Use `CheckpointConfig.setTolerableCheckpointFailureNumber(int)`.
org.apache.flink.formats.json.JsonRowDeserializationSchema.setFailOnMissingField(boolean) Use the provided `JsonRowDeserializationSchema.Builder` instead.
org.apache.flink.api.common.operators.DualInputOperator.setFirstInput(Operator<IN1>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.DualInputOperator.setFirstInputs(List<Operator<IN1>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.configuration.Configuration.setFloat(ConfigOption<Float>, float) use `Configuration.set(ConfigOption, Object)`
org.apache.flink.configuration.Configuration.setFloat(String, float) use `Configuration.set(ConfigOption, Object)`
org.apache.flink.streaming.api.environment.CheckpointConfig.setForceCheckpointing(boolean) This will be removed once iterations properly participate in checkpointing.
org.apache.flink.table.api.TableConfig.setIdleStateRetentionTime(Time, Time) use `TableConfig.setIdleStateRetention(Duration)` instead.
org.apache.flink.api.common.operators.SingleInputOperator.setInput(Operator<IN>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.setInputs(List<Operator<IN>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.SingleInputOperator.setInputs(List<Operator<IN>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.setInputs(Operator<IN>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.configuration.Configuration.setInteger(ConfigOption<Integer>, int) use `Configuration.set(ConfigOption, Object)`
org.apache.flink.configuration.Configuration.setInteger(String, int) use `Configuration.set(ConfigOption, Object)`
org.apache.flink.configuration.Configuration.setLong(ConfigOption<Long>, long) use `Configuration.set(ConfigOption, Object)`
org.apache.flink.configuration.Configuration.setLong(String, long) use `Configuration.set(ConfigOption, Object)`
org.apache.flink.table.data.writer.BinaryArrayWriter.setNullAt(int, LogicalType) Use `BinaryArrayWriter.createNullSetter(LogicalType)` for avoiding logical types during runtime.
org.apache.flink.api.common.ExecutionConfig.setNumberOfExecutionRetries(int) This method will be replaced by `ExecutionConfig.setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration)`. The `RestartStrategies.FixedDelayRestartStrategyConfiguration` contains the number of execution retries.
org.apache.flink.api.java.ExecutionEnvironment.setNumberOfExecutionRetries(int) This method will be replaced by `ExecutionEnvironment.setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration)`. The `RestartStrategies.FixedDelayRestartStrategyConfiguration` contains the number of execution retries.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.setNumberOfExecutionRetries(int) This method will be replaced by `StreamExecutionEnvironment.setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration)`. The `RestartStrategies.fixedDelayRestart(int, Duration)` contains the number of execution retries.
org.apache.flink.contrib.streaming.state.RocksDBStateBackend.setNumberOfTransferingThreads(int) Typo in method name. Use `RocksDBStateBackend.setNumberOfTransferThreads(int)` instead.
org.apache.flink.streaming.api.operators.AbstractStreamOperator.setProcessingTimeService(ProcessingTimeService) The `ProcessingTimeService` instance should be passed by the operator constructor and this method will be removed along with `SetupableStreamOperator`.
org.apache.flink.api.common.state.StateDescriptor.setQueryable(String) The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.
org.apache.flink.api.common.ExecutionConfig.setRestartStrategy(RestartStrategies.RestartStrategyConfiguration) The method is marked as deprecated because starting from Flink 1.19, the usage of all complex Java objects related to configuration, including their getter and setter methods, should be replaced by ConfigOption. In a future major version of Flink, this method will be removed entirely. It is recommended to switch to using the ConfigOptions provided by `RestartStrategyOptions` for configuring restart strategies.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.setRestartStrategy(RestartStrategies.RestartStrategyConfiguration) The method is marked as deprecated because starting from Flink 1.19, the usage of all complex Java objects related to configuration, including their getter and setter methods, should be replaced by ConfigOption. In a future major version of Flink, this method will be removed entirely. It is recommended to switch to using the ConfigOptions provided by `RestartStrategyOptions` for configuring restart strategies.
org.apache.flink.api.common.operators.DualInputOperator.setSecondInput(Operator<IN2>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.DualInputOperator.setSecondInputs(List<Operator<IN2>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.setStateBackend(StateBackend) The method is marked as deprecated because starting from Flink 1.19, the usage of all complex Java objects related to configuration, including their getter and setter methods, should be replaced by ConfigOption. In a future major version of Flink, this method will be removed entirely. It is recommended to switch to using the ConfigOptions provided for configuring state backend like the following code snippet: `Configuration config = new Configuration(); config.set(StateBackendOptions.STATE_BACKEND, "hashmap"); StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(config);` For more details on using ConfigOption for state backend configuration, please refer to the Flink documentation: state-backends
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.setStreamTimeCharacteristic(TimeCharacteristic) In Flink 1.12 the default stream time characteristic has been changed to `TimeCharacteristic.EventTime`, thus you don't need to call this method for enabling event-time support anymore. Explicitly using processing-time windows and timers works in event-time mode. If you need to disable watermarks, please use `ExecutionConfig.setAutoWatermarkInterval(long)`. If you are using `TimeCharacteristic.IngestionTime`, please manually set an appropriate `WatermarkStrategy`. If you are using generic "time window" operations (for example through `KeyedStream.window(WindowAssigner)` that change behaviour based on the time characteristic, please use equivalent operations that explicitly specify processing time or event time.
org.apache.flink.configuration.Configuration.setString(ConfigOption<String>, String) use `Configuration.set(ConfigOption, Object)`
org.apache.flink.api.common.state.StateTtlConfig.Builder.setTtl(Time) Use `StateTtlConfig.Builder.setTimeToLive(Duration)`
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.showLocks()
org.apache.flink.api.connector.sink.SinkWriter.snapshotState() implement `SinkWriter.snapshotState(long)`
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.socketTextStream(String, int, char) Use `StreamExecutionEnvironment.socketTextStream(String, int, String)` instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.socketTextStream(String, int, char, long) Use `StreamExecutionEnvironment.socketTextStream(String, int, String, long)` instead.
org.apache.flink.api.java.operators.DataSink.sortLocalOutput(int, Order) Use `DataSet.sortPartition(int, Order)` instead
org.apache.flink.api.java.operators.DataSink.sortLocalOutput(String, Order) Use `DataSet.sortPartition(String, Order)` instead
org.apache.flink.core.execution.JobClient.stopWithSavepoint(boolean, String) pass the format explicitly
org.apache.flink.table.factories.ModuleFactory.supportedProperties() Implement the `Factory` based stack instead.
org.apache.flink.table.factories.CatalogFactory.supportedProperties() Implement the `Factory` based stack instead.
org.apache.flink.table.catalog.Catalog.supportsManagedTable() This method will be removed soon. Please see FLIP-346 for more details.
org.apache.flink.api.common.io.FileInputFormat.supportsMultiPaths() Will be removed for Flink 2.0.
org.apache.flink.cep.pattern.Pattern.times(int, int, Time) Use `Pattern.times(int, int, Duration)`
org.apache.flink.cep.pattern.Pattern.times(int, Time) Using `Pattern.times(int, Duration)`
org.apache.flink.cep.pattern.Pattern.timesOrMore(int, Time) Use `Pattern.timesOrMore(int, Duration)`
org.apache.flink.streaming.api.datastream.KeyedStream.timeWindow(Time) Please use `KeyedStream.window(WindowAssigner)` with either `TumblingEventTimeWindows` or `TumblingProcessingTimeWindows`. For more information, see the deprecation notice on `TimeCharacteristic`
org.apache.flink.streaming.api.datastream.KeyedStream.timeWindow(Time, Time) Please use `KeyedStream.window(WindowAssigner)` with either `SlidingEventTimeWindows` or `SlidingProcessingTimeWindows`. For more information, see the deprecation notice on `TimeCharacteristic`
org.apache.flink.streaming.api.datastream.DataStream.timeWindowAll(Time) Please use `DataStream.windowAll(WindowAssigner)` with either `TumblingEventTimeWindows` or `TumblingProcessingTimeWindows`. For more information, see the deprecation notice on `TimeCharacteristic`
org.apache.flink.streaming.api.datastream.DataStream.timeWindowAll(Time, Time) Please use `DataStream.windowAll(WindowAssigner)` with either `SlidingEventTimeWindows` or `SlidingProcessingTimeWindows`. For more information, see the deprecation notice on `TimeCharacteristic`
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.toAppendStream(Table, Class<T>) Use `StreamTableEnvironment.toDataStream(Table, Class)` instead. It integrates with the new type system and supports all kinds of `DataTypes` that the table runtime can produce. The semantics might be slightly different for raw and structured types. Use `toDataStream(DataTypes.of(TypeInformation.of(Class)))` if `TypeInformation` should be used as source of truth.
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.toAppendStream(Table, TypeInformation<T>) Use `StreamTableEnvironment.toDataStream(Table, Class)` instead. It integrates with the new type system and supports all kinds of `DataTypes` that the table runtime can produce. The semantics might be slightly different for raw and structured types. Use `toDataStream(DataTypes.of(TypeInformation.of(Class)))` if `TypeInformation` should be used as source of truth.
org.apache.flink.table.api.EnvironmentSettings.toConfiguration() use `EnvironmentSettings.getConfiguration()` instead.
org.apache.flink.util.TimeUtils.toDuration(Time) Use `Duration` APIs
org.apache.flink.table.catalog.CatalogTable.toProperties() Only a `ResolvedCatalogTable` is serializable to properties.
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.toRetractStream(Table, Class<T>) Use `StreamTableEnvironment.toChangelogStream(Table, Schema)` instead. It integrates with the new type system and supports all kinds of `DataTypes` and every `ChangelogMode` that the table runtime can produce.
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.toRetractStream(Table, TypeInformation<T>) Use `StreamTableEnvironment.toChangelogStream(Table, Schema)` instead. It integrates with the new type system and supports all kinds of `DataTypes` and every `ChangelogMode` that the table runtime can produce.
org.apache.flink.table.runtime.typeutils.InternalTypeInfo.toRowFieldNames() `TypeInformation` should just be a thin wrapper of a serializer. This method only exists for legacy code. It is recommended to use the `RowType` instead for logical operations.
org.apache.flink.table.runtime.typeutils.InternalTypeInfo.toRowFieldTypes() `TypeInformation` should just be a thin wrapper of a serializer. This method only exists for legacy code. It is recommended to use the `RowType` instead for logical operations.
org.apache.flink.table.runtime.typeutils.InternalTypeInfo.toRowSize() `TypeInformation` should just be a thin wrapper of a serializer. This method only exists for legacy code. It is recommended to use the `RowType` instead for logical operations.
org.apache.flink.table.api.TableSchema.toRowType() Use `TableSchema.toRowDataType()` instead.
org.apache.flink.core.execution.JobClient.triggerSavepoint(String) pass the format explicitly
org.apache.flink.api.java.operators.JoinOperator.ProjectJoin.types(Class<?>...) Deprecated method only kept for compatibility.
org.apache.flink.api.java.operators.CrossOperator.ProjectCross.types(Class<?>...) Deprecated method only kept for compatibility.
org.apache.flink.api.java.operators.ProjectOperator.types(Class<?>...) Deprecated method only kept for compatibility.
org.apache.flink.fnexecution.v1.FlinkFnApi.Input.InputCase.valueOf(int) Use `FlinkFnApi.Input.InputCase.forNumber(int)` instead.
org.apache.flink.fnexecution.v1.FlinkFnApi.OverWindow.WindowType.valueOf(int) Use `FlinkFnApi.OverWindow.WindowType.forNumber(int)` instead.
org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.DataViewCase.valueOf(int) Use `FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.DataViewCase.forNumber(int)` instead.
org.apache.flink.fnexecution.v1.FlinkFnApi.GroupWindow.WindowType.valueOf(int) Use `FlinkFnApi.GroupWindow.WindowType.forNumber(int)` instead.
org.apache.flink.fnexecution.v1.FlinkFnApi.GroupWindow.WindowProperty.valueOf(int) Use `FlinkFnApi.GroupWindow.WindowProperty.forNumber(int)` instead.
org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.TypeName.valueOf(int) Use `FlinkFnApi.Schema.TypeName.forNumber(int)` instead.
org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.FieldType.TypeInfoCase.valueOf(int) Use `FlinkFnApi.Schema.FieldType.TypeInfoCase.forNumber(int)` instead.
org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TypeName.valueOf(int) Use `FlinkFnApi.TypeInfo.TypeName.forNumber(int)` instead.
org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TypeInfoCase.valueOf(int) Use `FlinkFnApi.TypeInfo.TypeInfoCase.forNumber(int)` instead.
org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.FunctionType.valueOf(int) Use `FlinkFnApi.UserDefinedDataStreamFunction.FunctionType.forNumber(int)` instead.
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.UpdateType.valueOf(int) Use `FlinkFnApi.StateDescriptor.StateTTLConfig.UpdateType.forNumber(int)` instead.
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.StateVisibility.valueOf(int) Use `FlinkFnApi.StateDescriptor.StateTTLConfig.StateVisibility.forNumber(int)` instead.
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.TtlTimeCharacteristic.valueOf(int) Use `FlinkFnApi.StateDescriptor.StateTTLConfig.TtlTimeCharacteristic.forNumber(int)` instead.
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.Strategies.valueOf(int) Use `FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.Strategies.forNumber(int)` instead.
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.EmptyCleanupStrategy.valueOf(int) Use `FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.EmptyCleanupStrategy.forNumber(int)` instead.
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry.CleanupStrategyCase.valueOf(int) Use `FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry.CleanupStrategyCase.forNumber(int)` instead.
org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.Mode.valueOf(int) Use `FlinkFnApi.CoderInfoDescriptor.Mode.forNumber(int)` instead.
org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.DataTypeCase.valueOf(int) Use `FlinkFnApi.CoderInfoDescriptor.DataTypeCase.forNumber(int)` instead.
org.apache.flink.test.util.TestUtils.waitUntilExternalizedCheckpointCreated(File) please use `org.apache.flink.runtime.testutils.CommonTestUtils#waitForCheckpoint(JobID, MiniCluster, Deadline)` which is less prone to `NoSuchFileException` and IO-intensive.
org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithWindow.with(CoGroupFunction<T1, T2, T>) This method will be removed once the `CoGroupedStreams.WithWindow.apply(CoGroupFunction)` method is fixed in the next major version of Flink (2.0).
org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithWindow.with(CoGroupFunction<T1, T2, T>, TypeInformation<T>) This method will be removed once the `CoGroupedStreams.WithWindow.apply(CoGroupFunction, TypeInformation)` method is fixed in the next major version of Flink (2.0).
org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow.with(FlatJoinFunction<T1, T2, T>) This method will be removed once the `JoinedStreams.WithWindow.apply(FlatJoinFunction)` method is fixed in the next major version of Flink (2.0).
org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow.with(FlatJoinFunction<T1, T2, T>, TypeInformation<T>) This method will be replaced by `JoinedStreams.WithWindow.apply(FlatJoinFunction, TypeInformation)` in Flink 2.0. So use the `JoinedStreams.WithWindow.apply(FlatJoinFunction, TypeInformation)` in the future.
org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow.with(JoinFunction<T1, T2, T>) This method will be removed once the `JoinedStreams.WithWindow.apply(JoinFunction)` method is fixed in the next major version of Flink (2.0).
org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow.with(JoinFunction<T1, T2, T>, TypeInformation<T>) This method will be removed once the `JoinedStreams.WithWindow.apply(JoinFunction, TypeInformation)` method is fixed in the next major version of Flink (2.0).
org.apache.flink.streaming.api.windowing.assigners.EventTimeSessionWindows.withGap(Time) Use `EventTimeSessionWindows.withGap(Duration)`
org.apache.flink.streaming.api.windowing.assigners.ProcessingTimeSessionWindows.withGap(Time) Use `ProcessingTimeSessionWindows.withGap(Duration)`
org.apache.flink.cep.pattern.Pattern.within(Time) Use `Pattern.within(Duration)`.
org.apache.flink.cep.pattern.Pattern.within(Time, WithinType) Use `Pattern.within(Duration, WithinType)`.
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.DefaultRollingPolicy.PolicyBuilder.withInactivityInterval(long) Use `DefaultRollingPolicy.PolicyBuilder.withInactivityInterval(Duration)` instead.
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.DefaultRollingPolicy.PolicyBuilder.withMaxPartSize(long) Use `DefaultRollingPolicy.PolicyBuilder.withMaxPartSize(MemorySize)` instead.
org.apache.flink.state.api.SavepointWriter.withOperator(String, StateBootstrapTransformation<T>)
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.DefaultRollingPolicy.PolicyBuilder.withRolloverInterval(long) Use `DefaultRollingPolicy.PolicyBuilder.withRolloverInterval(Duration)` instead.
org.apache.flink.table.data.writer.BinaryWriter.write(BinaryWriter, int, Object, LogicalType, TypeSerializer<?>) Use `BinaryWriter.createValueSetter(LogicalType)` for avoiding logical types during runtime.
org.apache.flink.core.fs.Path.write(DataOutputView) the method is deprecated since Flink 1.19 because Path will no longer implement `IOReadableWritable` in future versions. Please use `serializeToDataOutputView` instead.
org.apache.flink.streaming.api.datastream.DataStream.writeAsCsv(String) Please use the `StreamingFileSink` explicitly using the `DataStream.addSink(SinkFunction)` method.
org.apache.flink.streaming.api.datastream.DataStream.writeAsCsv(String, FileSystem.WriteMode) Please use the `StreamingFileSink` explicitly using the `DataStream.addSink(SinkFunction)` method.
org.apache.flink.streaming.api.datastream.DataStream.writeAsCsv(String, FileSystem.WriteMode, String, String) Please use the `StreamingFileSink` explicitly using the `DataStream.addSink(SinkFunction)` method.
org.apache.flink.streaming.api.datastream.DataStream.writeAsText(String) Please use the `StreamingFileSink` explicitly using the `DataStream.addSink(SinkFunction)` method.
org.apache.flink.streaming.api.datastream.DataStream.writeAsText(String, FileSystem.WriteMode) Please use the `StreamingFileSink` explicitly using the `DataStream.addSink(SinkFunction)` method.
org.apache.flink.streaming.api.datastream.DataStream.writeUsingOutputFormat(OutputFormat<T>) Please use the `StreamingFileSink` explicitly using the `DataStream.addSink(SinkFunction)` method.

Deprecated Constructors
Constructor and Description
org.apache.flink.connector.base.sink.writer.AsyncSinkWriter(ElementConverter<InputT, RequestEntryT>, Sink.InitContext, AsyncSinkWriterConfiguration, Collection<BufferedRequestState<RequestEntryT>>)
org.apache.flink.connector.base.sink.writer.AsyncSinkWriter(ElementConverter<InputT, RequestEntryT>, Sink.InitContext, int, int, int, long, long, long)
org.apache.flink.connector.base.sink.writer.AsyncSinkWriter(ElementConverter<InputT, RequestEntryT>, Sink.InitContext, int, int, int, long, long, long, Collection<BufferedRequestState<RequestEntryT>>)
org.apache.flink.formats.avro.typeutils.AvroSerializer(Class<T>, Class<? extends T>) Use `AvroSerializer(Class)` instead.
org.apache.flink.streaming.api.functions.timestamps.BoundedOutOfOrdernessTimestampExtractor(Time) Use `BoundedOutOfOrdernessTimestampExtractor(Duration)`
org.apache.flink.formats.json.JsonRowSerializationSchema.Builder(String) Use `JsonRowSerializationSchema.builder()` instead.
org.apache.flink.api.common.state.StateTtlConfig.Builder(Time) Use `StateTtlConfig.newBuilder(Duration)`
org.apache.flink.formats.json.JsonRowSerializationSchema.Builder(TypeInformation<Row>) Use `JsonRowSerializationSchema.builder()` instead.
org.apache.flink.table.expressions.CallExpression(FunctionDefinition, List<ResolvedExpression>, DataType) Use `CallExpression.anonymous(FunctionDefinition, List, DataType)` instead.
org.apache.flink.table.expressions.CallExpression(FunctionIdentifier, FunctionDefinition, List<ResolvedExpression>, DataType) Use `CallExpression.permanent(FunctionIdentifier, FunctionDefinition, List, DataType)` or `CallExpression.temporary(FunctionIdentifier, FunctionDefinition, List, DataType)` instead.
org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration(long, long, long, int, CheckpointRetentionPolicy, boolean, boolean, int, long) use `CheckpointCoordinatorConfiguration.builder()`.
org.apache.flink.table.plan.stats.ColumnStats(Long, Long, Double, Integer, Number, Number)
org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot(Class<? extends TypeSerializer>) correspondingSerializerClass is not used to resolve and cast after FLIP-263, please use `CompositeTypeSerializerSnapshot()` instead.
org.apache.flink.api.common.restartstrategy.RestartStrategies.ExponentialDelayRestartStrategyConfiguration(Time, Time, double, Time, double) Use `ExponentialDelayRestartStrategyConfiguration(Duration, Duration, double, Duration, double)`
org.apache.flink.api.common.restartstrategy.RestartStrategies.FailureRateRestartStrategyConfiguration(int, Time, Time) Use `FailureRateRestartStrategyConfiguration(int, Duration, Duration)`
org.apache.flink.connector.file.src.FileSourceSplit(String, Path, long, long) You should use `FileSourceSplit(String, Path, long, long, long, long)`
org.apache.flink.connector.file.src.FileSourceSplit(String, Path, long, long, String...) You should use `FileSourceSplit(String, Path, long, long, long, long, String...)`
org.apache.flink.connector.file.src.FileSourceSplit(String, Path, long, long, String[], CheckpointedPosition) You should use `FileSourceSplit(String, Path, long, long, long, long, String[], CheckpointedPosition)`
org.apache.flink.table.planner.plan.rules.logical.FlinkAggregateExpandDistinctAggregatesRule(Class<? extends LogicalAggregate>, boolean, RelFactories.JoinFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkAggregateExpandDistinctAggregatesRule(Class<? extends LogicalAggregate>, RelFactories.JoinFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkAggregateJoinTransposeRule(Class<? extends Aggregate>, RelFactories.AggregateFactory, Class<? extends Join>, RelFactories.JoinFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkAggregateJoinTransposeRule(Class<? extends Aggregate>, RelFactories.AggregateFactory, Class<? extends Join>, RelFactories.JoinFactory, boolean)
org.apache.flink.table.planner.plan.rules.logical.FlinkAggregateJoinTransposeRule(Class<? extends Aggregate>, RelFactories.AggregateFactory, Class<? extends Join>, RelFactories.JoinFactory, RelFactories.ProjectFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkAggregateJoinTransposeRule(Class<? extends Aggregate>, RelFactories.AggregateFactory, Class<? extends Join>, RelFactories.JoinFactory, RelFactories.ProjectFactory, boolean)
org.apache.flink.table.planner.plan.rules.logical.FlinkAggregateRemoveRule(Class<? extends Aggregate>)
org.apache.flink.table.planner.plan.rules.logical.FlinkBushyJoinReorderRule(RelBuilderFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkBushyJoinReorderRule(RelFactories.JoinFactory, RelFactories.ProjectFactory, RelFactories.FilterFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkJoinPushExpressionsRule(Class<? extends Join>, RelFactories.ProjectFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkJoinReorderRule(RelBuilderFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkJoinReorderRule(RelFactories.JoinFactory, RelFactories.ProjectFactory, RelFactories.FilterFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkJoinToMultiJoinRule(Class<? extends Join>)
org.apache.flink.table.planner.plan.rules.logical.FlinkJoinToMultiJoinRule(Class<? extends Join>, RelBuilderFactory)
org.apache.flink.connectors.hive.read.HiveSourceSplit(String, Path, long, long, String[], CheckpointedPosition, HiveTablePartition) You should use `HiveSourceSplit(String, Path, long, long, long, long, String[], CheckpointedPosition, HiveTablePartition)`
org.apache.flink.formats.json.JsonRowDeserializationSchema(String) Use the provided `JsonRowDeserializationSchema.Builder` instead.
org.apache.flink.formats.json.JsonRowDeserializationSchema(TypeInformation<Row>) Use the provided `JsonRowDeserializationSchema.Builder` instead.
org.apache.flink.table.api.dataview.ListView(TypeInformation<?>) This method uses the old type system. Please use a `DataTypeHint` instead if the reflective type extraction is not successful.
org.apache.flink.table.runtime.dataview.ListViewSpec(String, int, DataType, TypeSerializer<?>)
org.apache.calcite.rel.logical.LogicalTableScan(RelOptCluster, RelOptTable)
org.apache.calcite.rel.logical.LogicalTableScan(RelOptCluster, RelTraitSet, RelOptTable)
org.apache.flink.table.api.dataview.MapView(TypeInformation<?>, TypeInformation<?>) This method uses the old type system. Please use a `DataTypeHint` instead if the reflective type extraction is not successful.
org.apache.flink.table.runtime.dataview.MapViewSpec(String, int, DataType, boolean, TypeSerializer<?>, TypeSerializer<?>)
org.apache.flink.streaming.api.functions.sink.filesystem.OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverable(RecoverableWriter.ResumeRecoverable)
org.apache.flink.streaming.api.functions.sink.filesystem.OutputStreamBasedPartFileWriter.OutputStreamBasedPendingFileRecoverable(RecoverableWriter.CommitRecoverable)
org.apache.flink.contrib.streaming.state.RocksDBStateBackend(AbstractStateBackend) Use `RocksDBStateBackend(StateBackend)` instead.
org.apache.flink.contrib.streaming.state.RocksDBStateBackend(AbstractStateBackend, boolean) Use `RocksDBStateBackend(StateBackend, TernaryBoolean)` instead.
org.apache.flink.connector.base.source.reader.fetcher.SingleThreadFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>>, Supplier<SplitReader<E, SplitT>>) Please use `SingleThreadFetcherManager(Supplier, Configuration)` instead.
org.apache.flink.connector.base.source.reader.fetcher.SingleThreadFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>>, Supplier<SplitReader<E, SplitT>>, Configuration) Please use `SingleThreadFetcherManager(Supplier, Configuration)` instead.
org.apache.flink.connector.base.source.reader.fetcher.SingleThreadFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>>, Supplier<SplitReader<E, SplitT>>, Configuration, Consumer<Collection<String>>) Please use `SingleThreadFetcherManager(Supplier, Configuration, Consumer)` instead.
org.apache.flink.connector.base.source.reader.SingleThreadMultiplexSourceReaderBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>>, SingleThreadFetcherManager<E, SplitT>, RecordEmitter<E, T, SplitStateT>, Configuration, SourceReaderContext) Please use `SingleThreadMultiplexSourceReaderBase(SingleThreadFetcherManager, RecordEmitter, Configuration, SourceReaderContext)` instead.
org.apache.flink.connector.base.source.reader.SingleThreadMultiplexSourceReaderBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>>, SingleThreadFetcherManager<E, SplitT>, RecordEmitter<E, T, SplitStateT>, RecordEvaluator<T>, Configuration, SourceReaderContext) Please use `SingleThreadMultiplexSourceReaderBase(SingleThreadFetcherManager, RecordEmitter, RecordEvaluator, Configuration, SourceReaderContext)` instead.
org.apache.flink.connector.base.source.reader.SingleThreadMultiplexSourceReaderBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>>, Supplier<SplitReader<E, SplitT>>, RecordEmitter<E, T, SplitStateT>, Configuration, SourceReaderContext) Please use `SingleThreadMultiplexSourceReaderBase(Supplier, RecordEmitter, Configuration, SourceReaderContext)` instead.
org.apache.flink.connector.base.source.reader.SourceReaderBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>>, SplitFetcherManager<E, SplitT>, RecordEmitter<E, T, SplitStateT>, Configuration, SourceReaderContext) Please use `SourceReaderBase(SplitFetcherManager, RecordEmitter, Configuration, SourceReaderContext)` instead.
org.apache.flink.connector.base.source.reader.SourceReaderBase(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>>, SplitFetcherManager<E, SplitT>, RecordEmitter<E, T, SplitStateT>, RecordEvaluator<T>, Configuration, SourceReaderContext) Please use `SourceReaderBase(SplitFetcherManager, RecordEmitter, RecordEvaluator, Configuration, SourceReaderContext)` instead.
org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>>, Supplier<SplitReader<E, SplitT>>, Configuration) Please use `SplitFetcherManager(Supplier, Configuration)` instead.
org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager(FutureCompletingBlockingQueue<RecordsWithSplitIds<E>>, Supplier<SplitReader<E, SplitT>>, Configuration, Consumer<Collection<String>>) Please use `SplitFetcherManager(Supplier, Configuration, Consumer)` instead.
org.apache.calcite.sql2rel.SqlToRelConverter(RelOptTable.ViewExpander, SqlValidator, Prepare.CatalogReader, RelOptCluster, SqlRexConvertletTable)
org.apache.calcite.sql2rel.SqlToRelConverter(RelOptTable.ViewExpander, SqlValidator, Prepare.CatalogReader, RelOptPlanner, RexBuilder, SqlRexConvertletTable)
org.apache.flink.runtime.leaderretrieval.StandaloneLeaderRetrievalService(String) Use `StandaloneLeaderRetrievalService(String, UUID)` instead
org.apache.flink.table.types.logical.SymbolType(boolean, Class<T>) Symbol types have been simplified to not require a class.
org.apache.flink.table.types.logical.SymbolType(Class<T>) Symbol types have been simplified to not require a class.
org.apache.flink.table.api.TableConfig()
org.apache.flink.table.api.TableSchema(String[], TypeInformation<?>[]) Use the `TableSchema.Builder` instead.
org.apache.flink.api.common.state.ValueStateDescriptor(String, Class<T>, T) Use `ValueStateDescriptor(String, Class)` instead and manually manage the default value by checking whether the contents of the state is `null`.
org.apache.flink.api.common.state.ValueStateDescriptor(String, TypeInformation<T>, T) Use `ValueStateDescriptor(String, TypeInformation)` instead and manually manage the default value by checking whether the contents of the state is `null`.
org.apache.flink.api.common.state.ValueStateDescriptor(String, TypeSerializer<T>, T) Use `ValueStateDescriptor(String, TypeSerializer)` instead and manually manage the default value by checking whether the contents of the state is `null`.
org.apache.flink.api.common.eventtime.WatermarksWithIdleness(WatermarkGenerator<T>, Duration)
org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow(DataStream<T1>, DataStream<T2>, KeySelector<T1, KEY>, KeySelector<T2, KEY>, TypeInformation<KEY>, WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1, T2>, W>, Trigger<? super CoGroupedStreams.TaggedUnion<T1, T2>, ? super W>, Evictor<? super CoGroupedStreams.TaggedUnion<T1, T2>, ? super W>, Time) Use `WithWindow(DataStream, DataStream, KeySelector, KeySelector, TypeInformation, WindowAssigner, Trigger, Evictor, Duration)`.
org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithWindow(DataStream<T1>, DataStream<T2>, KeySelector<T1, KEY>, KeySelector<T2, KEY>, TypeInformation<KEY>, WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1, T2>, W>, Trigger<? super CoGroupedStreams.TaggedUnion<T1, T2>, ? super W>, Evictor<? super CoGroupedStreams.TaggedUnion<T1, T2>, ? super W>, Time) Use `WithWindow(DataStream, DataStream, KeySelector, KeySelector, TypeInformation, WindowAssigner, Trigger, Evictor, Duration)`

Deprecated Enum Constants
Enum Constant and Description
org.apache.hadoop.hive.conf.HiveConf.ConfVars.COMPACTOR_HISTORY_REAPER_INTERVAL Use MetastoreConf.COMPACTOR_HISTORY_REAPER_INTERVAL
org.apache.hadoop.hive.conf.HiveConf.ConfVars.COMPACTOR_HISTORY_RETENTION_ATTEMPTED Use MetastoreConf.COMPACTOR_HISTORY_RETENTION_ATTEMPTED
org.apache.hadoop.hive.conf.HiveConf.ConfVars.COMPACTOR_HISTORY_RETENTION_FAILED Use MetastoreConf.COMPACTOR_HISTORY_RETENTION_FAILED
org.apache.hadoop.hive.conf.HiveConf.ConfVars.COMPACTOR_HISTORY_RETENTION_SUCCEEDED Use MetastoreConf.COMPACTOR_HISTORY_RETENTION_SUCCEEDED
org.apache.hadoop.hive.conf.HiveConf.ConfVars.COMPACTOR_INITIATOR_FAILED_THRESHOLD Use MetastoreConf.COMPACTOR_INITIATOR_FAILED_THRESHOLD
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_COMPACTOR_INITIATOR_ON Use MetastoreConf.COMPACTOR_INITIATOR_ON
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_COMPACTOR_WORKER_THREADS Use MetastoreConf.COMPACTOR_WORKER_THREADS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_COUNT_OPEN_TXNS_INTERVAL Use MetastoreConf.COUNT_OPEN_TXNS_INTERVAL
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_GROUPBY_ORDERBY_POSITION_ALIAS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_LEGACY_SCHEMA_FOR_ALL_SERDES
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_MAX_OPEN_TXNS Use MetastoreConf.MAX_OPEN_TXNS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_METASTORE_FS_HANDLER_CLS Use MetastoreConf.FS_HANDLER_CLS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_METASTORE_SSL_KEYSTORE_PASSWORD Use MetastoreConf.SSL_KEYSTORE_PASSWORD
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_METASTORE_SSL_KEYSTORE_PATH Use MetastoreConf.SSL_KEYSTORE_PATH
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_METASTORE_SSL_TRUSTSTORE_PASSWORD Use MetastoreConf.SSL_TRUSTSTORE_PASSWORD
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_METASTORE_SSL_TRUSTSTORE_PATH Use MetastoreConf.SSL_TRUSTSTORE_PATH
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_METASTORE_STATS_NDV_DENSITY_FUNCTION Use MetastoreConf.STATS_NDV_DENSITY_FUNCTION
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_METASTORE_STATS_NDV_TUNER Use MetastoreConf.STATS_NDV_TUNER
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_METASTORE_USE_SSL Use MetastoreConf.USE_SSL
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_METRICS_REPORTER
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_SERVER2_THRIFT_HTTP_COOKIE_IS_SECURE
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_STATS_DEFAULT_AGGREGATOR Use MetastoreConf.STATS_DEFAULT_AGGRETATOR
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_STATS_DEFAULT_PUBLISHER Use MetastoreConf.STATS_DEFAULT_PUBLISHER
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_STATS_FETCH_BITVECTOR Use MetastoreConf.STATS_FETCH_BITVECTOR
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_SUPPORT_SPECICAL_CHARACTERS_IN_TABLE_NAMES Use MetastoreConf.SUPPORT_SPECIAL_CHARACTERS_IN_TABLE_NAMES
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_TIMEDOUT_TXN_REAPER_INTERVAL Use MetastoreConf.TIMEDOUT_TXN_REAPER_INTERVAL
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_TIMEDOUT_TXN_REAPER_START Use MetastoreConf.TIMEDOUT_TXN_REAPER_START
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_TXN_HEARTBEAT_THREADPOOL_SIZE Use MetastoreConf.TXN_HEARTBEAT_THREADPOOL_SIZE
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_TXN_MAX_OPEN_BATCH Use MetastoreConf.TXN_MAX_OPEN_BATCH
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_TXN_RETRYABLE_SQLEX_REGEX Use MetastoreConf.TXN_RETRYABLE_SQLEX_REGEX
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVE_TXN_TIMEOUT Use MetastoreConf.TXN_TIMEOUT
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HIVEMAPREDMODE
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HMSHANDLERATTEMPTS Use MetastoreConf.HMS_HANDLER_ATTEMPTS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HMSHANDLERFORCERELOADCONF Use MetastoreConf.HMS_HANDLER_FORCE_RELOAD_CONF
org.apache.hadoop.hive.conf.HiveConf.ConfVars.HMSHANDLERINTERVAL Use MetastoreConf.HMS_HANDLER_INTERVAL
org.apache.flink.runtime.jobgraph.RestoreMode.LEGACY
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METADATA_EXPORT_LOCATION Use MetastoreConf.METADATA_EXPORT_LOCATION
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_AGGREGATE_STATS_CACHE_CLEAN_UNTIL Use MetastoreConf.AGGREGATE_STATS_CACHE_CLEAN_UNTIL
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_AGGREGATE_STATS_CACHE_ENABLED Use MetastoreConf.AGGREGATE_STATS_CACHE_ENABLED
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_AGGREGATE_STATS_CACHE_FPP Use MetastoreConf.AGGREGATE_STATS_CACHE_FPP
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_AGGREGATE_STATS_CACHE_MAX_FULL Use MetastoreConf.AGGREGATE_STATS_CACHE_MAX_FULL
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_AGGREGATE_STATS_CACHE_MAX_PARTITIONS Use MetastoreConf.AGGREGATE_STATS_CACHE_MAX_PARTITIONS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_AGGREGATE_STATS_CACHE_MAX_READER_WAIT Use MetastoreConf.AGGREGATE_STATS_CACHE_MAX_READER_WAIT
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_AGGREGATE_STATS_CACHE_MAX_VARIANCE Use MetastoreConf.AGGREGATE_STATS_CACHE_MAX_VARIANCE
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_AGGREGATE_STATS_CACHE_MAX_WRITER_WAIT Use MetastoreConf.AGGREGATE_STATS_CACHE_MAX_WRITER_WAIT
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_AGGREGATE_STATS_CACHE_SIZE Use MetastoreConf.AGGREGATE_STATS_CACHE_SIZE
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_AGGREGATE_STATS_CACHE_TTL Use MetastoreConf.AGGREGATE_STATS_CACHE_TTL
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_AUTHORIZATION_STORAGE_AUTH_CHECKS Use MetastoreConf.AUTHORIZATION_STORAGE_AUTH_CHECKS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_AUTO_CREATE_ALL Use MetastoreConf.AUTO_CREATE_ALL
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_BATCH_RETRIEVE_MAX Use MetastoreConf.BATCH_RETRIEVE_MAX
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_BATCH_RETRIEVE_OBJECTS_MAX Use MetastoreConf.BATCH_RETRIEVE_OBJECTS_MAX
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_CACHE_LEVEL2 Use MetastoreConf.DATANUCLEUS_CACHE_LEVEL2
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_CACHE_PINOBJTYPES Use MetastoreConf.CACHE_PINOBJTYPES
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_CAPABILITY_CHECK Use MetastoreConf.CAPABILITY_CHECK
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_CLIENT_CONNECT_RETRY_DELAY Use MetastoreConf.CLIENT_CONNECT_RETRY_DELAY
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_CLIENT_KERBEROS_PRINCIPAL Use MetastoreConf.CLIENT_KERBEROS_PRINCIPAL
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_CLIENT_SOCKET_LIFETIME Use MetastoreConf.CLIENT_SOCKET_LIFETIME
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_CLIENT_SOCKET_TIMEOUT Use MetastoreConf.CLIENT_SOCKET_TIMEOUT
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_CLUSTER_DELEGATION_TOKEN_STORE_CLS Use MetastoreConf.DELEGATION_TOKEN_STORE_CLS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_CONNECTION_DRIVER Use MetastoreConf.CONNECTION_DRIVER
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_CONNECTION_POOLING_MAX_CONNECTIONS Use MetastoreConf.CONNECTION_POOLING_MAX_CONNECTIONS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_CONNECTION_POOLING_TYPE Use MetastoreConf.CONNECTION_POOLING_TYPE
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_CONNECTION_USER_NAME Use MetastoreConf.CONNECTION_USER_NAME
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_DATANUCLEUS_INIT_COL_INFO Use MetastoreConf.DATANUCLEUS_INIT_COL_INFO
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_DBACCESS_SSL_PROPS Use MetastoreConf.DBACCESS_SSL_PROPS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_DETACH_ALL_ON_COMMIT Use MetastoreConf.DETACH_ALL_ON_COMMIT
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_DIRECT_SQL_MAX_ELEMENTS_IN_CLAUSE Use MetastoreConf.DIRECT_SQL_MAX_ELEMENTS_IN_CLAUSE
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_DIRECT_SQL_MAX_ELEMENTS_VALUES_CLAUSE Use MetastoreConf.DIRECT_SQL_MAX_ELEMENTS_VALUES_CLAUSE
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_DIRECT_SQL_MAX_QUERY_LENGTH Use MetastoreConf.DIRECT_SQL_MAX_QUERY_LENGTH
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_DIRECT_SQL_PARTITION_BATCH_SIZE Use MetastoreConf.DIRECT_SQL_PARTITION_BATCH_SIZE
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_DISALLOW_INCOMPATIBLE_COL_TYPE_CHANGES Use MetastoreConf.DISALLOW_INCOMPATIBLE_COL_TYPE_CHANGES
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_END_FUNCTION_LISTENERS Use MetastoreConf.END_FUNCTION_LISTENERS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_EVENT_CLEAN_FREQ Use MetastoreConf.EVENT_CLEAN_FREQ
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_EVENT_DB_LISTENER_TTL Use MetastoreConf.EVENT_DB_LISTENER_TTL
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_EVENT_DB_NOTIFICATION_API_AUTH Use MetastoreConf.EVENT_DB_NOTIFICATION_API_AUTH
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_EVENT_EXPIRY_DURATION Use MetastoreConf.EVENT_EXPIRY_DURATION
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_EVENT_LISTENERS Use MetastoreConf.EVENT_LISTENERS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_EVENT_MESSAGE_FACTORY Use MetastoreConf.EVENT_MESSAGE_FACTORY
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_EXECUTE_SET_UGI Use MetastoreConf.EXECUTE_SET_UGI
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_EXPRESSION_PROXY_CLASS Use MetastoreConf.EXPRESSION_PROXY_CLASS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_FILTER_HOOK Use MetastoreConf.FILTER_HOOK
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_FS_HANDLER_THREADS_COUNT Use MetastoreConf.FS_HANDLER_THREADS_COUNT
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_HBASE_FILE_METADATA_THREADS Use MetastoreConf.FILE_METADATA_THREADS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_IDENTIFIER_FACTORY Use MetastoreConf.IDENTIFIER_FACTORY
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_INIT_HOOKS Use MetastoreConf.INIT_HOOKS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_INIT_METADATA_COUNT_ENABLED Use MetastoreConf.INIT_METADATA_COUNT_ENABLED
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_INTEGER_JDO_PUSHDOWN Use MetastoreConf.INTEGER_JDO_PUSHDOWN
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_KERBEROS_KEYTAB_FILE Use MetastoreConf.KERBEROS_KEYTAB_FILE
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_KERBEROS_PRINCIPAL Use MetastoreConf.KERBEROS_PRINCIPAL
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_LIMIT_PARTITION_REQUEST Use MetastoreConf.LIMIT_PARTITION_REQUEST
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_MANAGER_FACTORY_CLASS Use MetastoreConf.MANAGER_FACTORY_CLASS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_METRICS Use MetastoreConf.METRICS_ENABLED
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_NON_TRANSACTIONAL_READ Use MetastoreConf.NON_TRANSACTIONAL_READ
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_ORM_RETRIEVE_MAPNULLS_AS_EMPTY_STRINGS Use MetastoreConf.ORM_RETRIEVE_MAPNULLS_AS_EMPTY_STRINGS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_PART_INHERIT_TBL_PROPS Use MetastoreConf.PART_INHERIT_TBL_PROPS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_PARTITION_NAME_WHITELIST_PATTERN Use MetastoreConf.PARTITION_NAME_WHITELIST_PATTERN
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_PLUGIN_REGISTRY_BUNDLE_CHECK Use MetastoreConf.DATANUCLEUS_PLUGIN_REGISTRY_BUNDLE_CHECK
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_PRE_EVENT_LISTENERS Use MetastoreConf.PRE_EVENT_LISTENERS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_RAW_STORE_IMPL Use MetastoreConf.RAW_STORE_IMPL
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_SCHEMA_INFO_CLASS Use MetastoreConf.SCHEMA_INFO_CLASS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_SCHEMA_VERIFICATION Use MetastoreConf.SCHEMA_VERIFICATION
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_SCHEMA_VERIFICATION_RECORD_VERSION Use MetastoreConf.SCHEMA_VERIFICATION_RECORD_VERSION
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_SERVER_PORT Use MetastoreConf.SERVER_PORT
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_STORE_MANAGER_TYPE Use MetastoreConf.STORE_MANAGER_TYPE
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_TCP_KEEP_ALIVE Use MetastoreConf.TCP_KEEP_ALIVE
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_TOKEN_SIGNATURE Use MetastoreConf.TOKEN_SIGNATURE
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_TRANSACTION_ISOLATION Use MetastoreConf.DATANUCLEUS_TRANSACTION_ISOLATION
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_TRANSACTIONAL_EVENT_LISTENERS Use MetastoreConf.TRANSACTIONAL_EVENT_LISTENERS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_TRY_DIRECT_SQL Use MetastoreConf.TRY_DIRECT_SQL
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_TRY_DIRECT_SQL_DDL Use MetastoreConf.TRY_DIRECT_SQL_DDL
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_TXN_STORE_IMPL Use MetastoreConf.TXN_STORE_IMPL
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_URI_RESOLVER Use MetastoreConf.URI_RESOLVER
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_USE_LEGACY_VALUE_STRATEGY Use MetastoreConf.DATANUCLEUS_USE_LEGACY_VALUE_STRATEGY
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_USE_THRIFT_COMPACT_PROTOCOL Use MetastoreConf.USE_THRIFT_COMPACT_PROTOCOL
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_USE_THRIFT_FRAMED_TRANSPORT Use MetastoreConf.USE_THRIFT_FRAMED_TRANSPORT
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_USE_THRIFT_SASL Use MetastoreConf.USE_THRIFT_SASL
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_VALIDATE_COLUMNS Use MetastoreConf.VALIDATE_COLUMNS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_VALIDATE_CONSTRAINTS Use MetastoreConf.VALIDATE_CONSTRAINTS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_VALIDATE_TABLES Use MetastoreConf.VALIDATE_TABLES
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORE_WM_DEFAULT_POOL_SIZE Use MetastoreConf.WM_DEFAULT_POOL_SIZE
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORECONNECTURLHOOK Use MetastoreConf.CONNECT_URL_HOOK
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORECONNECTURLKEY Use MetastoreConf.CONNECT_URL_KEY
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTOREMULTITHREADED Use MetastoreConf.MULTITHREADED
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTOREPWD Use MetastoreConf.PWD
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORESELECTION Use MetastoreConf.THRIFT_URI_SELECTION
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORESERVERMAXMESSAGESIZE Use MetastoreConf.SERVER_MAX_MESSAGE_SIZE
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORESERVERMAXTHREADS Use MetastoreConf.SERVER_MAX_THREADS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORESERVERMINTHREADS Use MetastoreConf.SERVER_MIN_THREADS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORETHRIFTCONNECTIONRETRIES Use MetastoreConf.THRIFT_CONNECTION_RETRIES
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTORETHRIFTFAILURERETRIES Use MetastoreConf.THRIFT_FAILURE_RETRIES
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTOREURIS Use MetastoreConf.THRIFT_URIS
org.apache.hadoop.hive.conf.HiveConf.ConfVars.METASTOREWAREHOUSE Use MetastoreConf.WAREHOUSE
org.apache.hadoop.hive.conf.HiveConf.ConfVars.MOVE_EXPORTED_METADATA_TO_TRASH Use MetastoreConf.MOVE_EXPORTED_METADATA_TO_TRASH
org.apache.flink.configuration.JobManagerOptions.SchedulerType.Ng Use `JobManagerOptions.SchedulerType.Default` instead.
org.apache.hadoop.hive.conf.HiveConf.ConfVars.NOTIFICATION_SEQUENCE_LOCK_MAX_RETRIES Use MetastoreConf.NOTIFICATION_SEQUENCE_LOCK_MAX_RETRIES
org.apache.hadoop.hive.conf.HiveConf.ConfVars.NOTIFICATION_SEQUENCE_LOCK_RETRY_SLEEP_INTERVAL Use MetastoreConf.NOTIFICATION_SEQUENCE_LOCK_RETRY_SLEEP_INTERVAL
org.apache.flink.yarn.configuration.YarnDeploymentTarget.PER_JOB
org.apache.hadoop.hive.conf.HiveConf.ConfVars.SERDESUSINGMETASTOREFORSCHEMA Use MetastoreConf.SERDES_USING_METASTORE_FOR_SCHEMA
org.apache.flink.runtime.rest.messages.TerminationModeQueryParameter.TerminationMode.STOP Please use the "stop" command instead.
org.apache.flink.api.common.state.StateDescriptor.Type.UNKNOWN Enum for migrating from old checkpoints/savepoint versions.
org.apache.hadoop.hive.conf.HiveConf.ConfVars.WRITE_SET_REAPER_INTERVAL Use MetastoreConf.WRITE_SET_REAPER_INTERVAL

Back to Flink Website

Deprecated API

Contents

Back to Flink Website