Preview Release of Apache Flink 2.0
October 23, 2024 - Xintong SongThe Apache Flink community is actively preparing Flink 2.0, the first major release since Flink 1.0 launched 8 years ago. As a significant milestone, Flink 2.0 is set to introduce numerous innovative features and improvements, along with some compatibility-breaking changes. To facilitate early adaptation to these changes for our users and partner projects (e.g., connectors), and to offer a sneak peek into the exciting new features while gathering feedback, we are now providing a preview release of Flink 2.0.
NOTICE: Flink 2.0 Preview is not a stable release and should not be used in production environments. While this preview includes most of the breaking changes planned for Flink 2.0, the final release may still subject to additional modifications.
Breaking Changes #
API #
The following sets of APIs have been completely removed.
- DataSet API. Please migrate to DataStream API, or Table API/SQL if applicable. See also How to Migrate from DataSet to DataStream.
- Scala DataStream and DataSet API. Please migrate to the Java DataStream API.
- SourceFuction, SinkFunction and Sink V1. Please migrate to Source and Sink V2.
- TableSoure and TableSink. Please migrate to DynamicTableSource and DynamicTableSink. See also User-defined Sources & Sinks.
- TableSchema, TableColumn and Types. Please migrate to Schema, Column and DataTypes respectively.
Some deprecated methods have been removed from DataStream API. See also the list of breaking programming APIs.
Some deprecated fields have been removed from REST API. See also the list of breaking REST APIs.
NOTICE: You may find some of the removed APIs still exist in the code base, usually in a different package. They are for internal usages only and can be changed / removed anytime without notifications. Please DO NOT USE them.
Connector Adaption Plan #
As SourceFunction, SinkFunction and SinkV1 being removed, existing connectors depending on these APIs will not work on the Flink 2.x series. Here’s the plan for adapting the first-party connectors.
- A new version of Kafka connector, adapted to the API changes, will be released right after the release of Flink 2.0 Preview.
- JDBC and ElasticSearch connectors will be adapted by the formal release of Flink 2.0.
- We plan to gradually migrate the remaining first-party connectors within 3 subsequent minor releases (i.e., by Flink 2.3).
Configuration #
Configuration options meet the following criteria are removed. See also the list of removed configuration options.
- Annotated as
@Public
and have been deprecated for at least 2 minor releases. - Annotated as
@PublicEvolving
and have been deprecated for at least 1 minor releases.
The legacy configuration file flink-conf.yaml
is no longer supported. Please use config.yaml
with standard YAML format instead. A migration tool is provided to convert a legacy flink-conf.yaml
into a new config.yaml
. See Migrate from flink-conf.yaml to config.yaml for more details.
Configuration APIs that takes java objects as arguments are removed from StreamExecutionEnvironment
and ExecutionConfig
. They should now be set via Configuration
and ConfigOption
. See also the list of breaking programming APIs.
To avoid exposing internal interfaces, User-Defined Functions no longer have full access to ExecutionConfig
. Instead, necessary functions such as createSerializer()
, getGlobalJobParameters()
and isObjectReuseEnabled()
can now be accessed from RuntimeContext
directly.
Misc #
State Compatibility is not guaranteed between 1.x and 2.x.
Java 8 is no longer supported. The minimum Java version supported by Flink now is Java 11.
Legacy Mode of Hybrid Shuffle is removed.
Highlights of New Features #
Disaggregated State Storage and Management #
The past decade has witnessed a dramatic shift in Flink’s deployment mode, workload patterns, and hardware improvements. We’ve moved from the map-reduce era where workers are computation-storage tightly coupled nodes to a cloud-native world where containerized deployments on Kubernetes become standard. To enable Flink’s Cloud-Native future, we introduce Disaggregated State Storage and Management that uses remote storage as primary storage in Flink 2.0.
This new architecture solves the following challenges brought in the cloud-native era for Flink.
- Local Disk Constraints in containerization
- Spiky Resource Usage caused by compaction in the current state model
- Fast Rescaling for jobs with large states (hundreds of Terabytes)
- Light and Fast Checkpoint in a native way
However, simply extending the state store to read/write from remote DFS is insufficient due to the existing blocking execution model in Flink. In Flink 2.0, we propose asynchronous execution model and introduce ForStDB, a disaggregated statebackend solution for this purpose.
In the preview version, we offer a complete end-to-end trial using Nexmark Q20 (SQL Filter Join). This includes:
- Asynchronous execution: Full support for asynchronous state APIs and checkpointing.
- Asynchronous SQL Join operator: Rewrite SQL Join operators to enable asynchronous join execution.
- Hybrid Async & Sync Execution: Hybrid SQL Plan + Runtime Execution + State Access
- Performance: Demonstrate performance results directly writing to DFS in async execution mode
Materialized Table #
In Flink 1.20, we introduced Materialized Table as a MVP feature. Materialized Table is an innovative table type in Flink SQL, designed to further streamlining batch and stream data processing while providing a unified development experience. In the upcoming Flink 2.0 release, we are enhancing operational supports for Materialized Tables, including connector integration with cutting-edge lake formats and production-ready schedulers.
Adaptive Batch Execution #
In addition, Flink is continuously enhancing its adaptive batch execution capabilities. The upcoming Flink 2.0 release will introduce dynamic optimization of logical plans, in addition to physical plans, based on insights gained from the execution of previous stages. The initial set of optimization strategies includes the dynamic application of broadcast join and skewed join optimization.
Streaming Lakehouse #
Represented by the integration of Apache Flink and Apache Paimon, the Streaming Lakehouse architecture has extended the unified data storage, open format and cost-effectiveness of the Lakehouse paradigm to the real-time area. The upcoming Flink 2.0 release marks another significant step in enhancing the integration between Flink and Paimon. The Flink and Paimon communities are collaborating closely to adapt to each other’s strengths and fully leverage their cutting-edge features, yielding various improvements including SQL plan optimization utilizing Paimon’s rich merge engines, enhanced bucket-aware lookup join performance, and Paimon support for Flink’s Materialized Table, Adaptive Batch Execution and Speculative Execution.
Appendix #
List of breaking change programming APIs #
Removed Classes #
org.apache.flink.api.common.ExecutionConfig$SerializableSerializer
org.apache.flink.api.common.ExecutionMode
org.apache.flink.api.common.InputDependencyConstraint
org.apache.flink.api.common.restartstrategy.RestartStrategies$ExponentialDelayRestartStrategyConfiguration
org.apache.flink.api.common.restartstrategy.RestartStrategies$FailureRateRestartStrategyConfiguration
org.apache.flink.api.common.restartstrategy.RestartStrategies$FallbackRestartStrategyConfiguration
org.apache.flink.api.common.restartstrategy.RestartStrategies$FixedDelayRestartStrategyConfiguration
org.apache.flink.api.common.restartstrategy.RestartStrategies$NoRestartStrategyConfiguration
org.apache.flink.api.common.restartstrategy.RestartStrategies$RestartStrategyConfiguration
org.apache.flink.api.common.restartstrategy.RestartStrategies
org.apache.flink.api.common.time.Time
org.apache.flink.api.connector.sink.Committer
org.apache.flink.api.connector.sink.GlobalCommitter
org.apache.flink.api.connector.sink.Sink$InitContext
org.apache.flink.api.connector.sink.Sink$ProcessingTimeService$ProcessingTimeCallback
org.apache.flink.api.connector.sink.Sink$ProcessingTimeService
org.apache.flink.api.connector.sink.SinkWriter$Context
org.apache.flink.api.connector.sink.SinkWriter
org.apache.flink.api.connector.sink.Sink
org.apache.flink.api.connector.sink2.Sink$InitContextWrapper
org.apache.flink.api.connector.sink2.Sink$InitContext
org.apache.flink.api.connector.sink2.StatefulSink$StatefulSinkWriter
org.apache.flink.api.connector.sink2.StatefulSink$WithCompatibleState
org.apache.flink.api.connector.sink2.StatefulSink
org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink$PrecommittingSinkWriter
org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink
org.apache.flink.api.java.CollectionEnvironment
org.apache.flink.api.java.DataSet
org.apache.flink.api.java.ExecutionEnvironmentFactory
org.apache.flink.api.java.ExecutionEnvironment
org.apache.flink.api.java.LocalEnvironment
org.apache.flink.api.java.RemoteEnvironment
org.apache.flink.api.java.aggregation.Aggregations
org.apache.flink.api.java.aggregation.UnsupportedAggregationTypeException
org.apache.flink.api.java.functions.FlatMapIterator
org.apache.flink.api.java.functions.FunctionAnnotation$ForwardedFieldsFirst
org.apache.flink.api.java.functions.FunctionAnnotation$ForwardedFieldsSecond
org.apache.flink.api.java.functions.FunctionAnnotation$ForwardedFields
org.apache.flink.api.java.functions.FunctionAnnotation$NonForwardedFieldsFirst
org.apache.flink.api.java.functions.FunctionAnnotation$NonForwardedFieldsSecond
org.apache.flink.api.java.functions.FunctionAnnotation$NonForwardedFields
org.apache.flink.api.java.functions.FunctionAnnotation$ReadFieldsFirst
org.apache.flink.api.java.functions.FunctionAnnotation$ReadFieldsSecond
org.apache.flink.api.java.functions.FunctionAnnotation$ReadFields
org.apache.flink.api.java.functions.FunctionAnnotation
org.apache.flink.api.java.functions.GroupReduceIterator
org.apache.flink.api.java.io.CollectionInputFormat
org.apache.flink.api.java.io.CsvOutputFormat
org.apache.flink.api.java.io.CsvReader
org.apache.flink.api.java.io.DiscardingOutputFormat
org.apache.flink.api.java.io.IteratorInputFormat
org.apache.flink.api.java.io.LocalCollectionOutputFormat
org.apache.flink.api.java.io.ParallelIteratorInputFormat
org.apache.flink.api.java.io.PrimitiveInputFormat
org.apache.flink.api.java.io.PrintingOutputFormat
org.apache.flink.api.java.io.RowCsvInputFormat
org.apache.flink.api.java.io.SplitDataProperties$SourcePartitionerMarker
org.apache.flink.api.java.io.SplitDataProperties
org.apache.flink.api.java.io.TextInputFormat
org.apache.flink.api.java.io.TextOutputFormat$TextFormatter
org.apache.flink.api.java.io.TextOutputFormat
org.apache.flink.api.java.io.TextValueInputFormat
org.apache.flink.api.java.io.TypeSerializerInputFormat
org.apache.flink.api.java.io.TypeSerializerOutputFormat
org.apache.flink.api.java.operators.AggregateOperator
org.apache.flink.api.java.operators.CoGroupOperator$CoGroupOperatorSets
org.apache.flink.api.java.operators.CoGroupOperator
org.apache.flink.api.java.operators.CrossOperator$DefaultCross
org.apache.flink.api.java.operators.CrossOperator$ProjectCross
org.apache.flink.api.java.operators.CrossOperator
org.apache.flink.api.java.operators.CustomUnaryOperation
org.apache.flink.api.java.operators.DataSink
org.apache.flink.api.java.operators.DataSource
org.apache.flink.api.java.operators.DeltaIteration$SolutionSetPlaceHolder
org.apache.flink.api.java.operators.DeltaIteration$WorksetPlaceHolder
org.apache.flink.api.java.operators.DeltaIterationResultSet
org.apache.flink.api.java.operators.DeltaIteration
org.apache.flink.api.java.operators.DistinctOperator
org.apache.flink.api.java.operators.FilterOperator
org.apache.flink.api.java.operators.FlatMapOperator
org.apache.flink.api.java.operators.GroupCombineOperator
org.apache.flink.api.java.operators.GroupReduceOperator
org.apache.flink.api.java.operators.Grouping
org.apache.flink.api.java.operators.IterativeDataSet
org.apache.flink.api.java.operators.JoinOperator$DefaultJoin
org.apache.flink.api.java.operators.JoinOperator$EquiJoin
org.apache.flink.api.java.operators.JoinOperator$JoinOperatorSets$JoinOperatorSetsPredicate
org.apache.flink.api.java.operators.JoinOperator$JoinOperatorSets
org.apache.flink.api.java.operators.JoinOperator$ProjectJoin
org.apache.flink.api.java.operators.JoinOperator
org.apache.flink.api.java.operators.MapOperator
org.apache.flink.api.java.operators.MapPartitionOperator
org.apache.flink.api.java.operators.Operator
org.apache.flink.api.java.operators.PartitionOperator
org.apache.flink.api.java.operators.ProjectOperator
org.apache.flink.api.java.operators.ReduceOperator
org.apache.flink.api.java.operators.SingleInputOperator
org.apache.flink.api.java.operators.SingleInputUdfOperator
org.apache.flink.api.java.operators.SortPartitionOperator
org.apache.flink.api.java.operators.SortedGrouping
org.apache.flink.api.java.operators.TwoInputOperator
org.apache.flink.api.java.operators.TwoInputUdfOperator
org.apache.flink.api.java.operators.UdfOperator
org.apache.flink.api.java.operators.UnionOperator
org.apache.flink.api.java.operators.UnsortedGrouping
org.apache.flink.api.java.operators.join.JoinFunctionAssigner
org.apache.flink.api.java.operators.join.JoinOperatorSetsBase$JoinOperatorSetsPredicateBase
org.apache.flink.api.java.operators.join.JoinOperatorSetsBase
org.apache.flink.api.java.operators.join.JoinType
org.apache.flink.api.java.summarize.BooleanColumnSummary
org.apache.flink.api.java.summarize.ColumnSummary
org.apache.flink.api.java.summarize.NumericColumnSummary
org.apache.flink.api.java.summarize.ObjectColumnSummary
org.apache.flink.api.java.summarize.StringColumnSummary
org.apache.flink.api.java.utils.AbstractParameterTool
org.apache.flink.api.java.utils.DataSetUtils
org.apache.flink.api.java.utils.MultipleParameterTool
org.apache.flink.api.java.utils.ParameterTool
org.apache.flink.configuration.AkkaOptions
org.apache.flink.connector.file.src.reader.FileRecordFormat$Reader
org.apache.flink.connector.file.src.reader.FileRecordFormat
org.apache.flink.connector.testframe.external.sink.DataStreamSinkV1ExternalContext
org.apache.flink.core.execution.RestoreMode
org.apache.flink.datastream.api.stream.KeyedPartitionStream$TwoKeyedPartitionStreams
org.apache.flink.datastream.api.stream.NonKeyedPartitionStream$TwoNonKeyedPartitionStreams
org.apache.flink.formats.avro.AvroRowDeserializationSchema
org.apache.flink.formats.csv.CsvRowDeserializationSchema$Builder
org.apache.flink.formats.csv.CsvRowDeserializationSchema
org.apache.flink.formats.csv.CsvRowSerializationSchema$Builder
org.apache.flink.formats.csv.CsvRowSerializationSchema
org.apache.flink.formats.json.JsonRowDeserializationSchema$Builder
org.apache.flink.formats.json.JsonRowDeserializationSchema
org.apache.flink.formats.json.JsonRowSerializationSchema$Builder
org.apache.flink.formats.json.JsonRowSerializationSchema
org.apache.flink.metrics.reporter.InstantiateViaFactory
org.apache.flink.metrics.reporter.InterceptInstantiationViaReflection
org.apache.flink.runtime.jobgraph.SavepointConfigOptions
org.apache.flink.runtime.state.CheckpointListener
org.apache.flink.runtime.state.filesystem.FsStateBackendFactory
org.apache.flink.runtime.state.filesystem.FsStateBackend
org.apache.flink.runtime.state.memory.MemoryStateBackendFactory
org.apache.flink.runtime.state.memory.MemoryStateBackend
org.apache.flink.state.api.BootstrapTransformation
org.apache.flink.state.api.EvictingWindowReader
org.apache.flink.state.api.ExistingSavepoint
org.apache.flink.state.api.KeyedOperatorTransformation
org.apache.flink.state.api.NewSavepoint
org.apache.flink.state.api.OneInputOperatorTransformation
org.apache.flink.state.api.Savepoint
org.apache.flink.state.api.WindowReader
org.apache.flink.state.api.WindowedOperatorTransformation
org.apache.flink.state.api.WritableSavepoint
org.apache.flink.streaming.api.TimeCharacteristic
org.apache.flink.streaming.api.checkpoint.ExternallyInducedSource$CheckpointTrigger
org.apache.flink.streaming.api.checkpoint.ExternallyInducedSource
org.apache.flink.streaming.api.connector.sink2.WithPostCommitTopology
org.apache.flink.streaming.api.connector.sink2.WithPreCommitTopology
org.apache.flink.streaming.api.connector.sink2.WithPreWriteTopology
org.apache.flink.streaming.api.datastream.IterativeStream$ConnectedIterativeStreams
org.apache.flink.streaming.api.environment.CheckpointConfig$ExternalizedCheckpointCleanup
org.apache.flink.streaming.api.environment.ExecutionCheckpointingOptions
org.apache.flink.streaming.api.environment.StreamPipelineOptions
org.apache.flink.streaming.api.functions.AscendingTimestampExtractor
org.apache.flink.streaming.api.functions.sink.DiscardingSink
org.apache.flink.streaming.api.functions.sink.OutputFormatSinkFunction
org.apache.flink.streaming.api.functions.sink.PrintSinkFunction
org.apache.flink.streaming.api.functions.sink.RichSinkFunction
org.apache.flink.streaming.api.functions.sink.SinkFunction$Context
org.apache.flink.streaming.api.functions.sink.SinkFunction
org.apache.flink.streaming.api.functions.sink.SocketClientSink
org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction
org.apache.flink.streaming.api.functions.sink.WriteFormatAsCsv
org.apache.flink.streaming.api.functions.sink.WriteFormatAsText
org.apache.flink.streaming.api.functions.sink.WriteFormat
org.apache.flink.streaming.api.functions.sink.WriteSinkFunctionByMillis
org.apache.flink.streaming.api.functions.sink.WriteSinkFunction
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink$BulkFormatBuilder
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink$DefaultBulkFormatBuilder
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink$DefaultRowFormatBuilder
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink$RowFormatBuilder
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink
org.apache.flink.streaming.api.functions.source.FromElementsFunction
org.apache.flink.streaming.api.functions.source.FromIteratorFunction
org.apache.flink.streaming.api.functions.source.FromSplittableIteratorFunction
org.apache.flink.streaming.api.functions.source.MessageAcknowledgingSourceBase
org.apache.flink.streaming.api.functions.source.MultipleIdsMessageAcknowledgingSourceBase
org.apache.flink.streaming.api.functions.source.ParallelSourceFunction
org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction
org.apache.flink.streaming.api.functions.source.RichSourceFunction
org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction
org.apache.flink.streaming.api.functions.source.SourceFunction$SourceContext
org.apache.flink.streaming.api.functions.source.SourceFunction
org.apache.flink.streaming.api.functions.source.StatefulSequenceSource
org.apache.flink.streaming.api.functions.source.datagen.DataGeneratorSource
org.apache.flink.streaming.api.functions.windowing.RichProcessAllWindowFunction
org.apache.flink.streaming.api.functions.windowing.RichProcessWindowFunction
org.apache.flink.streaming.api.operators.SetupableStreamOperator
org.apache.flink.streaming.api.operators.YieldingOperatorFactory
org.apache.flink.streaming.api.windowing.time.Time
org.apache.flink.streaming.util.serialization.AbstractDeserializationSchema
org.apache.flink.streaming.util.serialization.DeserializationSchema
org.apache.flink.streaming.util.serialization.SerializationSchema
org.apache.flink.streaming.util.serialization.SimpleStringSchema
org.apache.flink.streaming.util.serialization.TypeInformationSerializationSchema
org.apache.flink.table.api.TableColumn$ComputedColumn
org.apache.flink.table.api.TableColumn$MetadataColumn
org.apache.flink.table.api.TableColumn$PhysicalColumn
org.apache.flink.table.api.TableColumn
org.apache.flink.table.api.TableSchema$Builder
org.apache.flink.table.api.TableSchema
org.apache.flink.table.api.constraints.Constraint$ConstraintType
org.apache.flink.table.api.constraints.Constraint
org.apache.flink.table.api.constraints.UniqueConstraint
org.apache.flink.table.connector.sink.SinkFunctionProvider
org.apache.flink.table.connector.sink.SinkProvider
org.apache.flink.table.connector.source.AsyncTableFunctionProvider
org.apache.flink.table.connector.source.SourceFunctionProvider
org.apache.flink.table.connector.source.TableFunctionProvider
org.apache.flink.table.descriptors.Descriptor
org.apache.flink.table.descriptors.RowtimeValidator
org.apache.flink.table.descriptors.Rowtime
org.apache.flink.table.descriptors.SchemaValidator
org.apache.flink.table.descriptors.Schema
org.apache.flink.table.factories.StreamTableSinkFactory
org.apache.flink.table.factories.StreamTableSourceFactory
org.apache.flink.table.factories.TableFactory
org.apache.flink.table.factories.TableSinkFactory$Context
org.apache.flink.table.factories.TableSinkFactory
org.apache.flink.table.factories.TableSourceFactory$Context
org.apache.flink.table.factories.TableSourceFactory
org.apache.flink.table.planner.codegen.agg.batch.HashAggCodeGenerator$
org.apache.flink.table.planner.plan.metadata.FlinkRelMdRowCount$
org.apache.flink.table.planner.plan.optimize.RelNodeBlockPlanBuilder$
org.apache.flink.table.planner.plan.rules.logical.JoinDeriveNullFilterRule$
org.apache.flink.table.planner.plan.rules.physical.batch.BatchPhysicalJoinRuleBase$
org.apache.flink.table.planner.plan.rules.physical.batch.BatchPhysicalSortMergeJoinRule$
org.apache.flink.table.planner.plan.rules.physical.batch.BatchPhysicalSortRule$
org.apache.flink.table.planner.plan.rules.physical.stream.IncrementalAggregateRule$
org.apache.flink.table.planner.plan.utils.FlinkRexUtil$
org.apache.flink.table.sinks.AppendStreamTableSink
org.apache.flink.table.sinks.OutputFormatTableSink
org.apache.flink.table.sinks.OverwritableTableSink
org.apache.flink.table.sinks.PartitionableTableSink
org.apache.flink.table.sinks.RetractStreamTableSink
org.apache.flink.table.sinks.TableSink
org.apache.flink.table.sinks.UpsertStreamTableSink
org.apache.flink.table.sources.DefinedFieldMapping
org.apache.flink.table.sources.DefinedProctimeAttribute
org.apache.flink.table.sources.DefinedRowtimeAttributes
org.apache.flink.table.sources.FieldComputer
org.apache.flink.table.sources.InputFormatTableSource
org.apache.flink.table.sources.LimitableTableSource
org.apache.flink.table.sources.LookupableTableSource
org.apache.flink.table.sources.NestedFieldsProjectableTableSource
org.apache.flink.table.sources.PartitionableTableSource
org.apache.flink.table.sources.ProjectableTableSource
org.apache.flink.table.sources.TableSource
org.apache.flink.table.sources.tsextractors.ExistingField
org.apache.flink.table.sources.tsextractors.StreamRecordTimestamp
org.apache.flink.table.sources.tsextractors.TimestampExtractor
org.apache.flink.table.types.logical.TypeInformationRawType
org.apache.flink.table.utils.TypeStringUtils
org.apache.flink.walkthrough.common.sink.AlertSink
org.apache.flink.walkthrough.common.source.TransactionSource
Modified Classes #
org.apache.flink.table.api.config.ExecutionConfigOptions
- field removed:
org.apache.flink.configuration.ConfigOption<java.lang.Boolean> TABLE_EXEC_LEGACY_TRANSFORMATION_UIDS
org.apache.flink.configuration.ConfigOption<java.lang.String> TABLE_EXEC_SHUFFLE_MODE
- field removed:
org.apache.flink.table.api.config.LookupJoinHintOptions
- method modified:
org.apache.flink.shaded.guava32.com.google.common.collect.ImmutableSet<org.apache.flink.configuration.ConfigOption><org.apache.flink.configuration.ConfigOption> (<-org.apache.flink.shaded.guava31.com.google.common.collect.ImmutableSet<org.apache.flink.configuration.ConfigOption><org.apache.flink.configuration.ConfigOption>) getRequiredOptions()
org.apache.flink.shaded.guava32.com.google.common.collect.ImmutableSet<org.apache.flink.configuration.ConfigOption><org.apache.flink.configuration.ConfigOption> (<-org.apache.flink.shaded.guava31.com.google.common.collect.ImmutableSet<org.apache.flink.configuration.ConfigOption><org.apache.flink.configuration.ConfigOption>) getSupportedOptions()
- method modified:
org.apache.flink.table.api.config.OptimizerConfigOptions
- field removed:
org.apache.flink.configuration.ConfigOption<java.lang.Boolean> TABLE_OPTIMIZER_SOURCE_PREDICATE_PUSHDOWN_ENABLED
org.apache.flink.configuration.ConfigOption<java.lang.Boolean> TABLE_OPTIMIZER_SOURCE_AGGREGATE_PUSHDOWN_ENABLED
- field removed:
org.apache.flink.table.api.Table
- method modified:
org.apache.flink.table.legacy.api.TableSchema (<-org.apache.flink.table.api.TableSchema) getSchema()
- method modified:
org.apache.flink.table.api.TableConfig
- method removed:
void setIdleStateRetentionTime(org.apache.flink.api.common.time.Time, org.apache.flink.api.common.time.Time)
- method removed:
org.apache.flink.table.api.TableResult
- method modified:
org.apache.flink.table.legacy.api.TableSchema (<-org.apache.flink.table.api.TableSchema) getTableSchema()
- method modified:
org.apache.flink.table.catalog.CatalogBaseTable
- method modified:
org.apache.flink.table.legacy.api.TableSchema (<-org.apache.flink.table.api.TableSchema) getSchema()
- method modified:
org.apache.flink.table.catalog.ResolvedCatalogBaseTable
- method modified:
org.apache.flink.table.legacy.api.TableSchema (<-org.apache.flink.table.api.TableSchema) getSchema()
- method modified:
org.apache.flink.table.functions.FunctionContext
- constructor removed:
FunctionContext(org.apache.flink.api.common.functions.RuntimeContext, java.lang.ClassLoader, org.apache.flink.configuration.Configuration)
- constructor removed:
org.apache.flink.api.common.eventtime.WatermarksWithIdleness
- constructor removed:
WatermarksWithIdleness(org.apache.flink.api.common.eventtime.WatermarkGenerator<T>, java.time.Duration)
- constructor removed:
org.apache.flink.api.common.ExecutionConfig
- field removed:
int PARALLELISM_AUTO_MAX
- method removed:
void addDefaultKryoSerializer(java.lang.Class<?>, com.esotericsoftware.kryo.Serializer<?>)
void addDefaultKryoSerializer(java.lang.Class<?>, java.lang.Class<? extends com.esotericsoftware.kryo.Serializer<? extends ?>>)
boolean canEqual(java.lang.Object)
void disableAutoTypeRegistration()
void disableForceAvro()
void disableForceKryo()
void disableGenericTypes()
void enableForceAvro()
void enableForceKryo()
void enableGenericTypes()
org.apache.flink.api.common.InputDependencyConstraint getDefaultInputDependencyConstraint()
java.util.LinkedHashMap<java.lang.Class<?>,java.lang.Class<com.esotericsoftware.kryo.Serializer<? extends ?>>> getDefaultKryoSerializerClasses()
java.util.LinkedHashMap<java.lang.Class<?>,org.apache.flink.api.common.ExecutionConfig$SerializableSerializer<?>> getDefaultKryoSerializers()
org.apache.flink.api.common.ExecutionMode getExecutionMode()
long getExecutionRetryDelay()
int getNumberOfExecutionRetries()
java.util.LinkedHashSet<java.lang.Class<?>> getRegisteredKryoTypes()
java.util.LinkedHashSet<java.lang.Class<?>> getRegisteredPojoTypes()
java.util.LinkedHashMap<java.lang.Class<?>,java.lang.Class<com.esotericsoftware.kryo.Serializer<? extends ?>>> getRegisteredTypesWithKryoSerializerClasses()
java.util.LinkedHashMap<java.lang.Class<?>,org.apache.flink.api.common.ExecutionConfig$SerializableSerializer<?>> getRegisteredTypesWithKryoSerializers()
org.apache.flink.api.common.restartstrategy.RestartStrategies$RestartStrategyConfiguration getRestartStrategy()
boolean hasGenericTypesDisabled()
boolean isAutoTypeRegistrationDisabled()
boolean isForceAvroEnabled()
boolean isForceKryoEnabled()
void registerKryoType(java.lang.Class<?>)
void registerPojoType(java.lang.Class<?>)
void registerTypeWithKryoSerializer(java.lang.Class<?>, com.esotericsoftware.kryo.Serializer<?>)
void registerTypeWithKryoSerializer(java.lang.Class<?>, java.lang.Class<? extends com.esotericsoftware.kryo.Serializer>)
void setDefaultInputDependencyConstraint(org.apache.flink.api.common.InputDependencyConstraint)
void setExecutionMode(org.apache.flink.api.common.ExecutionMode)
org.apache.flink.api.common.ExecutionConfig setExecutionRetryDelay(long)
org.apache.flink.api.common.ExecutionConfig setNumberOfExecutionRetries(int)
void setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies$RestartStrategyConfiguration)
- field removed:
org.apache.flink.api.common.functions.RichFunction
- method removed:
void open(org.apache.flink.configuration.Configuration)
- method modified:
(<- NON_ABSTRACT) void open(org.apache.flink.api.common.functions.OpenContext)
- method removed:
org.apache.flink.api.common.functions.RuntimeContext
- method removed:
int getAttemptNumber()
org.apache.flink.api.common.ExecutionConfig getExecutionConfig()
int getIndexOfThisSubtask()
org.apache.flink.api.common.JobID getJobId()
int getMaxNumberOfParallelSubtasks()
int getNumberOfParallelSubtasks()
java.lang.String getTaskName()
java.lang.String getTaskNameWithSubtasks()
- method removed:
org.apache.flink.api.common.io.BinaryInputFormat
- field removed:
java.lang.String BLOCK_SIZE_PARAMETER_KEY
- field removed:
org.apache.flink.api.common.io.BinaryOutputFormat
- field removed:
java.lang.String BLOCK_SIZE_PARAMETER_KEY
- field removed:
org.apache.flink.api.common.io.FileInputFormat
- field removed:
java.lang.String ENUMERATE_NESTED_FILES_FLAG
- method removed:
org.apache.flink.core.fs.Path getFilePath()
boolean supportsMultiPaths()
- field removed:
org.apache.flink.api.common.io.FileOutputFormat
- field removed:
java.lang.String FILE_PARAMETER_KEY
- field removed:
org.apache.flink.api.common.io.FinalizeOnMaster
- method removed:
void finalizeGlobal(int)
- method modified:
(<- NON_ABSTRACT) void finalizeGlobal(org.apache.flink.api.common.io.FinalizeOnMaster$FinalizationContext)
- method removed:
org.apache.flink.api.common.io.OutputFormat
- method removed:
void open(int, int)
- method modified:
(<- NON_ABSTRACT) void open(org.apache.flink.api.common.io.OutputFormat$InitializationContext)
- method removed:
org.apache.flink.api.common.JobExecutionResult
- method removed:
org.apache.flink.api.common.JobExecutionResult fromJobSubmissionResult(org.apache.flink.api.common.JobSubmissionResult)
java.lang.Integer getIntCounterResult(java.lang.String)
- method removed:
org.apache.flink.api.common.serialization.SerializerConfig
- method removed:
java.util.LinkedHashMap<java.lang.Class<?>,org.apache.flink.api.common.ExecutionConfig$SerializableSerializer<?>> getDefaultKryoSerializers()
java.util.LinkedHashMap<java.lang.Class<?>,org.apache.flink.api.common.ExecutionConfig$SerializableSerializer<?>> getRegisteredTypesWithKryoSerializers()
- method removed:
org.apache.flink.api.common.state.StateTtlConfig
- method removed:
org.apache.flink.api.common.time.Time getTtl()
org.apache.flink.api.common.state.StateTtlConfig$Builder newBuilder(org.apache.flink.api.common.time.Time)
- method removed:
org.apache.flink.api.common.state.StateTtlConfig$Builder
- constructor removed:
StateTtlConfig$Builder(org.apache.flink.api.common.time.Time)
- method removed:
org.apache.flink.api.common.state.StateTtlConfig$Builder setTtl(org.apache.flink.api.common.time.Time)
- constructor removed:
org.apache.flink.api.common.typeinfo.TypeInformation
- method modified:
(<- NON_ABSTRACT) org.apache.flink.api.common.typeutils.TypeSerializer<T><T> createSerializer(org.apache.flink.api.common.serialization.SerializerConfig)
- method removed:
org.apache.flink.api.common.typeutils.TypeSerializer<T> createSerializer(org.apache.flink.api.common.ExecutionConfig)
- method modified:
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot
- method removed:
org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<T> resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializer<T>)
- method modified:
(<- NON_ABSTRACT) org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<T><T> resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<T><T>)
- method removed:
org.apache.flink.api.connector.sink2.Sink
- method removed:
org.apache.flink.api.connector.sink2.SinkWriter<InputT> createWriter(org.apache.flink.api.connector.sink2.Sink$InitContext)
- method modified:
(<- NON_ABSTRACT) org.apache.flink.api.connector.sink2.SinkWriter<InputT><InputT> createWriter(org.apache.flink.api.connector.sink2.WriterInitContext)
- method removed:
org.apache.flink.api.java.typeutils.PojoTypeInfo
- method removed:
org.apache.flink.api.java.typeutils.runtime.PojoSerializer<T> createPojoSerializer(org.apache.flink.api.common.ExecutionConfig)
- method removed:
org.apache.flink.api.java.typeutils.RowTypeInfo
- method removed:
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.types.Row> createLegacySerializer(org.apache.flink.api.common.serialization.SerializerConfig)
- method removed:
org.apache.flink.configuration.CheckpointingOptions
- field removed:
org.apache.flink.configuration.ConfigOption<java.lang.Boolean> LOCAL_RECOVERY
org.apache.flink.configuration.ConfigOption<java.lang.String> STATE_BACKEND
org.apache.flink.configuration.ConfigOption<java.lang.Boolean> ASYNC_SNAPSHOTS
- field removed:
org.apache.flink.configuration.ClusterOptions
- field removed:
org.apache.flink.configuration.ConfigOption<java.lang.Boolean> FINE_GRAINED_SHUFFLE_MODE_ALL_BLOCKING
org.apache.flink.configuration.ConfigOption<java.lang.Boolean> EVENLY_SPREAD_OUT_SLOTS_STRATEGY
- field removed:
org.apache.flink.configuration.ConfigConstants
- field removed:
java.lang.String HA_ZOOKEEPER_LEADER_PATH
double DEFAULT_AKKA_WATCH_THRESHOLD
int DEFAULT_JOB_MANAGER_IPC_PORT
java.lang.String JOB_MANAGER_WEB_TMPDIR_KEY
int DEFAULT_TASK_MANAGER_MEMORY_SEGMENT_SIZE
java.lang.String METRICS_SCOPE_NAMING_TASK
java.lang.String ZOOKEEPER_NAMESPACE_KEY
int DEFAULT_AKKA_DISPATCHER_THROUGHPUT
java.lang.String RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS
java.lang.String MESOS_MASTER_URL
java.lang.String FLINK_BASE_DIR_PATH_KEY
java.lang.String JOB_MANAGER_WEB_SSL_ENABLED
java.lang.String YARN_APPLICATION_TAGS
java.lang.String HDFS_SITE_CONFIG
java.lang.String EXECUTION_RETRY_DELAY_KEY
int DEFAULT_MESOS_ARTIFACT_SERVER_PORT
boolean DEFAULT_SECURITY_SSL_VERIFY_HOSTNAME
java.lang.String CONTAINERIZED_HEAP_CUTOFF_MIN
java.lang.String YARN_HEARTBEAT_DELAY_SECONDS
java.lang.String AKKA_SSL_ENABLED
java.lang.String HA_MODE
java.lang.String ZOOKEEPER_MESOS_WORKERS_PATH
boolean DEFAULT_ZOOKEEPER_SASL_DISABLE
java.lang.String METRICS_SCOPE_DELIMITER
java.lang.String LOCAL_NUMBER_RESOURCE_MANAGER
java.lang.String AKKA_TCP_TIMEOUT
java.lang.String METRICS_SCOPE_NAMING_OPERATOR
java.lang.String ZOOKEEPER_RECOVERY_PATH
int DEFAULT_ZOOKEEPER_LEADER_PORT
java.lang.String DEFAULT_ZOOKEEPER_LATCH_PATH
int DEFAULT_ZOOKEEPER_PEER_PORT
java.lang.String METRICS_SCOPE_NAMING_TM_JOB
int DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_NUM_SAMPLES
java.lang.String HA_ZOOKEEPER_SESSION_TIMEOUT
java.lang.String FLINK_JVM_OPTIONS
java.lang.String HA_ZOOKEEPER_CHECKPOINT_COUNTER_PATH
java.lang.String METRICS_SCOPE_NAMING_JM
java.lang.String DEFAULT_YARN_JOB_MANAGER_PORT
boolean DEFAULT_JOB_MANAGER_WEB_CHECKPOINTS_DISABLE
java.lang.String HA_ZOOKEEPER_QUORUM_KEY
boolean DEFAULT_JOB_MANAGER_WEB_SUBMIT_ENABLED
java.lang.String JOB_MANAGER_WEB_CHECKPOINTS_HISTORY_SIZE
java.lang.String ZOOKEEPER_JOBGRAPHS_PATH
java.lang.String ZOOKEEPER_SASL_SERVICE_NAME
java.lang.String DEFAULT_AKKA_LOOKUP_TIMEOUT
java.lang.String RESTART_STRATEGY_FAILURE_RATE_MAX_FAILURES_PER_INTERVAL
java.lang.String JOB_MANAGER_WEB_PORT_KEY
java.lang.String METRICS_LATENCY_HISTORY_SIZE
int DEFAULT_BLOB_FETCH_BACKLOG
java.lang.String JOB_MANAGER_WEB_BACK_PRESSURE_REFRESH_INTERVAL
float DEFAULT_SORT_SPILLING_THRESHOLD
java.lang.String DEFAULT_AKKA_TRANSPORT_HEARTBEAT_INTERVAL
java.lang.String CONTAINERIZED_MASTER_ENV_PREFIX
int DEFAULT_JOB_MANAGER_WEB_ARCHIVE_COUNT
java.lang.String TASK_MANAGER_HOSTNAME_KEY
java.lang.String AKKA_WATCH_HEARTBEAT_INTERVAL
java.lang.String DEFAULT_TASK_MANAGER_TMP_PATH
int DEFAULT_EXECUTION_RETRIES
int DEFAULT_JOB_MANAGER_WEB_FRONTEND_PORT
java.lang.String JOB_MANAGER_WEB_LOG_PATH_KEY
java.lang.String TASK_MANAGER_MEMORY_SIZE_KEY
java.lang.String DEFAULT_MESOS_RESOURCEMANAGER_FRAMEWORK_NAME
java.lang.String TASK_MANAGER_DATA_PORT_KEY
java.lang.String ZOOKEEPER_CHECKPOINTS_PATH
java.lang.String HA_JOB_MANAGER_PORT
java.lang.String TASK_MANAGER_REFUSED_REGISTRATION_PAUSE
java.lang.String CONTAINERIZED_HEAP_CUTOFF_RATIO
java.lang.String DEFAULT_SORT_SPILLING_THRESHOLD_KEY
java.lang.String YARN_CONTAINER_START_COMMAND_TEMPLATE
boolean DEFAULT_JOB_MANAGER_WEB_SSL_ENABLED
java.lang.String LIBRARY_CACHE_MANAGER_CLEANUP_INTERVAL
java.lang.String JOB_MANAGER_WEB_CHECKPOINTS_DISABLE
java.lang.String DEFAULT_ZOOKEEPER_LEADER_PATH
int DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_DELAY
java.lang.String DEFAULT_TASK_MANAGER_MAX_REGISTRATION_PAUSE
java.lang.String METRICS_REPORTERS_LIST
java.lang.String DEFAULT_RECOVERY_MODE
int DEFAULT_METRICS_LATENCY_HISTORY_SIZE
java.lang.String TASK_MANAGER_INITIAL_REGISTRATION_PAUSE
java.lang.String DEFAULT_MESOS_RESOURCEMANAGER_FRAMEWORK_ROLE
int DEFAULT_JOB_MANAGER_WEB_CHECKPOINTS_HISTORY_SIZE
java.lang.String YARN_PROPERTIES_FILE_LOCATION
java.lang.String RECOVERY_JOB_MANAGER_PORT
boolean DEFAULT_SECURITY_SSL_ENABLED
java.lang.String MESOS_FAILOVER_TIMEOUT_SECONDS
java.lang.String RUNTIME_HASH_JOIN_BLOOM_FILTERS_KEY
java.lang.String ZOOKEEPER_LEADER_PATH
java.lang.String ZOOKEEPER_MAX_RETRY_ATTEMPTS
java.lang.String HA_ZOOKEEPER_CHECKPOINTS_PATH
java.lang.String MESOS_RESOURCEMANAGER_FRAMEWORK_ROLE
int DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_REFRESH_INTERVAL
java.lang.String DEFAULT_ZOOKEEPER_MESOS_WORKERS_PATH
java.lang.String JOB_MANAGER_IPC_PORT_KEY
java.lang.String AKKA_WATCH_HEARTBEAT_PAUSE
java.lang.String MESOS_RESOURCEMANAGER_FRAMEWORK_NAME
java.lang.String DELIMITED_FORMAT_MAX_SAMPLE_LENGTH_KEY
java.lang.String STATE_BACKEND
java.lang.String MESOS_RESOURCEMANAGER_FRAMEWORK_PRINCIPAL
long DEFAULT_TASK_MANAGER_DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS
java.lang.String DEFAULT_AKKA_CLIENT_TIMEOUT
int DEFAULT_SPILLING_MAX_FAN
java.lang.String TASK_MANAGER_IPC_PORT_KEY
java.lang.String TASK_MANAGER_MEMORY_OFF_HEAP_KEY
boolean DEFAULT_FILESYSTEM_OVERWRITE
boolean DEFAULT_USE_LARGE_RECORD_HANDLER
java.lang.String HA_ZOOKEEPER_JOBGRAPHS_PATH
boolean DEFAULT_BLOB_SERVICE_SSL_ENABLED
java.lang.String ZOOKEEPER_SESSION_TIMEOUT
java.lang.String TASK_MANAGER_NETWORK_DEFAULT_IO_MODE
java.lang.String SECURITY_SSL_TRUSTSTORE_PASSWORD
int DEFAULT_ZOOKEEPER_MAX_RETRY_ATTEMPTS
java.lang.String AKKA_STARTUP_TIMEOUT
java.lang.String TASK_MANAGER_TMP_DIR_KEY
java.lang.String USE_LARGE_RECORD_HANDLER_KEY
java.lang.String DEFAULT_ZOOKEEPER_DIR_KEY
int DEFAULT_YARN_MIN_HEAP_CUTOFF
java.lang.String TASK_MANAGER_DATA_SSL_ENABLED
java.lang.String HDFS_DEFAULT_CONFIG
boolean DEFAULT_TASK_MANAGER_DATA_SSL_ENABLED
java.lang.String DEFAULT_ZOOKEEPER_JOBGRAPHS_PATH
java.lang.String HA_ZOOKEEPER_MESOS_WORKERS_PATH
java.lang.String BLOB_STORAGE_DIRECTORY_KEY
java.lang.String DEFAULT_STATE_BACKEND
java.lang.String HA_ZOOKEEPER_RETRY_WAIT
java.lang.String AKKA_ASK_TIMEOUT
java.lang.String JOB_MANAGER_WEB_SUBMIT_ENABLED_KEY
java.lang.String DEFAULT_ZOOKEEPER_NAMESPACE_KEY
java.lang.String DEFAULT_ZOOKEEPER_CHECKPOINTS_PATH
int DEFAULT_LOCAL_NUMBER_JOB_MANAGER
java.lang.String AKKA_TRANSPORT_HEARTBEAT_INTERVAL
java.lang.String DEFAULT_ZOOKEEPER_CHECKPOINT_COUNTER_PATH
java.lang.String FS_STREAM_OPENING_TIMEOUT_KEY
java.lang.String SECURITY_SSL_TRUSTSTORE
java.lang.String METRICS_SCOPE_NAMING_JM_JOB
java.lang.String MESOS_INITIAL_TASKS
java.lang.String AKKA_FRAMESIZE
int DEFAULT_ZOOKEEPER_INIT_LIMIT
java.lang.String JOB_MANAGER_WEB_BACK_PRESSURE_CLEAN_UP_INTERVAL
java.lang.String SECURITY_SSL_KEYSTORE
boolean DEFAULT_MESOS_ARTIFACT_SERVER_SSL_ENABLED
java.lang.String HA_ZOOKEEPER_MAX_RETRY_ATTEMPTS
int DEFAULT_PARALLELISM
java.lang.String RECOVERY_MODE
java.lang.String EXECUTION_RETRIES_KEY
java.lang.String METRICS_REPORTER_SCOPE_DELIMITER
java.lang.String LOCAL_START_WEBSERVER
java.lang.String LOCAL_NUMBER_JOB_MANAGER
java.lang.String RESTART_STRATEGY
java.lang.String ZOOKEEPER_QUORUM_KEY
int DEFAULT_MESOS_FAILOVER_TIMEOUT_SECS
boolean DEFAULT_TASK_MANAGER_MEMORY_PRE_ALLOCATE
int DEFAULT_LOCAL_NUMBER_RESOURCE_MANAGER
java.lang.String HA_ZOOKEEPER_CLIENT_ACL
java.lang.String METRICS_REPORTER_FACTORY_CLASS_SUFFIX
boolean DEFAULT_FILESYSTEM_ALWAYS_CREATE_DIRECTORY
java.lang.String BLOB_FETCH_CONCURRENT_KEY
java.lang.String FILESYSTEM_DEFAULT_OVERWRITE_KEY
java.lang.String RESOURCE_MANAGER_IPC_PORT_KEY
java.lang.String DEFAULT_AKKA_ASK_TIMEOUT
int DEFAULT_ZOOKEEPER_CLIENT_PORT
double DEFAULT_AKKA_TRANSPORT_THRESHOLD
java.lang.String DEFAULT_AKKA_FRAMESIZE
java.lang.String TASK_MANAGER_NUM_TASK_SLOTS
java.lang.String YARN_APPLICATION_MASTER_ENV_PREFIX
java.lang.String JOB_MANAGER_WEB_BACK_PRESSURE_DELAY
long DEFAULT_TASK_CANCELLATION_INTERVAL_MILLIS
java.lang.String TASK_MANAGER_MEMORY_PRE_ALLOCATE_KEY
java.lang.String FILESYSTEM_SCHEME
java.lang.String TASK_MANAGER_MAX_REGISTRATION_DURATION
java.lang.String HA_ZOOKEEPER_DIR_KEY
java.lang.String DEFAULT_MESOS_RESOURCEMANAGER_FRAMEWORK_USER
java.lang.String DEFAULT_FILESYSTEM_SCHEME
java.lang.String MESOS_RESOURCEMANAGER_FRAMEWORK_SECRET
int DEFAULT_DELIMITED_FORMAT_MAX_SAMPLE_LEN
java.lang.String ENV_FLINK_BIN_DIR
float DEFAULT_YARN_HEAP_CUTOFF_RATIO
java.lang.String SAVEPOINT_FS_DIRECTORY_KEY
java.lang.String AKKA_JVM_EXIT_ON_FATAL_ERROR
java.lang.String ZOOKEEPER_RETRY_WAIT
java.lang.String HA_ZOOKEEPER_NAMESPACE_KEY
java.lang.String ZOOKEEPER_CONNECTION_TIMEOUT
java.lang.String TASK_MANAGER_NETWORK_NUM_BUFFERS_KEY
java.lang.String JOB_MANAGER_WEB_ARCHIVE_COUNT
int DEFAULT_RESOURCE_MANAGER_IPC_PORT
int DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_CLEAN_UP_INTERVAL
java.lang.String YARN_REALLOCATE_FAILED_CONTAINERS
java.lang.String SECURITY_SSL_KEYSTORE_PASSWORD
java.lang.String DEFAULT_HA_JOB_MANAGER_PORT
java.lang.String BLOB_FETCH_RETRIES_KEY
java.lang.String METRICS_REPORTER_EXCLUDED_VARIABLES
java.lang.String DEFAULT_SECURITY_SSL_PROTOCOL
java.lang.String RECOVERY_JOB_DELAY
java.lang.String TASK_CANCELLATION_INTERVAL_MILLIS
java.lang.String YARN_APPLICATION_MASTER_PORT
int DEFAULT_TASK_MANAGER_DATA_PORT
java.lang.String RESTART_STRATEGY_FAILURE_RATE_FAILURE_RATE_INTERVAL
java.lang.String YARN_TASK_MANAGER_ENV_PREFIX
int DEFAULT_DELIMITED_FORMAT_MIN_LINE_SAMPLES
java.lang.String AKKA_LOG_LIFECYCLE_EVENTS
boolean DEFAULT_AKKA_LOG_LIFECYCLE_EVENTS
java.lang.String SECURITY_SSL_ENABLED
int DEFAULT_DELIMITED_FORMAT_MAX_LINE_SAMPLES
java.lang.String LOCAL_NUMBER_TASK_MANAGER
java.lang.String DEFAULT_TASK_MANAGER_REFUSED_REGISTRATION_PAUSE
java.lang.String DEFAULT_SECURITY_SSL_ALGORITHMS
java.lang.String MESOS_MAX_FAILED_TASKS
int DEFAULT_TASK_MANAGER_IPC_PORT
org.apache.flink.configuration.ConfigOption<java.lang.String> DEFAULT_JOB_MANAGER_WEB_FRONTEND_ADDRESS
java.lang.String SECURITY_SSL_ALGORITHMS
int DEFAULT_ZOOKEEPER_CONNECTION_TIMEOUT
java.lang.String YARN_HEAP_CUTOFF_RATIO
java.lang.String HA_ZOOKEEPER_LATCH_PATH
int DEFAULT_ZOOKEEPER_SESSION_TIMEOUT
java.lang.String DEFAULT_SPILLING_MAX_FAN_KEY
java.lang.String AKKA_WATCH_THRESHOLD
java.lang.String TASK_MANAGER_DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS
java.lang.String HA_ZOOKEEPER_STORAGE_PATH
java.lang.String DEFAULT_BLOB_SERVER_PORT
java.lang.String AKKA_TRANSPORT_THRESHOLD
java.lang.String ZOOKEEPER_CHECKPOINT_COUNTER_PATH
boolean DEFAULT_RUNTIME_HASH_JOIN_BLOOM_FILTERS
int DEFAULT_BLOB_FETCH_CONCURRENT
java.lang.String BLOB_SERVER_PORT
org.apache.flink.configuration.ConfigOption<java.lang.String> RESTART_STRATEGY_FIXED_DELAY_DELAY
java.lang.String METRICS_REPORTER_CLASS_SUFFIX
java.lang.String ZOOKEEPER_DIR_KEY
java.lang.String JOB_MANAGER_IPC_ADDRESS_KEY
int DEFAULT_TASK_MANAGER_NETWORK_NUM_BUFFERS
java.lang.String DEFAULT_AKKA_TRANSPORT_HEARTBEAT_PAUSE
java.lang.String MESOS_ARTIFACT_SERVER_SSL_ENABLED
java.lang.String RESTART_STRATEGY_FAILURE_RATE_DELAY
java.lang.String DELIMITED_FORMAT_MIN_LINE_SAMPLES_KEY
java.lang.String BLOB_FETCH_BACKLOG_KEY
java.lang.String FILESYSTEM_OUTPUT_ALWAYS_CREATE_DIRECTORY_KEY
java.lang.String DEFAULT_TASK_MANAGER_MAX_REGISTRATION_DURATION
java.lang.String TASK_MANAGER_LOG_PATH_KEY
java.lang.String DEFAULT_TASK_MANAGER_NETWORK_DEFAULT_IO_MODE
int DEFAULT_YARN_HEAP_CUTOFF
java.lang.String SECURITY_SSL_PROTOCOL
java.lang.String JOB_MANAGER_WEB_BACK_PRESSURE_NUM_SAMPLES
java.lang.String CHECKPOINTS_DIRECTORY_KEY
java.lang.String DELIMITED_FORMAT_MAX_LINE_SAMPLES_KEY
java.lang.String PATH_HADOOP_CONFIG
java.lang.String ZOOKEEPER_SASL_DISABLE
java.lang.String AKKA_LOOKUP_TIMEOUT
java.lang.String YARN_HEAP_CUTOFF_MIN
java.lang.String AKKA_CLIENT_TIMEOUT
int DEFAULT_ZOOKEEPER_SYNC_LIMIT
java.lang.String DEFAULT_HA_MODE
java.lang.String CONTAINERIZED_TASK_MANAGER_ENV_PREFIX
java.lang.String HA_ZOOKEEPER_CONNECTION_TIMEOUT
java.lang.String METRICS_REPORTER_ADDITIONAL_VARIABLES
java.lang.String MESOS_ARTIFACT_SERVER_PORT_KEY
java.lang.String TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD
java.lang.String TASK_MANAGER_MEMORY_SEGMENT_SIZE_KEY
java.lang.String YARN_APPLICATION_ATTEMPTS
java.lang.String AKKA_TRANSPORT_HEARTBEAT_PAUSE
java.lang.String DEFAULT_TASK_MANAGER_INITIAL_REGISTRATION_PAUSE
java.lang.String SECURITY_SSL_VERIFY_HOSTNAME
java.lang.String DEFAULT_PARALLELISM_KEY
java.lang.String AKKA_DISPATCHER_THROUGHPUT
java.lang.String TASK_MANAGER_MEMORY_FRACTION_KEY
java.lang.String JOB_MANAGER_WEB_UPLOAD_DIR_KEY
java.lang.String SECURITY_SSL_KEY_PASSWORD
int DEFAULT_BLOB_FETCH_RETRIES
java.lang.String MESOS_RESOURCEMANAGER_FRAMEWORK_USER
java.lang.String BLOB_SERVICE_SSL_ENABLED
java.lang.String DEFAULT_YARN_APPLICATION_MASTER_PORT
java.lang.String METRICS_SCOPE_NAMING_TM
java.lang.String TASK_MANAGER_MAX_REGISTARTION_PAUSE
long DEFAULT_LIBRARY_CACHE_MANAGER_CLEANUP_INTERVAL
int DEFAULT_FS_STREAM_OPENING_TIMEOUT
java.lang.String YARN_VCORES
java.lang.String YARN_MAX_FAILED_CONTAINERS
java.lang.String METRICS_REPORTER_INTERVAL_SUFFIX
java.lang.String DEFAULT_HA_ZOOKEEPER_CLIENT_ACL
float DEFAULT_MEMORY_MANAGER_MEMORY_FRACTION
java.lang.String SAVEPOINT_DIRECTORY_KEY
int DEFAULT_ZOOKEEPER_RETRY_WAIT
java.lang.String ZOOKEEPER_LATCH_PATH
java.lang.String DEFAULT_RECOVERY_JOB_MANAGER_PORT
boolean DEFAULT_TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD
boolean DEFAULT_AKKA_SSL_ENABLED
- field removed:
org.apache.flink.configuration.ConfigOption
- method removed:
java.lang.Iterable<java.lang.String> deprecatedKeys()
boolean hasDeprecatedKeys()
- method removed:
org.apache.flink.configuration.ConfigOptions$OptionBuilder
- method removed:
org.apache.flink.configuration.ConfigOption<T> defaultValue(java.lang.Object)
org.apache.flink.configuration.ConfigOption<java.lang.String> noDefaultValue()
- method removed:
org.apache.flink.configuration.Configuration
- method removed:
boolean getBoolean(java.lang.String, boolean)
boolean getBoolean(org.apache.flink.configuration.ConfigOption<java.lang.Boolean>)
boolean getBoolean(org.apache.flink.configuration.ConfigOption<java.lang.Boolean>, boolean)
byte[] getBytes(java.lang.String, byte[])
java.lang.Class<T> getClass(java.lang.String, java.lang.Class<? extends T>, java.lang.ClassLoader)
double getDouble(java.lang.String, double)
double getDouble(org.apache.flink.configuration.ConfigOption<java.lang.Double>)
double getDouble(org.apache.flink.configuration.ConfigOption<java.lang.Double>, double)
float getFloat(java.lang.String, float)
float getFloat(org.apache.flink.configuration.ConfigOption<java.lang.Float>)
float getFloat(org.apache.flink.configuration.ConfigOption<java.lang.Float>, float)
int getInteger(java.lang.String, int)
int getInteger(org.apache.flink.configuration.ConfigOption<java.lang.Integer>)
int getInteger(org.apache.flink.configuration.ConfigOption<java.lang.Integer>, int)
long getLong(java.lang.String, long)
long getLong(org.apache.flink.configuration.ConfigOption<java.lang.Long>)
long getLong(org.apache.flink.configuration.ConfigOption<java.lang.Long>, long)
java.lang.String getString(org.apache.flink.configuration.ConfigOption<java.lang.String>)
java.lang.String getString(org.apache.flink.configuration.ConfigOption<java.lang.String>, java.lang.String)
void setBoolean(java.lang.String, boolean)
void setBoolean(org.apache.flink.configuration.ConfigOption<java.lang.Boolean>, boolean)
void setBytes(java.lang.String, byte[])
void setClass(java.lang.String, java.lang.Class<?>)
void setDouble(java.lang.String, double)
void setDouble(org.apache.flink.configuration.ConfigOption<java.lang.Double>, double)
void setFloat(java.lang.String, float)
void setFloat(org.apache.flink.configuration.ConfigOption<java.lang.Float>, float)
void setInteger(java.lang.String, int)
void setInteger(org.apache.flink.configuration.ConfigOption<java.lang.Integer>, int)
void setLong(java.lang.String, long)
void setLong(org.apache.flink.configuration.ConfigOption<java.lang.Long>, long)
void setString(org.apache.flink.configuration.ConfigOption<java.lang.String>, java.lang.String)
- method removed:
org.apache.flink.configuration.HighAvailabilityOptions
- field removed:
org.apache.flink.configuration.ConfigOption<java.lang.String> ZOOKEEPER_RUNNING_JOB_REGISTRY_PATH
org.apache.flink.configuration.ConfigOption<java.lang.String> HA_JOB_DELAY
- field removed:
org.apache.flink.configuration.JobManagerOptions
- field removed:
org.apache.flink.configuration.ConfigOption<java.lang.Integer> JOB_MANAGER_HEAP_MEMORY_MB
org.apache.flink.configuration.ConfigOption<java.time.Duration> BLOCK_SLOW_NODE_DURATION
org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> ADAPTIVE_BATCH_SCHEDULER_AVG_DATA_VOLUME_PER_TASK
org.apache.flink.configuration.ConfigOption<java.lang.Integer> SPECULATIVE_MAX_CONCURRENT_EXECUTIONS
org.apache.flink.configuration.ConfigOption<java.lang.Integer> ADAPTIVE_BATCH_SCHEDULER_DEFAULT_SOURCE_PARALLELISM
org.apache.flink.configuration.ConfigOption<java.lang.Integer> ADAPTIVE_BATCH_SCHEDULER_MAX_PARALLELISM
org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> JOB_MANAGER_HEAP_MEMORY
org.apache.flink.configuration.ConfigOption<java.lang.Integer> ADAPTIVE_BATCH_SCHEDULER_MIN_PARALLELISM
org.apache.flink.configuration.ConfigOption<java.lang.Boolean> SPECULATIVE_ENABLED
- field removed:
org.apache.flink.configuration.JobManagerOptions$SchedulerType
- field removed:
org.apache.flink.configuration.JobManagerOptions$SchedulerType Ng
- field removed:
org.apache.flink.configuration.MetricOptions
- field removed:
org.apache.flink.configuration.ConfigOption<java.lang.String> REPORTER_CLASS
- field removed:
org.apache.flink.configuration.NettyShuffleEnvironmentOptions
- field removed:
org.apache.flink.configuration.ConfigOption<java.lang.Integer> NUM_THREADS_CLIENT
org.apache.flink.configuration.ConfigOption<java.lang.Integer> NETWORK_BUFFERS_PER_CHANNEL
org.apache.flink.configuration.ConfigOption<java.lang.Integer> HYBRID_SHUFFLE_SPILLED_INDEX_REGION_GROUP_SIZE
org.apache.flink.configuration.ConfigOption<java.lang.Integer> CONNECT_BACKLOG
org.apache.flink.configuration.ConfigOption<java.lang.Boolean> NETWORK_HYBRID_SHUFFLE_ENABLE_NEW_MODE
org.apache.flink.configuration.ConfigOption<java.lang.Float> NETWORK_BUFFERS_MEMORY_FRACTION
org.apache.flink.configuration.ConfigOption<java.lang.Integer> NUM_ARENAS
org.apache.flink.configuration.ConfigOption<java.lang.Integer> NUM_THREADS_SERVER
org.apache.flink.configuration.ConfigOption<java.lang.Long> HYBRID_SHUFFLE_NUM_RETAINED_IN_MEMORY_REGIONS_MAX
org.apache.flink.configuration.ConfigOption<java.lang.String> NETWORK_BUFFERS_MEMORY_MIN
org.apache.flink.configuration.ConfigOption<java.lang.String> TRANSPORT_TYPE
org.apache.flink.configuration.ConfigOption<java.lang.String> NETWORK_BLOCKING_SHUFFLE_TYPE
org.apache.flink.configuration.ConfigOption<java.lang.Integer> NETWORK_MAX_OVERDRAFT_BUFFERS_PER_GATE
org.apache.flink.configuration.ConfigOption<java.lang.Long> NETWORK_EXCLUSIVE_BUFFERS_REQUEST_TIMEOUT_MILLISECONDS
org.apache.flink.configuration.ConfigOption<java.lang.Boolean> BATCH_SHUFFLE_COMPRESSION_ENABLED
org.apache.flink.configuration.ConfigOption<java.lang.Integer> SEND_RECEIVE_BUFFER_SIZE
org.apache.flink.configuration.ConfigOption<java.lang.String> NETWORK_BUFFERS_MEMORY_MAX
org.apache.flink.configuration.ConfigOption<java.lang.Integer> NETWORK_EXTRA_BUFFERS_PER_GATE
org.apache.flink.configuration.ConfigOption<java.lang.Integer> NETWORK_SORT_SHUFFLE_MIN_PARALLELISM
org.apache.flink.configuration.ConfigOption<java.lang.Integer> NETWORK_NUM_BUFFERS
org.apache.flink.configuration.ConfigOption<java.lang.Integer> NETWORK_MAX_BUFFERS_PER_CHANNEL
org.apache.flink.configuration.ConfigOption<java.lang.Integer> MAX_NUM_TCP_CONNECTIONS
- field removed:
org.apache.flink.configuration.PipelineOptions
- field removed:
org.apache.flink.configuration.ConfigOption<java.util.List<java.lang.String>> KRYO_DEFAULT_SERIALIZERS
org.apache.flink.configuration.ConfigOption<java.util.List<java.lang.String>> POJO_REGISTERED_CLASSES
org.apache.flink.configuration.ConfigOption<java.lang.Boolean> AUTO_TYPE_REGISTRATION
org.apache.flink.configuration.ConfigOption<java.util.List<java.lang.String>> KRYO_REGISTERED_CLASSES
- field removed:
org.apache.flink.configuration.ResourceManagerOptions
- field removed:
org.apache.flink.configuration.ConfigOption<java.lang.Integer> LOCAL_NUMBER_RESOURCE_MANAGER
org.apache.flink.configuration.ConfigOption<java.lang.Boolean> TASK_MANAGER_RELEASE_WHEN_RESULT_CONSUMED
org.apache.flink.configuration.ConfigOption<java.lang.Long> SLOT_MANAGER_TASK_MANAGER_TIMEOUT
- field removed:
org.apache.flink.configuration.SecurityOptions
- field removed:
org.apache.flink.configuration.ConfigOption<java.lang.Double> KERBEROS_TOKENS_RENEWAL_TIME_RATIO
org.apache.flink.configuration.ConfigOption<java.time.Duration> KERBEROS_TOKENS_RENEWAL_RETRY_BACKOFF
org.apache.flink.configuration.ConfigOption<java.lang.Boolean> KERBEROS_FETCH_DELEGATION_TOKEN
org.apache.flink.configuration.ConfigOption<java.lang.Boolean> SSL_ENABLED
- field removed:
org.apache.flink.configuration.StateBackendOptions
- field removed:
org.apache.flink.configuration.ConfigOption<java.lang.Integer> LATENCY_TRACK_HISTORY_SIZE
org.apache.flink.configuration.ConfigOption<java.lang.Boolean> LATENCY_TRACK_STATE_NAME_AS_VARIABLE
org.apache.flink.configuration.ConfigOption<java.lang.Boolean> LATENCY_TRACK_ENABLED
org.apache.flink.configuration.ConfigOption<java.lang.Integer> LATENCY_TRACK_SAMPLE_INTERVAL
- field removed:
org.apache.flink.configuration.TaskManagerOptions
- field removed:
org.apache.flink.configuration.ConfigOption<java.time.Duration> REGISTRATION_MAX_BACKOFF
org.apache.flink.configuration.ConfigOption<java.time.Duration> INITIAL_REGISTRATION_BACKOFF
org.apache.flink.configuration.ConfigOption<java.lang.Boolean> EXIT_ON_FATAL_AKKA_ERROR
org.apache.flink.configuration.ConfigOption<java.lang.Integer> TASK_MANAGER_HEAP_MEMORY_MB
java.lang.String MANAGED_MEMORY_CONSUMER_NAME_DATAPROC
org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> TASK_MANAGER_HEAP_MEMORY
org.apache.flink.configuration.ConfigOption<java.time.Duration> REFUSED_REGISTRATION_BACKOFF
- field removed:
org.apache.flink.configuration.TaskManagerOptions$TaskManagerLoadBalanceMode
- method removed:
org.apache.flink.configuration.TaskManagerOptions$TaskManagerLoadBalanceMode loadFromConfiguration(org.apache.flink.configuration.Configuration)
- method removed:
org.apache.flink.configuration.WebOptions
- field removed:
org.apache.flink.configuration.ConfigOption<java.lang.Integer> BACKPRESSURE_DELAY
org.apache.flink.configuration.ConfigOption<java.lang.Integer> PORT
org.apache.flink.configuration.ConfigOption<java.lang.Integer> BACKPRESSURE_REFRESH_INTERVAL
org.apache.flink.configuration.ConfigOption<java.lang.Integer> BACKPRESSURE_NUM_SAMPLES
org.apache.flink.configuration.ConfigOption<java.lang.String> ADDRESS
org.apache.flink.configuration.ConfigOption<java.lang.Integer> BACKPRESSURE_CLEANUP_INTERVAL
org.apache.flink.configuration.ConfigOption<java.lang.Boolean> SSL_ENABLED
- field removed:
org.apache.flink.connector.base.sink.AsyncSinkBase
- interface removed:
org.apache.flink.api.connector.sink2.StatefulSink
- interface removed:
org.apache.flink.connector.base.sink.writer.AsyncSinkWriter
- constructor removed:
AsyncSinkWriter(org.apache.flink.connector.base.sink.writer.ElementConverter<InputT,RequestEntryT>, org.apache.flink.api.connector.sink2.Sink$InitContext, int, int, int, long, long, long)
AsyncSinkWriter(org.apache.flink.connector.base.sink.writer.ElementConverter<InputT,RequestEntryT>, org.apache.flink.api.connector.sink2.Sink$InitContext, int, int, int, long, long, long, java.util.Collection<org.apache.flink.connector.base.sink.writer.BufferedRequestState<RequestEntryT>>)
AsyncSinkWriter(org.apache.flink.connector.base.sink.writer.ElementConverter<InputT,RequestEntryT>, org.apache.flink.api.connector.sink2.Sink$InitContext, org.apache.flink.connector.base.sink.writer.config.AsyncSinkWriterConfiguration, java.util.Collection<org.apache.flink.connector.base.sink.writer.BufferedRequestState<RequestEntryT>>)
- constructor removed:
org.apache.flink.connector.base.sink.writer.ElementConverter
- method removed:
void open(org.apache.flink.api.connector.sink2.Sink$InitContext)
- method removed:
org.apache.flink.connector.base.source.reader.fetcher.SingleThreadFetcherManager
- constructor removed:
SingleThreadFetcherManager(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<E>>, java.util.function.Supplier<org.apache.flink.connector.base.source.reader.splitreader.SplitReader<E,SplitT>>)
SingleThreadFetcherManager(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<E>>, java.util.function.Supplier<org.apache.flink.connector.base.source.reader.splitreader.SplitReader<E,SplitT>>, org.apache.flink.configuration.Configuration)
SingleThreadFetcherManager(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<E>>, java.util.function.Supplier<org.apache.flink.connector.base.source.reader.splitreader.SplitReader<E,SplitT>>, org.apache.flink.configuration.Configuration, java.util.function.Consumer<java.util.Collection<java.lang.String>>)
- constructor removed:
org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager
- constructor removed:
SplitFetcherManager(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<E>>, java.util.function.Supplier<org.apache.flink.connector.base.source.reader.splitreader.SplitReader<E,SplitT>>, org.apache.flink.configuration.Configuration, java.util.function.Consumer<java.util.Collection<java.lang.String>>)
SplitFetcherManager(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<E>>, java.util.function.Supplier<org.apache.flink.connector.base.source.reader.splitreader.SplitReader<E,SplitT>>, org.apache.flink.configuration.Configuration)
- constructor removed:
org.apache.flink.connector.base.source.reader.SingleThreadMultiplexSourceReaderBase
- constructor removed:
SingleThreadMultiplexSourceReaderBase(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<E>>, java.util.function.Supplier<org.apache.flink.connector.base.source.reader.splitreader.SplitReader<E,SplitT>>, org.apache.flink.connector.base.source.reader.RecordEmitter<E,T,SplitStateT>, org.apache.flink.configuration.Configuration, org.apache.flink.api.connector.source.SourceReaderContext)
SingleThreadMultiplexSourceReaderBase(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<E>>, org.apache.flink.connector.base.source.reader.fetcher.SingleThreadFetcherManager<E,SplitT>, org.apache.flink.connector.base.source.reader.RecordEmitter<E,T,SplitStateT>, org.apache.flink.configuration.Configuration, org.apache.flink.api.connector.source.SourceReaderContext)
SingleThreadMultiplexSourceReaderBase(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<E>>, org.apache.flink.connector.base.source.reader.fetcher.SingleThreadFetcherManager<E,SplitT>, org.apache.flink.connector.base.source.reader.RecordEmitter<E,T,SplitStateT>, org.apache.flink.connector.base.source.reader.RecordEvaluator<T>, org.apache.flink.configuration.Configuration, org.apache.flink.api.connector.source.SourceReaderContext)
- constructor removed:
org.apache.flink.connector.base.source.reader.SourceReaderBase
- constructor removed:
SourceReaderBase(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<E>>, org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager<E,SplitT>, org.apache.flink.connector.base.source.reader.RecordEmitter<E,T,SplitStateT>, org.apache.flink.configuration.Configuration, org.apache.flink.api.connector.source.SourceReaderContext)
SourceReaderBase(org.apache.flink.connector.base.source.reader.synchronization.FutureCompletingBlockingQueue<org.apache.flink.connector.base.source.reader.RecordsWithSplitIds<E>>, org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager<E,SplitT>, org.apache.flink.connector.base.source.reader.RecordEmitter<E,T,SplitStateT>, org.apache.flink.connector.base.source.reader.RecordEvaluator<T>, org.apache.flink.configuration.Configuration, org.apache.flink.api.connector.source.SourceReaderContext)
- constructor removed:
org.apache.flink.core.execution.JobClient
- method removed:
java.util.concurrent.CompletableFuture<java.lang.String> stopWithSavepoint(boolean, java.lang.String)
java.util.concurrent.CompletableFuture<java.lang.String> triggerSavepoint(java.lang.String)
- method removed:
org.apache.flink.core.failure.FailureEnricher$Context
- method removed:
org.apache.flink.api.common.JobID getJobId()
java.lang.String getJobName()
- method removed:
org.apache.flink.core.fs.FileSystem
- method removed:
org.apache.flink.core.fs.FileSystemKind getKind()
- method removed:
org.apache.flink.core.fs.Path
- interface removed:
org.apache.flink.core.io.IOReadableWritable
- interface removed:
org.apache.flink.datastream.api.stream.KeyedPartitionStream
- method modified:
org.apache.flink.datastream.api.stream.KeyedPartitionStream$ProcessConfigurableAndTwoKeyedPartitionStreams<K,OUT1,OUT2><K,OUT1,OUT2> (<-org.apache.flink.datastream.api.stream.KeyedPartitionStream$TwoKeyedPartitionStreams<K,OUT1,OUT2><K,OUT1,OUT2>) process(org.apache.flink.datastream.api.function.TwoOutputStreamProcessFunction<T,OUT1,OUT2><T,OUT1,OUT2>, org.apache.flink.api.java.functions.KeySelector<OUT1,K><OUT1,K>, org.apache.flink.api.java.functions.KeySelector<OUT2,K><OUT2,K>)
org.apache.flink.datastream.api.stream.NonKeyedPartitionStream$ProcessConfigurableAndTwoNonKeyedPartitionStream<OUT1,OUT2><OUT1,OUT2> (<-org.apache.flink.datastream.api.stream.NonKeyedPartitionStream$TwoNonKeyedPartitionStreams<OUT1,OUT2><OUT1,OUT2>) process(org.apache.flink.datastream.api.function.TwoOutputStreamProcessFunction<T,OUT1,OUT2><T,OUT1,OUT2>)
- method modified:
org.apache.flink.datastream.api.stream.NonKeyedPartitionStream
- method modified:
org.apache.flink.datastream.api.stream.NonKeyedPartitionStream$ProcessConfigurableAndTwoNonKeyedPartitionStream<OUT1,OUT2><OUT1,OUT2> (<-org.apache.flink.datastream.api.stream.NonKeyedPartitionStream$TwoNonKeyedPartitionStreams<OUT1,OUT2><OUT1,OUT2>) process(org.apache.flink.datastream.api.function.TwoOutputStreamProcessFunction<T,OUT1,OUT2><T,OUT1,OUT2>)
- method modified:
org.apache.flink.streaming.api.connector.sink2.CommittableMessage
- method removed:
java.util.OptionalLong getCheckpointId()
- method removed:
org.apache.flink.streaming.api.connector.sink2.CommittableSummary
- constructor removed:
CommittableSummary(int, int, java.lang.Long, int, int, int)
- constructor removed:
org.apache.flink.streaming.api.connector.sink2.CommittableWithLineage
- constructor removed:
CommittableWithLineage(java.lang.Object, java.lang.Long, int)
- constructor removed:
org.apache.flink.streaming.api.datastream.AllWindowedStream
- method removed:
org.apache.flink.streaming.api.datastream.AllWindowedStream<T,W> allowedLateness(org.apache.flink.streaming.api.windowing.time.Time)
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<R> apply(org.apache.flink.api.common.functions.ReduceFunction<T>, org.apache.flink.streaming.api.functions.windowing.AllWindowFunction<T,R,W>)
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<R> apply(org.apache.flink.api.common.functions.ReduceFunction<T>, org.apache.flink.streaming.api.functions.windowing.AllWindowFunction<T,R,W>, org.apache.flink.api.common.typeinfo.TypeInformation<R>)
- method removed:
org.apache.flink.streaming.api.datastream.CoGroupedStreams$WithWindow
- method removed:
org.apache.flink.streaming.api.datastream.CoGroupedStreams$WithWindow<T1,T2,KEY,W> allowedLateness(org.apache.flink.streaming.api.windowing.time.Time)
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<T> with(org.apache.flink.api.common.functions.CoGroupFunction<T1,T2,T>)
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<T> with(org.apache.flink.api.common.functions.CoGroupFunction<T1,T2,T>, org.apache.flink.api.common.typeinfo.TypeInformation<T>)
- method modified:
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<T><T> (<-org.apache.flink.streaming.api.datastream.DataStream<T><T>) apply(org.apache.flink.api.common.functions.CoGroupFunction<T1,T2,T><T1,T2,T>)
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<T><T> (<-org.apache.flink.streaming.api.datastream.DataStream<T><T>) apply(org.apache.flink.api.common.functions.CoGroupFunction<T1,T2,T><T1,T2,T>, org.apache.flink.api.common.typeinfo.TypeInformation<T><T>)
- method removed:
org.apache.flink.streaming.api.datastream.DataStream
- method removed:
org.apache.flink.streaming.api.datastream.DataStreamSink<T> addSink(org.apache.flink.streaming.api.functions.sink.SinkFunction<T>)
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<T> assignTimestampsAndWatermarks(org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks<T>)
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<T> assignTimestampsAndWatermarks(org.apache.flink.streaming.api.functions.AssignerWithPunctuatedWatermarks<T>)
org.apache.flink.streaming.api.datastream.IterativeStream<T> iterate()
org.apache.flink.streaming.api.datastream.IterativeStream<T> iterate(long)
org.apache.flink.streaming.api.datastream.KeyedStream<T,org.apache.flink.api.java.tuple.Tuple> keyBy(int[])
org.apache.flink.streaming.api.datastream.KeyedStream<T,org.apache.flink.api.java.tuple.Tuple> keyBy(java.lang.String[])
org.apache.flink.streaming.api.datastream.DataStream<T> partitionCustom(org.apache.flink.api.common.functions.Partitioner<K>, int)
org.apache.flink.streaming.api.datastream.DataStream<T> partitionCustom(org.apache.flink.api.common.functions.Partitioner<K>, java.lang.String)
org.apache.flink.streaming.api.datastream.DataStreamSink<T> sinkTo(org.apache.flink.api.connector.sink.Sink<T,?,?,?>)
org.apache.flink.streaming.api.datastream.DataStreamSink<T> sinkTo(org.apache.flink.api.connector.sink.Sink<T,?,?,?>, org.apache.flink.streaming.api.datastream.CustomSinkOperatorUidHashes)
org.apache.flink.streaming.api.datastream.AllWindowedStream<T,org.apache.flink.streaming.api.windowing.windows.TimeWindow> timeWindowAll(org.apache.flink.streaming.api.windowing.time.Time)
org.apache.flink.streaming.api.datastream.AllWindowedStream<T,org.apache.flink.streaming.api.windowing.windows.TimeWindow> timeWindowAll(org.apache.flink.streaming.api.windowing.time.Time, org.apache.flink.streaming.api.windowing.time.Time)
org.apache.flink.streaming.api.datastream.DataStreamSink<T> writeAsCsv(java.lang.String)
org.apache.flink.streaming.api.datastream.DataStreamSink<T> writeAsCsv(java.lang.String, org.apache.flink.core.fs.FileSystem$WriteMode)
org.apache.flink.streaming.api.datastream.DataStreamSink<T> writeAsCsv(java.lang.String, org.apache.flink.core.fs.FileSystem$WriteMode, java.lang.String, java.lang.String)
org.apache.flink.streaming.api.datastream.DataStreamSink<T> writeAsText(java.lang.String)
org.apache.flink.streaming.api.datastream.DataStreamSink<T> writeAsText(java.lang.String, org.apache.flink.core.fs.FileSystem$WriteMode)
- method removed:
org.apache.flink.streaming.api.datastream.DataStreamUtils
- method removed:
java.util.Iterator<OUT> collect(org.apache.flink.streaming.api.datastream.DataStream<OUT>)
java.util.Iterator<OUT> collect(org.apache.flink.streaming.api.datastream.DataStream<OUT>, java.lang.String)
java.util.List<E> collectBoundedStream(org.apache.flink.streaming.api.datastream.DataStream<E>, java.lang.String)
java.util.List<E> collectRecordsFromUnboundedStream(org.apache.flink.streaming.api.operators.collect.ClientAndIterator<E>, int)
java.util.List<E> collectUnboundedStream(org.apache.flink.streaming.api.datastream.DataStream<E>, int, java.lang.String)
org.apache.flink.streaming.api.operators.collect.ClientAndIterator<OUT> collectWithClient(org.apache.flink.streaming.api.datastream.DataStream<OUT>, java.lang.String)
- method removed:
org.apache.flink.streaming.api.datastream.JoinedStreams$WithWindow
- method removed:
org.apache.flink.streaming.api.datastream.JoinedStreams$WithWindow<T1,T2,KEY,W> allowedLateness(org.apache.flink.streaming.api.windowing.time.Time)
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<T> with(org.apache.flink.api.common.functions.JoinFunction<T1,T2,T>)
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<T> with(org.apache.flink.api.common.functions.FlatJoinFunction<T1,T2,T>, org.apache.flink.api.common.typeinfo.TypeInformation<T>)
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<T> with(org.apache.flink.api.common.functions.FlatJoinFunction<T1,T2,T>)
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<T> with(org.apache.flink.api.common.functions.JoinFunction<T1,T2,T>, org.apache.flink.api.common.typeinfo.TypeInformation<T>)
- method modified:
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<T><T> (<-org.apache.flink.streaming.api.datastream.DataStream<T><T>) apply(org.apache.flink.api.common.functions.JoinFunction<T1,T2,T><T1,T2,T>)
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<T><T> (<-org.apache.flink.streaming.api.datastream.DataStream<T><T>) apply(org.apache.flink.api.common.functions.FlatJoinFunction<T1,T2,T><T1,T2,T>, org.apache.flink.api.common.typeinfo.TypeInformation<T><T>)
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<T><T> (<-org.apache.flink.streaming.api.datastream.DataStream<T><T>) apply(org.apache.flink.api.common.functions.FlatJoinFunction<T1,T2,T><T1,T2,T>)
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<T><T> (<-org.apache.flink.streaming.api.datastream.DataStream<T><T>) apply(org.apache.flink.api.common.functions.JoinFunction<T1,T2,T><T1,T2,T>, org.apache.flink.api.common.typeinfo.TypeInformation<T><T>)
- method removed:
org.apache.flink.streaming.api.datastream.KeyedStream
- method removed:
org.apache.flink.streaming.api.datastream.WindowedStream<T,KEY,org.apache.flink.streaming.api.windowing.windows.TimeWindow> timeWindow(org.apache.flink.streaming.api.windowing.time.Time)
org.apache.flink.streaming.api.datastream.WindowedStream<T,KEY,org.apache.flink.streaming.api.windowing.windows.TimeWindow> timeWindow(org.apache.flink.streaming.api.windowing.time.Time, org.apache.flink.streaming.api.windowing.time.Time)
- method removed:
org.apache.flink.streaming.api.datastream.KeyedStream$IntervalJoin
- method removed:
org.apache.flink.streaming.api.datastream.KeyedStream$IntervalJoined<T1,T2,KEY> between(org.apache.flink.streaming.api.windowing.time.Time, org.apache.flink.streaming.api.windowing.time.Time)
- method removed:
org.apache.flink.streaming.api.datastream.WindowedStream
- method removed:
org.apache.flink.streaming.api.datastream.WindowedStream<T,K,W> allowedLateness(org.apache.flink.streaming.api.windowing.time.Time)
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<R> apply(org.apache.flink.api.common.functions.ReduceFunction<T>, org.apache.flink.streaming.api.functions.windowing.WindowFunction<T,R,K,W>)
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator<R> apply(org.apache.flink.api.common.functions.ReduceFunction<T>, org.apache.flink.streaming.api.functions.windowing.WindowFunction<T,R,K,W>, org.apache.flink.api.common.typeinfo.TypeInformation<R>)
- method removed:
org.apache.flink.streaming.api.environment.CheckpointConfig
- field removed:
int UNDEFINED_TOLERABLE_CHECKPOINT_NUMBER
long DEFAULT_TIMEOUT
long DEFAULT_MIN_PAUSE_BETWEEN_CHECKPOINTS
org.apache.flink.streaming.api.CheckpointingMode DEFAULT_MODE
int DEFAULT_MAX_CONCURRENT_CHECKPOINTS
int DEFAULT_CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA
- method removed:
void enableExternalizedCheckpoints(org.apache.flink.streaming.api.environment.CheckpointConfig$ExternalizedCheckpointCleanup)
java.time.Duration getAlignmentTimeout()
org.apache.flink.runtime.state.CheckpointStorage getCheckpointStorage()
org.apache.flink.streaming.api.environment.CheckpointConfig$ExternalizedCheckpointCleanup getExternalizedCheckpointCleanup()
boolean isFailOnCheckpointingErrors()
boolean isForceCheckpointing()
void setAlignmentTimeout(java.time.Duration)
void setCheckpointStorage(org.apache.flink.runtime.state.CheckpointStorage)
void setCheckpointStorage(java.lang.String)
void setCheckpointStorage(java.net.URI)
void setCheckpointStorage(org.apache.flink.core.fs.Path)
void setExternalizedCheckpointCleanup(org.apache.flink.streaming.api.environment.CheckpointConfig$ExternalizedCheckpointCleanup)
void setFailOnCheckpointingErrors(boolean)
void setForceCheckpointing(boolean)
- field removed:
org.apache.flink.streaming.api.environment.RemoteStreamEnvironment
- method removed:
org.apache.flink.configuration.Configuration getClientConfiguration()
- method removed:
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
- field removed:
java.lang.String DEFAULT_JOB_NAME
- method removed:
void addDefaultKryoSerializer(java.lang.Class<?>, com.esotericsoftware.kryo.Serializer<?>)
void addDefaultKryoSerializer(java.lang.Class<?>, java.lang.Class<? extends com.esotericsoftware.kryo.Serializer<? extends ?>>)
org.apache.flink.streaming.api.datastream.DataStreamSource<OUT> addSource(org.apache.flink.streaming.api.functions.source.SourceFunction<OUT>)
org.apache.flink.streaming.api.datastream.DataStreamSource<OUT> addSource(org.apache.flink.streaming.api.functions.source.SourceFunction<OUT>, java.lang.String)
org.apache.flink.streaming.api.datastream.DataStreamSource<OUT> addSource(org.apache.flink.streaming.api.functions.source.SourceFunction<OUT>, org.apache.flink.api.common.typeinfo.TypeInformation<OUT>)
org.apache.flink.streaming.api.datastream.DataStreamSource<OUT> addSource(org.apache.flink.streaming.api.functions.source.SourceFunction<OUT>, java.lang.String, org.apache.flink.api.common.typeinfo.TypeInformation<OUT>)
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment enableCheckpointing(long, org.apache.flink.streaming.api.CheckpointingMode, boolean)
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment enableCheckpointing()
int getNumberOfExecutionRetries()
org.apache.flink.api.common.restartstrategy.RestartStrategies$RestartStrategyConfiguration getRestartStrategy()
org.apache.flink.runtime.state.StateBackend getStateBackend()
org.apache.flink.streaming.api.TimeCharacteristic getStreamTimeCharacteristic()
boolean isForceCheckpointing()
org.apache.flink.streaming.api.datastream.DataStream<java.lang.String> readFileStream(java.lang.String, long, org.apache.flink.streaming.api.functions.source.FileMonitoringFunction$WatchType)
org.apache.flink.streaming.api.datastream.DataStreamSource<java.lang.String> readTextFile(java.lang.String)
org.apache.flink.streaming.api.datastream.DataStreamSource<java.lang.String> readTextFile(java.lang.String, java.lang.String)
void registerType(java.lang.Class<?>)
void registerTypeWithKryoSerializer(java.lang.Class<?>, com.esotericsoftware.kryo.Serializer<?>)
void registerTypeWithKryoSerializer(java.lang.Class<?>, java.lang.Class<? extends com.esotericsoftware.kryo.Serializer>)
void setNumberOfExecutionRetries(int)
void setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies$RestartStrategyConfiguration)
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment setStateBackend(org.apache.flink.runtime.state.StateBackend)
void setStreamTimeCharacteristic(org.apache.flink.streaming.api.TimeCharacteristic)
- field removed:
org.apache.flink.streaming.api.operators.AbstractStreamOperator
- interface removed:
org.apache.flink.streaming.api.operators.SetupableStreamOperator
- method modified:
PROTECTED (<- PUBLIC) void setProcessingTimeService(org.apache.flink.streaming.runtime.tasks.ProcessingTimeService)
PROTECTED (<- PUBLIC) void setup(org.apache.flink.streaming.runtime.tasks.StreamTask<?,?><?,?>, org.apache.flink.streaming.api.graph.StreamConfig, org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<OUT>><org.apache.flink.streaming.runtime.streamrecord.StreamRecord<OUT>>)
- interface removed:
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator
- method modified:
PROTECTED (<- PUBLIC) void setup(org.apache.flink.streaming.runtime.tasks.StreamTask<?,?><?,?>, org.apache.flink.streaming.api.graph.StreamConfig, org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<OUT>><org.apache.flink.streaming.runtime.streamrecord.StreamRecord<OUT>>)
- method modified:
org.apache.flink.streaming.api.windowing.assigners.EventTimeSessionWindows
- method removed:
org.apache.flink.streaming.api.windowing.assigners.EventTimeSessionWindows withGap(org.apache.flink.streaming.api.windowing.time.Time)
- method removed:
org.apache.flink.streaming.api.windowing.assigners.ProcessingTimeSessionWindows
- method removed:
org.apache.flink.streaming.api.windowing.assigners.ProcessingTimeSessionWindows withGap(org.apache.flink.streaming.api.windowing.time.Time)
- method removed:
org.apache.flink.streaming.api.windowing.assigners.SlidingEventTimeWindows
- method removed:
org.apache.flink.streaming.api.windowing.assigners.SlidingEventTimeWindows of(org.apache.flink.streaming.api.windowing.time.Time, org.apache.flink.streaming.api.windowing.time.Time)
org.apache.flink.streaming.api.windowing.assigners.SlidingEventTimeWindows of(org.apache.flink.streaming.api.windowing.time.Time, org.apache.flink.streaming.api.windowing.time.Time, org.apache.flink.streaming.api.windowing.time.Time)
- method removed:
org.apache.flink.streaming.api.windowing.assigners.SlidingProcessingTimeWindows
- method removed:
org.apache.flink.streaming.api.windowing.assigners.SlidingProcessingTimeWindows of(org.apache.flink.streaming.api.windowing.time.Time, org.apache.flink.streaming.api.windowing.time.Time)
org.apache.flink.streaming.api.windowing.assigners.SlidingProcessingTimeWindows of(org.apache.flink.streaming.api.windowing.time.Time, org.apache.flink.streaming.api.windowing.time.Time, org.apache.flink.streaming.api.windowing.time.Time)
- method removed:
org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows
- method removed:
org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows of(org.apache.flink.streaming.api.windowing.time.Time)
org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows of(org.apache.flink.streaming.api.windowing.time.Time, org.apache.flink.streaming.api.windowing.time.Time)
org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows of(org.apache.flink.streaming.api.windowing.time.Time, org.apache.flink.streaming.api.windowing.time.Time, org.apache.flink.streaming.api.windowing.assigners.WindowStagger)
- method removed:
org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows
- method removed:
org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows of(org.apache.flink.streaming.api.windowing.time.Time)
org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows of(org.apache.flink.streaming.api.windowing.time.Time, org.apache.flink.streaming.api.windowing.time.Time)
org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows of(org.apache.flink.streaming.api.windowing.time.Time, org.apache.flink.streaming.api.windowing.time.Time, org.apache.flink.streaming.api.windowing.assigners.WindowStagger)
- method removed:
org.apache.flink.streaming.api.windowing.assigners.WindowAssigner
- method modified:
(<- NON_ABSTRACT) org.apache.flink.streaming.api.windowing.triggers.Trigger<T,W><T,W> getDefaultTrigger()
- method removed:
org.apache.flink.streaming.api.windowing.triggers.Trigger<T,W> getDefaultTrigger(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment)
- method modified:
org.apache.flink.streaming.api.windowing.evictors.TimeEvictor
- method removed:
org.apache.flink.streaming.api.windowing.evictors.TimeEvictor<W> of(org.apache.flink.streaming.api.windowing.time.Time)
org.apache.flink.streaming.api.windowing.evictors.TimeEvictor<W> of(org.apache.flink.streaming.api.windowing.time.Time, boolean)
- method removed:
org.apache.flink.streaming.api.windowing.triggers.ContinuousEventTimeTrigger
- method removed:
org.apache.flink.streaming.api.windowing.triggers.ContinuousEventTimeTrigger<W> of(org.apache.flink.streaming.api.windowing.time.Time)
- method removed:
org.apache.flink.streaming.api.windowing.triggers.ContinuousProcessingTimeTrigger
- method removed:
org.apache.flink.streaming.api.windowing.triggers.ContinuousProcessingTimeTrigger<W> of(org.apache.flink.streaming.api.windowing.time.Time)
- method removed:
org.apache.flink.streaming.api.windowing.triggers.Trigger$TriggerContext
- method removed:
org.apache.flink.api.common.state.ValueState<S> getKeyValueState(java.lang.String, java.lang.Class<S>, java.io.Serializable)
org.apache.flink.api.common.state.ValueState<S> getKeyValueState(java.lang.String, org.apache.flink.api.common.typeinfo.TypeInformation<S>, java.io.Serializable)
- method removed:
org.apache.flink.streaming.experimental.CollectSink
- interface removed:
org.apache.flink.streaming.api.functions.sink.SinkFunction
- superclass modified:
org.apache.flink.streaming.api.functions.sink.legacy.RichSinkFunction (<- org.apache.flink.streaming.api.functions.sink.RichSinkFunction)
- interface removed:
org.apache.flink.types.DoubleValue
- interface removed:
org.apache.flink.types.Key
- interface removed:
org.apache.flink.types.FloatValue
- interface removed:
org.apache.flink.types.Key
- interface removed:
org.apache.flink.types.NormalizableKey
- interface removed:
org.apache.flink.core.io.IOReadableWritable
org.apache.flink.types.Value
org.apache.flink.types.Key
java.io.Serializable
- interface removed:
org.apache.flink.test.junit5.MiniClusterExtension
- method removed:
org.apache.flink.test.util.TestEnvironment getTestEnvironment()
- method removed:
org.apache.flink.metrics.prometheus.PrometheusPushGatewayReporterOptions
- field removed:
org.apache.flink.configuration.ConfigOption<java.lang.Integer> PORT
org.apache.flink.configuration.ConfigOption<java.lang.String> HOST
- field removed:
org.apache.flink.formats.csv.CsvReaderFormat
- method removed:
org.apache.flink.formats.csv.CsvReaderFormat<T> forSchema(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvMapper, org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.csv.CsvSchema, org.apache.flink.api.common.typeinfo.TypeInformation<T>)
- method removed:
org.apache.flink.state.forst.ForStOptionsFactory
- method removed:
org.rocksdb.ColumnFamilyOptions createColumnOptions(org.rocksdb.ColumnFamilyOptions, java.util.Collection<java.lang.AutoCloseable>)
org.rocksdb.DBOptions createDBOptions(org.rocksdb.DBOptions, java.util.Collection<java.lang.AutoCloseable>)
org.rocksdb.ReadOptions createReadOptions(org.rocksdb.ReadOptions, java.util.Collection<java.lang.AutoCloseable>)
org.rocksdb.WriteOptions createWriteOptions(org.rocksdb.WriteOptions, java.util.Collection<java.lang.AutoCloseable>)
- method removed:
org.apache.flink.state.forst.fs.ForStFlinkFileSystem
- constructor removed:
ForStFlinkFileSystem(org.apache.flink.core.fs.FileSystem)
- method removed:
org.apache.flink.core.fs.FileSystemKind getKind()
- constructor removed:
org.apache.flink.table.client.config.SqlClientOptions
- field removed:
org.apache.flink.configuration.ConfigOption<java.lang.Integer> DISPLAY_MAX_COLUMN_WIDTH
- field removed:
org.apache.flink.table.runtime.typeutils.SortedMapTypeInfo
- method removed:
org.apache.flink.api.common.typeutils.TypeSerializer<java.util.SortedMap<K,V>> createSerializer(org.apache.flink.api.common.ExecutionConfig)
- method removed:
org.apache.flink.connector.file.sink.FileSink
- method removed:
org.apache.flink.api.connector.sink2.SinkWriter<IN> createWriter(org.apache.flink.api.connector.sink2.Sink$InitContext)
- method removed:
org.apache.flink.connector.file.src.FileSource
- method removed:
org.apache.flink.connector.file.src.FileSource$FileSourceBuilder<T> forRecordFileFormat(org.apache.flink.connector.file.src.reader.FileRecordFormat<T>, org.apache.flink.core.fs.Path[])
- method removed:
org.apache.flink.connector.file.src.FileSourceSplit
- constructor removed:
FileSourceSplit(java.lang.String, org.apache.flink.core.fs.Path, long, long)
FileSourceSplit(java.lang.String, org.apache.flink.core.fs.Path, long, long, java.lang.String[])
FileSourceSplit(java.lang.String, org.apache.flink.core.fs.Path, long, long, java.lang.String[], org.apache.flink.connector.file.src.util.CheckpointedPosition)
- constructor removed:
org.apache.flink.state.api.functions.KeyedStateReaderFunction
- method removed:
void open(org.apache.flink.configuration.Configuration)
- method removed:
org.apache.flink.state.api.OperatorTransformation
- method removed:
org.apache.flink.state.api.OneInputOperatorTransformation<T> bootstrapWith(org.apache.flink.api.java.DataSet<T>)
- method removed:
org.apache.flink.state.api.SavepointReader
- method removed:
org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.api.java.tuple.Tuple2<K,V>> readBroadcastState(java.lang.String, java.lang.String, org.apache.flink.api.common.typeinfo.TypeInformation<K>, org.apache.flink.api.common.typeinfo.TypeInformation<V>)
org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.api.java.tuple.Tuple2<K,V>> readBroadcastState(java.lang.String, java.lang.String, org.apache.flink.api.common.typeinfo.TypeInformation<K>, org.apache.flink.api.common.typeinfo.TypeInformation<V>, org.apache.flink.api.common.typeutils.TypeSerializer<K>, org.apache.flink.api.common.typeutils.TypeSerializer<V>)
org.apache.flink.streaming.api.datastream.DataStream<OUT> readKeyedState(java.lang.String, org.apache.flink.state.api.functions.KeyedStateReaderFunction<K,OUT>)
org.apache.flink.streaming.api.datastream.DataStream<OUT> readKeyedState(java.lang.String, org.apache.flink.state.api.functions.KeyedStateReaderFunction<K,OUT>, org.apache.flink.api.common.typeinfo.TypeInformation<K>, org.apache.flink.api.common.typeinfo.TypeInformation<OUT>)
org.apache.flink.streaming.api.datastream.DataStream<T> readListState(java.lang.String, java.lang.String, org.apache.flink.api.common.typeinfo.TypeInformation<T>)
org.apache.flink.streaming.api.datastream.DataStream<T> readListState(java.lang.String, java.lang.String, org.apache.flink.api.common.typeinfo.TypeInformation<T>, org.apache.flink.api.common.typeutils.TypeSerializer<T>)
org.apache.flink.streaming.api.datastream.DataStream<T> readUnionState(java.lang.String, java.lang.String, org.apache.flink.api.common.typeinfo.TypeInformation<T>)
org.apache.flink.streaming.api.datastream.DataStream<T> readUnionState(java.lang.String, java.lang.String, org.apache.flink.api.common.typeinfo.TypeInformation<T>, org.apache.flink.api.common.typeutils.TypeSerializer<T>)
- method removed:
org.apache.flink.state.api.SavepointWriter
- method removed:
org.apache.flink.state.api.SavepointWriter fromExistingSavepoint(java.lang.String)
org.apache.flink.state.api.SavepointWriter fromExistingSavepoint(java.lang.String, org.apache.flink.runtime.state.StateBackend)
org.apache.flink.state.api.SavepointWriter newSavepoint(int)
org.apache.flink.state.api.SavepointWriter newSavepoint(org.apache.flink.runtime.state.StateBackend, int)
org.apache.flink.state.api.SavepointWriter removeOperator(java.lang.String)
org.apache.flink.state.api.SavepointWriter withOperator(java.lang.String, org.apache.flink.state.api.StateBootstrapTransformation<T>)
- method removed:
org.apache.flink.state.api.SavepointWriterOperatorFactory
- method modified:
org.apache.flink.streaming.api.operators.StreamOperatorFactory<org.apache.flink.state.api.output.TaggedOperatorSubtaskState><org.apache.flink.state.api.output.TaggedOperatorSubtaskState> (<-org.apache.flink.streaming.api.operators.StreamOperator<org.apache.flink.state.api.output.TaggedOperatorSubtaskState><org.apache.flink.state.api.output.TaggedOperatorSubtaskState>) createOperator(long, org.apache.flink.core.fs.Path)
- method modified:
List of removed configuration options #
- cluster.evenly-spread-out-slots
- fine-grained.shuffle-mode.all-blocking
- high-availability.job.delay
- high-availability.zookeeper.path.running-registry
- jobmanager.adaptive-batch-scheduler.avg-data-volume-per-task
- jobmanager.adaptive-batch-scheduler.default-source-parallelism
- jobmanager.adaptive-batch-scheduler.max-parallelism
- jobmanager.adaptive-batch-scheduler.min-parallelism
- jobmanager.adaptive-batch-scheduler.speculative.block-slow-node-duration
- jobmanager.adaptive-batch-scheduler.speculative.enabled
- jobmanager.adaptive-batch-scheduler.speculative.max-concurrent-executions
- jobmanager.heap.mb
- jobmanager.heap.size
- jobmanager.web.backpressure.cleanup-interval
- jobmanager.web.backpressure.delay-between-samples
- jobmanager.web.backpressure.num-samples
- jobmanager.web.backpressure.refresh-interval
- jobmanager.web.ssl.enabled
- local.number-resourcemanager
- pipeline.auto-type-registration
- pipeline.default-kryo-serializers
- pipeline.registered-kryo-types
- pipeline.registered-pojo-types
- recovery.job.delay
- resourcemanager.taskmanager-release.wait.result.consumed
- security.kerberos.fetch.delegation-token
- security.kerberos.tokens.renewal.retry.backoff
- security.kerberos.tokens.renewal.time-ratio
- security.ssl.enabled
- slotmanager.taskmanager-timeout
- sql-client.display.max-column-width
- state.backend.async
- state.backend.latency-track.history-size
- state.backend.latency-track.keyed-state-enabled
- state.backend.latency-track.sample-interval
- state.backend.latency-track.state-name-as-variable
- state.backend.local-recovery
- state.backend.rocksdb.checkpointdir
- state.backend.type
- streaming-source.consume-order
- table.exec.deduplicate.insert-and-updateafter-sensitive.enabled
- table.exec.deduplicate.mini-batch.compact-changes.enabled
- table.exec.legacy-transformation-uids
- table.exec.shuffle-mode
- table.exec.topn-cache-size
- table.optimizer.source.aggregate-pushdown-enabled
- table.optimizer.source.predicate-pushdown-enabled
- table.optimizer.sql-to-rel.project.merge.enabled
- taskmanager.exit-on-fatal-akka-error
- taskmanager.heap.mb
- taskmanager.heap.size
- taskmanager.initial-registration-pause
- taskmanager.max-registration-pause
- taskmanager.net.client.numThreads
- taskmanager.net.num-arenas
- taskmanager.net.sendReceiveBufferSize
- taskmanager.net.server.backlog
- taskmanager.net.server.numThreads
- taskmanager.net.transport
- taskmanager.network.batch-shuffle.compression.enabled
- taskmanager.network.blocking-shuffle.compression.enabled
- taskmanager.network.blocking-shuffle.type
- taskmanager.network.hybrid-shuffle.enable-new-mode
- taskmanager.network.hybrid-shuffle.num-retained-in-memory-regions-max
- taskmanager.network.hybrid-shuffle.spill-index-region-group-size
- taskmanager.network.hybrid-shuffle.spill-index-segment-size
- taskmanager.network.max-num-tcp-connections
- taskmanager.network.memory.buffers-per-channel
- taskmanager.network.memory.exclusive-buffers-request-timeout-ms
- taskmanager.network.memory.floating-buffers-per-gate
- taskmanager.network.memory.fraction
- taskmanager.network.memory.max
- taskmanager.network.memory.max-buffers-per-channel
- taskmanager.network.memory.max-overdraft-buffers-per-gate
- taskmanager.network.memory.min
- taskmanager.network.netty.client.numThreads
- taskmanager.network.netty.num-arenas
- taskmanager.network.netty.sendReceiveBufferSize
- taskmanager.network.netty.server.backlog
- taskmanager.network.netty.server.numThreads
- taskmanager.network.netty.transport
- taskmanager.network.numberOfBuffers
- taskmanager.network.sort-shuffle.min-parallelism
- taskmanager.refused-registration-pause
- taskmanager.registration.initial-backoff
- taskmanager.registration.max-backoff
- taskmanager.registration.refused-backoff
- web.address
- web.backpressure.cleanup-interval
- web.backpressure.delay-between-samples
- web.backpressure.num-samples
- web.backpressure.refresh-interval
- web.port
- web.ssl.enabled
List of REST APIs changes #
REST API | Changes |
---|---|
/taskmanagers/:taskmanagerid | In its response, “metrics.memorySegmentsAvailable” and “metrics.memorySegmentsTotal” are removed. |
/jobs/:jobid/config | In its response, the “execution-mode” property is removed. |
/jars/:jarid/run | In its request, the internal type of “claimMode” and “restoreMode” are changed from RestoreMode to RecoveryClaimMode, but their json structure is not affected. |
/jobs/:jobid/vertices/:vertexid /jobs/:jobid/vertices/:vertexid/subtasks/accumulators /jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex /jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/attempts/:attempt /jobs/:jobid/vertices/:vertexid/subtasktimes /jobs/:jobid/vertices/:vertexid/taskmanagers /jobs/:jobid/taskmanagers/:taskmanagerid/log-url |
In their responses, the “host”, “subtasks.host” or “taskmanagers.host” property is removed. |
List of removed CLI options #
- sql-client.sh:
-u,--update <SQL update statement>
is removed
- flink-client:
run-application
action is removed: Please userun -t kubernetes-application
to run Kubernetes Application mode