Deprecated List (flink 1.9-SNAPSHOT API)

Deprecated Interfaces
Interface and Description
org.apache.flink.table.sinks.BatchTableSink use `OutputFormatTableSink` instead.
org.apache.flink.table.sources.BatchTableSource use `InputFormatTableSource` instead.
org.apache.flink.streaming.connectors.fs.bucketing.Bucketer
org.apache.flink.streaming.connectors.fs.Clock
org.apache.flink.streaming.util.serialization.DeserializationSchema Use `DeserializationSchema` instead.
org.apache.flink.streaming.connectors.elasticsearch2.ElasticsearchSinkFunction Deprecated since 1.2, to be removed at 2.0. This class has been deprecated due to package relocation. Please use `ElasticsearchSinkFunction` instead.
org.apache.flink.table.catalog.ExternalCatalog use `Catalog` instead.
org.apache.flink.table.factories.ExternalCatalogFactory use `CatalogFactory` instead.
org.apache.flink.api.common.functions.FoldFunction use `AggregateFunction` instead
org.apache.flink.api.common.state.FoldingState will be removed in a future version in favor of `AggregatingState`
org.apache.flink.runtime.state.internal.InternalFoldingState will be removed in a future version
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.api.QueryConfig Set the configuration on `TableConfig`.
org.apache.flink.streaming.connectors.elasticsearch2.RequestIndexer Deprecated since 1.2, to be removed at 2.0. This class has been deprecated due to package relocation. Please use `RequestIndexer` instead.
org.apache.flink.table.descriptors.SchematicDescriptor This class can be dropped once we remove external catalog support.
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.runtime.tasks.StreamTask<?, ?>, org.apache.flink.streaming.api.graph.StreamConfig, org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<OUT>>)` and passing the required parameters to the Operator's constructor in create method.
org.apache.flink.streaming.api.functions.TimestampExtractor This class has been replaced by `AssignerWithPeriodicWatermarks` and `AssignerWithPunctuatedWatermarks`
org.apache.flink.streaming.connectors.fs.Writer

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.connectors.fs.AvroKeyValueSinkWriter
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.streaming.connectors.fs.bucketing.BasePathBucketer
org.apache.flink.table.api.BatchQueryConfig Set the configuration on `TableConfig`.
org.apache.flink.streaming.connectors.fs.bucketing.BucketingSink Please use the `StreamingFileSink` instead.
org.apache.flink.streaming.runtime.io.BufferSpiller
org.apache.flink.streaming.runtime.io.BufferSpiller.SpilledBufferOrEventSequence
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.streaming.connectors.fs.bucketing.DateTimeBucketer
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.table.descriptors.ExternalCatalogDescriptor use `CatalogDescriptor` instead.
org.apache.flink.table.descriptors.ExternalCatalogDescriptorValidator use `CatalogDescriptorValidator` instead.
org.apache.flink.table.catalog.ExternalCatalogTable use `CatalogTable` instead.
org.apache.flink.streaming.runtime.operators.ExtractTimestampsOperator Subsumed by `TimestampsAndPeriodicWatermarksOperator` and `TimestampsAndPunctuatedWatermarksOperator`.
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.streaming.connectors.kafka.FlinkKafkaConsumer081 Use `FlinkKafkaConsumer08`
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer082 Use `FlinkKafkaConsumer08`
org.apache.flink.streaming.connectors.kafka.partitioner.FlinkKafkaDelegatePartitioner Delegate for `KafkaPartitioner`, use `FlinkKafkaPartitioner` instead
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010.FlinkKafkaProducer010Configuration This class is deprecated since the factory methods `writeToKafkaWithTimestamps` for the producer are also deprecated.
org.apache.flink.streaming.api.functions.windowing.FoldApplyAllWindowFunction will be removed in a future version
org.apache.flink.streaming.api.functions.windowing.FoldApplyProcessAllWindowFunction will be removed in a future version
org.apache.flink.streaming.api.functions.windowing.FoldApplyProcessWindowFunction will be removed in a future version
org.apache.flink.streaming.api.functions.windowing.FoldApplyWindowFunction will be removed in a future version
org.apache.flink.api.common.state.FoldingStateDescriptor will be removed in a future version in favor of `AggregatingStateDescriptor`
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.HiveScalarSqlFunction TODO hack code, its logical should be integrated to ScalarSqlFunction
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.queryablestate.client.state.ImmutableFoldingState
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.partitioner.KafkaPartitioner This partitioner does not handle partitioning properly in the case of multiple topics, and has been deprecated. Please use `FlinkKafkaPartitioner` instead.
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.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.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.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.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.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.runtime.webmonitor.handlers.ProgramArgsQueryParameter please, use `JarRequestBody.FIELD_NAME_PROGRAM_ARGUMENTS_LIST`
org.apache.flink.api.common.functions.RichFoldFunction use `RichAggregateFunction` 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.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.streaming.connectors.fs.SequenceFileWriter
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.api.datastream.SplitStream
org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializer.StreamElementSerializerConfigSnapshot see `StreamElementSerializer.StreamElementSerializerSnapshot`.
org.apache.flink.streaming.api.operators.StreamGroupedFold will be removed in a future version
org.apache.flink.table.api.StreamQueryConfig Set the configuration on `TableConfig`.
org.apache.flink.streaming.connectors.fs.StreamWriterBase
org.apache.flink.streaming.connectors.fs.StringWriter
org.apache.flink.streaming.connectors.fs.SystemClock
org.apache.flink.table.util.TableConnectorUtil Use `TableConnectorUtils` instead.
org.apache.flink.runtime.checkpoint.TaskState Internal class for savepoint backwards compatibility. Don't use for other purposes.
org.apache.flink.runtime.rest.messages.TerminationModeQueryParameter Only kept to detect legacy usages of the cancel/stop command. Please use the "stop" command instead.
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.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
org.apache.flink.table.runtime.types.TypeInfoLogicalTypeConverter
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.
org.apache.flink.api.common.state.StateTtlConfig.TimeCharacteristic will be removed in a future version in favor of `StateTtlConfig.TtlTimeCharacteristic`
org.apache.flink.runtime.rest.messages.TerminationModeQueryParameter.TerminationMode Please use the "stop" command instead.

Deprecated Annotation Types
Annotation Type and Description
org.apache.flink.api.java.functions.FunctionAnnotation.SkipCodeAnalysis The code analysis code has been removed and this annotation has no effect.

Deprecated Fields
Field and Description
org.apache.flink.configuration.ConfigConstants.AKKA_ASK_TIMEOUT Use `AkkaOptions.ASK_TIMEOUT` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_CLIENT_TIMEOUT Use `AkkaOptions.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 Use `AkkaOptions.WATCH_HEARTBEAT_INTERVAL` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_WATCH_HEARTBEAT_PAUSE Use `AkkaOptions.WATCH_HEARTBEAT_PAUSE` instead.
org.apache.flink.configuration.ConfigConstants.AKKA_WATCH_THRESHOLD Use `AkkaOptions.WATCH_THRESHOLD` instead.
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.ConfigConstants.CONTAINERIZED_HEAP_CUTOFF_MIN Use `ResourceManagerOptions.CONTAINERIZED_HEAP_CUTOFF_MIN` instead.
org.apache.flink.configuration.ConfigConstants.CONTAINERIZED_HEAP_CUTOFF_RATIO Use `ResourceManagerOptions.CONTAINERIZED_HEAP_CUTOFF_RATIO` instead.
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 `AkkaOptions.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 Use `AkkaOptions.WATCH_THRESHOLD` instead.
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 `TaskManagerOptions.MANAGED_MEMORY_FRACTION` provides the default value now
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 `TaskManagerOptions.INITIAL_REGISTRATION_BACKOFF` 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 `TaskManagerOptions.REGISTRATION_MAX_BACKOFF` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_TASK_MANAGER_MEMORY_PRE_ALLOCATE `TaskManagerOptions.MANAGED_MEMORY_PRE_ALLOCATE` provides the default value now
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 `TaskManagerOptions.REFUSED_REGISTRATION_BACKOFF` 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_YARN_APPLICATION_MASTER_PORT Not used anymore, but remain here until Flink 2.0
org.apache.flink.configuration.ConfigConstants.DEFAULT_YARN_HEAP_CUTOFF Use `ResourceManagerOptions.CONTAINERIZED_HEAP_CUTOFF_MIN` instead.
org.apache.flink.configuration.ConfigConstants.DEFAULT_YARN_HEAP_CUTOFF_RATIO Use `ResourceManagerOptions.CONTAINERIZED_HEAP_CUTOFF_RATIO` instead.
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.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.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.calcite.avatica.util.DateTimeUtils.GMT_ZONE Use `DateTimeUtils.UTC_ZONE`
org.apache.flink.configuration.ConfigConstants.HA_JOB_DELAY Deprecated in favour of `HighAvailabilityOptions.HA_JOB_DELAY`.
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.JobManagerOptions.JOB_MANAGER_HEAP_MEMORY_MB use `JobManagerOptions.JOB_MANAGER_HEAP_MEMORY`
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.configuration.ConfigConstants.LIBRARY_CACHE_MANAGER_CLEANUP_INTERVAL use `BlobServerOptions.CLEANUP_INTERVAL` instead
org.apache.flink.configuration.ConfigConstants.LOCAL_NUMBER_RESOURCE_MANAGER Use `ResourceManagerOptions.LOCAL_NUMBER_RESOURCE_MANAGER` instead.
org.apache.flink.configuration.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_CREDIT_MODEL Will be removed for Flink 1.6 when the old code will be dropped in favour of credit-based flow control.
org.apache.flink.configuration.NettyShuffleEnvironmentOptions.NETWORK_NUM_BUFFERS use `NettyShuffleEnvironmentOptions.NETWORK_BUFFERS_MEMORY_FRACTION`, `NettyShuffleEnvironmentOptions.NETWORK_BUFFERS_MEMORY_MIN`, and `NettyShuffleEnvironmentOptions.NETWORK_BUFFERS_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 Deprecated in favour of `ConfigConstants.HA_JOB_DELAY`.
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.ConfigConstants.RESOURCE_MANAGER_IPC_PORT_KEY Use `ResourceManagerOptions.IPC_PORT` 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.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.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_MB use `TaskManagerOptions.TASK_MANAGER_HEAP_MEMORY`
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_HOSTNAME_KEY use `TaskManagerOptions.HOST` instead
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_INITIAL_REGISTRATION_PAUSE use `TaskManagerOptions.INITIAL_REGISTRATION_BACKOFF` 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 `TaskManagerOptions.REGISTRATION_MAX_BACKOFF` 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 Use `TaskManagerOptions.MANAGED_MEMORY_FRACTION` instead
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_MEMORY_OFF_HEAP_KEY Use `TaskManagerOptions.MEMORY_OFF_HEAP` instead
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_MEMORY_PRE_ALLOCATE_KEY Use `TaskManagerOptions.MANAGED_MEMORY_PRE_ALLOCATE` instead
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 `TaskManagerOptions.REFUSED_REGISTRATION_BACKOFF` 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.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 in favor of `#CONTAINERIZED_HEAP_CUTOFF_MIN`
org.apache.flink.configuration.ConfigConstants.YARN_HEAP_CUTOFF_RATIO in favor of `#CONTAINERIZED_HEAP_CUTOFF_RATIO`
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.hadoop.conf.Configuration.addDeprecation(String, String[]) use `Configuration.addDeprecation(String key, String newKey)` instead
org.apache.hadoop.conf.Configuration.addDeprecation(String, String[], String) use `Configuration.addDeprecation(String key, String newKey, String customMessage)` instead
org.apache.flink.api.common.operators.DualInputOperator.addFirstInput(Operator<IN1>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.DualInputOperator.addFirstInputs(List<Operator<IN1>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.SingleInputOperator.addInput(List<Operator<IN>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.addInput(Operator<IN>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.SingleInputOperator.addInput(Operator<IN>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.addInputs(List<? extends Operator<IN>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.DualInputOperator.addSecondInput(Operator<IN2>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.DualInputOperator.addSecondInputs(List<Operator<IN2>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.streaming.api.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.streaming.api.datastream.AllWindowedStream.apply(R, FoldFunction<T, R>, AllWindowFunction<R, R, W>) Use `AllWindowedStream.fold(Object, FoldFunction, AllWindowFunction)` instead.
org.apache.flink.streaming.api.datastream.AllWindowedStream.apply(R, FoldFunction<T, R>, AllWindowFunction<R, R, W>, TypeInformation<R>) Use `AllWindowedStream.fold(Object, FoldFunction, AllWindowFunction, TypeInformation, TypeInformation)` instead.
org.apache.flink.streaming.api.datastream.WindowedStream.apply(R, FoldFunction<T, R>, WindowFunction<R, R, K, W>) Use `WindowedStream.fold(Object, FoldFunction, WindowFunction)` instead.
org.apache.flink.streaming.api.datastream.WindowedStream.apply(R, FoldFunction<T, R>, WindowFunction<R, R, K, W>, TypeInformation<R>) Use `WindowedStream.fold(Object, FoldFunction, WindowFunction, TypeInformation, TypeInformation)` instead.
org.apache.flink.streaming.api.datastream.KeyedStream.asQueryableState(String, FoldingStateDescriptor<T, ACC>) will be removed in a future version
org.apache.flink.streaming.api.datastream.DataStream.assignTimestamps(TimestampExtractor<T>) Please use `DataStream.assignTimestampsAndWatermarks(AssignerWithPeriodicWatermarks)` of `DataStream.assignTimestampsAndWatermarks(AssignerWithPunctuatedWatermarks)` instead.
org.apache.flink.client.program.JobWithJars.buildUserCodeClassLoader(List<URL>, List<URL>, ClassLoader) Use `JobWithJars.buildUserCodeClassLoader(List, List, ClassLoader, Configuration)`
org.apache.flink.api.java.utils.DataSetUtils.checksumHashCode(DataSet<T>) replaced with `org.apache.flink.graph.asm.dataset.ChecksumHashCode` in Gelly
org.apache.flink.api.common.state.StateTtlConfig.Builder.cleanupInRocksdbCompactFilter() Use more general configuration method `StateTtlConfig.Builder.cleanupInBackground()` instead
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.runtime.checkpoint.savepoint.SavepointV2.convertToOperatorStateSavepointV2(Map<JobVertexID, ExecutionJobVertex>, Savepoint) Only kept for backwards-compatibility with versions < 1.3. Will be removed in the future.
org.apache.flink.core.fs.FileSystem.create(Path, boolean) Use `FileSystem.create(Path, WriteMode)` instead.
org.apache.flink.core.fs.LimitedConnectionsFileSystem.create(Path, boolean, int, short, long)
org.apache.flink.core.fs.FileSystem.create(Path, boolean, int, short, long) Deprecated because not well supported across types of file systems. Control the behavior of specific file systems via configurations instead.
org.apache.flink.table.api.java.StreamTableEnvironment.create(StreamExecutionEnvironment, TableConfig) Use `StreamTableEnvironment.create(StreamExecutionEnvironment)` and `TableEnvironment.getConfig()` for manipulating `TableConfig`.
org.apache.calcite.sql2rel.RelDecorrelator.decorrelateQuery(RelNode)
org.apache.flink.configuration.ConfigOption.deprecatedKeys() Replaced by `ConfigOption.fallbackKeys()`
org.apache.flink.table.descriptors.SchemaValidator.deriveTableSinkSchema(DescriptorProperties) This method combines two separate concepts of table schema and field mapping. This should be split into two methods once we have support for the corresponding interfaces (see FLINK-9870).
org.apache.flink.streaming.connectors.fs.bucketing.BucketingSink.disableCleanupOnOpen() This option is deprecated and remains only for backwards compatibility. We do not clean up lingering files anymore.
org.apache.flink.table.sinks.StreamTableSink.emitDataStream(DataStream<T>) This method will be removed in future versions as it returns nothing. It is recommended to use `StreamTableSink.consumeDataStream(DataStream)` instead which returns the `DataStreamSink`. The returned `DataStreamSink` will be used to set resources for the sink operator. If the `StreamTableSink.consumeDataStream(DataStream)` is implemented, this method can be empty implementation.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.enableCheckpointing() Use `StreamExecutionEnvironment.enableCheckpointing(long)` instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.enableCheckpointing(long, CheckpointingMode, boolean) Use `StreamExecutionEnvironment.enableCheckpointing(long, CheckpointingMode)` instead. Forcing checkpoints will be removed in the future.
org.apache.flink.streaming.api.environment.RemoteStreamEnvironment.executeRemotely(StreamGraph, List<URL>)
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.factories.TableFactoryUtil.findAndCreateExternalCatalog(Descriptor)
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.streaming.api.datastream.AllWindowedStream.fold(ACC, FoldFunction<T, ACC>, AllWindowFunction<ACC, R, W>) use `AllWindowedStream.aggregate(AggregateFunction, ProcessAllWindowFunction)` instead
org.apache.flink.streaming.api.datastream.AllWindowedStream.fold(ACC, FoldFunction<T, ACC>, AllWindowFunction<ACC, R, W>, TypeInformation<ACC>, TypeInformation<R>) use `AllWindowedStream.aggregate(AggregateFunction, AllWindowFunction, TypeInformation, TypeInformation)` instead
org.apache.flink.streaming.api.datastream.AllWindowedStream.fold(ACC, FoldFunction<T, ACC>, ProcessAllWindowFunction<ACC, R, W>) use `AllWindowedStream.aggregate(AggregateFunction, ProcessAllWindowFunction)` instead
org.apache.flink.streaming.api.datastream.AllWindowedStream.fold(ACC, FoldFunction<T, ACC>, ProcessAllWindowFunction<ACC, R, W>, TypeInformation<ACC>, TypeInformation<R>) use `AllWindowedStream.aggregate(AggregateFunction, ProcessAllWindowFunction, TypeInformation, TypeInformation, TypeInformation)` instead
org.apache.flink.streaming.api.datastream.WindowedStream.fold(ACC, FoldFunction<T, ACC>, ProcessWindowFunction<ACC, R, K, W>) use `WindowedStream.aggregate(AggregateFunction, WindowFunction)` instead
org.apache.flink.streaming.api.datastream.WindowedStream.fold(ACC, FoldFunction<T, ACC>, ProcessWindowFunction<ACC, R, K, W>, TypeInformation<ACC>, TypeInformation<R>) use `WindowedStream.aggregate(AggregateFunction, WindowFunction, TypeInformation, TypeInformation)` instead
org.apache.flink.streaming.api.datastream.WindowedStream.fold(ACC, FoldFunction<T, ACC>, WindowFunction<ACC, R, K, W>) use `WindowedStream.aggregate(AggregateFunction, WindowFunction)` instead
org.apache.flink.streaming.api.datastream.WindowedStream.fold(ACC, FoldFunction<T, ACC>, WindowFunction<ACC, R, K, W>, TypeInformation<ACC>, TypeInformation<R>) use `WindowedStream.aggregate(AggregateFunction, ProcessWindowFunction, TypeInformation, TypeInformation, TypeInformation)` instead
org.apache.flink.streaming.api.datastream.AllWindowedStream.fold(R, FoldFunction<T, R>) use `AllWindowedStream.aggregate(AggregateFunction)` instead
org.apache.flink.streaming.api.datastream.WindowedStream.fold(R, FoldFunction<T, R>) use `WindowedStream.aggregate(AggregationFunction)` instead
org.apache.flink.streaming.api.datastream.KeyedStream.fold(R, FoldFunction<T, R>) will be removed in a future version
org.apache.flink.streaming.api.datastream.AllWindowedStream.fold(R, FoldFunction<T, R>, TypeInformation<R>) use `AllWindowedStream.aggregate(AggregateFunction, TypeInformation, TypeInformation)` instead
org.apache.flink.streaming.api.datastream.WindowedStream.fold(R, FoldFunction<T, R>, TypeInformation<R>) use `WindowedStream.aggregate(AggregateFunction, TypeInformation, TypeInformation)` instead
org.apache.flink.api.common.JobExecutionResult.fromJobSubmissionResult(JobSubmissionResult) Will be removed in future versions.
org.apache.flink.table.api.TableSchema.fromTypeInfo(TypeInformation<?>) This method will be removed soon. Use `DataTypes` to declare types.
org.apache.flink.api.common.functions.RuntimeContext.getAllAccumulators() Use getAccumulator(..) to obtain the value of an accumulator.
org.apache.flink.state.api.runtime.SavepointRuntimeContext.getAllAccumulators()
org.apache.flink.runtime.state.filesystem.FsStateBackend.getBasePath() Deprecated in favor of `FsStateBackend.getCheckpointPath()`.
org.apache.flink.core.memory.DataOutputSerializer.getByteArray() Replaced by `DataOutputSerializer.getSharedBuffer()` for a better, safer name.
org.apache.flink.api.common.ExecutionConfig.getCodeAnalysisMode() The code analysis code has been removed and this method does not return anything interesting.
org.apache.flink.sql.parser.impl.SimpleCharStream.getColumn()
org.apache.flink.table.api.TableEnvironment.getCompletionHints(String, int) Will be removed in the next release
org.apache.flink.core.fs.LimitedConnectionsFileSystem.getDefaultBlockSize()
org.apache.flink.core.fs.FileSystem.getDefaultBlockSize() This value is no longer used and is meaningless.
org.apache.flink.table.runtime.types.ClassLogicalTypeConverter.getDefaultExternalClassForType(LogicalType)
org.apache.flink.api.common.ExecutionConfig.getExecutionRetryDelay() Should no longer be used because it is subsumed by RestartStrategyConfiguration
org.apache.flink.table.catalog.CatalogManager.getExternalCatalog(String) `ExternalCatalog` APIs will be dropped
org.apache.flink.table.catalog.CatalogManager.getExternalCatalogs() `ExternalCatalog` APIs will be dropped
org.apache.flink.table.sinks.TableSink.getFieldNames() Use the field names of `TableSink.getTableSchema()` instead.
org.apache.flink.table.api.TableSchema.getFieldType(int) This method will be removed in future versions as it uses the old type system. It is recommended to use `TableSchema.getFieldDataType(int)` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.api.TableSchema.getFieldType(String) This method will be removed in future versions as it uses the old type system. It is recommended to use `TableSchema.getFieldDataType(String)` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.api.TableSchema.getFieldTypes() This method will be removed in future versions as it uses the old type system. It is recommended to use `TableSchema.getFieldDataTypes()` instead which uses the new type system based on `DataTypes`. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.sinks.TableSink.getFieldTypes() Use the field types of `TableSink.getTableSchema()` instead.
org.apache.flink.api.common.io.FileInputFormat.getFilePath() Please use getFilePaths() instead.
org.apache.flink.api.common.functions.RuntimeContext.getFoldingState(FoldingStateDescriptor<T, ACC>) will be removed in a future version in favor of `AggregatingState`
org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext.getFoldingState(FoldingStateDescriptor<T, ACC>)
org.apache.flink.api.common.state.KeyedStateStore.getFoldingState(FoldingStateDescriptor<T, ACC>) will be removed in a future version in favor of `AggregatingState`
org.apache.flink.state.api.runtime.SavepointRuntimeContext.getFoldingState(FoldingStateDescriptor<T, ACC>)
org.apache.flink.api.java.typeutils.TypeExtractor.getFoldReturnTypes(FoldFunction<IN, OUT>, TypeInformation<IN>) will be removed in a future version
org.apache.flink.api.java.typeutils.TypeExtractor.getFoldReturnTypes(FoldFunction<IN, OUT>, TypeInformation<IN>, String, boolean) will be removed in a future version
org.apache.flink.api.common.JobExecutionResult.getIntCounterResult(String) Will be removed in future versions. Use `JobExecutionResult.getAccumulatorResult(java.lang.String)` instead.
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.sql.parser.impl.SimpleCharStream.getLine()
org.apache.flink.runtime.io.network.buffer.Buffer.getMemorySegment()
org.apache.flink.runtime.io.network.buffer.Buffer.getMemorySegmentOffset()
org.apache.flink.api.common.ExecutionConfig.getNumberOfExecutionRetries() Should no longer be used because it is subsumed by RestartStrategyConfiguration
org.apache.flink.api.java.ExecutionEnvironment.getNumberOfExecutionRetries() This method will be replaced by `ExecutionEnvironment.getRestartStrategy()`. The `RestartStrategies.FixedDelayRestartStrategyConfiguration` contains the number of execution retries.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getNumberOfExecutionRetries() This method will be replaced by `StreamExecutionEnvironment.getRestartStrategy()`.
org.apache.flink.api.common.state.OperatorStateStore.getOperatorState(ListStateDescriptor<S>) since 1.3.0. This was deprecated as part of a refinement to the function names. Please use `OperatorStateStore.getListState(ListStateDescriptor)` instead.
org.apache.flink.runtime.state.DefaultOperatorStateBackend.getOperatorState(ListStateDescriptor<S>) This was deprecated as part of a refinement to the function names. Please use `DefaultOperatorStateBackend.getListState(ListStateDescriptor)` instead.
org.apache.calcite.plan.RelOptCluster.getOriginalExpression()
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.calcite.plan.RelOptCluster.getQuery()
org.apache.flink.table.api.TableEnvironment.getRegisteredExternalCatalog(String) the `ExternalCatalog` API is deprecated. Use the corresponding `Catalog` API.
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.core.fs.FileSystemSafetyNet.getSafetyNetCloseableRegistryForThread() This method should be removed after FLINK-6684 is implemented.
org.apache.flink.api.common.state.OperatorStateStore.getSerializableListState(String) since 1.3.0. Using Java serialization for persisting state is not encouraged. Please use `OperatorStateStore.getListState(ListStateDescriptor)` instead.
org.apache.flink.runtime.state.DefaultOperatorStateBackend.getSerializableListState(String) Using Java serialization for persisting state is not encouraged. Please use `DefaultOperatorStateBackend.getListState(ListStateDescriptor)` instead.
org.apache.flink.table.catalog.ExternalCatalogTable.getTableStats() This method exists for backwards-compatibility only.
org.apache.flink.runtime.checkpoint.savepoint.Savepoint.getTaskStates() Only kept for backwards-compatibility with versionS < 1.3. Will be removed in the future.
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, QueryConfig) use `Table.insertInto(QueryConfig, String, String...)`
org.apache.flink.streaming.api.functions.sink.SinkFunction.invoke(IN) Use `SinkFunction.invoke(Object, Context)`.
org.apache.flink.runtime.jobmanager.scheduler.CoLocationConstraint.isAssignedAndAlive() Should only be called by legacy code
org.apache.flink.yarn.AbstractYarnClusterDescriptor.isDetachedMode() The cluster descriptor should not know about this option.
org.apache.flink.streaming.api.environment.CheckpointConfig.isFailOnCheckpointingErrors() Use `CheckpointConfig.getTolerableCheckpointFailureNumber()`.
org.apache.flink.api.common.ExecutionConfig.isFailTaskOnCheckpointError() This method takes no effect since we would not forward the configuration from the checkpoint config to the task, and we have not supported task to fail on checkpoint error. Please use CheckpointConfig.getTolerableCheckpointFailureNumber() to know the behavior on checkpoint errors.
org.apache.flink.streaming.api.environment.CheckpointConfig.isForceCheckpointing() This will be removed once iterations properly participate in checkpointing.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.isForceCheckpointing() Forcing checkpoints will be removed in future version.
org.apache.flink.api.common.ExecutionConfig.isLatencyTrackingEnabled() will be removed in a future version
org.apache.flink.api.common.io.DelimitedInputFormat.loadGlobalConfigParams() Please use `loadConfigParameters(Configuration config`
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.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.calcite.avatica.util.DateTimeUtils.parseDateFormat(String, String, TimeZone)
org.apache.calcite.avatica.util.DateTimeUtils.parsePrecisionDateTimeLiteral(String, String, TimeZone)
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.catalog.CatalogManager.registerExternalCatalog(String, ExternalCatalog) `ExternalCatalog` APIs will be dropped
org.apache.flink.table.api.TableEnvironment.registerExternalCatalog(String, ExternalCatalog) the `ExternalCatalog` API is deprecated. Use the corresponding `Catalog` API.
org.apache.flink.runtime.io.network.metrics.NettyShuffleMetricFactory.registerLegacyNetworkMetrics(boolean, 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.registerTableSink(String, String[], TypeInformation<?>[], TableSink<?>) Use `TableEnvironment.registerTableSink(String, TableSink)` instead.
org.apache.flink.runtime.jobmaster.LogicalSlot.releaseSlot() Added because extended the actual releaseSlot method with cause parameter.
org.apache.flink.table.functions.AggregateFunction.requiresOver() Use `AggregateFunction.getRequirements()` instead.
org.apache.flink.api.common.typeutils.NestedSerializersSnapshotDelegate.resolveCompatibilityWithNested(TypeSerializerSchemaCompatibility<?>, TypeSerializer<?>...) this no method will be removed in the future. Resolving compatibility for nested serializers is now handled by `CompositeTypeSerializerSnapshot`.
org.apache.flink.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.api.common.ExecutionConfig.setCodeAnalysisMode(CodeAnalysisMode) The code analysis code has been removed and this method has no effect.
org.apache.flink.yarn.AbstractYarnClusterDescriptor.setDetachedMode(boolean) The cluster descriptor should not know about this option.
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.ExecutionConfig.setFailTaskOnCheckpointError(boolean) This method takes no effect since we would not forward the configuration from the checkpoint config to the task, and we have not supported task to fail on checkpoint error. Please use CheckpointConfig.setTolerableCheckpointFailureNumber(int) to determine the behavior on checkpoint errors.
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.api.common.operators.SingleInputOperator.setInput(Operator<IN>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.setInputs(List<Operator<IN>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.SingleInputOperator.setInputs(List<Operator<IN>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.setInputs(Operator<IN>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.ExecutionConfig.setNumberOfExecutionRetries(int) This method will be replaced by `ExecutionConfig.setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration)`. The `RestartStrategies.FixedDelayRestartStrategyConfiguration` contains the number of execution retries.
org.apache.flink.api.java.ExecutionEnvironment.setNumberOfExecutionRetries(int) This method will be replaced by `ExecutionEnvironment.setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration)`. The `RestartStrategies.FixedDelayRestartStrategyConfiguration` contains the number of execution retries.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.setNumberOfExecutionRetries(int) This method will be replaced by `StreamExecutionEnvironment.setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration)`. The `RestartStrategies.fixedDelayRestart(int, Time)` contains the number of execution retries.
org.apache.calcite.plan.RelOptCluster.setOriginalExpression(RexNode)
org.apache.flink.api.common.operators.DualInputOperator.setSecondInput(Operator<IN2>...) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.api.common.operators.DualInputOperator.setSecondInputs(List<Operator<IN2>>) This method will be removed in future versions. Use the `Union` operator instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.setStateBackend(AbstractStateBackend) Use `StreamExecutionEnvironment.setStateBackend(StateBackend)` instead.
org.apache.flink.api.common.state.StateTtlConfig.Builder.setTimeCharacteristic(StateTtlConfig.TimeCharacteristic) will be removed in a future version in favor of `StateTtlConfig.Builder.setTtlTimeCharacteristic(org.apache.flink.api.common.state.StateTtlConfig.TtlTimeCharacteristic)`
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.streaming.api.datastream.DataStream.split(OutputSelector<T>) Please use side output instead.
org.apache.flink.api.common.io.FileInputFormat.supportsMultiPaths() Will be removed for Flink 2.0.
org.apache.flink.table.api.TableSchema.toRowType() Use `TableSchema.toRowDataType()` instead.
org.apache.calcite.plan.RelOptCluster.traitSetOf(RelTrait...) For `traitSetOf(t1, t2)`, use `RelOptCluster.traitSet()`().replace(t1).replace(t2).
org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureStatsTrackerImpl.triggerStackTraceSample(ExecutionJobVertex) `BackPressureStatsTrackerImpl.getOperatorBackPressureStats(ExecutionJobVertex)` will trigger stack trace sampling automatically.
org.apache.flink.api.java.operators.CrossOperator.ProjectCross.types(Class<?>...) Deprecated method only kept for compatibility.
org.apache.flink.api.java.operators.JoinOperator.ProjectJoin.types(Class<?>...) Deprecated method only kept for compatibility.
org.apache.flink.api.java.operators.ProjectOperator.types(Class<?>...) Deprecated method only kept for compatibility.
org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithWindow.with(CoGroupFunction<T1, T2, T>) This method will be removed once the `CoGroupedStreams.WithWindow.apply(CoGroupFunction)` method is fixed in the next major version of Flink (2.0).
org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithWindow.with(CoGroupFunction<T1, T2, T>, TypeInformation<T>) This method will be removed once the `CoGroupedStreams.WithWindow.apply(CoGroupFunction, TypeInformation)` method is fixed in the next major version of Flink (2.0).
org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow.with(FlatJoinFunction<T1, T2, T>) This method will be removed once the `JoinedStreams.WithWindow.apply(FlatJoinFunction)` method is fixed in the next major version of Flink (2.0).
org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow.with(FlatJoinFunction<T1, T2, T>, TypeInformation<T>) This method will be replaced by `JoinedStreams.WithWindow.apply(FlatJoinFunction, TypeInformation)` in Flink 2.0. So use the `JoinedStreams.WithWindow.apply(FlatJoinFunction, TypeInformation)` in the future.
org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow.with(JoinFunction<T1, T2, T>) This method will be removed once the `JoinedStreams.WithWindow.apply(JoinFunction)` method is fixed in the next major version of Flink (2.0).
org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow.with(JoinFunction<T1, T2, T>, TypeInformation<T>) This method will be removed once the `JoinedStreams.WithWindow.apply(JoinFunction, TypeInformation)` method is fixed in the next major version of Flink (2.0).
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010.writeToKafkaWithTimestamps(DataStream<T>, String, KeyedSerializationSchema<T>, Properties) Use `FlinkKafkaProducer010.FlinkKafkaProducer010(String, KeyedSerializationSchema, Properties)` and call `FlinkKafkaProducer010.setWriteTimestampToKafka(boolean)`.
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010.writeToKafkaWithTimestamps(DataStream<T>, String, KeyedSerializationSchema<T>, Properties, FlinkKafkaPartitioner<T>) Use `FlinkKafkaProducer010.FlinkKafkaProducer010(String, KeyedSerializationSchema, Properties, FlinkKafkaPartitioner)` and call `FlinkKafkaProducer010.setWriteTimestampToKafka(boolean)`.
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010.writeToKafkaWithTimestamps(DataStream<T>, String, KeyedSerializationSchema<T>, Properties, KafkaPartitioner<T>) This is a deprecated since it does not correctly handle partitioning when producing to multiple topics. Use `FlinkKafkaProducer010.FlinkKafkaProducer010(String, SerializationSchema, Properties, FlinkKafkaPartitioner)` instead.
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010.writeToKafkaWithTimestamps(DataStream<T>, String, SerializationSchema<T>, Properties) Use `FlinkKafkaProducer010.FlinkKafkaProducer010(String, KeyedSerializationSchema, Properties)` and call `FlinkKafkaProducer010.setWriteTimestampToKafka(boolean)`.

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.streaming.connectors.elasticsearch2.ElasticsearchSink(Map<String, String>, List<InetSocketAddress>, ElasticsearchSinkFunction<T>) Deprecated since 1.2, to be removed at 2.0. Please use `ElasticsearchSink.ElasticsearchSink(Map, List, org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkFunction)` instead.
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.planner.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.planner.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.planner.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.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.table.planner.plan.rules.logical.FlinkJoinToMultiJoinRule(Class<? extends Join>)
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer081(String, DeserializationSchema<T>, Properties) Use `FlinkKafkaConsumer08.FlinkKafkaConsumer08(String, DeserializationSchema, Properties)`
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer082(String, DeserializationSchema<T>, Properties) Use `FlinkKafkaConsumer08.FlinkKafkaConsumer08(String, DeserializationSchema, Properties)`
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, SerializationSchema<IN>, Properties) use `FlinkKafkaProducer.FlinkKafkaProducer(String, KafkaSerializationSchema, Properties, FlinkKafkaProducer.Semantic)`
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, SerializationSchema<IN>, Properties, Optional<FlinkKafkaPartitioner<IN>>) 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.streaming.connectors.kafka.FlinkKafkaProducer(String, String, SerializationSchema<IN>) use `FlinkKafkaProducer.FlinkKafkaProducer(String, KafkaSerializationSchema, Properties, FlinkKafkaProducer.Semantic)`
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010(String, KeyedSerializationSchema<T>, Properties, KafkaPartitioner<T>) This is a deprecated constructor that does not correctly handle partitioning when producing to multiple topics. Use `FlinkKafkaProducer010.FlinkKafkaProducer010(String, SerializationSchema, Properties, FlinkKafkaPartitioner)` instead.
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010(String, SerializationSchema<T>, Properties, KafkaPartitioner<T>) This is a deprecated since it does not correctly handle partitioning when producing to multiple topics. Use `FlinkKafkaProducer010.FlinkKafkaProducer010(String, SerializationSchema, Properties, FlinkKafkaPartitioner)` instead.
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer08(String, KeyedSerializationSchema<IN>, Properties, KafkaPartitioner<IN>) This is a deprecated constructor that does not correctly handle partitioning when producing to multiple topics. Use `FlinkKafkaProducer08.FlinkKafkaProducer08(String, KeyedSerializationSchema, Properties, FlinkKafkaPartitioner)` instead.
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer08(String, SerializationSchema<IN>, Properties, KafkaPartitioner<IN>) This is a deprecated constructor that does not correctly handle partitioning when producing to multiple topics. Use `FlinkKafkaProducer08.FlinkKafkaProducer08(String, SerializationSchema, Properties, FlinkKafkaPartitioner)` instead.
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer09(String, KeyedSerializationSchema<IN>, Properties, KafkaPartitioner<IN>) This is a deprecated constructor that does not correctly handle partitioning when producing to multiple topics. Use `FlinkKafkaProducer09.FlinkKafkaProducer09(String, KeyedSerializationSchema, Properties, FlinkKafkaPartitioner)` instead.
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer09(String, SerializationSchema<IN>, Properties, KafkaPartitioner<IN>) This is a deprecated constructor that does not correctly handle partitioning when producing to multiple topics. Use `FlinkKafkaProducer09.FlinkKafkaProducer09(String, SerializationSchema, Properties, FlinkKafkaPartitioner)` instead.
org.apache.flink.formats.json.JsonRowDeserializationSchema(String) Use the provided `JsonRowDeserializationSchema.Builder` instead.
org.apache.flink.formats.json.JsonRowDeserializationSchema(TypeInformation<Row>) Use the provided `JsonRowDeserializationSchema.Builder` instead.
org.apache.flink.formats.json.JsonRowSerializationSchema(TypeInformation<Row>) Use the provided `JsonRowSerializationSchema.Builder` instead.
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.checkpoint.savepoint.SavepointV2(long, Collection<TaskState>) Only kept for backwards-compatibility with versions < 1.3. Will be removed in the future.
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.api.common.state.StateDescriptor.Type.UNKNOWN
Enum for migrating from old checkpoints/savepoint versions.

Back to Flink Website

Deprecated API

Contents