This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch release-2.2
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-2.2 by this push:
new eb65369a2d5 [FLINK-38797][python] Fixed
CsvSchemaBuilder.set_null_value to return self
eb65369a2d5 is described below
commit eb65369a2d5af341d7dc4e6227572a92ef777763
Author: Wren Chan <[email protected]>
AuthorDate: Tue Dec 9 20:47:12 2025 -0500
[FLINK-38797][python] Fixed CsvSchemaBuilder.set_null_value to return self
This closes #27331.
---
flink-python/pyflink/datastream/formats/csv.py | 1 +
.../pyflink/datastream/formats/tests/test_csv.py | 24 ++++++++++++++++++++++
2 files changed, 25 insertions(+)
diff --git a/flink-python/pyflink/datastream/formats/csv.py
b/flink-python/pyflink/datastream/formats/csv.py
index 53f85a15441..d7da4a03afd 100644
--- a/flink-python/pyflink/datastream/formats/csv.py
+++ b/flink-python/pyflink/datastream/formats/csv.py
@@ -237,6 +237,7 @@ class CsvSchemaBuilder(object):
Set literal for null value, default to empty sequence.
"""
self._j_schema_builder.setNullValue(null_value)
+ return self
def disable_quote_char(self):
"""
diff --git a/flink-python/pyflink/datastream/formats/tests/test_csv.py
b/flink-python/pyflink/datastream/formats/tests/test_csv.py
index 97d32826020..a088cfb502c 100644
--- a/flink-python/pyflink/datastream/formats/tests/test_csv.py
+++ b/flink-python/pyflink/datastream/formats/tests/test_csv.py
@@ -77,6 +77,12 @@ class FileSourceCsvReaderFormatTests(object):
self.env.execute('test_csv_strict_headers')
_check_csv_strict_headers_results(self,
self.test_sink.get_results(True, False))
+ def test_csv_default_null_value(self):
+ schema, lines = _create_csv_default_null_value_schema_and_lines()
+ self._build_csv_job(schema, lines)
+ self.env.execute('test_csv_default_null_value')
+ _check_csv_default_null_value_results(self,
self.test_sink.get_results(True, False))
+
def test_csv_default_quote_char(self):
schema, lines = _create_csv_default_quote_char_schema_and_lines()
self._build_csv_job(schema, lines)
@@ -344,6 +350,24 @@ def _check_csv_use_header_results(test, results):
test.assertEqual(row['number'], 123)
+def _create_csv_default_null_value_schema_and_lines() -> Tuple[CsvSchema,
List[str]]:
+ schema = CsvSchema.builder() \
+ .add_string_column('string') \
+ .add_number_column('number') \
+ .set_null_value('') \
+ .build()
+ lines = [
+ ',123\n'
+ ]
+ return schema, lines
+
+
+def _check_csv_default_null_value_results(test, results):
+ row = results[0]
+ test.assertEqual(row['string'], None)
+ test.assertEqual(row['number'], 123)
+
+
def _create_csv_strict_headers_schema_and_lines() -> Tuple[CsvSchema,
List[str]]:
schema = CsvSchema.builder() \
.add_string_column('string') \
