Deprecated List (Flink : 1.14-SNAPSHOT API)

Deprecated Interfaces
Interface and Description
org.apache.flink.table.sinks.AppendStreamTableSink This interface has been replaced by `DynamicTableSink`. The new interface consumes internal data structures. See FLIP-95 for more information.
org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks
org.apache.flink.streaming.api.functions.AssignerWithPunctuatedWatermarks
org.apache.flink.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.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.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.table.factories.FileSystemFormatFactory This interface has been replaced by `BulkReaderFormatFactory` and `BulkWriterFormatFactory`.
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.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.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.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.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.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.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.

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.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.timestamps.AscendingTimestampExtractor
org.apache.flink.streaming.api.functions.AscendingTimestampExtractor Extend `AscendingTimestampExtractor` instead.
org.apache.flink.formats.avro.typeutils.AvroSerializer.AvroSchemaSerializerConfigSnapshot
org.apache.flink.streaming.api.windowing.assigners.BaseAlignedWindowAssigner will be removed in a future version. please use other `WindowAssigner`s listed under `org.apache.flink.streaming.api.windowing.assigners`.
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.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.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.api.common.typeutils.base.EnumSerializer.EnumSerializerConfigSnapshot
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.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.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.table.planner.functions.utils.HiveAggSqlFunction TODO hack code, its logical should be integrated to AggSqlFunction
org.apache.flink.table.planner.functions.utils.HiveTableSqlFunction TODO hack code, its logical should be integrated to TableSqlFunction
org.apache.flink.table.planner.functions.utils.HiveTableSqlFunction.HiveOperandTypeChecker TODO hack code, should modify calcite getRowType to pass operand types
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`, will remove this once `JdbcUpsertTableSink` is removed.
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.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.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.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.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.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.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.api.java.typeutils.runtime.PojoSerializer.PojoSerializerConfigSnapshot This snapshot class is no longer being used. It has been fully replaced by `PojoSerializerSnapshot`.
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.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.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.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.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.streaming.api.windowing.assigners.SlidingTimeWindows Please use `SlidingEventTimeWindows`.
org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializer.StreamElementSerializerConfigSnapshot see `StreamElementSerializer.StreamElementSerializerSnapshot`.
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.table.api.TableColumn See `ResolvedSchema` and `Column`.
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.runtime.checkpoint.TaskState Internal class for savepoint backwards compatibility. Don't use for other purposes.
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.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.windowing.assigners.TumblingTimeWindows Please use `TumblingEventTimeWindows`.
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.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.runtime.rest.messages.YarnStopJobTerminationHeaders This should be removed once we can send arbitrary REST calls via the Yarn proxy.

Deprecated Enums
Enum and Description
org.apache.flink.api.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.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.table.api.PlannerType The old planner has been removed in Flink 1.14. Since there is only one planner left (previously called the 'blink' planner), this class is obsolete and will be removed in future versions.
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.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 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 aways 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.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.configuration.TaskManagerOptions.INITIAL_REGISTRATION_BACKOFF use `ClusterOptions.INITIAL_REGISTRATION_TIMEOUT` instead
org.apache.flink.runtime.metrics.MetricNames.IO_CURRENT_INPUT_1_WATERMARK
org.apache.flink.runtime.metrics.MetricNames.IO_CURRENT_INPUT_2_WATERMARK
org.apache.flink.configuration.JobManagerOptions.JOB_MANAGER_HEAP_MEMORY use `JobManagerOptions.TOTAL_FLINK_MEMORY` for standalone setups and `JobManagerOptions.TOTAL_PROCESS_MEMORY` for containerized setups.
org.apache.flink.configuration.JobManagerOptions.JOB_MANAGER_HEAP_MEMORY_MB use `JobManagerOptions.TOTAL_FLINK_MEMORY` for standalone setups and `JobManagerOptions.TOTAL_PROCESS_MEMORY` for containerized setups.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_IPC_ADDRESS_KEY Use `JobManagerOptions.ADDRESS` instead
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_IPC_PORT_KEY Use `JobManagerOptions.PORT` instead
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_ARCHIVE_COUNT Use `WebOptions.ARCHIVE_COUNT` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_BACK_PRESSURE_CLEAN_UP_INTERVAL - no longer used.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_BACK_PRESSURE_DELAY - no longer used.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_BACK_PRESSURE_NUM_SAMPLES - no longer used.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_BACK_PRESSURE_REFRESH_INTERVAL - no longer used.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_CHECKPOINTS_DISABLE Not possible to disable any longer. Use history size of 0.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_CHECKPOINTS_HISTORY_SIZE Use `WebOptions.CHECKPOINTS_HISTORY_SIZE` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_LOG_PATH_KEY Use `WebOptions.LOG_PATH` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_PORT_KEY Use `WebOptions.PORT` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_SSL_ENABLED Use `WebOptions.SSL_ENABLED` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_SUBMIT_ENABLED_KEY Use `WebOptions.SUBMIT_ENABLE` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_TMPDIR_KEY Use `WebOptions.TMP_DIR` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_UPLOAD_DIR_KEY Use `WebOptions.UPLOAD_DIR` instead.
org.apache.flink.table.api.dataview.MapView.keyType
org.apache.flink.configuration.ConfigConstants.LIBRARY_CACHE_MANAGER_CLEANUP_INTERVAL use `BlobServerOptions.CLEANUP_INTERVAL` instead
org.apache.flink.configuration.ConfigConstants.LOCAL_NUMBER_RESOURCE_MANAGER Use `ResourceManagerOptions.LOCAL_NUMBER_RESOURCE_MANAGER` instead.
org.apache.flink.configuration.ResourceManagerOptions.LOCAL_NUMBER_RESOURCE_MANAGER
org.apache.flink.configuration.ConfigConstants.LOCAL_START_WEBSERVER Has no effect; the web-server is always started. Will be removed in 2.0.
org.apache.flink.configuration.AkkaOptions.LOOKUP_TIMEOUT use `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_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.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.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.ConfigConstants.RESOURCE_MANAGER_IPC_PORT_KEY Use `ResourceManagerOptions.IPC_PORT` instead.
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.ConfigConstants.STATE_BACKEND Use `CheckpointingOptions.STATE_BACKEND` instead.
org.apache.flink.configuration.CheckpointingOptions.STATE_BACKEND Use `StateBackendOptions.STATE_BACKEND`.
org.apache.flink.table.api.config.ExecutionConfigOptions.TABLE_EXEC_SHUFFLE_MODE Use `ExecutionOptions.BATCH_SHUFFLE_MODE` instead.
org.apache.flink.table.api.config.TableConfigOptions.TABLE_PLANNER
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.JavaParser.tokenNames Use `JavaParser.VOCABULARY` instead.
org.apache.flink.table.codesplit.JavaLexer.tokenNames Use `JavaLexer.VOCABULARY` instead.
org.apache.flink.table.codesplit.JavaParser.tokenNames Use `JavaParser.VOCABULARY` instead.
org.apache.flink.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.flink.table.api.Table.addColumns(String) use `Table.addColumns(Expression...)`
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.flink.api.common.operators.DualInputOperator.addFirstInput(Operator<IN1>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.DualInputOperator.addFirstInputs(List<Operator<IN1>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.SingleInputOperator.addInput(List<Operator<IN>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.addInput(Operator<IN>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.SingleInputOperator.addInput(Operator<IN>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.addInputs(List<? extends Operator<IN>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.table.api.Table.addOrReplaceColumns(String) use `Table.addOrReplaceColumns(Expression...)`
org.apache.flink.api.common.operators.DualInputOperator.addSecondInput(Operator<IN2>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.DualInputOperator.addSecondInputs(List<Operator<IN2>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.table.api.Table.aggregate(String) use `Table.aggregate(Expression)`
org.apache.flink.table.api.WindowGroupedTable.aggregate(String) use `WindowGroupedTable.aggregate(Expression)`
org.apache.flink.table.api.GroupedTable.aggregate(String) use `GroupedTable.aggregate(Expression)`
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.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.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.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.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.LimitedConnectionsFileSystem.create(Path, boolean, int, short, long)
org.apache.flink.core.fs.FileSystem.create(Path, boolean, int, short, long) Deprecated because not well supported across types of file systems. Control the behavior of specific file systems via configurations instead.
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.create(StreamExecutionEnvironment, TableConfig) Use `StreamTableEnvironment.create(StreamExecutionEnvironment)` and `TableEnvironment.getConfig()` for manipulating `TableConfig`.
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.contrib.streaming.state.PredefinedOptions.createColumnOptions() use `PredefinedOptions.createColumnOptions(Collection)` instead.
org.apache.flink.contrib.streaming.state.PredefinedOptions.createDBOptions() use `PredefinedOptions.createColumnOptions(Collection)` 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.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.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.Table.createTemporalTableFunction(String, String) use `Table.createTemporalTableFunction(Expression, Expression)`
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.createTemporaryView(String, DataStream<T>, Expression...) Use `StreamTableEnvironment.createTemporaryView(String, DataStream, Schema)` instead. In most cases, `StreamTableEnvironment.createTemporaryView(String, DataStream)` should already be sufficient. It integrates with the new type system and supports all kinds of `DataTypes` that the table runtime can consume. The semantics might be slightly different for raw and structured types.
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.createTemporaryView(String, DataStream<T>, String) use `StreamTableEnvironment.createTemporaryView(String, DataStream, Expression...)`
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.configuration.ConfigOption.deprecatedKeys() Replaced by `ConfigOption.fallbackKeys()`
org.apache.flink.table.descriptors.SchemaValidator.deriveTableSinkSchema(DescriptorProperties) This method combines two separate concepts of table schema and field mapping. This should be split into two methods once we have support for the corresponding interfaces (see FLINK-9870).
org.apache.flink.table.api.Table.dropColumns(String) use `Table.dropColumns(Expression...)`
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.flink.streaming.api.environment.CheckpointConfig.enableExternalizedCheckpoints(CheckpointConfig.ExternalizedCheckpointCleanup) use `CheckpointConfig.setExternalizedCheckpointCleanup(ExternalizedCheckpointCleanup)` instead.
org.apache.flink.table.api.SlideWithSize.every(String) use `SlideWithSize.every(Expression)`
org.apache.flink.table.api.TableEnvironment.execute(String) use `TableEnvironment.executeSql(String)` or `Table.executeInsert(String)` for single sink, use `TableEnvironment.createStatementSet()` for multiple sinks.
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.execute(String) Use `StreamExecutionEnvironment.execute(String)` instead or directly call the execute methods of the Table API such as `TableEnvironment.executeSql(String)`.
org.apache.flink.table.api.TableEnvironment.explain(boolean) use `StatementSet.explain(ExplainDetail...)`.
org.apache.flink.table.api.TableEnvironment.explain(Table) use `Table.explain(ExplainDetail...)`.
org.apache.flink.table.api.TableEnvironment.explain(Table, boolean) use `Table.explain(ExplainDetail...)`.
org.apache.flink.table.sources.CsvTableSource.Builder.field(String, TypeInformation<?>) This method will be removed in future versions as it uses the old type system. It is recommended to use `CsvTableSource.Builder.field(String, DataType)` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.api.TableSchema.Builder.field(String, TypeInformation<?>) This method will be removed in future versions as it uses the old type system. It is recommended to use `TableSchema.Builder.field(String, DataType)` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.descriptors.Schema.field(String, TypeInformation<?>) This method will be removed in future versions as it uses the old type system. Please use `Schema.field(String, DataType)` instead.
org.apache.flink.api.java.io.CsvReader.fieldDelimiter(char) Please use `CsvReader.fieldDelimiter(String)`.
org.apache.flink.table.api.Table.filter(String) use `Table.filter(Expression)`
org.apache.flink.table.api.Table.flatAggregate(String) use `Table.flatAggregate(Expression)`
org.apache.flink.table.api.WindowGroupedTable.flatAggregate(String) use `WindowGroupedTable.flatAggregate(Expression)`
org.apache.flink.table.api.GroupedTable.flatAggregate(String) use `GroupedTable.flatAggregate(Expression)`
org.apache.flink.table.api.Table.flatMap(String) use `Table.flatMap(Expression)`
org.apache.flink.cep.PatternStream.flatSelect(PatternFlatTimeoutFunction<T, L>, PatternFlatSelectFunction<T, R>) Use `PatternStream.flatSelect(OutputTag, PatternFlatTimeoutFunction, PatternFlatSelectFunction)` that returns timed out events as a side-output
org.apache.flink.table.api.OverWindowPartitionedOrderedPreceding.following(String) use `OverWindowPartitionedOrderedPreceding.following(Expression)`
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.api.bridge.java.StreamTableEnvironment.fromDataStream(DataStream<T>, String) use `StreamTableEnvironment.fromDataStream(DataStream, Expression...)`
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.
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.
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.
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.
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.TableEnvironment.fromTableSource(TableSource<?>)
org.apache.flink.table.api.TableSchema.fromTypeInfo(TypeInformation<?>) This method will be removed soon. Use `DataTypes` to declare types.
org.apache.flink.table.api.Table.fullOuterJoin(Table, String) use `Table.fullOuterJoin(Table, Expression)`
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.LimitedConnectionsFileSystem.getDefaultBlockSize()
org.apache.flink.core.fs.FileSystem.getDefaultBlockSize() This value is no longer used and is meaningless.
org.apache.flink.table.runtime.types.ClassLogicalTypeConverter.getDefaultExternalClassForType(LogicalType)
org.apache.flink.api.common.ExecutionConfig.getDefaultInputDependencyConstraint() due to the deprecation of `InputDependencyConstraint`.
org.apache.flink.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.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.table.sinks.TableSink.getFieldTypes() Use the field types of `TableSink.getTableSchema()` instead.
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.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.table.filesystem.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.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.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.api.Table.getSchema() This method has been deprecated as part of FLIP-164. `TableSchema` has been replaced by two more dedicated classes `Schema` and `ResolvedSchema`. Use `Schema` for declaration in APIs. `ResolvedSchema` is offered by the framework after resolution and validation.
org.apache.flink.table.catalog.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.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.JavaParser.getTokenNames()
org.apache.flink.table.codesplit.JavaLexer.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.table.api.Table.groupBy(String) use `Table.groupBy(Expression...)`
org.apache.flink.table.api.GroupWindowedTable.groupBy(String) use `GroupWindowedTable.groupBy(Expression...)`
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.table.api.Table.insertInto(String) use `Table.executeInsert(String)` for single sink, use `TableEnvironment.createStatementSet()` for multiple sinks.
org.apache.flink.table.api.TableEnvironment.insertInto(String, Table) use `Table.executeInsert(String)` for single sink, use `TableEnvironment.createStatementSet()` for multiple sinks.
org.apache.flink.table.api.TableEnvironment.insertInto(Table, String, String...) use `Table.executeInsert(String)` for single sink, use `TableEnvironment.createStatementSet()` for multiple sinks.
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.table.api.EnvironmentSettings.isBlinkPlanner() The old planner has been removed in Flink 1.14. Since there is only one planner left (previously called the 'blink' planner), this method is obsolete and will be removed in future versions.
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.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.table.api.Table.join(Table, String) use `Table.join(Table, Expression)`
org.apache.flink.table.api.Table.joinLateral(String) use `Table.joinLateral(Expression)`
org.apache.flink.table.api.Table.joinLateral(String, String) use `Table.joinLateral(Expression, Expression)`
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.api.Table.leftOuterJoin(Table, String) use `Table.leftOuterJoin(Table, Expression)`
org.apache.flink.table.api.Table.leftOuterJoinLateral(String) use `Table.leftOuterJoinLateral(Expression)`
org.apache.flink.table.api.Table.leftOuterJoinLateral(String, String) use `Table.leftOuterJoinLateral(Expression, Expression)`
org.apache.flink.api.common.io.DelimitedInputFormat.loadGlobalConfigParams() Please use `loadConfigParameters(Configuration config`
org.apache.flink.table.api.Table.map(String) use `Table.map(Expression)`
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.streaming.api.windowing.assigners.TumblingTimeWindows.of(Time) Please use `TumblingEventTimeWindows.of(Time)`.
org.apache.flink.streaming.api.windowing.assigners.SlidingTimeWindows.of(Time, Time) Please use `SlidingEventTimeWindows.of(Time, Time)`.
org.apache.flink.table.api.TumbleWithSize.on(String) use `TumbleWithSize.on(Expression)`
org.apache.flink.table.api.SlideWithSizeAndSlide.on(String) use `SlideWithSizeAndSlide.on(Expression)`
org.apache.flink.table.api.SessionWithGap.on(String) use `SessionWithGap.on(Expression)`
org.apache.flink.table.api.Over.orderBy(String) use `Over.orderBy(Expression)`
org.apache.flink.table.api.Table.orderBy(String) use `Table.orderBy(Expression...)`
org.apache.flink.table.api.OverWindowPartitioned.orderBy(String) use `OverWindowPartitioned.orderBy(Expression)`
org.apache.flink.table.api.Slide.over(String) use `Slide.over(Expression)`
org.apache.flink.table.api.Tumble.over(String) use `Tumble.over(Expression)`
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.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.table.api.OverWindowPartitionedOrdered.preceding(String) use `OverWindowPartitionedOrdered.preceding(Expression)`
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.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.readFileStream(String, long, FileMonitoringFunction.WatchType) Use `StreamExecutionEnvironment.readFile(FileInputFormat, String, FileProcessingMode, long)` instead.
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.registerDataStream(String, DataStream<T>, String) use `StreamTableEnvironment.createTemporaryView(String, DataStream, Expression...)`
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.api.Table.renameColumns(String) use `Table.renameColumns(Expression...)`
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.Table.rightOuterJoin(Table, String) use `Table.rightOuterJoin(Table, Expression)`
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.table.api.FlatAggregateTable.select(String) use `FlatAggregateTable.select(Expression...)`
org.apache.flink.table.api.Table.select(String) use `Table.select(Expression...)`
org.apache.flink.table.api.OverWindowedTable.select(String) use `OverWindowedTable.select(Expression...)`
org.apache.flink.table.api.WindowGroupedTable.select(String) use `WindowGroupedTable.select(Expression...)`
org.apache.flink.table.api.AggregatedTable.select(String) use `AggregatedTable.select(Expression...)`
org.apache.flink.table.api.GroupedTable.select(String) use `GroupedTable.select(Expression...)`
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.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.GenericDataSinkBase.setInputs(List<Operator<IN>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.SingleInputOperator.setInputs(List<Operator<IN>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.setInputs(Operator<IN>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.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.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.table.api.TableEnvironment.sqlUpdate(String) use `TableEnvironment.executeSql(String)` for single statement, use `TableEnvironment.createStatementSet()` for multiple DML statements.
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.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.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.table.api.EnvironmentSettings.Builder.useAnyPlanner() The old planner has been removed in Flink 1.14. Since there is only one planner left (previously called the 'blink' planner), this setting is obsolete and will be removed in future versions.
org.apache.flink.table.api.EnvironmentSettings.Builder.useBlinkPlanner() The old planner has been removed in Flink 1.14. Since there is only one planner left (previously called the 'blink' planner), this setting is obsolete and will be removed in future versions.
org.apache.flink.table.api.EnvironmentSettings.Builder.useOldPlanner() The old planner has been removed in Flink 1.14. Since there is only one planner left (previously called the 'blink' planner), this setting will throw an exception.
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.table.api.Table.where(String) use `Table.where(Expression)`
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.table.api.Session.withGap(String) use `Session.withGap(Expression)`
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.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.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.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.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.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.planner.typeutils.DataViewUtils.ListViewSpec(String, int, DataType, TypeSerializer<?>)
org.apache.calcite.rel.logical.LogicalTableScan(RelOptCluster, RelOptTable)
org.apache.calcite.rel.logical.LogicalTableScan(RelOptCluster, RelTraitSet, RelOptTable)
org.apache.flink.table.api.dataview.MapView(TypeInformation<?>, TypeInformation<?>) This method uses the old type system. Please use a `DataTypeHint` instead if the reflective type extraction is not successful.
org.apache.flink.table.planner.typeutils.DataViewUtils.MapViewSpec(String, int, DataType, boolean, TypeSerializer<?>, TypeSerializer<?>)
org.apache.calcite.rex.RexSimplify(RexBuilder, boolean, RexExecutor)
org.apache.calcite.rex.RexSimplify(RexBuilder, RelOptPredicateList, boolean, RexExecutor)
org.apache.flink.contrib.streaming.state.RocksDBStateBackend(AbstractStateBackend) Use `RocksDBStateBackend(StateBackend)` instead.
org.apache.flink.contrib.streaming.state.RocksDBStateBackend(AbstractStateBackend, boolean) Use `RocksDBStateBackend(StateBackend, TernaryBoolean)` instead.
org.apache.flink.runtime.leaderretrieval.StandaloneLeaderRetrievalService(String) Use `StandaloneLeaderRetrievalService(String, UUID)` instead
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.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.

Back to Flink Website

Deprecated API

Contents

Back to Flink Website