Deprecated List (Flink : 1.12-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 and only works with the Blink planner. See FLIP-95 for more information.
org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks
org.apache.flink.streaming.api.functions.AssignerWithPunctuatedWatermarks
org.apache.flink.table.sinks.BatchTableSink use `OutputFormatTableSink` instead.
org.apache.flink.table.factories.BatchTableSinkFactory This interface has been replaced by `DynamicTableSinkFactory`. The new interface creates instances of `DynamicTableSink` and only works with the Blink planner. See FLIP-95 for more information.
org.apache.flink.table.sources.BatchTableSource use `InputFormatTableSource` instead.
org.apache.flink.table.factories.BatchTableSourceFactory This interface has been replaced by `DynamicTableSourceFactory`. The new interface creates instances of `DynamicTableSource` and only works with the Blink planner. See FLIP-95 for more information.
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.sources.DefinedFieldMapping This interface will not be supported in the new source design around `DynamicTableSource` which only works with the Blink planner. 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` which only works with the Blink planner. 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` which only works with the Blink planner. Use the concept of computed columns instead. See FLIP-95 for more information.
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` which only works with the Blink planner. 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` which only works with the Blink planner. 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` which only works with the Blink planner. 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` which only works with the Blink planner. 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` which only works with the Blink planner. 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` which only works with the Blink planner. 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` which only works with the Blink planner. 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` which only works with the Blink planner. 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` which only works with the Blink planner. 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 and only works with the Blink planner. 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 and only works with the Blink planner. 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` and only works with the Blink planner. 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 and only works with the Blink planner. 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` and only works with the Blink planner. 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 and only works with the Blink planner. 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 and only works with the Blink planner. 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 and only works with the Blink planner. See FLIP-95 for more information.

Deprecated Classes
Class and Description
org.apache.flink.streaming.util.serialization.AbstractDeserializationSchema Use `AbstractDeserializationSchema` instead.
org.apache.flink.cep.pattern.conditions.AndCondition Please use `RichAndCondition` instead. This class exists just for backwards compatibility and will be removed in FLINK-10113.
org.apache.flink.streaming.api.functions.AscendingTimestampExtractor Extend `AscendingTimestampExtractor` instead.
org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor
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.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.api.java.typeutils.runtime.CopyableValueSerializer.CopyableValueSerializerConfigSnapshot
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.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 and only works with the Blink planner. 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.handler.job.metrics.JobVertexMetricsHandler This class is subsumed by `SubtaskMetricsHandler` and is only kept for backwards-compatibility.
org.apache.flink.streaming.connectors.kafka.KafkaTableSink Use `KafkaDynamicSink` via `KafkaDynamicTableFactory`.
org.apache.flink.streaming.connectors.kafka.KafkaTableSinkBase Use `KafkaDynamicSink` via `KafkaDynamicTableFactory`.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource Use `KafkaDynamicSource` via `KafkaDynamicTableFactory`.
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBase Use `KafkaDynamicSource` via `KafkaDynamicTableFactory`.
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactory Use `KafkaDynamicTableFactory`.
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase Use `KafkaDynamicTableFactory`.
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.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.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.OldCsv Use the RFC-compliant `Csv` format in the dedicated flink-formats/flink-csv module instead when writing to Kafka.
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 and only works with the Blink planner. 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.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.sources.RowtimeAttributeDescriptor This interface will not be supported in the new source design around `DynamicTableSource` which only works with the Blink planner. Use the concept of computed columns instead. See FLIP-95 for more information.
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.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.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.util.TableConnectorUtil Use `TableConnectorUtils` instead.
org.apache.flink.addons.hbase1.TableInputFormat please use `HBaseInputFormat`.
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` which only works with the Blink planner. 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.api.java.typeutils.runtime.ValueSerializer.ValueSerializerConfigSnapshot
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.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.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.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.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 in favor of `MesosOptions#ARTIFACT_SERVER_PORT_KEY`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_MESOS_ARTIFACT_SERVER_SSL_ENABLED in favor of `MesosOptions#ARTIFACT_SERVER_SSL_ENABLED`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_MESOS_FAILOVER_TIMEOUT_SECS in favor of `MesosOptions#FAILOVER_TIMEOUT_SECONDS`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_MESOS_RESOURCEMANAGER_FRAMEWORK_NAME in favor of `MesosOptions#RESOURCEMANAGER_FRAMEWORK_NAME`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_MESOS_RESOURCEMANAGER_FRAMEWORK_ROLE in favor of `MesosOptions#RESOURCEMANAGER_FRAMEWORK_ROLE`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_MESOS_RESOURCEMANAGER_FRAMEWORK_USER in favor of `MesosOptions#RESOURCEMANAGER_FRAMEWORK_USER`.
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 in favor of `HighAvailabilityOptions.HA_ZOOKEEPER_CHECKPOINT_COUNTER_PATH`
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_CHECKPOINTS_PATH in favor of `HighAvailabilityOptions.HA_ZOOKEEPER_CHECKPOINTS_PATH`.
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 in favor of `HighAvailabilityOptions.HA_ZOOKEEPER_LATCH_PATH`.
org.apache.flink.configuration.ConfigConstants.DEFAULT_ZOOKEEPER_LEADER_PATH in favor of `HighAvailabilityOptions.HA_ZOOKEEPER_LEADER_PATH`.
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 in favor of `HighAvailabilityOptions.HA_ZOOKEEPER_MESOS_WORKERS_PATH`.
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.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.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 in favor of `HighAvailabilityOptions.HA_ZOOKEEPER_CHECKPOINT_COUNTER_PATH`.
org.apache.flink.configuration.ConfigConstants.HA_ZOOKEEPER_CHECKPOINTS_PATH in favor of `HighAvailabilityOptions.HA_ZOOKEEPER_CHECKPOINTS_PATH`.
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 in favor of `HighAvailabilityOptions.HA_ZOOKEEPER_LATCH_PATH`.
org.apache.flink.configuration.ConfigConstants.HA_ZOOKEEPER_LEADER_PATH in favor of `HighAvailabilityOptions.HA_ZOOKEEPER_LEADER_PATH`.
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 in favor of `HighAvailabilityOptions.HA_ZOOKEEPER_MESOS_WORKERS_PATH`.
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 Use `WebOptions.BACKPRESSURE_CLEANUP_INTERVAL` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_BACK_PRESSURE_DELAY Use `WebOptions.BACKPRESSURE_DELAY` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_BACK_PRESSURE_NUM_SAMPLES Use `WebOptions.BACKPRESSURE_NUM_SAMPLES` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_BACK_PRESSURE_REFRESH_INTERVAL Use `WebOptions.BACKPRESSURE_REFRESH_INTERVAL` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_CHECKPOINTS_DISABLE Not possible to disable any longer. Use history size of 0.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_CHECKPOINTS_HISTORY_SIZE Use `WebOptions.CHECKPOINTS_HISTORY_SIZE` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_LOG_PATH_KEY Use `WebOptions.LOG_PATH` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_PORT_KEY Use `WebOptions.PORT` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_SSL_ENABLED Use `WebOptions.SSL_ENABLED` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_SUBMIT_ENABLED_KEY Use `WebOptions.SUBMIT_ENABLE` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_TMPDIR_KEY Use `WebOptions.TMP_DIR` instead.
org.apache.flink.configuration.ConfigConstants.JOB_MANAGER_WEB_UPLOAD_DIR_KEY Use `WebOptions.UPLOAD_DIR` instead.
org.apache.flink.table.api.dataview.MapView.keyType
org.apache.flink.configuration.ConfigConstants.LIBRARY_CACHE_MANAGER_CLEANUP_INTERVAL use `BlobServerOptions.CLEANUP_INTERVAL` instead
org.apache.flink.configuration.ResourceManagerOptions.LOCAL_NUMBER_RESOURCE_MANAGER
org.apache.flink.configuration.ConfigConstants.LOCAL_NUMBER_RESOURCE_MANAGER Use `ResourceManagerOptions.LOCAL_NUMBER_RESOURCE_MANAGER` instead.
org.apache.flink.configuration.ConfigConstants.LOCAL_START_WEBSERVER Has no effect; the web-server is always started. Will be removed in 2.0.
org.apache.flink.configuration.ConfigConstants.MESOS_ARTIFACT_SERVER_PORT_KEY in favor of `MesosOptions#ARTIFACT_SERVER_PORT_KEY`.
org.apache.flink.configuration.ConfigConstants.MESOS_ARTIFACT_SERVER_SSL_ENABLED in favor of `MesosOptions#ARTIFACT_SERVER_SSL_ENABLED`.
org.apache.flink.configuration.ConfigConstants.MESOS_FAILOVER_TIMEOUT_SECONDS in favor of `MesosOptions#FAILOVER_TIMEOUT_SECONDS`.
org.apache.flink.configuration.ConfigConstants.MESOS_INITIAL_TASKS in favor of `MesosOptions#INITIAL_TASKS`.
org.apache.flink.configuration.ConfigConstants.MESOS_MASTER_URL in favor of `MesosOptions#MASTER_URL`.
org.apache.flink.configuration.ConfigConstants.MESOS_MAX_FAILED_TASKS in favor of `MesosOptions#MAX_FAILED_TASKS`.
org.apache.flink.configuration.ConfigConstants.MESOS_RESOURCEMANAGER_FRAMEWORK_NAME in favor of `MesosOptions#RESOURCEMANAGER_FRAMEWORK_NAME`.
org.apache.flink.configuration.ConfigConstants.MESOS_RESOURCEMANAGER_FRAMEWORK_PRINCIPAL in favor of `MesosOptions#RESOURCEMANAGER_FRAMEWORK_PRINCIPAL`.
org.apache.flink.configuration.ConfigConstants.MESOS_RESOURCEMANAGER_FRAMEWORK_ROLE in favor of `MesosOptions#RESOURCEMANAGER_FRAMEWORK_ROLE`.
org.apache.flink.configuration.ConfigConstants.MESOS_RESOURCEMANAGER_FRAMEWORK_SECRET in favor of `MesosOptions#RESOURCEMANAGER_FRAMEWORK_SECRET`.
org.apache.flink.configuration.ConfigConstants.MESOS_RESOURCEMANAGER_FRAMEWORK_USER in favor of `MesosOptions#RESOURCEMANAGER_FRAMEWORK_USER`.
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.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.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.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.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.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 Deprecated in favour of `ConfigConstants.HA_ZOOKEEPER_MESOS_WORKERS_PATH`.
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.SingleInputOperator.addInput(Operator<IN>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.addInput(Operator<IN>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.addInputs(List<? extends Operator<IN>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.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.table.api.TableEnvironment.connect(ConnectorDescriptor) The SQL `CREATE TABLE` DDL is richer than this part of the API. This method might be refactored in the next versions. Please use `executeSql(ddl)` to register a table instead.
org.apache.flink.table.api.bridge.java.BatchTableEnvironment.connect(ConnectorDescriptor) The SQL `CREATE TABLE` DDL is richer than this part of the API. This method might be refactored in the next versions. Please use `executeSql(ddl)` to register a table instead.
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.connect(ConnectorDescriptor) The SQL `CREATE TABLE` DDL is richer than this part of the API. This method might be refactored in the next versions. Please use `executeSql(ddl)` to register a table instead.
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.DefaultRollingPolicy.create()
org.apache.flink.core.fs.FileSystem.create(Path, boolean) Use `FileSystem.create(Path, WriteMode)` instead.
org.apache.flink.core.fs.FileSystem.create(Path, boolean, int, short, long) Deprecated because not well supported across types of file systems. Control the behavior of specific file systems via configurations instead.
org.apache.flink.core.fs.LimitedConnectionsFileSystem.create(Path, boolean, int, short, long)
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.create(StreamExecutionEnvironment, TableConfig) Use `StreamTableEnvironment.create(StreamExecutionEnvironment)` and `TableEnvironment.getConfig()` for manipulating `TableConfig`.
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.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.BatchTableEnvironment.createTemporaryView(String, DataSet<T>, String) use `BatchTableEnvironment.createTemporaryView(String, DataSet, Expression...)`
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.Csv.deriveSchema() Derivation format schema from table's schema is the default behavior now. So there is no need to explicitly declare to derive schema.
org.apache.flink.table.descriptors.Json.deriveSchema() Derivation format schema from table's schema is the default behavior now. So there is no need to explicitly declare to derive schema.
org.apache.flink.table.descriptors.OldCsv.deriveSchema() Derivation format schema from table's schema is the default behavior now. So there is no need to explicitly declare to derive schema.
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.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.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.descriptors.OldCsv.field(String, DataType) `OldCsv` supports derive schema from table schema by default, it is no longer necessary to explicitly declare the format schema. This method will be removed in the future.
org.apache.flink.table.descriptors.OldCsv.field(String, String) `OldCsv` supports derive schema from table schema by default, it is no longer necessary to explicitly declare the format schema. This method will be removed in the future.
org.apache.flink.table.sources.CsvTableSource.Builder.field(String, TypeInformation<?>) This method will be removed in future versions as it uses the old type system. It is recommended to use `CsvTableSource.Builder.field(String, DataType)` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.descriptors.OldCsv.field(String, TypeInformation<?>) `OldCsv` supports derive schema from table schema by default, it is no longer necessary to explicitly declare the format schema. This method will be removed in the future.
org.apache.flink.table.descriptors.Schema.field(String, TypeInformation<?>) This method will be removed in future versions as it uses the old type system. Please use `Schema.field(String, DataType)` instead.
org.apache.flink.table.api.TableSchema.Builder.field(String, TypeInformation<?>) This method will be removed in future versions as it uses the old type system. It is recommended to use `TableSchema.Builder.field(String, DataType)` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.api.java.io.CsvReader.fieldDelimiter(char) Please use `CsvReader.fieldDelimiter(String)`.
org.apache.flink.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.BatchTableEnvironment.fromDataSet(DataSet<T>, String) use `BatchTableEnvironment.fromDataSet(DataSet, Expression...)`
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.fromDataStream(DataStream<T>, String) use `StreamTableEnvironment.fromDataStream(DataStream, Expression...)`
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.runtime.types.LogicalTypeDataTypeConverter.fromLogicalTypeToDataType(LogicalType)
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.runtime.state.filesystem.FsStateBackend.getBasePath() Deprecated in favor of `FsStateBackend.getCheckpointPath()`.
org.apache.flink.configuration.Configuration.getBoolean(String, boolean) use `Configuration.getBoolean(ConfigOption, boolean)` or `Configuration.getOptional(ConfigOption)`
org.apache.flink.core.memory.DataOutputSerializer.getByteArray() Replaced by `DataOutputSerializer.getSharedBuffer()` for a better, safer name.
org.apache.flink.runtime.checkpoint.PendingCheckpoint.getCheckpointId() use `PendingCheckpoint.getCheckpointID()`
org.apache.flink.streaming.api.environment.RemoteStreamEnvironment.getClientConfiguration() This method is going to be removed in the next releases.
org.apache.flink.sql.parser.impl.SimpleCharStream.getColumn()
org.apache.flink.sql.parser.hive.impl.SimpleCharStream.getColumn()
org.apache.flink.table.api.TableEnvironment.getCompletionHints(String, int) Will be removed in the next release
org.apache.flink.core.fs.FileSystem.getDefaultBlockSize() This value is no longer used and is meaningless.
org.apache.flink.core.fs.LimitedConnectionsFileSystem.getDefaultBlockSize()
org.apache.flink.table.runtime.types.ClassLogicalTypeConverter.getDefaultExternalClassForType(LogicalType)
org.apache.flink.configuration.Configuration.getDouble(String, double) use `Configuration.getDouble(ConfigOption, double)` or `Configuration.getOptional(ConfigOption)`
org.apache.flink.api.common.ExecutionConfig.getExecutionRetryDelay() Should no longer be used because it is subsumed by RestartStrategyConfiguration
org.apache.flink.table.sinks.TableSink.getFieldNames() Use the field names of `TableSink.getTableSchema()` instead.
org.apache.flink.table.api.TableSchema.getFieldType(int) This method will be removed in future versions as it uses the old type system. It is recommended to use `TableSchema.getFieldDataType(int)` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.api.TableSchema.getFieldType(String) This method will be removed in future versions as it uses the old type system. It is recommended to use `TableSchema.getFieldDataType(String)` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.sinks.TableSink.getFieldTypes() Use the field types of `TableSink.getTableSchema()` instead.
org.apache.flink.table.api.TableSchema.getFieldTypes() This method will be removed in future versions as it uses the old type system. It is recommended to use `TableSchema.getFieldDataTypes()` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.api.common.io.FileInputFormat.getFilePath() Please use getFilePaths() instead.
org.apache.flink.configuration.Configuration.getFloat(String, float) use `Configuration.getFloat(ConfigOption, float)` or `Configuration.getOptional(ConfigOption)`
org.apache.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.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.java.ExecutionEnvironment.getNumberOfExecutionRetries() This method will be replaced by `ExecutionEnvironment.getRestartStrategy()`. The `RestartStrategies.FixedDelayRestartStrategyConfiguration` contains the number of execution retries.
org.apache.flink.api.common.ExecutionConfig.getNumberOfExecutionRetries() Should no longer be used because it is subsumed by RestartStrategyConfiguration
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.ScalarFunction.getParameterTypes(Class<?>[]) This method uses the old type system and is based on the old reflective extraction logic. The method will be removed in future versions and is only called when using the deprecated `TableEnvironment.registerFunction(...)` method. The new reflective extraction logic (possibly enriched with `DataTypeHint` and `FunctionHint`) should be powerful enough to cover most use cases. For advanced users, it is possible to override `UserDefinedFunction.getTypeInference(DataTypeFactory)`.
org.apache.flink.table.functions.TableFunction.getParameterTypes(Class<?>[]) This method uses the old type system and is based on the old reflective extraction logic. The method will be removed in future versions and is only called when using the deprecated `TableEnvironment.registerFunction(...)` method. The new reflective extraction logic (possibly enriched with `DataTypeHint` and `FunctionHint`) should be powerful enough to cover most use cases. For advanced users, it is possible to override `UserDefinedFunction.getTypeInference(DataTypeFactory)`.
org.apache.flink.table.catalog.CatalogBaseTable.getProperties() Use `CatalogBaseTable.getOptions()`.
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.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.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.GroupWindowedTable.groupBy(String) use `GroupWindowedTable.groupBy(Expression...)`
org.apache.flink.table.api.Table.groupBy(String) use `Table.groupBy(Expression...)`
org.apache.flink.configuration.ConfigOption.hasDeprecatedKeys() Replaced by `ConfigOption.hasFallbackKeys()`
org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer.init(Map<EventId, Lockable<V>>, Map<NodeId, Lockable<SharedBufferNode>>) Only for state migration!
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.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.streaming.api.environment.CheckpointConfig.isPreferCheckpointForRecovery() Don't activate prefer checkpoints for recovery because it can lead to data loss and duplicate output. This option will soon be removed. See FLINK-20427 for more information.
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.table.descriptors.Json.jsonSchema(String) `Json` supports derive schema from table schema by default, it is no longer necessary to explicitly declare the format schema. This method will be removed in the future.
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.SessionWithGap.on(String) use `SessionWithGap.on(Expression)`
org.apache.flink.table.api.SlideWithSizeAndSlide.on(String) use `SlideWithSizeAndSlide.on(Expression)`
org.apache.flink.table.api.TumbleWithSize.on(String) use `TumbleWithSize.on(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.Over.orderBy(String) use `Over.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.BatchTableEnvironment.registerDataSet(String, DataSet<T>) use `BatchTableEnvironment.createTemporaryView(String, DataSet)`
org.apache.flink.table.api.bridge.java.BatchTableEnvironment.registerDataSet(String, DataSet<T>, String) use `BatchTableEnvironment.createTemporaryView(String, DataSet, String)`
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.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.runtime.checkpoint.CheckpointCoordinator.restoreLatestCheckpointedState(Map<JobVertexID, ExecutionJobVertex>, boolean, boolean)
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.table.descriptors.OldCsv.schema(TableSchema) `OldCsv` supports derive schema from table schema by default, it is no longer necessary to explicitly declare the format schema. This method will be removed in the future.
org.apache.flink.table.descriptors.Csv.schema(TypeInformation<Row>) `Csv` supports derive schema from table schema by default, it is no longer necessary to explicitly declare the format schema. This method will be removed in the future.
org.apache.flink.table.descriptors.Json.schema(TypeInformation<Row>) `Json` supports derive schema from table schema by default, it is no longer necessary to explicitly declare the format schema. This method will be removed in the future.
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.Table.select(String) use `Table.select(Expression...)`
org.apache.flink.table.api.WindowGroupedTable.select(String) use `WindowGroupedTable.select(Expression...)`
org.apache.flink.table.api.GroupedTable.select(String) use `GroupedTable.select(Expression...)`
org.apache.flink.table.api.OverWindowedTable.select(String) use `OverWindowedTable.select(Expression...)`
org.apache.flink.table.api.FlatAggregateTable.select(String) use `FlatAggregateTable.select(Expression...)`
org.apache.flink.table.api.AggregatedTable.select(String) use `AggregatedTable.select(Expression...)`
org.apache.flink.api.common.ExecutionConfig.setExecutionRetryDelay(long) This method will be replaced by `ExecutionConfig.setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration)`. The `RestartStrategies.FixedDelayRestartStrategyConfiguration` contains the delay between successive execution attempts.
org.apache.flink.streaming.api.environment.CheckpointConfig.setFailOnCheckpointingErrors(boolean) Use `CheckpointConfig.setTolerableCheckpointFailureNumber(int)`.
org.apache.flink.formats.json.JsonRowDeserializationSchema.setFailOnMissingField(boolean) Use the provided `JsonRowDeserializationSchema.Builder` instead.
org.apache.flink.api.common.operators.DualInputOperator.setFirstInput(Operator<IN1>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.DualInputOperator.setFirstInputs(List<Operator<IN1>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.streaming.api.environment.CheckpointConfig.setForceCheckpointing(boolean) This will be removed once iterations properly participate in checkpointing.
org.apache.flink.table.api.TableConfig.setIdleStateRetentionTime(Time, Time) use `TableConfig.setIdleStateRetention(Duration)` instead.
org.apache.flink.api.common.operators.SingleInputOperator.setInput(Operator<IN>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.SingleInputOperator.setInputs(List<Operator<IN>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.setInputs(List<Operator<IN>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.setInputs(Operator<IN>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.table.data.writer.BinaryArrayWriter.setNullAt(int, LogicalType) Use `BinaryArrayWriter.createNullSetter(LogicalType)` for avoiding logical types during runtime.
org.apache.flink.api.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.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.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.environment.CheckpointConfig.setPreferCheckpointForRecovery(boolean) Don't activate prefer checkpoints for recovery because it can lead to data loss and duplicate output. This option will soon be removed. See FLINK-20427 for more information.
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.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.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.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.JoinOperator.ProjectJoin.types(Class<?>...) Deprecated method only kept for compatibility.
org.apache.flink.api.java.operators.CrossOperator.ProjectCross.types(Class<?>...) Deprecated method only kept for compatibility.
org.apache.flink.api.java.operators.ProjectOperator.types(Class<?>...) Deprecated method only kept for compatibility.
org.apache.flink.runtime.executiongraph.ExecutionGraph.updateState(TaskExecutionState)
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.UserDefinedDataStreamFunction.FunctionType.valueOf(int) Use `FlinkFnApi.UserDefinedDataStreamFunction.FunctionType.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.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.FieldType.TypeInfoCase.valueOf(int) Use `FlinkFnApi.TypeInfo.FieldType.TypeInfoCase.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.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, boolean, int) 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.plan.rules.logical.FlinkFilterJoinRule.FlinkFilterIntoJoinRule(boolean, RelFactories.FilterFactory, RelFactories.ProjectFactory, FlinkFilterJoinRule.Predicate)
org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule(RelOptRuleOperand, String, boolean, RelFactories.FilterFactory, RelFactories.ProjectFactory)
org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule(RelOptRuleOperand, String, boolean, RelFactories.FilterFactory, RelFactories.ProjectFactory, FlinkFilterJoinRule.Predicate)
org.apache.flink.table.plan.rules.logical.FlinkFilterJoinRule.FlinkJoinConditionPushRule(RelFactories.FilterFactory, RelFactories.ProjectFactory, FlinkFilterJoinRule.Predicate)
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.FlinkKafkaProducer(String, KafkaSerializationSchema, Properties, FlinkKafkaProducer.Semantic)`
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, KeyedSerializationSchema<IN>, Properties, FlinkKafkaProducer.Semantic) use `FlinkKafkaProducer.FlinkKafkaProducer(String, KafkaSerializationSchema, Properties, FlinkKafkaProducer.Semantic)`
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, KeyedSerializationSchema<IN>, Properties, Optional<FlinkKafkaPartitioner<IN>>) use `FlinkKafkaProducer.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.FlinkKafkaProducer(String, KafkaSerializationSchema, Properties, FlinkKafkaProducer.Semantic)`
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, String, KeyedSerializationSchema<IN>) use `FlinkKafkaProducer.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.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.RocksDBStateBackend(StateBackend)` instead.
org.apache.flink.contrib.streaming.state.RocksDBStateBackend(AbstractStateBackend, boolean) Use `RocksDBStateBackend.RocksDBStateBackend(StateBackend, TernaryBoolean)` instead.
org.apache.flink.runtime.leaderretrieval.StandaloneLeaderRetrievalService(String) Use `StandaloneLeaderRetrievalService.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.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.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.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