-
Classes Class Description org.apache.flink.streaming.api.datastream.IterativeStream This method is deprecated since Flink 1.19. The only known use case of this Iteration API comes from Flink ML, which already has its own implementation of iteration and no longer uses this API. If there's any use cases other than Flink ML that needs iteration support, please reach out to dev@flink.apache.org and we can consider making the Flink ML iteration implementation a separate common library.org.apache.flink.streaming.api.datastream.IterativeStream.ConnectedIterativeStreams This method is deprecated since Flink 1.19. The only known use case of this Iteration API comes from Flink ML, which already has its own implementation of iteration and no longer uses this API. If there's any use cases other than Flink ML that needs iteration support, please reach out to dev@flink.apache.org and we can consider making the Flink ML iteration implementation a separate common library.org.apache.flink.streaming.api.datastream.QueryableStateStream The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.org.apache.flink.streaming.api.functions.AscendingTimestampExtractor ExtendAscendingTimestampExtractorinstead.org.apache.flink.streaming.api.functions.IngestionTimeExtractor org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink Useorg.apache.flink.connector.file.sink.FileSinkinstead.org.apache.flink.streaming.api.functions.sink.OutputFormatSinkFunction Please use theStreamingFileSinkfor writing to files from a streaming program.org.apache.flink.streaming.api.functions.sink.WriteFormat Please use theStreamingFileSinkfor writing to files from a streaming program.org.apache.flink.streaming.api.functions.sink.WriteFormatAsCsv Please use theStreamingFileSinkfor writing to files from a streaming program.org.apache.flink.streaming.api.functions.sink.WriteFormatAsText Please use theStreamingFileSinkfor writing to files from a streaming program.org.apache.flink.streaming.api.functions.sink.WriteSinkFunction Please use theStreamingFileSinkfor writing to files from a streaming program.org.apache.flink.streaming.api.functions.sink.WriteSinkFunctionByMillis Please use theStreamingFileSinkfor writing to files from a streaming program.org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction This class is based on theSourceFunctionAPI, which is due to be removed. Use the newSourceAPI instead.org.apache.flink.streaming.api.functions.source.datagen.DataGeneratorSource Useorg.apache.flink.connector.datagen.source.DataGeneratorSourceinstead.org.apache.flink.streaming.api.functions.source.FileMonitoringFunction Internal class deprecated in favour ofContinuousFileMonitoringFunction.org.apache.flink.streaming.api.functions.source.FileReadFunction Internal class deprecated in favour ofContinuousFileMonitoringFunction.org.apache.flink.streaming.api.functions.source.FromElementsFunction This class is based on theSourceFunctionAPI, which is due to be removed. Use the newSourceAPI instead.org.apache.flink.streaming.api.functions.source.FromIteratorFunction This class is based on theSourceFunctionAPI, which is due to be removed. Use the newSourceAPI instead.org.apache.flink.streaming.api.functions.source.FromSplittableIteratorFunction This class is based on theSourceFunctionAPI, which is due to be removed. Use the newSourceAPI instead.org.apache.flink.streaming.api.functions.source.InputFormatSourceFunction This class is based on theSourceFunctionAPI, which is due to be removed. Use the newSourceAPI instead.org.apache.flink.streaming.api.functions.source.MessageAcknowledgingSourceBase This class is based on theSourceFunctionAPI, which is due to be removed. Use the newSourceAPI instead.org.apache.flink.streaming.api.functions.source.MultipleIdsMessageAcknowledgingSourceBase This class is based on theSourceFunctionAPI, which is due to be removed. Use the newSourceAPI instead.org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction This class is based on theSourceFunctionAPI, which is due to be removed. Use the newSourceAPI instead.org.apache.flink.streaming.api.functions.source.RichSourceFunction This class is based on theSourceFunctionAPI, which is due to be removed. Use the newSourceAPI instead.org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction This class is based on theSourceFunctionAPI, which is due to be removed. Use the newSourceAPI instead.org.apache.flink.streaming.api.functions.source.StatefulSequenceSource This class is based on theSourceFunctionAPI, which is due to be removed. Use the newSourceAPI instead.org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor org.apache.flink.streaming.api.functions.windowing.RichProcessAllWindowFunction useProcessAllWindowFunctioninsteadorg.apache.flink.streaming.api.functions.windowing.RichProcessWindowFunction useProcessWindowFunctioninsteadorg.apache.flink.streaming.api.operators.co.LegacyKeyedCoProcessOperator Replaced byKeyedCoProcessOperatorwhich takesKeyedCoProcessFunctionorg.apache.flink.streaming.api.operators.LegacyKeyedProcessOperator Replaced byKeyedProcessOperatorwhich takesKeyedProcessFunctionorg.apache.flink.streaming.api.operators.StreamSource This class is based on theSourceFunctionAPI, which is due to be removed. Use the newSourceAPI instead.org.apache.flink.streaming.api.operators.StreamSourceContexts This class is based on theSourceFunctionAPI, which is due to be removed. Use the newSourceAPI instead.org.apache.flink.streaming.api.windowing.time.Time UseDurationorg.apache.flink.streaming.runtime.tasks.SourceStreamTask This class is based on theSourceFunctionAPI, which is due to be removed. Use the newSourceAPI instead.org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor.SynchronizedStreamTaskActionExecutor this class should only be used inSourceStreamTaskwhich exposes the checkpoint lock as part of Public API.org.apache.flink.streaming.util.serialization.AbstractDeserializationSchema UseAbstractDeserializationSchemainstead.org.apache.flink.streaming.util.serialization.SimpleStringSchema UseSimpleStringSchemainstead.org.apache.flink.streaming.util.serialization.TypeInformationSerializationSchema UseTypeInformationSerializationSchemainstead.
-
Enums Enum Description org.apache.flink.streaming.api.TimeCharacteristic In Flink 1.12 the default stream time characteristic has been changed toTimeCharacteristic.EventTime, thus you don't need to call this method for enabling event-time support anymore. Explicitly using processing-time windows and timers works in event-time mode. If you need to disable watermarks, please useExecutionConfig.setAutoWatermarkInterval(long). If you are usingTimeCharacteristic.IngestionTime, please manually set an appropriateWatermarkStrategy. If you are using generic "time window" operations (for exampleKeyedStream.timeWindow(org.apache.flink.streaming.api.windowing.time.Time)that change behaviour based on the time characteristic, please use equivalent operations that explicitly specify processing time or event time.
-
Fields Field Description org.apache.flink.streaming.api.environment.CheckpointConfig.DEFAULT_CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA This field is no longer used. Please useExecutionCheckpointingOptions.CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATAinstead.org.apache.flink.streaming.api.environment.CheckpointConfig.DEFAULT_MAX_CONCURRENT_CHECKPOINTS This field is no longer used. Please useExecutionCheckpointingOptions.MAX_CONCURRENT_CHECKPOINTSinstead.org.apache.flink.streaming.api.environment.CheckpointConfig.DEFAULT_MIN_PAUSE_BETWEEN_CHECKPOINTS This field is no longer used. Please useExecutionCheckpointingOptions.MIN_PAUSE_BETWEEN_CHECKPOINTSinstead.org.apache.flink.streaming.api.environment.CheckpointConfig.DEFAULT_MODE org.apache.flink.streaming.api.environment.CheckpointConfig.DEFAULT_TIMEOUT This field is no longer used. Please useExecutionCheckpointingOptions.CHECKPOINTING_TIMEOUTinstead.org.apache.flink.streaming.api.environment.CheckpointConfig.UNDEFINED_TOLERABLE_CHECKPOINT_NUMBER This field is no longer used.org.apache.flink.streaming.api.environment.ExecutionCheckpointingOptions.ALIGNMENT_TIMEOUT org.apache.flink.streaming.api.environment.ExecutionCheckpointingOptions.FORCE_CHECKPOINTING This will be removed once iterations properly participate in checkpointing.org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.DEFAULT_JOB_NAME This constant does not fit well to batch runtime mode.org.apache.flink.streaming.api.environment.StreamPipelineOptions.TIME_CHARACTERISTIC In Flink 1.12 the default stream time characteristic has been changed toTimeCharacteristic.EventTime, thus you don't need to set this option for enabling event-time support anymore. Explicitly using processing-time windows and timers works in event-time mode. If you need to disable watermarks, please setPipelineOptions.AUTO_WATERMARK_INTERVALto 0. If you are usingTimeCharacteristic.IngestionTime, please manually set an appropriateWatermarkStrategy. If you are using generic "time window" operations (for exampleKeyedStream.timeWindow(org.apache.flink.streaming.api.windowing.time.Time)that change behaviour based on the time characteristic, please use equivalent operations that explicitly specify processing time or event time.
-
Methods Method Description org.apache.flink.streaming.api.connector.sink2.CommittableMessage.getCheckpointId() org.apache.flink.streaming.api.datastream.AllWindowedStream.allowedLateness(Time) UseAllWindowedStream.allowedLateness(Duration), instead.org.apache.flink.streaming.api.datastream.AllWindowedStream.apply(ReduceFunction<T>, AllWindowFunction<T, R, W>) org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithWindow.allowedLateness(Time) org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithWindow.with(CoGroupFunction<T1, T2, T>) This method will be removed once theCoGroupedStreams.WithWindow.apply(CoGroupFunction)method is fixed in the next major version of Flink (2.0).org.apache.flink.streaming.api.datastream.DataStream.assignTimestampsAndWatermarks(AssignerWithPeriodicWatermarks<T>) Please useDataStream.assignTimestampsAndWatermarks(WatermarkStrategy)instead.org.apache.flink.streaming.api.datastream.DataStream.iterate() This method is deprecated since Flink 1.19. The only known use case of this Iteration API comes from Flink ML, which already has its own implementation of iteration and no longer uses this API. If there's any use cases other than Flink ML that needs iteration support, please reach out to dev@flink.apache.org and we can consider making the Flink ML iteration implementation a separate common library.org.apache.flink.streaming.api.datastream.DataStream.keyBy(int...) org.apache.flink.streaming.api.datastream.DataStream.partitionCustom(Partitioner<K>, int) org.apache.flink.streaming.api.datastream.DataStream.timeWindowAll(Time) Please useDataStream.windowAll(WindowAssigner)with eitherTumblingEventTimeWindowsorTumblingProcessingTimeWindows. For more information, see the deprecation notice onTimeCharacteristicorg.apache.flink.streaming.api.datastream.DataStream.writeAsCsv(String) Please use theStreamingFileSinkexplicitly using theDataStream.addSink(SinkFunction)method.org.apache.flink.streaming.api.datastream.DataStream.writeAsText(String) Please use theStreamingFileSinkexplicitly using theDataStream.addSink(SinkFunction)method.org.apache.flink.streaming.api.datastream.DataStream.writeUsingOutputFormat(OutputFormat<T>) Please use theStreamingFileSinkexplicitly using theDataStream.addSink(SinkFunction)method.org.apache.flink.streaming.api.datastream.DataStreamUtils.collect(DataStream<OUT>) Please useDataStream.executeAndCollect().org.apache.flink.streaming.api.datastream.DataStreamUtils.collectBoundedStream(DataStream<E>, String) Please useDataStream.executeAndCollect().org.apache.flink.streaming.api.datastream.DataStreamUtils.collectRecordsFromUnboundedStream(ClientAndIterator<E>, int) Please useDataStream.executeAndCollect().org.apache.flink.streaming.api.datastream.DataStreamUtils.collectUnboundedStream(DataStream<E>, int, String) Please useDataStream.executeAndCollect().org.apache.flink.streaming.api.datastream.DataStreamUtils.collectWithClient(DataStream<OUT>, String) Please useDataStream.executeAndCollect().org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow.allowedLateness(Time) org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow.with(JoinFunction<T1, T2, T>) This method will be removed once theJoinedStreams.WithWindow.apply(JoinFunction)method is fixed in the next major version of Flink (2.0).org.apache.flink.streaming.api.datastream.KeyedStream.asQueryableState(String) The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.org.apache.flink.streaming.api.datastream.KeyedStream.IntervalJoin.between(Time, Time) org.apache.flink.streaming.api.datastream.KeyedStream.process(ProcessFunction<T, R>) org.apache.flink.streaming.api.datastream.KeyedStream.timeWindow(Time) Please useKeyedStream.window(WindowAssigner)with eitherTumblingEventTimeWindowsorTumblingProcessingTimeWindows. For more information, see the deprecation notice onTimeCharacteristicorg.apache.flink.streaming.api.datastream.WindowedStream.allowedLateness(Time) org.apache.flink.streaming.api.datastream.WindowedStream.apply(ReduceFunction<T>, WindowFunction<T, R, K, W>) org.apache.flink.streaming.api.environment.CheckpointConfig.enableExternalizedCheckpoints(CheckpointConfig.ExternalizedCheckpointCleanup) org.apache.flink.streaming.api.environment.CheckpointConfig.getAlignmentTimeout() UserCheckpointConfig.getAlignedCheckpointTimeout()instead.org.apache.flink.streaming.api.environment.CheckpointConfig.getCheckpointStorage() The method is marked as deprecated because starting from Flink 1.19, the usage of all complex Java objects related to configuration, including their getter and setter methods, should be replaced by ConfigOption. In a future major version of Flink, this method will be removed entirely. It is recommended to find which checkpoint storage is used by checkpoint storage ConfigOption. For more details on using ConfigOption for checkpoint storage configuration, please refer to the Flink documentation: Checkpointsorg.apache.flink.streaming.api.environment.CheckpointConfig.isFailOnCheckpointingErrors() org.apache.flink.streaming.api.environment.CheckpointConfig.isForceCheckpointing() This will be removed once iterations properly participate in checkpointing.org.apache.flink.streaming.api.environment.CheckpointConfig.setAlignmentTimeout(Duration) org.apache.flink.streaming.api.environment.CheckpointConfig.setCheckpointStorage(CheckpointStorage) The method is marked as deprecated because starting from Flink 1.19, the usage of all complex Java objects related to configuration, including their getter and setter methods, should be replaced by ConfigOption. In a future major version of Flink, this method will be removed entirely. It is recommended to switch to using the ConfigOptions provided for configuring checkpoint storage like the following code snippet:
For more details on using ConfigOption for checkpoint storage configuration, please refer to the Flink documentation: CheckpointsConfiguration config = new Configuration(); config.set(CheckpointingOptions.CHECKPOINT_STORAGE, "filesystem"); config.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, "file:///flink/checkpoints"); StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(config);org.apache.flink.streaming.api.environment.CheckpointConfig.setFailOnCheckpointingErrors(boolean) org.apache.flink.streaming.api.environment.CheckpointConfig.setForceCheckpointing(boolean) This will be removed once iterations properly participate in checkpointing.org.apache.flink.streaming.api.environment.RemoteStreamEnvironment.getClientConfiguration() This method is going to be removed in the next releases.org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addDefaultKryoSerializer(Class<?>, T) Register data types and serializers through hard codes is deprecated, because you need to modify the codes when upgrading job version. Instance-type serializer definition where serializers are serialized and written into the snapshot and deserialized for use is deprecated as well. Use class-type serializer definition byPipelineOptions.SERIALIZATION_CONFIGinstead, 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.streaming.api.environment.StreamExecutionEnvironment.addSource(SourceFunction<OUT>) This method relies on theSourceFunctionAPI, which is due to be removed. Use theStreamExecutionEnvironment.fromSource(Source, WatermarkStrategy, String)method based on the newSourceAPI instead.org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.enableCheckpointing(long, CheckpointingMode, boolean) UseStreamExecutionEnvironment.enableCheckpointing(long, CheckpointingMode)instead. Forcing checkpoints will be removed in the future.org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.fromCollection(Collection<OUT>) This method will be removed a future release, possibly as early as version 2.0. UseStreamExecutionEnvironment.fromData(Collection)instead.org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.fromElements(OUT...) This method will be removed a future release, possibly as early as version 2.0. Use#fromData(OUT...)instead.org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.generateSequence(long, long) UseStreamExecutionEnvironment.fromSequence(long, long)instead to create a new data stream that containsNumberSequenceSource.org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getNumberOfExecutionRetries() This method will be replaced byStreamExecutionEnvironment.getRestartStrategy().org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getRestartStrategy() The method is marked as deprecated because starting from Flink 1.19, the usage of all complex Java objects related to configuration, including their getter and setter methods, should be replaced by ConfigOption. In a future major version of Flink, this method will be removed entirely. It is recommended to switch to using the ConfigOptions provided byRestartStrategyOptionsfor configuring restart strategies.org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getStateBackend() The method is marked as deprecated because starting from Flink 1.19, the usage of all complex Java objects related to configuration, including their getter and setter methods, should be replaced by ConfigOption. In a future major version of Flink, this method will be removed entirely. It is recommended to find which state backend is used by state backend ConfigOption. For more details on using ConfigOption for state backend configuration, please refer to the Flink documentation: state-backendsorg.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getStreamTimeCharacteristic() SeeStreamExecutionEnvironment.setStreamTimeCharacteristic(TimeCharacteristic)for deprecation notice.org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.isForceCheckpointing() Forcing checkpoints will be removed in future version.org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.readFile(FileInputFormat<OUT>, String) UseFileSource#forRecordStreamFormat()/forBulkFileFormat()/forRecordFileFormat() instead. An example of reading a file using a simpleTextLineInputFormat:FileSource<String> source = FileSource.forRecordStreamFormat( new TextLineInputFormat(), new Path("/foo/bar")) .build();org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.readFileStream(String, long, FileMonitoringFunction.WatchType) org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.readTextFile(String) UseFileSource#forRecordStreamFormat()/forBulkFileFormat()/forRecordFileFormat() instead. An example of reading a file using a simpleTextLineInputFormat:FileSource<String> source = FileSource.forRecordStreamFormat( new TextLineInputFormat(), new Path("/foo/bar")) .build();org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.registerType(Class<?>) Register data types and serializers through hard codes is deprecated, because you need to modify the codes when upgrading job version. You should configure this by config optionPipelineOptions.SERIALIZATION_CONFIG.org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.registerTypeWithKryoSerializer(Class<?>, T) Register data types and serializers through hard codes is deprecated, because you need to modify the codes when upgrading job version. Instance-type serializer definition where serializers are serialized and written into the snapshot and deserialized for use is deprecated as well. Use class-type serializer definition byPipelineOptions.SERIALIZATION_CONFIGinstead, 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.streaming.api.environment.StreamExecutionEnvironment.setNumberOfExecutionRetries(int) This method will be replaced byStreamExecutionEnvironment.setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration). TheRestartStrategies.fixedDelayRestart(int, Duration)contains the number of execution retries.org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.setRestartStrategy(RestartStrategies.RestartStrategyConfiguration) The method is marked as deprecated because starting from Flink 1.19, the usage of all complex Java objects related to configuration, including their getter and setter methods, should be replaced by ConfigOption. In a future major version of Flink, this method will be removed entirely. It is recommended to switch to using the ConfigOptions provided byRestartStrategyOptionsfor configuring restart strategies.org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.setStateBackend(StateBackend) The method is marked as deprecated because starting from Flink 1.19, the usage of all complex Java objects related to configuration, including their getter and setter methods, should be replaced by ConfigOption. In a future major version of Flink, this method will be removed entirely. It is recommended to switch to using the ConfigOptions provided for configuring state backend like the following code snippet:
For more details on using ConfigOption for state backend configuration, please refer to the Flink documentation: state-backendsConfiguration config = new Configuration(); config.set(StateBackendOptions.STATE_BACKEND, "hashmap"); StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(config);org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.setStreamTimeCharacteristic(TimeCharacteristic) In Flink 1.12 the default stream time characteristic has been changed toTimeCharacteristic.EventTime, thus you don't need to call this method for enabling event-time support anymore. Explicitly using processing-time windows and timers works in event-time mode. If you need to disable watermarks, please useExecutionConfig.setAutoWatermarkInterval(long). If you are usingTimeCharacteristic.IngestionTime, please manually set an appropriateWatermarkStrategy. If you are using generic "time window" operations (for example throughKeyedStream.window(WindowAssigner)that change behaviour based on the time characteristic, please use equivalent operations that explicitly specify processing time or event time.org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.socketTextStream(String, int, char, long) org.apache.flink.streaming.api.functions.sink.OutputFormatSinkFunction.open(Configuration) This method is deprecated since Flink 1.19. The users are recommended to implementopen(OpenContext openContext)and overrideopen(Configuration parameters)with an empty body instead. 1. If you implementopen(OpenContext openContext), theopen(OpenContext openContext)will be invoked and theopen(Configuration parameters)won't be invoked. 2. If you don't implementopen(OpenContext openContext), theopen(Configuration parameters)will be invoked in the default implementation of theopen(OpenContext openContext).org.apache.flink.streaming.api.functions.sink.PrintSinkFunction.open(Configuration) This method is deprecated since Flink 1.19. The users are recommended to implementopen(OpenContext openContext)and overrideopen(Configuration parameters)with an empty body instead. 1. If you implementopen(OpenContext openContext), theopen(OpenContext openContext)will be invoked and theopen(Configuration parameters)won't be invoked. 2. If you don't implementopen(OpenContext openContext), theopen(Configuration parameters)will be invoked in the default implementation of theopen(OpenContext openContext).org.apache.flink.streaming.api.functions.sink.SinkFunction.invoke(IN) org.apache.flink.streaming.api.functions.sink.SocketClientSink.open(Configuration) This method is deprecated since Flink 1.19. The users are recommended to implementopen(OpenContext openContext)and overrideopen(Configuration parameters)with an empty body instead. 1. If you implementopen(OpenContext openContext), theopen(OpenContext openContext)will be invoked and theopen(Configuration parameters)won't be invoked. 2. If you don't implementopen(OpenContext openContext), theopen(Configuration parameters)will be invoked in the default implementation of theopen(OpenContext openContext).org.apache.flink.streaming.api.functions.source.FromSplittableIteratorFunction.open(Configuration) This method is deprecated since Flink 1.19. The users are recommended to implementopen(OpenContext openContext)and overrideopen(Configuration parameters)with an empty body instead. 1. If you implementopen(OpenContext openContext), theopen(OpenContext openContext)will be invoked and theopen(Configuration parameters)won't be invoked. 2. If you don't implementopen(OpenContext openContext), theopen(Configuration parameters)will be invoked in the default implementation of theopen(OpenContext openContext).org.apache.flink.streaming.api.functions.source.MultipleIdsMessageAcknowledgingSourceBase.open(Configuration) This method is deprecated since Flink 1.19. The users are recommended to implementopen(OpenContext openContext)and overrideopen(Configuration parameters)with an empty body instead. 1. If you implementopen(OpenContext openContext), theopen(OpenContext openContext)will be invoked and theopen(Configuration parameters)won't be invoked. 2. If you don't implementopen(OpenContext openContext), theopen(Configuration parameters)will be invoked in the default implementation of theopen(OpenContext openContext).org.apache.flink.streaming.api.graph.StreamConfig.getTypeSerializerIn1(ClassLoader) org.apache.flink.streaming.api.graph.StreamConfig.getTypeSerializerIn2(ClassLoader) org.apache.flink.streaming.api.graph.StreamGraph.getStreamEdgesOrThrow(int, int) org.apache.flink.streaming.api.operators.AbstractStreamOperator.setProcessingTimeService(ProcessingTimeService) TheProcessingTimeServiceinstance should be passed by the operator constructor and this method will be removed along withSetupableStreamOperator.org.apache.flink.streaming.api.windowing.assigners.EventTimeSessionWindows.withGap(Time) org.apache.flink.streaming.api.windowing.assigners.ProcessingTimeSessionWindows.withGap(Time) org.apache.flink.streaming.api.windowing.assigners.SlidingEventTimeWindows.of(Time, Time) org.apache.flink.streaming.api.windowing.assigners.SlidingProcessingTimeWindows.of(Time, Time) org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows.of(Time) org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows.of(Time) org.apache.flink.streaming.api.windowing.assigners.WindowAssigner.getDefaultTrigger(StreamExecutionEnvironment) the method is deprecated since Flink 1.19 becauseStreamExecutionEnvironmentis unused. Please usegetDefaultTriggerand override this method with an empty body instead. 1. If you overridegetDefaultTrigger(), thegetDefaultTrigger()will be invoked and thegetDefaultTrigger(StreamExecutionEnvironment env)won't be invoked. 2. If you don't overridegetDefaultTrigger(), thegetDefaultTrigger(StreamExecutionEnvironment env)will be invoked in the default implementation of thegetDefaultTrigger().org.apache.flink.streaming.api.windowing.evictors.TimeEvictor.of(Time) org.apache.flink.streaming.api.windowing.triggers.ContinuousEventTimeTrigger.of(Time) org.apache.flink.streaming.api.windowing.triggers.ContinuousProcessingTimeTrigger.of(Time) org.apache.flink.streaming.api.windowing.triggers.Trigger.TriggerContext.getKeyValueState(String, Class<S>, S) org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorBuilder.allowedLateness(Time)