Deprecated List (Flink : 1.16-SNAPSHOT API)

Deprecated Interfaces
Interface and Description
org.apache.flink.streaming.connectors.elasticsearch.ActionRequestFailureHandler This has been deprecated and will be removed in the future.
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.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.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.streaming.connectors.elasticsearch.ElasticsearchSinkFunction This has been deprecated and will be removed in the future.
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.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.streaming.util.serialization.KeyedDeserializationSchema Use `KafkaDeserializationSchema`.
org.apache.flink.streaming.util.serialization.KeyedSerializationSchema Use `KafkaSerializationSchema`.
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.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.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.streaming.connectors.elasticsearch.RequestIndexer This has been deprecated and will be removed in the future.
org.apache.flink.streaming.connectors.elasticsearch7.RestClientFactory This has been deprecated and will be removed in the future.
org.apache.flink.streaming.connectors.elasticsearch6.RestClientFactory This has been deprecated and will be removed in the future.
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.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.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.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.

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.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.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.state.api.BootstrapTransformation Use `StateBootstrapTransformation` instead.
org.apache.flink.state.api.runtime.BootstrapTransformationWithID
org.apache.flink.state.api.output.BoundedOneInputStreamTaskRunner
org.apache.flink.batch.connectors.cassandra.CassandraOutputFormat Please use CassandraTupleOutputFormat instead.
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.streaming.api.datastream.CoGroupedStreams.UnionSerializerConfigSnapshot this snapshot class is no longer in use, and is maintained only for backwards compatibility. It is fully replaced by `CoGroupedStreams.UnionSerializerSnapshot`.
org.apache.flink.api.common.typeutils.base.CollectionSerializerConfigSnapshot this snapshot class should no longer be used by any serializers as their snapshot.
org.apache.flink.api.common.typeutils.CompositeSerializer.ConfigSnapshot this snapshot class is no longer in use by any serializers, and is only kept around for backwards compatibility. All subclass serializers should have their own serializer snapshot classes.
org.apache.flink.table.descriptors.ConnectorDescriptorValidator
org.apache.flink.api.java.typeutils.runtime.CopyableValueSerializer.CopyableValueSerializerConfigSnapshot
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.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.table.operations.DataStreamQueryOperation
org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory
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.typeutils.runtime.EitherSerializerConfigSnapshot
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.streaming.connectors.elasticsearch7.ElasticsearchSink This sink has been deprecated in favor of `ElasticsearchSink`
org.apache.flink.streaming.connectors.elasticsearch6.ElasticsearchSink This sink has been deprecated in favor of `ElasticsearchSink`
org.apache.flink.streaming.connectors.elasticsearch7.ElasticsearchSink.Builder This has been deprecated, please use `Elasticsearch7SinkBuilder`.
org.apache.flink.streaming.connectors.elasticsearch6.ElasticsearchSink.Builder This has been deprecated, please use `Elasticsearch6SinkBuilder`.
org.apache.flink.api.common.typeutils.base.EnumSerializer.EnumSerializerConfigSnapshot
org.apache.flink.state.api.EvictingWindowReader
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.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.streaming.connectors.kafka.FlinkKafkaConsumer
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer Please use `KafkaSink`.
org.apache.flink.streaming.connectors.kinesis.FlinkKinesisProducer This producer based on the Kinesis Producer Library KPL has been superseded. The new sink can be found in the module `flink-connectors/flink-connector-aws-kinesis-streams` and package `KinesisStreamsSink`. It is based on the AWS SDK for Java 2.x. The work to replace this sink was carried out in FLINK-24227.
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.runtime.state.filesystem.FsStateBackend
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.state.api.output.partitioner.HashSelector
org.apache.flink.connectors.hive.read.HiveBulkFormatAdapter Please use `HiveInputFormat`.
org.apache.flink.streaming.api.functions.IngestionTimeExtractor
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.connector.jdbc.internal.executor.InsertOrUpdateJdbcExecutor This has been replaced with `TableInsertOrUpdateStatementExecutor`
org.apache.flink.table.planner.operations.InternalDataStreamQueryOperation
org.apache.flink.streaming.api.operators.co.IntervalJoinOperator.BufferSerializerConfigSnapshot this snapshot class is no longer in use, and is maintained only for backwards compatibility. It is fully replaced by `IntervalJoinOperator.BufferEntrySerializerSnapshot`.
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.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.connectors.kinesis.model.KinesisStreamShard Will be remove in a future version in favor of `StreamShardHandle`.
org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer.KryoSerializerConfigSnapshot
org.apache.flink.kubernetes.highavailability.KubernetesLeaderElectionDriver in favour of `KubernetesMultipleComponentLeaderElectionDriver`
org.apache.flink.kubernetes.highavailability.KubernetesLeaderElectionDriverFactory in favour of `KubernetesMultipleComponentLeaderElectionDriverFactory`
org.apache.flink.kubernetes.highavailability.KubernetesLeaderRetrievalDriverFactory in favour of `KubernetesMultipleComponentLeaderRetrievalDriverFactory`
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.dataview.ListViewSerializer
org.apache.flink.table.dataview.ListViewSerializerSnapshot
org.apache.flink.table.dataview.ListViewTypeInfo
org.apache.flink.table.dataview.ListViewTypeInfoFactory
org.apache.flink.table.runtime.types.LogicalTypeDataTypeConverter
org.apache.flink.api.common.typeutils.base.MapSerializerConfigSnapshot this snapshot class should not be used by any serializer anymore.
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.test.util.MiniClusterResource This class should be replaced with `MiniClusterWithClientResource`.
org.apache.flink.test.util.MiniClusterResourceConfiguration This class should be replaced with `MiniClusterResourceConfiguration`.
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.nfa.NFA.NFASerializerConfigSnapshot This snapshot class is no longer in use, and only maintained for backwards compatibility purposes. It is fully replaced by `NFA.MigratedNFASerializerSnapshot`.
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.api.java.typeutils.runtime.NullableSerializer.NullableSerializerConfigSnapshot this snapshot class is no longer in use, and is maintained only for backwards compatibility purposes. It is fully replaced by `NullableSerializer.NullableSerializerSnapshot`.
org.apache.flink.table.dataview.NullAwareMapSerializer
org.apache.flink.table.dataview.NullAwareMapSerializerSnapshot
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.utils.Option These classes will be dropped in the next version. Use `ParameterTool` or a third-party command line parsing library instead.
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.common.typeutils.ParameterlessTypeSerializerConfig this snapshot class is no longer used by any serializers, and is maintained only for backward compatibility reasons. It is fully replaced by `SimpleTypeSerializerSnapshot`.
org.apache.flink.formats.parquet.avro.ParquetAvroWriters use `AvroParquetWriters` instead.
org.apache.flink.api.java.typeutils.runtime.PojoSerializer.PojoSerializerConfigSnapshot This snapshot class is no longer being used. It has been fully replaced by `PojoSerializerSnapshot`.
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.streaming.connectors.kinesis.config.ProducerConfigConstants This class is deprecated in favor of the official AWS Kinesis producer configuration keys. See here for the full list of available configs. For configuring the region and credentials, please use the keys in `AWSConfigConstants`.
org.apache.flink.runtime.webmonitor.handlers.ProgramArgsQueryParameter please, use `JarRequestBody.FIELD_NAME_PROGRAM_ARGUMENTS_LIST`
org.apache.flink.api.java.utils.RequiredParameters These classes will be dropped in the next version. Use `ParameterTool` or a third-party command line parsing library instead.
org.apache.flink.streaming.connectors.elasticsearch.util.RetryRejectedExecutionFailureHandler This hase been deprecated and will be removed in the future.
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.contrib.streaming.state.RocksDBStateBackend
org.apache.flink.api.java.typeutils.runtime.RowSerializer.RowSerializerConfigSnapshot this snapshot class is no longer in use, and is maintained only for backwards compatibility. It is fully replaced by `RowSerializer.RowSerializerSnapshot`.
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.typeutils.ScalaOptionSerializerConfigSnapshot this snapshot class is no longer in use, and is maintained only for backwards compatibility. It is fully replaced by `ScalaOptionSerializerSnapshot`.
org.apache.flink.table.functions.ScalarFunctionDefinition Non-legacy functions can simply omit this wrapper for declarations.
org.apache.flink.api.scala.typeutils.ScalaTrySerializerConfigSnapshot
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.cep.nfa.SharedBuffer everything in this class is deprecated. Those are only migration procedures from older versions.
org.apache.flink.cep.nfa.SharedBuffer.SharedBufferSerializerConfigSnapshot This snapshot class is no longer in use, and only maintained for backwards compatibility purposes. It is fully replaced by `SharedBuffer.SharedBufferSerializerSnapshot`.
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.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.calcite.sql2rel.SqlToRelConverter.ConfigBuilder
org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializer.StreamElementSerializerConfigSnapshot see `StreamElementSerializer.StreamElementSerializerSnapshot`.
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink Use `FileSink` 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.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.connector.file.src.reader.TextLineFormat Please use `TextLineInputFormat`.
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.streaming.api.operators.TimerSerializer.TimerSerializerConfigSnapshot this snapshot class is no longer in use, and is maintained only for backwards compatibility purposes. It is fully replaced by `TimerSerializerSnapshot`.
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.api.scala.typeutils.TraversableSerializerConfigSnapshot This is being replaced with `TraversableSerializerSnapshot`.
org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction.StateSerializerConfigSnapshot this snapshot class is no longer in use, and is maintained only for backwards compatibility purposes. It is fully replaced by `TwoPhaseCommitSinkFunction.StateSerializerSnapshot`.
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.common.typeutils.TypeSerializerConfigSnapshot
org.apache.flink.api.common.typeutils.TypeSerializerSerializationUtil This utility class was used to write serializers into checkpoints. Starting from Flink 1.6.x, this should no longer happen, and therefore this class is deprecated. It remains here for backwards compatibility paths.
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.table.api.constraints.UniqueConstraint See `ResolvedSchema` and `UniqueConstraint`.
org.apache.flink.api.java.typeutils.runtime.ValueSerializer.ValueSerializerConfigSnapshot
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.api.java.typeutils.runtime.WritableSerializer.WritableSerializerConfigSnapshot This class is no longer used as a snapshot for any serializer. It is fully replaced by `WritableSerializer.WritableSerializerSnapshot`.
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.
org.apache.flink.runtime.leaderelection.ZooKeeperLeaderElectionDriver in favour of `ZooKeeperMultipleComponentLeaderElectionDriver`
org.apache.flink.runtime.leaderelection.ZooKeeperLeaderElectionDriverFactory in favour of `ZooKeeperMultipleComponentLeaderElectionDriverFactory`

