Huang Xingbo created FLINK-20666: ------------------------------------ Summary: Fix the deserialized Row losing the field_name information in PyFlink Key: FLINK-20666 URL: https://issues.apache.org/jira/browse/FLINK-20666 Project: Flink Issue Type: Bug Components: API / Python Affects Versions: 1.11.2, 1.12.0 Reporter: Huang Xingbo
Now, the deserialized Row loses the field_name information. {code:java} @udf(result_type=DataTypes.STRING()) def get_string_element(my_list): my_string = 'xxx' for element in my_list: if element.integer_element == 2: # element lost the field_name information my_string = element.string_element return my_string t = t_env.from_elements( [("1", [Row(3, "flink")]), ("3", [Row(2, "pyflink")]), ("2", [Row(2, "python")])], DataTypes.ROW( [DataTypes.FIELD("Key", DataTypes.STRING()), DataTypes.FIELD("List_element", DataTypes.ARRAY(DataTypes.ROW( [DataTypes.FIELD("integer_element", DataTypes.INT()), DataTypes.FIELD("string_element", DataTypes.STRING())])))])) print(t.select(get_string_element(t.List_element)).to_pandas()) {code} element lost the field_name information -- This message was sent by Atlassian Jira (v8.3.4#803005)