This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 4559b851b22 [FLINK-34084][config] Deprecate unused configuration in
BinaryInput/OutputFormat and FileInput/OutputFormat
4559b851b22 is described below
commit 4559b851b22d6ffa197aa311adbea15b21a43c66
Author: sxnan <[email protected]>
AuthorDate: Tue Jan 9 17:37:55 2024 +0800
[FLINK-34084][config] Deprecate unused configuration in
BinaryInput/OutputFormat and FileInput/OutputFormat
This closes #24090
---
.../src/main/java/org/apache/flink/api/common/io/BinaryInputFormat.java | 2 +-
.../main/java/org/apache/flink/api/common/io/BinaryOutputFormat.java | 2 +-
.../src/main/java/org/apache/flink/api/common/io/FileInputFormat.java | 1 +
.../src/main/java/org/apache/flink/api/common/io/FileOutputFormat.java | 2 +-
4 files changed, 4 insertions(+), 3 deletions(-)
diff --git
a/flink-core/src/main/java/org/apache/flink/api/common/io/BinaryInputFormat.java
b/flink-core/src/main/java/org/apache/flink/api/common/io/BinaryInputFormat.java
index 75f4bb2a7fa..6d7c7fcdbb9 100644
---
a/flink-core/src/main/java/org/apache/flink/api/common/io/BinaryInputFormat.java
+++
b/flink-core/src/main/java/org/apache/flink/api/common/io/BinaryInputFormat.java
@@ -61,7 +61,7 @@ public abstract class BinaryInputFormat<T> extends
FileInputFormat<T>
private static final Logger LOG =
LoggerFactory.getLogger(BinaryInputFormat.class);
/** The config parameter which defines the fixed length of a record. */
- public static final String BLOCK_SIZE_PARAMETER_KEY = "input.block_size";
+ @Deprecated public static final String BLOCK_SIZE_PARAMETER_KEY =
"input.block_size";
public static final long NATIVE_BLOCK_SIZE = Long.MIN_VALUE;
diff --git
a/flink-core/src/main/java/org/apache/flink/api/common/io/BinaryOutputFormat.java
b/flink-core/src/main/java/org/apache/flink/api/common/io/BinaryOutputFormat.java
index 4a58be3aa28..f2dc9ca8883 100644
---
a/flink-core/src/main/java/org/apache/flink/api/common/io/BinaryOutputFormat.java
+++
b/flink-core/src/main/java/org/apache/flink/api/common/io/BinaryOutputFormat.java
@@ -33,7 +33,7 @@ public abstract class BinaryOutputFormat<T> extends
FileOutputFormat<T> {
private static final long serialVersionUID = 1L;
/** The config parameter which defines the fixed length of a record. */
- public static final String BLOCK_SIZE_PARAMETER_KEY = "output.block_size";
+ @Deprecated public static final String BLOCK_SIZE_PARAMETER_KEY =
"output.block_size";
public static final long NATIVE_BLOCK_SIZE = Long.MIN_VALUE;
diff --git
a/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java
b/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java
index 04844512001..b8c57eb6615 100644
---
a/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java
+++
b/flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java
@@ -1140,5 +1140,6 @@ public abstract class FileInputFormat<OT> extends
RichInputFormat<OT, FileInputS
private static final String FILE_PARAMETER_KEY = "input.file.path";
/** The config parameter which defines whether input directories are
recursively traversed. */
+ @Deprecated
public static final String ENUMERATE_NESTED_FILES_FLAG =
"recursive.file.enumeration";
}
diff --git
a/flink-core/src/main/java/org/apache/flink/api/common/io/FileOutputFormat.java
b/flink-core/src/main/java/org/apache/flink/api/common/io/FileOutputFormat.java
index fbb017c69c0..79933878a92 100644
---
a/flink-core/src/main/java/org/apache/flink/api/common/io/FileOutputFormat.java
+++
b/flink-core/src/main/java/org/apache/flink/api/common/io/FileOutputFormat.java
@@ -92,7 +92,7 @@ public abstract class FileOutputFormat<IT> extends
RichOutputFormat<IT>
private static final Logger LOG =
LoggerFactory.getLogger(FileOutputFormat.class);
/** The key under which the name of the target path is stored in the
configuration. */
- public static final String FILE_PARAMETER_KEY = "flink.output.file";
+ @Deprecated public static final String FILE_PARAMETER_KEY =
"flink.output.file";
/** The path of the file to be written. */
protected Path outputFilePath;
