This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch release-1.20
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.20 by this push:
new 51dc7d346b1 [FLINK-41246][python] Fix nested Row conversion (#29643)
51dc7d346b1 is described below
commit 51dc7d346b1962b4812c11e780352003b313f138
Author: Dian Fu <[email protected]>
AuthorDate: Wed Oct 28 14:47:08 2026 +0800
[FLINK-41246][python] Fix nested Row conversion (#29643)
---
flink-python/pyflink/table/tests/test_table_environment_api.py | 8 ++++----
flink-python/pyflink/table/utils.py | 2 +-
2 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/flink-python/pyflink/table/tests/test_table_environment_api.py
b/flink-python/pyflink/table/tests/test_table_environment_api.py
index 46918203a0d..ff029b1bc1d 100644
--- a/flink-python/pyflink/table/tests/test_table_environment_api.py
+++ b/flink-python/pyflink/table/tests/test_table_environment_api.py
@@ -646,8 +646,8 @@ class
StreamTableEnvironmentTests(PyFlinkStreamTableTestCase):
1.98932, bytearray(b'pyflink'), 'pyflink',
datetime.date(2014, 9, 13), datetime.time(12,
0, 0, 123000),
datetime.datetime(2018, 3, 11, 3, 0, 0, 123000),
- [Row(['[pyflink]']), Row(['[pyflink]']),
Row(['[pyflink]'])],
- {1: Row(['[flink]']), 2: Row(['[pyflink]'])},
+ [Row('pyflink'), Row('pyflink'),
Row('pyflink')],
+ {1: Row('flink'), 2: Row('pyflink')},
decimal.Decimal('1000000000000000000.050000000000000000'),
decimal.Decimal('1000000000000000000.059999999999999999'))]
source = self.t_env.from_elements(
@@ -655,8 +655,8 @@ class
StreamTableEnvironmentTests(PyFlinkStreamTableTestCase):
datetime.date(2014, 9, 13), datetime.time(hour=12, minute=0,
second=0,
microsecond=123000),
datetime.datetime(2018, 3, 11, 3, 0, 0, 123000),
- [Row(['pyflink']), Row(['pyflink']), Row(['pyflink'])],
- {1: Row(['flink']), 2: Row(['pyflink'])},
decimal.Decimal('1000000000000000000.05'),
+ [Row('pyflink'), Row('pyflink'), Row('pyflink')],
+ {1: Row('flink'), 2: Row('pyflink')},
decimal.Decimal('1000000000000000000.05'),
decimal.Decimal('1000000000000000000.05999999999999999899999999999'))],
DataTypes.ROW(
[DataTypes.FIELD("a", DataTypes.BIGINT()),
DataTypes.FIELD("b", DataTypes.BIGINT()),
DataTypes.FIELD("c", DataTypes.TINYINT()),
diff --git a/flink-python/pyflink/table/utils.py
b/flink-python/pyflink/table/utils.py
index 0987fe83137..7305765f21b 100644
--- a/flink-python/pyflink/table/utils.py
+++ b/flink-python/pyflink/table/utils.py
@@ -114,7 +114,7 @@ def pickled_bytes_to_python_converter(data, field_type:
DataType):
fields = []
for d, d_type in data:
fields.append(pickled_bytes_to_python_converter(d, d_type))
- result_row = Row(fields)
+ result_row = Row(*fields)
result_row.set_row_kind(row_kind)
return result_row
else:
