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 1d1bf5c8f69 [FLINK-34975][state/forst] Execute read/write state
request in different executor (#25360)
new aac4e8bb2e9 [FLINK-36257][API] Remove easy-to-drop deprecated API
new 7989f485f10 [FLINK-36257][K8S] Remove legacy k8s labels
The 2 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:
.../flink/orc/OrcColumnarRowFileInputFormat.java | 55 -------
.../formats/parquet/avro/ParquetAvroWriters.java | 71 ---------
.../resources/KubernetesLeaderElector.java | 5 +-
.../flink/kubernetes/utils/KubernetesUtils.java | 10 +-
.../resources/KubernetesLeaderElectorITCase.java | 9 +-
.../apache/flink/state/api/SavepointReader.java | 92 ------------
.../apache/flink/state/api/SavepointWriter.java | 41 -----
.../flink/state/api/output/BoundedStreamTask.java | 165 ---------------------
.../state/api/output/TimestampAssignerWrapper.java | 42 ------
.../state/api/output/partitioner/HashSelector.java | 48 ------
.../partitioner/KeyGroupRangePartitioner.java | 45 ------
.../flink/state/api/SavepointWriterTest.java | 8 -
.../metrics/reporter/InstantiateViaFactory.java | 39 -----
.../InterceptInstantiationViaReflection.java | 38 -----
14 files changed, 4 insertions(+), 664 deletions(-)
delete mode 100644
flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcColumnarRowFileInputFormat.java
delete mode 100644
flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/ParquetAvroWriters.java
delete mode 100644
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/BoundedStreamTask.java
delete mode 100644
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/TimestampAssignerWrapper.java
delete mode 100644
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/partitioner/HashSelector.java
delete mode 100644
flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/partitioner/KeyGroupRangePartitioner.java
delete mode 100644
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/reporter/InstantiateViaFactory.java
delete mode 100644
flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/reporter/InterceptInstantiationViaReflection.java