Deprecated Enums
Enum and Description
org.apache.flink.api.common.CodeAnalysisMode The code analysis code has been removed and this enum has no effect. NOTE It can not be removed from the codebase for now, because it had been serialized as part of the `ExecutionConfig` which in turn had been serialized as part of the `PojoSerializer`. This class can be removed when we drop support for pre 1.8 serializer snapshots that contained java serialized serializers (`TypeSerializerConfigSnapshot`).
org.apache.flink.table.api.config.ExecutionConfigOptions.LegacyCastBehaviour
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.utils.OptionType These classes will be dropped in the next version. Use `ParameterTool` or a third-party command line parsing library instead.
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.utils.RequiredParametersException These classes will be dropped in the next version. Use `ParameterTool` or a third-party command line parsing library instead.

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.WebOptions.ADDRESS
org.apache.flink.streaming.connectors.kinesis.config.ProducerConfigConstants.AGGREGATION_MAX_COUNT This is deprecated in favor of the official AWS Kinesis producer configuration keys. Please use `AggregationMaxCount` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_ASK_TIMEOUT Use `AkkaOptions.ASK_TIMEOUT` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_CLIENT_TIMEOUT Use `ClientOptions#CLIENT_TIMEOUT` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_DISPATCHER_THROUGHPUT Use `AkkaOptions.DISPATCHER_THROUGHPUT` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_FRAMESIZE Use `AkkaOptions.FRAMESIZE` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_JVM_EXIT_ON_FATAL_ERROR Use `AkkaOptions.JVM_EXIT_ON_FATAL_ERROR` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_LOG_LIFECYCLE_EVENTS Use `AkkaOptions.LOG_LIFECYCLE_EVENTS` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_LOOKUP_TIMEOUT Use `AkkaOptions.LOOKUP_TIMEOUT` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_SSL_ENABLED Use `AkkaOptions.SSL_ENABLED` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_STARTUP_TIMEOUT Use `AkkaOptions.STARTUP_TIMEOUT` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_TCP_TIMEOUT Use `AkkaOptions.TCP_TIMEOUT` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_TRANSPORT_HEARTBEAT_INTERVAL Use `AkkaOptions#TRANSPORT_HEARTBEAT_INTERVAL` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_TRANSPORT_HEARTBEAT_PAUSE Use `AkkaOptions#TRANSPORT_HEARTBEAT_PAUSE` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_TRANSPORT_THRESHOLD Use `AkkaOptions#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 `AkkaOptions.ASK_TIMEOUT_DURATION`
org.apache.flink.configuration.CheckpointingOptions.ASYNC_SNAPSHOTS Checkpoints are always asynchronous.
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.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.streaming.connectors.kinesis.config.ProducerConfigConstants.COLLECTION_MAX_COUNT This is deprecated in favor of the official AWS Kinesis producer configuration keys. Please use `CollectionMaxCount` 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 `AkkaOptions.ASK_TIMEOUT` 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 `AkkaOptions.DISPATCHER_THROUGHPUT` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_AKKA_FRAMESIZE Use `AkkaOptions.FRAMESIZE` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_AKKA_LOG_LIFECYCLE_EVENTS Use `AkkaOptions.LOG_LIFECYCLE_EVENTS` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_AKKA_LOOKUP_TIMEOUT Use `AkkaOptions.LOOKUP_TIMEOUT` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_AKKA_SSL_ENABLED Use `AkkaOptions.SSL_ENABLED` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_AKKA_TRANSPORT_HEARTBEAT_INTERVAL Use `AkkaOptions#TRANSPORT_HEARTBEAT_INTERVAL` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_AKKA_TRANSPORT_HEARTBEAT_PAUSE Use `AkkaOptions#TRANSPORT_HEARTBEAT_PAUSE` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_AKKA_TRANSPORT_THRESHOLD Use `AkkaOptions#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.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_FILESYSTEM_ALWAYS_CREATE_DIRECTORY Use `CoreOptions.FILESYSTEM_OUTPUT_ALWAYS_CREATE_DIRECTORY` instead.
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_RESOURCE_MANAGER Use `ResourceManagerOptions.LOCAL_NUMBER_RESOURCE_MANAGER` 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.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_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.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.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.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.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.runtime.state.StateBackendLoader.FS_STATE_BACKEND_NAME
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_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.calcite.rel.core.Values.IS_EMPTY
org.apache.calcite.rel.core.Values.IS_NOT_EMPTY
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.table.api.dataview.MapView.keyType
org.apache.flink.configuration.ConfigConstants.LIBRARY_CACHE_MANAGER_CLEANUP_INTERVAL use `BlobServerOptions.CLEANUP_INTERVAL` instead
org.apache.flink.configuration.ResourceManagerOptions.LOCAL_NUMBER_RESOURCE_MANAGER
org.apache.flink.configuration.ConfigConstants.LOCAL_NUMBER_RESOURCE_MANAGER Use `ResourceManagerOptions.LOCAL_NUMBER_RESOURCE_MANAGER` 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.connector.jdbc.table.JdbcConnectorOptions.LOOKUP_CACHE_MAX_ROWS please use `LookupOptions.PARTIAL_CACHE_MAX_ROWS` instead.
org.apache.flink.connector.hbase.table.HBaseConnectorOptions.LOOKUP_CACHE_MAX_ROWS Please use `LookupOptions.PARTIAL_CACHE_MAX_ROWS` instead.
org.apache.flink.connector.jdbc.table.JdbcConnectorOptions.LOOKUP_CACHE_MISSING_KEY please use `LookupOptions.PARTIAL_CACHE_CACHE_MISSING_KEY` instead.
org.apache.flink.connector.jdbc.table.JdbcConnectorOptions.LOOKUP_CACHE_TTL please use `LookupOptions.PARTIAL_CACHE_EXPIRE_AFTER_WRITE` instead.
org.apache.flink.connector.hbase.table.HBaseConnectorOptions.LOOKUP_CACHE_TTL Please use `LookupOptions.PARTIAL_CACHE_EXPIRE_AFTER_WRITE` instead.
org.apache.flink.connector.jdbc.table.JdbcConnectorOptions.LOOKUP_MAX_RETRIES please use `LookupOptions.MAX_RETRIES` instead.
org.apache.flink.connector.hbase.table.HBaseConnectorOptions.LOOKUP_MAX_RETRIES Please used `LookupOptions.MAX_RETRIES` instead.
org.apache.flink.configuration.AkkaOptions.LOOKUP_TIMEOUT use `AkkaOptions.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.WebOptions.PORT Use `RestOptions.PORT` instead
org.apache.flink.metrics.prometheus.PrometheusPushGatewayReporterOptions.PORT
org.apache.flink.connector.pulsar.sink.PulsarSinkOptions.PULSAR_MAX_PENDING_MESSAGES Use `PulsarOptions.PULSAR_MEMORY_LIMIT_BYTES` since Pulsar 2.10.0
org.apache.flink.connector.pulsar.sink.PulsarSinkOptions.PULSAR_MAX_PENDING_MESSAGES_ACROSS_PARTITIONS Use `PulsarOptions.PULSAR_MEMORY_LIMIT_BYTES` since Pulsar 2.10.0
org.apache.flink.connector.pulsar.source.PulsarSourceOptions.PULSAR_SUBSCRIPTION_INITIAL_POSITION This option would be reset by `StartCursor`, no need to use it anymore. Pulsar didn't support this config option before 1.10.1, so we have to remove this config option.
org.apache.flink.connector.pulsar.source.PulsarSourceOptions.PULSAR_TRANSACTION_TIMEOUT_MILLIS Use `PulsarSourceOptions.PULSAR_READ_TRANSACTION_TIMEOUT` instead. This would be removed in the next release.
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.ResourceManagerOptions.SLOT_REQUEST_TIMEOUT Use `JobManagerOptions.SLOT_REQUEST_TIMEOUT`.
org.apache.flink.configuration.SecurityOptions.SSL_ENABLED Use `SecurityOptions.SSL_INTERNAL_ENABLED` and `SecurityOptions.SSL_REST_ENABLED` instead.
org.apache.flink.configuration.WebOptions.SSL_ENABLED
org.apache.flink.configuration.CheckpointingOptions.STATE_BACKEND Use `StateBackendOptions.STATE_BACKEND`.
org.apache.flink.configuration.ConfigConstants.STATE_BACKEND Use `CheckpointingOptions.STATE_BACKEND` instead.
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_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.table.codesplit.JavaLexer.tokenNames Use `JavaLexer.VOCABULARY` instead.
org.apache.flink.table.codesplit.JavaParser.tokenNames Use `JavaParser.VOCABULARY` instead.
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.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.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.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.streaming.connectors.elasticsearch.RequestIndexer.add(ActionRequest...) use the `DeleteRequest`, `IndexRequest` or `UpdateRequest`
org.apache.hadoop.conf.Configuration.addDeprecation(String, String[]) use `Configuration.addDeprecation(String key, String newKey)` instead
org.apache.hadoop.conf.Configuration.addDeprecation(String, String[], String) use `Configuration.addDeprecation(String key, String newKey, String customMessage)` instead
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.SingleInputOperator.addInput(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.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.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.DataStream.assignTimestampsAndWatermarks(AssignerWithPeriodicWatermarks<T>) Please use `DataStream.assignTimestampsAndWatermarks(WatermarkStrategy)` instead.
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.assignTimestampsAndWatermarks(AssignerWithPeriodicWatermarks<T>) Please use `FlinkKafkaConsumerBase.assignTimestampsAndWatermarks(WatermarkStrategy)` instead.
org.apache.flink.streaming.api.datastream.DataStream.assignTimestampsAndWatermarks(AssignerWithPunctuatedWatermarks<T>) Please use `DataStream.assignTimestampsAndWatermarks(WatermarkStrategy)` instead.
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.assignTimestampsAndWatermarks(AssignerWithPunctuatedWatermarks<T>) Please use `FlinkKafkaConsumerBase.assignTimestampsAndWatermarks(WatermarkStrategy)` instead.
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.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>) replaced with `org.apache.flink.graph.asm.dataset.ChecksumHashCode` in Gelly
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.calcite.sql2rel.SqlToRelConverter.configBuilder()
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.connector.hbase.util.HBaseSerde.convertToRow(Result) Use `HBaseSerde.convertToReusedRow(Result)` instead.
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.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.core.fs.LimitedConnectionsFileSystem.create(Path, boolean, int, short, long)
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.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(ExecutionConfig)
org.apache.flink.table.factories.ModuleFactory.createModule(Map<String, String>) Use `ModuleFactory.createModule(Context)` instead and implement `Factory` instead of `TableFactory`.
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.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.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.calcite.rel.core.Filter.estimateFilteredRows(RelNode, RexNode)
org.apache.calcite.rel.core.Filter.estimateFilteredRows(RelNode, RexProgram)
org.apache.calcite.rel.core.Union.estimateRowCount(RelNode)
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.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.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.api.java.io.CsvReader.fieldDelimiter(char) Please use `CsvReader.fieldDelimiter(String)`.
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.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.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.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.connector.pulsar.source.enumerator.cursor.StartCursor.fromMessageTime(long) Use `StartCursor.fromPublishTime(long)` instead.
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.runtime.state.filesystem.FsStateBackend.getBasePath() Deprecated in favor of `FsStateBackend.getCheckpointPath()`.
org.apache.flink.configuration.Configuration.getBoolean(String, boolean) use `Configuration.getBoolean(ConfigOption, boolean)` or `Configuration.getOptional(ConfigOption)`
org.apache.flink.core.memory.DataOutputSerializer.getByteArray() Replaced by `DataOutputSerializer.getSharedBuffer()` for a better, safer name.
org.apache.flink.runtime.checkpoint.PendingCheckpoint.getCheckpointId() use `PendingCheckpoint.getCheckpointID()`
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.sql.parser.hive.impl.SimpleCharStream.getColumn()
org.apache.flink.table.api.TableEnvironment.getCompletionHints(String, int) Will be removed in the next release
org.apache.flink.core.fs.FileSystem.getDefaultBlockSize() This value is no longer used and is meaningless.
org.apache.flink.core.fs.LimitedConnectionsFileSystem.getDefaultBlockSize()
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.configuration.Configuration.getDouble(String, double) use `Configuration.getDouble(ConfigOption, double)` or `Configuration.getOptional(ConfigOption)`
org.apache.flink.api.common.ExecutionConfig.getExecutionRetryDelay() Should no longer be used because it is subsumed by RestartStrategyConfiguration
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(String, float) use `Configuration.getFloat(ConfigOption, float)` or `Configuration.getOptional(ConfigOption)`
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(String, int) use `Configuration.getInteger(ConfigOption, int)` or `Configuration.getOptional(ConfigOption)`
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.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.sql.parser.hive.impl.SimpleCharStream.getLine()
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(String, long) use `Configuration.getLong(ConfigOption, long)` or `Configuration.getOptional(ConfigOption)`
org.apache.flink.table.api.TableConfig.getMaxIdleStateRetentionTime() use`getIdleStateRetention` instead.
org.apache.flink.table.planner.utils.TableConfigUtils.getMaxIdleStateRetentionTime(ReadableConfig)
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 `CommonTestUtils.getLatestCompletedCheckpointPath(JobID, MiniCluster)` which is less prone to `NoSuchFileException` and IO-intensive.
org.apache.flink.test.util.TestUtils.getMostRecentCompletedCheckpointMaybe(File) please use `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.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.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.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.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.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.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.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.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(String, String) use `Configuration.getString(ConfigOption, String)` or `Configuration.getOptional(ConfigOption)`
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.table.codesplit.JavaLexer.getTokenNames()
org.apache.flink.table.codesplit.JavaParser.getTokenNames()
org.apache.flink.table.codesplit.JavaParser.getTokenNames()
org.apache.flink.table.codesplit.JavaLexer.getTokenNames()
org.apache.flink.streaming.api.graph.StreamConfig.getTypeSerializerIn1(ClassLoader)
org.apache.flink.streaming.api.graph.StreamConfig.getTypeSerializerIn2(ClassLoader)
org.apache.flink.runtime.highavailability.HighAvailabilityServices.getWebMonitorLeaderElectionService() Use `HighAvailabilityServices.getClusterRestEndpointLeaderElectionService()` instead.
org.apache.flink.runtime.highavailability.HighAvailabilityServices.getWebMonitorLeaderRetriever() just use `HighAvailabilityServices.getClusterRestEndpointLeaderRetriever()` instead of this method.
org.apache.flink.configuration.ConfigOption.hasDeprecatedKeys() Replaced by `ConfigOption.hasFallbackKeys()`
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.core.fs.EntropyInjector.isEntropyInjecting(FileSystem) Use `EntropyInjector.isEntropyInjecting(FileSystem, Path)` instead.
org.apache.flink.streaming.api.environment.CheckpointConfig.isFailOnCheckpointingErrors() Use `CheckpointConfig.getTolerableCheckpointFailureNumber()`.
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.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(TypeSerializer)` instead.
org.apache.flink.runtime.state.KeyedStateBackend.isStateImmutableInStateBackend(CheckpointType)
org.apache.calcite.sql2rel.SqlToRelConverter.isTrimUnusedFields()
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.CastRule.Context.legacyBehaviour()
org.apache.flink.table.planner.functions.casting.CodeGeneratorCastRule.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.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.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.connector.pulsar.source.enumerator.topic.range.RangeGenerator.open(Configuration, SourceConfiguration) Use `RangeGenerator.open(SourceConfiguration)` instead.
org.apache.flink.connector.pulsar.source.reader.deserializer.PulsarDeserializationSchema.open(DeserializationSchema.InitializationContext) Use {`#open(InitializationContext, SourceConfiguration)`} 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.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.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.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.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.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.runtime.jobmaster.LogicalSlot.releaseSlot() Added because extended the actual releaseSlot method with cause parameter.
org.apache.flink.table.factories.CatalogFactory.requiredContext() Implement the `Factory` based stack instead.
org.apache.flink.table.factories.ModuleFactory.requiredContext() Implement the `Factory` based stack instead.
org.apache.flink.api.common.typeutils.NestedSerializersSnapshotDelegate.resolveCompatibilityWithNested(TypeSerializerSchemaCompatibility<?>, TypeSerializer<?>...) this no method will be removed in the future. Resolving compatibility for nested serializers is now handled by `CompositeTypeSerializerSnapshot`.
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.api.common.ExecutionConfig.setDefaultInputDependencyConstraint(InputDependencyConstraint) due to the deprecation of `InputDependencyConstraint`.
org.apache.flink.connector.kafka.sink.KafkaSinkBuilder.setDeliverGuarantee(DeliveryGuarantee) Will be removed in future versions. Use `KafkaSinkBuilder.setDeliveryGuarantee(org.apache.flink.connector.base.DeliveryGuarantee)` instead.
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.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.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(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.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, Time)` 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.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.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 `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.hadoop.hive.metastore.HiveMetaStoreClient.showLocks()
org.apache.calcite.rex.RexSimplify.simplifyAnd(RexCall)
org.apache.calcite.rex.RexSimplify.simplifyAnds(Iterable<? extends RexNode>)
org.apache.calcite.rex.RexSimplify.simplifyOr(RexCall)
org.apache.calcite.rex.RexSimplify.simplifyOrs(List<RexNode>)
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.CatalogFactory.supportedProperties() Implement the `Factory` based stack instead.
org.apache.flink.table.factories.ModuleFactory.supportedProperties() Implement the `Factory` based stack instead.
org.apache.flink.api.common.io.FileInputFormat.supportsMultiPaths() Will be removed for Flink 2.0.
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.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.connector.jdbc.utils.JdbcTypeUtil.typeInformationToSqlType(TypeInformation<?>)
org.apache.flink.api.java.operators.CrossOperator.ProjectCross.types(Class<?>...) Deprecated method only kept for compatibility.
org.apache.flink.api.java.operators.JoinOperator.ProjectJoin.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.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.streaming.api.functions.sink.filesystem.rollingpolicies.DefaultRollingPolicy.PolicyBuilder.withRolloverInterval(long) Use `DefaultRollingPolicy.PolicyBuilder.withRolloverInterval(Duration)` instead.
org.apache.calcite.rex.RexSimplify.withUnknownAsFalse(boolean) Use methods with a `RexUnknownAs` argument, such as `RexSimplify.simplify(RexNode, RexUnknownAs)`.
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.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, 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.formats.json.JsonRowSerializationSchema.Builder(String) Use `JsonRowSerializationSchema.builder()` instead.
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.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.FlinkJoinPushExpressionsRule(Class<? extends Join>, RelFactories.ProjectFactory)
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.streaming.connectors.kafka.FlinkKafkaProducer(String, KeyedSerializationSchema<IN>, Properties) use `FlinkKafkaProducer(String, KafkaSerializationSchema, Properties, FlinkKafkaProducer.Semantic)`
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, KeyedSerializationSchema<IN>, Properties, FlinkKafkaProducer.Semantic) use `FlinkKafkaProducer(String, KafkaSerializationSchema, Properties, FlinkKafkaProducer.Semantic)`
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, KeyedSerializationSchema<IN>, Properties, Optional<FlinkKafkaPartitioner<IN>>) use `FlinkKafkaProducer(String, KafkaSerializationSchema, Properties, FlinkKafkaProducer.Semantic)`
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, KeyedSerializationSchema<IN>, Properties, Optional<FlinkKafkaPartitioner<IN>>, FlinkKafkaProducer.Semantic, int) use `FlinkKafkaProducer(String, KafkaSerializationSchema, Properties, FlinkKafkaProducer.Semantic)`
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, String, KeyedSerializationSchema<IN>) use `FlinkKafkaProducer(String, KafkaSerializationSchema, Properties, FlinkKafkaProducer.Semantic)`
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.connector.jdbc.catalog.JdbcCatalog(String, String, String, String, String) please use `JdbcCatalog(ClassLoader, String, String, String, String, String)` instead.
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.LogicalFilter(RelOptCluster, RelNode, RexNode)
org.apache.calcite.rel.logical.LogicalFilter(RelOptCluster, RelTraitSet, RelNode, RexNode)
org.apache.calcite.rel.logical.LogicalIntersect(RelOptCluster, List<RelNode>, boolean)
org.apache.calcite.rel.logical.LogicalMinus(RelOptCluster, List<RelNode>, boolean)
org.apache.calcite.rel.logical.LogicalTableScan(RelOptCluster, RelOptTable)
org.apache.calcite.rel.logical.LogicalTableScan(RelOptCluster, RelTraitSet, RelOptTable)
org.apache.calcite.rel.logical.LogicalUnion(RelOptCluster, List<RelNode>, boolean)
org.apache.calcite.rel.logical.LogicalValues(RelOptCluster, RelDataType, ImmutableList<ImmutableList<RexLiteral>>)
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.calcite.rex.RexSimplify(RexBuilder, boolean, RexExecutor)
org.apache.calcite.rex.RexSimplify(RexBuilder, RelOptPredicateList, boolean, RexExecutor)
org.apache.calcite.rel.core.Window.RexWinAggCall(SqlAggFunction, RelDataType, List<RexNode>, int, boolean)
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.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`.

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.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