Deprecated List (flink 1.6-SNAPSHOT API)

Deprecated Interfaces
Interface and Description
org.apache.flink.streaming.connectors.fs.Bucketer use `Bucketer` instead.
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.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.streaming.connectors.elasticsearch.IndexRequestBuilder Deprecated since version 1.2, to be removed at version 2.0. Please create a `ElasticsearchSink` using a `ElasticsearchSinkFunction` instead.
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.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.streaming.util.serialization.SerializationSchema Use `SerializationSchema` instead.
org.apache.flink.streaming.api.functions.TimestampExtractor This class has been replaced by `AssignerWithPeriodicWatermarks` and `AssignerWithPunctuatedWatermarks`

Deprecated Classes
Class and Description
org.apache.flink.streaming.util.serialization.AbstractDeserializationSchema Use `AbstractDeserializationSchema` instead.
org.apache.flink.streaming.api.functions.AscendingTimestampExtractor Extend `AscendingTimestampExtractor` instead.
org.apache.flink.api.java.typeutils.runtime.AvroSerializer
org.apache.flink.formats.avro.typeutils.AvroSerializer.AvroSerializerConfigSnapshot The `AvroSerializer.AvroSchemaSerializerConfigSnapshot` should be used instead.
org.apache.flink.api.java.typeutils.AvroTypeInfo Please use `org.apache.flink.formats.avro.typeutils.AvroTypeInfo` in the `flink-avro` module. This class will be removed in the near future.
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.connectors.fs.DateTimeBucketer use `DateTimeBucketer` 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.FlinkKafkaProducer Use `FlinkKafkaProducer08`.
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.queryablestate.client.state.ImmutableFoldingState
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.runtime.rest.handler.legacy.metrics.JobVertexMetricsHandler This class is subsumed by `SubtaskMetricsHandler` and is only kept for backwards-compatibility.
org.apache.flink.streaming.util.serialization.JSONDeserializationSchema Please use `JsonNodeDeserializationSchema` in the "flink-json" module.
org.apache.flink.streaming.util.serialization.JsonRowDeserializationSchema Please use `JsonRowDeserializationSchema` in the "flink-json" module.
org.apache.flink.streaming.util.serialization.JsonRowSerializationSchema Please use `JsonRowSerializationSchema` in the "flink-json" module.
org.apache.flink.streaming.connectors.kafka.Kafka010AvroTableSource Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka010AvroTableSource.Builder Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSink Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSource Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSource.Builder Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka011AvroTableSource Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka011AvroTableSource.Builder Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka011JsonTableSource Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka011JsonTableSource.Builder Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka08AvroTableSource Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka08AvroTableSource.Builder Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSink Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSource Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSource.Builder Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka09AvroTableSource Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka09AvroTableSource.Builder Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSink Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSource Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSource.Builder Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.KafkaAvroTableSource Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.KafkaAvroTableSource.Builder Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSink Use table descriptors instead of implementation-specific classes.
org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSource Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSource.Builder Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
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.streaming.connectors.kafka.KafkaTableSource.Builder Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.api.operators.LegacyKeyedProcessOperator Replaced by `KeyedProcessOperator` which takes `KeyedProcessFunction`
org.apache.flink.cep.nfa.NFA.NFASerializer
org.apache.flink.cep.nfa.NFA.NFASerializerConfigSnapshot
org.apache.flink.streaming.connectors.fs.NonRollingBucketer use `BasePathBucketer` instead.
org.apache.flink.streaming.api.functions.sink.OutputFormatSinkFunction Please use the `BucketingSink` for writing to files from a streaming program.
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.streaming.connectors.fs.RollingSink use `BucketingSink` instead.
org.apache.flink.cep.nfa.SharedBuffer everything in this class is deprecated. Those are only migration procedures from older versions.
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.api.operators.StreamGroupedFold will be removed in a future version
org.apache.flink.runtime.checkpoint.TaskState Internal class for savepoint backwards compatibility. Don't use for other purposes.
org.apache.flink.streaming.api.windowing.assigners.TumblingTimeWindows Please use `TumblingEventTimeWindows`.
org.apache.flink.streaming.util.serialization.TypeInformationSerializationSchema Use `TypeInformationSerializationSchema` instead.
org.apache.flink.streaming.api.functions.sink.WriteFormat Please use the `BucketingSink` for writing to files from a streaming program.
org.apache.flink.streaming.api.functions.sink.WriteFormatAsCsv Please use the `BucketingSink` for writing to files from a streaming program.
org.apache.flink.streaming.api.functions.sink.WriteFormatAsText Please use the `BucketingSink` for writing to files from a streaming program.
org.apache.flink.streaming.api.functions.sink.WriteSinkFunction Please use the `BucketingSink` for writing to files from a streaming program.
org.apache.flink.streaming.api.functions.sink.WriteSinkFunctionByMillis Please use the `BucketingSink` 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.test.util.TestBaseUtils.CodebaseType
Will be irrelevant once the legacy mode has been removed.

