-
Classes Class Description org.apache.flink.api.common.ExecutionConfig.SerializableSerializer The class is deprecated because instance-type serializer definition where serializers are serialized and written into the snapshot and deserialized for use is deprecated. Use class-type serializer definition instead, where only the class name is written into the snapshot and new instance of the serializer is created for use. This is a breaking change, and it will be removed in Flink 2.0.org.apache.flink.api.common.restartstrategy.RestartStrategies TheRestartStrategiesclass is marked as deprecated because starting from Flink 1.19, all complex Java objects related to configuration should be replaced by ConfigOption. In a future major version of Flink, this class will be removed entirely. It is recommended to switch to using the ConfigOptions provided byRestartStrategyOptionsfor configuring restart strategies like the following code snippet:
For more details on using ConfigOption for restart strategies, please refer to the Flink documentation: restart-strategiesConfiguration config = new Configuration(); config.set(RestartStrategyOptions.RESTART_STRATEGY, "fixed-delay"); config.set(RestartStrategyOptions.RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS, 3); config.set(RestartStrategyOptions.RESTART_STRATEGY_FIXED_DELAY_DELAY, Duration.ofMinutes(1)); StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(config);org.apache.flink.api.common.time.Time UseDurationorg.apache.flink.api.common.typeutils.base.GenericArraySerializerConfigSnapshot this is deprecated and no longer used by theGenericArraySerializer. It has been replaced byGenericArraySerializerSnapshot.org.apache.flink.api.connector.sink2.Sink.InitContextWrapper Internal, do not use it.org.apache.flink.api.java.typeutils.runtime.EitherSerializerSnapshot this snapshot class is no longer used by any serializers. Instead,JavaEitherSerializerSnapshotis used.org.apache.flink.configuration.AkkaOptions UseRpcOptionsinstead.org.apache.flink.configuration.QueryableStateOptions The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.
-
Enums Enum Description org.apache.flink.api.common.ExecutionMode TheExecutionModeis deprecated because it's only used in DataSet APIs. All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.org.apache.flink.api.common.InputDependencyConstraint InputDependencyConstraintis not used anymore and will be deleted in one of the future versions. It was previously used in the scheduler implementations that were removed as part of FLINK-20589.
-
Constructors Constructor Description org.apache.flink.api.common.eventtime.WatermarksWithIdleness(WatermarkGenerator<T>, Duration) org.apache.flink.api.common.restartstrategy.RestartStrategies.ExponentialDelayRestartStrategyConfiguration(Time, Time, double, Time, double) org.apache.flink.api.common.restartstrategy.RestartStrategies.FailureRateRestartStrategyConfiguration(int, Time, Time) org.apache.flink.api.common.state.StateTtlConfig.Builder(Time) org.apache.flink.api.common.state.ValueStateDescriptor(String, Class<T>, T) UseValueStateDescriptor(String, Class)instead and manually manage the default value by checking whether the contents of the state isnull.org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot(Class<? extends TypeSerializer>) correspondingSerializerClass is not used to resolve and cast after FLIP-263, please useCompositeTypeSerializerSnapshot()instead.
-
Enum Constants Enum Constant Description org.apache.flink.api.common.state.StateDescriptor.Type.UNKNOWN Enum for migrating from old checkpoints/savepoint versions.org.apache.flink.configuration.JobManagerOptions.SchedulerType.Ng UseJobManagerOptions.SchedulerType.Defaultinstead.org.apache.flink.core.execution.RestoreMode.LEGACY