-
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.environment.ExecutionCheckpointingOptions All configuration items in this class have been moved toCheckpointingOptions.org.apache.flink.streaming.api.environment.StreamPipelineOptions This option class is deprecated in 1.20 and will be removed in 2.0.org.apache.flink.streaming.api.functions.AscendingTimestampExtractor ExtendAscendingTimestampExtractorinstead.org.apache.flink.streaming.api.functions.IngestionTimeExtractor org.apache.flink.streaming.api.functions.sink.DiscardingSink This interface will be removed in future versions. Use the newDiscardingSinkinterface instead.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.PrintSinkFunction This interface will be removed in future versions. Use the newPrintSinkinterface instead.org.apache.flink.streaming.api.functions.sink.RichSinkFunction This interface will be removed in future versions. Use the newSinkinterface instead.org.apache.flink.streaming.api.functions.sink.SocketClientSink This interface will be removed in future versions. Use the newSinkinterface instead.org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction This interface will be removed in future versions. Use the newSinkinterface instead.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.CheckpointingMode This class has been moved toCheckpointingMode.org.apache.flink.streaming.api.environment.CheckpointConfig.ExternalizedCheckpointCleanup This class has been moved toExternalizedCheckpointRetention.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.
-
Methods Method Description org.apache.flink.streaming.api.connector.sink2.CommittableMessage.getCheckpointId() org.apache.flink.streaming.api.connector.sink2.CommittableMessage.getCheckpointIdOrEOI() the special value EOI is not used anymoreorg.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.getCheckpointingMode() UseCheckpointConfig.getCheckpointingConsistencyMode()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.getExternalizedCheckpointCleanup() org.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.setCheckpointingMode(CheckpointingMode) 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.setExternalizedCheckpointCleanup(CheckpointConfig.ExternalizedCheckpointCleanup) 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) 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.getCheckpointingMode() 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)