Deprecated API

Contents

• Deprecated Interfaces
• Deprecated Classes
• Deprecated Fields
• Deprecated Methods
• Deprecated Constructors
• Deprecated Enum Constants

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.formats.avro.typeutils.AvroSerializer.AvroSchemaSerializerConfigSnapshot
org.apache.flink.streaming.api.windowing.assigners.BaseAlignedWindowAssigner will be removed in a future version. please use other WindowAssigners listed under org.apache.flink.streaming.api.windowing.assigners.
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.api.common.typeutils.base.CollectionSerializerConfigSnapshot this snapshot class should no longer be used by any serializers as their snapshot.
org.apache.flink.api.common.typeutils.CompatibilityUtil this utility class still uses the old serializer compatibility interfaces, and is therefore deprecated. See TypeSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer) and TypeSerializerSchemaCompatibility.
org.apache.flink.streaming.connectors.fs.DateTimeBucketer use DateTimeBucketer instead.
org.apache.flink.api.java.typeutils.runtime.EitherSerializerConfigSnapshot
org.apache.flink.streaming.runtime.operators.ExtractTimestampsOperator Subsumed by TimestampsAndPeriodicWatermarksOperator and TimestampsAndPunctuatedWatermarksOperator.
org.apache.flink.streaming.api.functions.source.FileMonitoringFunction Internal class deprecated in favour of ContinuousFileMonitoringFunction.
org.apache.flink.streaming.api.functions.source.FileReadFunction Internal class deprecated in favour of ContinuousFileMonitoringFunction.
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer081 Use FlinkKafkaConsumer08
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer082 Use FlinkKafkaConsumer08
org.apache.flink.streaming.connectors.kafka.partitioner.FlinkKafkaDelegatePartitioner Delegate for KafkaPartitioner, use FlinkKafkaPartitioner instead
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010.FlinkKafkaProducer010Configuration This class is deprecated since the factory methods writeToKafkaWithTimestamps for the producer are also deprecated.
org.apache.flink.streaming.api.functions.windowing.FoldApplyAllWindowFunction will be removed in a future version
org.apache.flink.streaming.api.functions.windowing.FoldApplyProcessAllWindowFunction will be removed in a future version
org.apache.flink.streaming.api.functions.windowing.FoldApplyProcessWindowFunction will be removed in a future version
org.apache.flink.streaming.api.functions.windowing.FoldApplyWindowFunction will be removed in a future version
org.apache.flink.api.common.state.FoldingStateDescriptor will be removed in a future version in favor of AggregatingStateDescriptor
org.apache.flink.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.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.KafkaTableSourceBase.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.api.common.typeutils.base.MapSerializerConfigSnapshot this snapshot class should not be used by any serializer anymore.
org.apache.flink.test.util.MiniClusterResource This class should be replaced with MiniClusterWithClientResource.
org.apache.flink.test.util.MiniClusterResourceConfiguration This class should be replaced with MiniClusterResourceConfiguration.
org.apache.flink.cep.nfa.NFA.NFASerializer
org.apache.flink.cep.nfa.NFA.NFASerializerConfigSnapshot
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.runtime.webmonitor.handlers.ProgramArgsQueryParameter please, use JarRequestBody.FIELD_NAME_PROGRAM_ARGUMENTS_LIST
org.apache.flink.api.common.functions.RichFoldFunction use RichAggregateFunction instead
org.apache.flink.streaming.api.functions.windowing.RichProcessAllWindowFunction use ProcessAllWindowFunction instead
org.apache.flink.streaming.api.functions.windowing.RichProcessWindowFunction use ProcessWindowFunction instead
org.apache.flink.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.api.common.typeutils.TypeSerializerConfigSnapshot
org.apache.flink.api.common.typeutils.TypeSerializerSerializationUtil This utility class was used to write serializers into checkpoints. Starting from Flink 1.6.x, this should no longer happen, and therefore this class is deprecated. It remains here for backwards compatibility paths.
org.apache.flink.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 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.mesos.configuration.MesosOptions.INITIAL_TASKS
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.mesos.configuration.MesosOptions.MAX_FAILED_TASKS
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.ResourceManagerOptions.TASK_MANAGER_RELEASE_WHEN_RESULT_CONSUMED The default value should be reasonable enough in all cases, this option is to fallback to older behaviour which will be removed or refactored in future.
org.apache.flink.configuration.ConfigConstants.TASK_MANAGER_TMP_DIR_KEY Use CoreOptions.TMP_DIRS instead
org.apache.flink.configuration.ConfigConstants.YARN_APPLICATION_ATTEMPTS in favor of YarnConfigOptions#APPLICATION_ATTEMPTS.
org.apache.flink.configuration.ConfigConstants.YARN_APPLICATION_MASTER_ENV_PREFIX Please use CONTAINERIZED_MASTER_ENV_PREFIX.
org.apache.flink.configuration.ConfigConstants.YARN_APPLICATION_MASTER_PORT in favor of YarnConfigOptions#APPLICATION_MASTER_PORT.
org.apache.flink.configuration.ConfigConstants.YARN_APPLICATION_TAGS in favor of YarnConfigOptions#APPLICATION_TAGS.
org.apache.flink.client.cli.CliFrontendParser.YARN_DETACHED_OPTION use non-prefixed variant CliFrontendParser.DETACHED_OPTION for both YARN and non-YARN deployments
org.apache.flink.configuration.ConfigConstants.YARN_HEAP_CUTOFF_MIN in favor of #CONTAINERIZED_HEAP_CUTOFF_MIN
org.apache.flink.configuration.ConfigConstants.YARN_HEAP_CUTOFF_RATIO in favor of #CONTAINERIZED_HEAP_CUTOFF_RATIO
org.apache.flink.configuration.ConfigConstants.YARN_HEARTBEAT_DELAY_SECONDS in favor of YarnConfigOptions#HEARTBEAT_DELAY_SECONDS.
org.apache.flink.configuration.ConfigConstants.YARN_MAX_FAILED_CONTAINERS in favor of YarnConfigOptions#MAX_FAILED_CONTAINERS.
org.apache.flink.configuration.ConfigConstants.YARN_PROPERTIES_FILE_LOCATION in favor of YarnConfigOptions#PROPERTIES_FILE_LOCATION.
org.apache.flink.configuration.ConfigConstants.YARN_REALLOCATE_FAILED_CONTAINERS Not used anymore
org.apache.flink.configuration.ConfigConstants.YARN_TASK_MANAGER_ENV_PREFIX Please use CONTAINERIZED_TASK_MANAGER_ENV_PREFIX.
org.apache.flink.configuration.ConfigConstants.YARN_VCORES in favor of YarnConfigOptions#VCORES.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_CHECKPOINT_COUNTER_PATH Deprecated in favour of ConfigConstants.HA_ZOOKEEPER_CHECKPOINT_COUNTER_PATH.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_CHECKPOINTS_PATH Deprecated in favour of ConfigConstants.HA_ZOOKEEPER_CHECKPOINTS_PATH.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_CONNECTION_TIMEOUT Deprecated in favour of ConfigConstants.HA_ZOOKEEPER_CONNECTION_TIMEOUT.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_DIR_KEY Deprecated in favour of ConfigConstants.HA_ZOOKEEPER_DIR_KEY.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_JOBGRAPHS_PATH Deprecated in favour of ConfigConstants.HA_ZOOKEEPER_JOBGRAPHS_PATH.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_LATCH_PATH Deprecated in favour of ConfigConstants.HA_ZOOKEEPER_LATCH_PATH.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_LEADER_PATH Deprecated in favour of ConfigConstants.HA_ZOOKEEPER_LEADER_PATH.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_MAX_RETRY_ATTEMPTS Deprecated in favour of ConfigConstants.HA_ZOOKEEPER_MAX_RETRY_ATTEMPTS.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_MESOS_WORKERS_PATH Deprecated in favour of ConfigConstants.HA_ZOOKEEPER_MESOS_WORKERS_PATH.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_NAMESPACE_KEY Deprecated in favour of ConfigConstants.HA_ZOOKEEPER_NAMESPACE_KEY.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_QUORUM_KEY Deprecated in favour of ConfigConstants.HA_ZOOKEEPER_QUORUM_KEY.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_RECOVERY_PATH Deprecated in favour of ConfigConstants.HA_ZOOKEEPER_STORAGE_PATH.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_RETRY_WAIT Deprecated in favour of ConfigConstants.HA_ZOOKEEPER_RETRY_WAIT.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_SASL_DISABLE in favor of SecurityOptions.ZOOKEEPER_SASL_DISABLE.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_SASL_SERVICE_NAME in favor of SecurityOptions.ZOOKEEPER_SASL_SERVICE_NAME.
org.apache.flink.configuration.ConfigConstants.ZOOKEEPER_SESSION_TIMEOUT Deprecated in favour of ConfigConstants.HA_ZOOKEEPER_SESSION_TIMEOUT.