Deprecated Enums
Enum and Description
org.apache.flink.test.util.TestBaseUtils.CodebaseType Will be irrelevant once the legacy mode has been removed.

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 `TaskManagerOptions.DATA_PORT` instead
org.apache.flink.configuration.ConfigConstants.DEFAULT_TASK_MANAGER_DATA_SSL_ENABLED use `TaskManagerOptions.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_NUM_BUFFERS `TaskManagerOptions.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.TaskManagerOptions.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.TaskManagerOptions.NETWORK_NUM_BUFFERS use `TaskManagerOptions.NETWORK_BUFFERS_MEMORY_FRACTION`, `TaskManagerOptions.NETWORK_BUFFERS_MEMORY_MIN`, and `TaskManagerOptions.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 `TaskManagerOptions.DATA_PORT` instead
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_DATA_SSL_ENABLED use `TaskManagerOptions.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_NUM_BUFFERS_KEY Use `TaskManagerOptions.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.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.runtime.history.FsJobArchivist.archiveJob(Path, AccessExecutionGraph) only kept for legacy reasons
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.streaming.connectors.kafka.Kafka011JsonTableSource.Builder.build() Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka011AvroTableSource.Builder.build() Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka010AvroTableSource.Builder.build() Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSource.Builder.build() Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSource.Builder.build() Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka09AvroTableSource.Builder.build() Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka08AvroTableSource.Builder.build() Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSource.Builder.build() Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.Builder.build() Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka011JsonTableSource.builder() Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka011AvroTableSource.builder() Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka010AvroTableSource.builder() Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSource.builder() Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSource.builder() Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka09AvroTableSource.builder() Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka08AvroTableSource.builder() Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSource.builder() Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.Builder.builder() Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.runtime.executiongraph.ExecutionGraphBuilder.buildGraph(ExecutionGraph, JobGraph, Configuration, ScheduledExecutorService, Executor, SlotProvider, ClassLoader, CheckpointRecoveryFactory, Time, RestartStrategy, MetricGroup, int, BlobWriter, Time, Logger)
org.apache.flink.api.java.utils.DataSetUtils.checksumHashCode(DataSet<T>) replaced with `org.apache.flink.graph.asm.dataset.ChecksumHashCode` in Gelly
org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSource.Builder.configureTableSource(T) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.Builder.configureTableSource(T) Use table descriptors instead of implementation-specific builders.
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.streaming.connectors.kafka.KafkaTableSink.createCopy()
org.apache.flink.streaming.connectors.kafka.KafkaTableSink.createSerializationSchema(RowTypeInfo) Use the constructor to pass a serialization schema instead.
org.apache.flink.streaming.connectors.fs.RollingSink.disableCleanupOnOpen() This option is deprecated and remains only for backwards compatibility. We do not clean up lingering files anymore.
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.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.connectors.kafka.KafkaJsonTableSource.Builder.failOnMissingField(boolean) Use table descriptors instead of implementation-specific builders.
org.apache.flink.api.java.io.CsvReader.fieldDelimiter(char) Please use `CsvReader.fieldDelimiter(String)`.
org.apache.flink.cep.PatternStream.flatSelect(PatternFlatTimeoutFunction<T, L>, PatternFlatSelectFunction<T, R>) Use `PatternStream.flatSelect(OutputTag, PatternFlatTimeoutFunction, PatternFlatSelectFunction)` that returns timed out events as a side-output
org.apache.flink.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, 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, 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.streaming.connectors.kafka.KafkaAvroTableSource.Builder.forAvroRecordClass(Class<? extends SpecificRecordBase>) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSource.Builder.forJsonSchema(TableSchema) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.Builder.forTopic(String) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.Builder.fromEarliest() Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.Builder.fromGroupOffsets() Use table descriptors instead of implementation-specific builders.
org.apache.flink.api.common.JobExecutionResult.fromJobSubmissionResult(JobSubmissionResult) Will be removed in future versions.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.Builder.fromLatest() Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.Builder.fromSpecificOffsets(Map<KafkaTopicPartition, Long>) Use table descriptors instead of implementation-specific builders.
org.apache.flink.api.common.functions.RuntimeContext.getAllAccumulators() Use getAccumulator(..) to obtain the value of an accumulator.
org.apache.flink.streaming.connectors.kafka.KafkaAvroTableSource.Builder.getAvroRecordClass() Use table descriptors instead of implementation-specific builders.
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.test.util.MiniClusterResourceConfiguration.getCodebaseType() Will be irrelevant once the legacy mode has been removed.
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.api.common.ExecutionConfig.getExecutionRetryDelay() Should no longer be used because it is subsumed by RestartStrategyConfiguration
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.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.connectors.kafka.KafkaJsonTableSource.Builder.getJsonSchema() Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.Builder.getKafkaProps() Use table descriptors instead of implementation-specific builders.
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.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.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.streaming.connectors.kafka.KafkaTableSource.Builder.getTableSchema() Use table descriptors instead of implementation-specific builders.
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.streaming.connectors.kafka.KafkaTableSource.Builder.getTopic() Use table descriptors instead of implementation-specific builders.
org.apache.flink.cep.nfa.sharedbuffer.SharedBuffer.init(Map<EventId, Lockable<V>>, Map<NodeId, Lockable<SharedBufferNode>>) Only for state migration!
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 (if using `Scheduler`)
org.apache.flink.yarn.AbstractYarnClusterDescriptor.isDetachedMode() The cluster descriptor should not know about this option.
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.runtime.jobmaster.LogicalSlot.releaseSlot() Added because extended the actual releaseSlot method with cause parameter.
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.test.util.MiniClusterResourceConfiguration.Builder.setCodebaseType(TestBaseUtils.CodebaseType) Will be irrelevant once the legacy mode has been removed.
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.connectors.kafka.Kafka011JsonTableSource.setFailOnMissingField(boolean) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSource.setFailOnMissingField(boolean) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSource.setFailOnMissingField(boolean) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSource.setFailOnMissingField(boolean) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSource.setFailOnMissingField(boolean) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka011JsonTableSource.setFieldMapping(Map<String, String>) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka011AvroTableSource.setFieldMapping(Map<String, String>) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka010AvroTableSource.setFieldMapping(Map<String, String>) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSource.setFieldMapping(Map<String, String>) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSource.setFieldMapping(Map<String, String>) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka09AvroTableSource.setFieldMapping(Map<String, String>) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka08AvroTableSource.setFieldMapping(Map<String, String>) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSource.setFieldMapping(Map<String, String>) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.setFieldMapping(Map<String, String>) Use table descriptors instead of implementation-specific builders.
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.flink.streaming.connectors.kafka.Kafka011JsonTableSource.setProctimeAttribute(String) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka011AvroTableSource.setProctimeAttribute(String) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka010AvroTableSource.setProctimeAttribute(String) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSource.setProctimeAttribute(String) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSource.setProctimeAttribute(String) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka09AvroTableSource.setProctimeAttribute(String) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka08AvroTableSource.setProctimeAttribute(String) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSource.setProctimeAttribute(String) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.setProctimeAttribute(String) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka011JsonTableSource.setRowtimeAttributeDescriptor(RowtimeAttributeDescriptor) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka011AvroTableSource.setRowtimeAttributeDescriptor(RowtimeAttributeDescriptor) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka010AvroTableSource.setRowtimeAttributeDescriptor(RowtimeAttributeDescriptor) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSource.setRowtimeAttributeDescriptor(RowtimeAttributeDescriptor) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSource.setRowtimeAttributeDescriptor(RowtimeAttributeDescriptor) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka09AvroTableSource.setRowtimeAttributeDescriptor(RowtimeAttributeDescriptor) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka08AvroTableSource.setRowtimeAttributeDescriptor(RowtimeAttributeDescriptor) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSource.setRowtimeAttributeDescriptor(RowtimeAttributeDescriptor) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.setRowtimeAttributeDescriptors(List<RowtimeAttributeDescriptor>) Use table descriptors instead of implementation-specific builders.
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.connectors.kafka.KafkaTableSource.setSpecificStartupOffsets(Map<KafkaTopicPartition, Long>) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.setStartupMode(StartupMode) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.setStateBackend(AbstractStateBackend) Use `StreamExecutionEnvironment.setStateBackend(StateBackend)` instead.
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 ouput instead.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.Builder.supportsKafkaTimestamps() Use table descriptors instead of implementation-specific builders.
org.apache.flink.api.common.io.FileInputFormat.supportsMultiPaths() Will be removed for Flink 2.0.
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.configuration.ConfigOption.withDescription(String) use version with `Description`
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.Builder.withKafkaProperties(Properties) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.Builder.withKafkaTimestampAsRowtimeAttribute(String, WatermarkStrategy) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.Builder.withProctimeAttribute(String) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.Builder.withRowtimeAttribute(String, TimestampExtractor, WatermarkStrategy) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.Builder.withSchema(TableSchema) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaAvroTableSource.Builder.withTableToAvroMapping(Map<String, String>) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSource.Builder.withTableToJsonMapping(Map<String, String>) Use table descriptors instead of implementation-specific builders.
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.elasticsearch.ElasticsearchSink(Map<String, String>, IndexRequestBuilder<T>) Deprecated since version 1.2, to be removed at version 2.0. Please use `ElasticsearchSink.ElasticsearchSink(Map, ElasticsearchSinkFunction)` 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.streaming.connectors.elasticsearch.ElasticsearchSink(Map<String, String>, List<TransportAddress>, IndexRequestBuilder<T>) Deprecated since 1.2, to be removed at 2.0. Please use `ElasticsearchSink.ElasticsearchSink(Map, List, ElasticsearchSinkFunction)` instead.
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 `FlinkKafkaProducer08.FlinkKafkaProducer08(String, KeyedSerializationSchema, Properties)`
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, KeyedSerializationSchema<IN>, Properties, KafkaPartitioner) Use `FlinkKafkaProducer08.FlinkKafkaProducer08(String, KeyedSerializationSchema, Properties, KafkaPartitioner)`
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, SerializationSchema<IN>, Properties) Use `FlinkKafkaProducer08.FlinkKafkaProducer08(String, SerializationSchema, Properties)`
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, SerializationSchema<IN>, Properties, KafkaPartitioner) Use `FlinkKafkaProducer08.FlinkKafkaProducer08(String, SerializationSchema, Properties, KafkaPartitioner)`
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, String, KeyedSerializationSchema<IN>) Use `FlinkKafkaProducer08.FlinkKafkaProducer08(String, String, KeyedSerializationSchema)`
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, String, SerializationSchema<IN>) Use `FlinkKafkaProducer08.FlinkKafkaProducer08(String, String, SerializationSchema)`
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.streaming.util.serialization.JsonRowDeserializationSchema(TypeInformation<Row>) Please use `JsonRowDeserializationSchema` in the "flink-json" module.
org.apache.flink.streaming.util.serialization.JsonRowSerializationSchema(TypeInformation<Row>) Please use `JsonRowSerializationSchema` in the "flink-json" module.
org.apache.flink.streaming.connectors.kafka.Kafka010AvroTableSource(String, Properties, TableSchema, Class<? extends SpecificRecordBase>) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSink(String, Properties) Use table descriptors instead of implementation-specific classes.
org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSink(String, Properties, FlinkKafkaPartitioner<Row>) Use table descriptors instead of implementation-specific classes.
org.apache.flink.streaming.connectors.kafka.Kafka010JsonTableSource(String, Properties, TableSchema, TableSchema) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka011AvroTableSource(String, Properties, TableSchema, Class<? extends SpecificRecordBase>) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka011JsonTableSource(String, Properties, TableSchema, TableSchema) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka08AvroTableSource(String, Properties, TableSchema, Class<? extends SpecificRecordBase>) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSink(String, Properties) Use table descriptors instead of implementation-specific classes.
org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSink(String, Properties, FlinkKafkaPartitioner<Row>) Use table descriptors instead of implementation-specific classes.
org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSink(String, Properties, KafkaPartitioner<Row>) This is a deprecated constructor that does not correctly handle partitioning when producing to multiple topics. Use `Kafka08JsonTableSink.Kafka08JsonTableSink(String, Properties, FlinkKafkaPartitioner)` instead.
org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSource(String, Properties, TableSchema, TableSchema) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSink(String, Properties) Use table descriptors instead of implementation-specific classes.
org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSink(String, Properties, FlinkKafkaPartitioner<Row>) Use table descriptors instead of implementation-specific classes.
org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSink(String, Properties, KafkaPartitioner<Row>) This is a deprecated constructor that does not correctly handle partitioning when producing to multiple topics. Use `Kafka09JsonTableSink.Kafka09JsonTableSink(String, Properties, FlinkKafkaPartitioner)` instead.
org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSource(String, Properties, TableSchema, TableSchema) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaAvroTableSource(String, Properties, TableSchema, Class<? extends SpecificRecordBase>) Use the `Kafka` descriptor together with descriptors for schema and format instead. Descriptors allow for implementation-agnostic definition of tables. See also `TableEnvironment.connect(ConnectorDescriptor)`.
org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSink(String, Properties, FlinkKafkaPartitioner<Row>) Use table descriptors instead of implementation-specific classes.
org.apache.flink.streaming.connectors.kafka.KafkaJsonTableSource(String, Properties, TableSchema, TableSchema) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSink(String, Properties, FlinkKafkaPartitioner<Row>) Use table descriptors instead of implementation-specific classes.
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.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

Back to Flink Website