This is an automated email from the ASF dual-hosted git repository.
guoweijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 6a290caf82a [FLINK-36390][core] Remove deprecated open(Configuration)
method in RichFunction
new 2f888bab51e [hotfix][batch] Fix incorrectly use of ExecutionMode in
AdaptiveBatchSchedulerFactory
new aa514a03175 [FLINK-36366][core] Remove deprecate API in flink-core
exclude connector and state part
new 6633719c728 [FLINK-36366][core] Remove deprecated serializer related
config option and method
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/content.zh/docs/dev/table/data_stream_api.md | 2 -
docs/content/docs/dev/table/data_stream_api.md | 3 -
.../connector/file/table/FileSystemTableSink.java | 4 +-
.../connector/file/table/PartitionWriter.java | 3 +-
.../file/src/testutils/TestingFileSystem.java | 7 -
.../connector/file/table/PartitionWriterTest.java | 2 +-
.../hive/write/HiveOutputFormatFactory.java | 2 +-
.../java/hadoop/mapred/HadoopOutputFormatBase.java | 9 +-
.../hadoop/mapreduce/HadoopOutputFormatBase.java | 8 +-
.../java/hadoop/mapred/HadoopOutputFormatTest.java | 17 +-
.../hadoop/mapreduce/HadoopOutputFormatTest.java | 17 +-
.../flink/api/common/ArchivedExecutionConfig.java | 9 -
.../apache/flink/api/common/ExecutionConfig.java | 406 ---------------------
.../api/common/InputDependencyConstraint.java | 39 --
.../flink/api/common/JobExecutionResult.java | 39 --
...rchiveable.java => SerializableSerializer.java} | 24 +-
.../common/eventtime/WatermarksWithIdleness.java | 10 -
.../flink/api/common/io/BinaryOutputFormat.java | 4 +-
.../flink/api/common/io/DelimitedInputFormat.java | 6 -
.../flink/api/common/io/FileInputFormat.java | 67 +---
.../flink/api/common/io/FileOutputFormat.java | 5 +-
.../flink/api/common/io/FinalizeOnMaster.java | 15 +-
.../io/FirstAttemptInitializationContext.java | 44 +--
.../flink/api/common/io/GenericCsvInputFormat.java | 5 -
.../apache/flink/api/common/io/OutputFormat.java | 17 +-
.../flink/api/common/io/OutputFormatBase.java | 4 +-
.../api/common/operators/DualInputOperator.java | 102 ------
.../api/common/operators/GenericDataSinkBase.java | 72 +---
.../api/common/operators/SingleInputOperator.java | 52 ---
.../api/common/serialization/SerializerConfig.java | 21 --
.../common/serialization/SerializerConfigImpl.java | 35 +-
.../flink/api/java/typeutils/RowTypeInfo.java | 15 -
.../java/typeutils/runtime/KryoRegistration.java | 11 +-
.../typeutils/runtime/kryo/KryoSerializer.java | 34 +-
.../runtime/kryo/KryoSerializerSnapshot.java | 2 +-
.../runtime/kryo/KryoSerializerSnapshotData.java | 2 +-
.../java/typeutils/runtime/kryo/Serializers.java | 3 +-
.../apache/flink/configuration/ConfigOption.java | 29 --
.../apache/flink/configuration/ConfigOptions.java | 33 --
.../flink/configuration/PipelineOptions.java | 69 ----
.../core/execution/DetachedJobExecutionResult.java | 5 -
.../org/apache/flink/core/execution/JobClient.java | 34 --
.../flink/core/fs/DuplicatingFileSystem.java | 59 ---
.../java/org/apache/flink/core/fs/FileSystem.java | 8 -
.../java/org/apache/flink/core/fs/IFileSystem.java | 8 -
.../core/fs/LimitedConnectionsFileSystem.java | 5 -
.../flink/core/fs/PluginFileSystemFactory.java | 7 -
.../flink/core/fs/SafetyNetWrapperFileSystem.java | 5 -
.../flink/core/fs/local/LocalFileSystem.java | 6 -
.../flink/core/memory/DataOutputSerializer.java | 6 -
.../ExecutionConfigFromConfigurationTest.java | 11 -
.../flink/api/common/ExecutionConfigTest.java | 88 ++---
.../eventtime/WatermarksWithIdlenessTest.java | 8 +-
.../flink/api/common/io/BinaryInputFormatTest.java | 5 -
.../api/common/io/DelimitedInputFormatTest.java | 5 -
.../flink/api/common/io/FileInputFormatTest.java | 46 +--
.../flink/api/common/io/FileOutputFormatTest.java | 58 +--
.../flink/api/common/io/OutputFormatBaseTest.java | 12 +-
.../operators/util/TestNonRichOutputFormat.java | 2 +-
.../operators/util/TestRichOutputFormat.java | 2 +-
.../serialization/SerializerConfigImplTest.java | 98 +----
.../api/common/state/StateDescriptorTest.java | 2 +-
.../typeutils/runtime/LegacyRowSerializerTest.java | 185 ----------
.../java/typeutils/runtime/PojoSerializerTest.java | 5 +-
.../PojoSerializerUpgradeTestSpecifications.java | 18 +-
.../flink/configuration/ConfigOptionTest.java | 30 --
.../UnmodifiableConfigurationTest.java | 3 +-
.../flink/core/fs/FileSystemBehaviorTestSuite.java | 7 -
...LimitedConnectionsFileSystemDelegationTest.java | 8 -
.../flink/core/fs/local/LocalFileSystemTest.java | 7 -
.../tests/scala/JavaJobWithKryoSerializer.java | 12 +-
.../fs/anotherdummy/AnotherDummyFSFileSystem.java | 6 -
.../apache/flink/fs/dummy/DummyFSFileSystem.java | 6 -
.../flink/runtime/fs/hdfs/HadoopFileSystem.java | 8 -
.../apache/flink/runtime/fs/hdfs/HdfsKindTest.java | 11 -
.../flink/fs/osshadoop/FlinkOSSFileSystem.java | 6 -
.../flink/fs/osshadoop/OSSFileSystemFactory.java | 2 +
.../flink/fs/s3/common/FlinkS3FileSystem.java | 6 -
.../apache/flink/formats/avro/AvroInputFormat.java | 5 -
.../flink/formats/avro/AvroOutputFormat.java | 4 +-
.../avro/utils/AvroKryoSerializerUtils.java | 15 +-
.../flink/formats/avro/AvroOutputFormatTest.java | 37 +-
.../avro/typeutils/AvroTypeExtractionTest.java | 2 +-
.../flink/formats/csv/AbstractCsvInputFormat.java | 5 -
.../hdfstests/ContinuousFileProcessingTest.java | 2 +-
.../java/org/apache/flink/hdfstests/HDFSTest.java | 5 +-
.../flink/api/java/ExecutionEnvironment.java | 82 -----
.../main/java/org/apache/flink/api/java/Utils.java | 6 +-
.../api/java/io/BlockingShuffleOutputFormat.java | 2 +-
.../apache/flink/api/java/io/CsvOutputFormat.java | 4 +-
.../flink/api/java/io/DiscardingOutputFormat.java | 2 +-
.../api/java/io/LocalCollectionOutputFormat.java | 2 +-
.../flink/api/java/io/PrintingOutputFormat.java | 4 +-
.../apache/flink/api/java/io/TextInputFormat.java | 5 -
.../apache/flink/api/java/io/TextOutputFormat.java | 4 +-
.../flink/api/java/io/TextValueInputFormat.java | 5 -
.../apache/flink/api/java/utils/PlanGenerator.java | 12 +-
.../flink/api/common/io/SerializedFormatTest.java | 2 +-
.../flink/api/java/io/CsvOutputFormatTest.java | 5 +-
.../api/java/io/PrintingOutputFormatTest.java | 22 +-
.../api/java/io/TypeSerializerFormatTest.java | 3 +-
.../flink/state/api/output/FileCopyFunction.java | 2 +-
.../state/api/output/SavepointOutputFormat.java | 5 +-
.../api/output/SavepointOutputFormatTest.java | 5 +-
flink-python/pyflink/common/configuration.py | 5 +-
flink-python/pyflink/common/execution_config.py | 22 --
.../pyflink/common/tests/test_execution_config.py | 38 --
.../itcases/AbstractQueryableStateTestBase.java | 10 +-
.../AdaptiveBatchSchedulerFactory.java | 6 +-
.../environment/StreamExecutionEnvironment.java | 127 -------
.../executiongraph/ArchivedExecutionGraphTest.java | 1 -
.../flink/runtime/jobgraph/JobTaskVertexTest.java | 4 +-
.../utils/ArchivedExecutionConfigBuilder.java | 2 -
.../runtime/state/OperatorStateBackendTest.java | 2 +-
.../flink/runtime/state/StateBackendTestBase.java | 51 ++-
.../runtime/util/bash/FlinkConfigLoaderTest.java | 20 -
.../api/operators/StateDescriptorPassingTest.java | 51 ++-
.../api/operators/StreamingRuntimeContextTest.java | 22 +-
.../streamrecord/StreamElementSerializerTest.java | 4 +-
.../changelog/ChangelogStateBackendTestUtils.java | 4 +-
.../flink/state/forst/fs/ForStFlinkFileSystem.java | 6 -
...ecutionEnvironmentComplexConfigurationTest.java | 7 +-
.../api/graph/StreamingJobGraphGeneratorTest.java | 6 +
.../utils/DummyStreamExecutionEnvironment.java | 37 --
.../table/planner/sinks/CollectTableSink.scala | 4 +-
.../factories/TestValuesRuntimeFunctions.java | 4 +-
.../planner/runtime/utils/StreamTestSink.scala | 4 +-
.../planner/utils/MemoryTableSourceSinkUtil.scala | 2 +-
.../runtime/operators/sink/SinkOperatorTest.java | 2 +-
.../flink/test/accumulators/AccumulatorITCase.java | 1 -
.../test/accumulators/AccumulatorLiveITCase.java | 2 +-
.../flink/test/io/RichInputOutputITCase.java | 2 +-
.../flink/test/operators/GroupReduceITCase.java | 5 +-
.../RegisterTypeWithKryoSerializerITCase.java | 139 -------
.../test/runtime/ShuffleCompressionITCase.java | 12 +-
.../common/sink/LoggerOutputFormat.java | 2 +-
pom.xml | 6 +
137 files changed, 462 insertions(+), 2443 deletions(-)
delete mode 100644
flink-core/src/main/java/org/apache/flink/api/common/InputDependencyConstraint.java
copy flink-core/src/main/java/org/apache/flink/api/common/{Archiveable.java =>
SerializableSerializer.java} (59%)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/watermark/WatermarkEmitStrategy.java
=>
flink-core/src/main/java/org/apache/flink/api/common/io/FirstAttemptInitializationContext.java
(52%)
delete mode 100644
flink-core/src/main/java/org/apache/flink/core/fs/DuplicatingFileSystem.java
delete mode 100644
flink-core/src/test/java/org/apache/flink/api/java/typeutils/runtime/LegacyRowSerializerTest.java
delete mode 100644
flink-tests/src/test/java/org/apache/flink/test/runtime/RegisterTypeWithKryoSerializerITCase.java