Deprecated Methods

Method and Description
org.apache.flink.streaming.connectors.elasticsearch.RequestIndexer.add(ActionRequest...) use the DeleteRequest, IndexRequest or UpdateRequest
org.apache.hadoop.conf.Configuration.addDeprecation(String, String[]) use Configuration.addDeprecation(String key, String newKey) instead
org.apache.hadoop.conf.Configuration.addDeprecation(String, String[], String) use Configuration.addDeprecation(String key, String newKey, String customMessage) instead
org.apache.flink.api.common.operators.DualInputOperator.addFirstInput(Operator<IN1>...) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.DualInputOperator.addFirstInputs(List<Operator<IN1>>) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.SingleInputOperator.addInput(List<Operator<IN>>) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.addInput(Operator<IN>...) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.SingleInputOperator.addInput(Operator<IN>...) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.addInputs(List<? extends Operator<IN>>) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.DualInputOperator.addSecondInput(Operator<IN2>...) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.DualInputOperator.addSecondInputs(List<Operator<IN2>>) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.streaming.api.datastream.AllWindowedStream.apply(ReduceFunction<T>, AllWindowFunction<T, R, W>) Use AllWindowedStream.reduce(ReduceFunction, AllWindowFunction) instead.
org.apache.flink.streaming.api.datastream.AllWindowedStream.apply(ReduceFunction<T>, AllWindowFunction<T, R, W>, TypeInformation<R>) Use AllWindowedStream.reduce(ReduceFunction, AllWindowFunction, TypeInformation) instead.
org.apache.flink.streaming.api.datastream.WindowedStream.apply(ReduceFunction<T>, WindowFunction<T, R, K, W>) Use WindowedStream.reduce(ReduceFunction, WindowFunction) instead.
org.apache.flink.streaming.api.datastream.WindowedStream.apply(ReduceFunction<T>, WindowFunction<T, R, K, W>, TypeInformation<R>) Use WindowedStream.reduce(ReduceFunction, WindowFunction, TypeInformation) instead.
org.apache.flink.streaming.api.datastream.AllWindowedStream.apply(R, FoldFunction<T, R>, AllWindowFunction<R, R, W>) Use AllWindowedStream.fold(Object, FoldFunction, AllWindowFunction) instead.
org.apache.flink.streaming.api.datastream.AllWindowedStream.apply(R, FoldFunction<T, R>, AllWindowFunction<R, R, W>, TypeInformation<R>) Use AllWindowedStream.fold(Object, FoldFunction, AllWindowFunction, TypeInformation, TypeInformation) instead.
org.apache.flink.streaming.api.datastream.WindowedStream.apply(R, FoldFunction<T, R>, WindowFunction<R, R, K, W>) Use WindowedStream.fold(Object, FoldFunction, WindowFunction) instead.
org.apache.flink.streaming.api.datastream.WindowedStream.apply(R, FoldFunction<T, R>, WindowFunction<R, R, K, W>, TypeInformation<R>) Use WindowedStream.fold(Object, FoldFunction, WindowFunction, TypeInformation, TypeInformation) instead.
org.apache.flink.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.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.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.KafkaTableSourceBase.Builder.build() Use table descriptors instead of implementation-specific builders.
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.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.KafkaTableSourceBase.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.KafkaTableSourceBase.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.KafkaTableSinkBase.createCopy()
org.apache.flink.streaming.connectors.kafka.KafkaTableSinkBase.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.api.common.typeutils.TypeSerializer.ensureCompatibility(TypeSerializerConfigSnapshot<?>) Replaced by TypeSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer).
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.KafkaTableSourceBase.Builder.forTopic(String) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBase.Builder.fromEarliest() Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBase.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.KafkaTableSourceBase.Builder.fromLatest() Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBase.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.table.api.TableSchema.getColumnNames() Use TableSchema.getFieldNames() instead. Can be dropped after 1.7.
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.KafkaTableSourceBase.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.KafkaTableSourceBase.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.KafkaTableSourceBase.Builder.getTopic() Use table descriptors instead of implementation-specific builders.
org.apache.flink.table.api.TableSchema.getTypes() Use TableSchema.getFieldTypes() instead. Can be dropped after 1.7.
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.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.Kafka08JsonTableSource.setFailOnMissingField(boolean) Use table descriptors instead of implementation-specific builders.
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.KafkaJsonTableSource.setFailOnMissingField(boolean) 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.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.KafkaTableSourceBase.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.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.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.KafkaTableSourceBase.setProctimeAttribute(String) 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.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.KafkaTableSourceBase.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.KafkaTableSourceBase.setSpecificStartupOffsets(Map<KafkaTopicPartition, Long>) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBase.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.KafkaTableSourceBase.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.streaming.connectors.kafka.KafkaTableSourceBase.Builder.withKafkaProperties(Properties) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBase.Builder.withKafkaTimestampAsRowtimeAttribute(String, WatermarkStrategy) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBase.Builder.withProctimeAttribute(String) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBase.Builder.withRowtimeAttribute(String, TimestampExtractor, WatermarkStrategy) Use table descriptors instead of implementation-specific builders.
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBase.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.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.KafkaTableSinkBase(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.