[FLINK-21412] pyflink DataTypes.DECIMAL is not available

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.12.0
• Fix Version/s: 1.12.2, 1.13.0
• Component/s: API / Python
• Labels: pull-request-available

Environment

python 3.7.5

pyflink 1.12.1

• Assignee: Dian Fu
• Reporter: awayne
• Created: 19/Feb/21 03:07
• Updated: 26/Feb/21 23:00
• Resolved: 22/Feb/21 01:55

Description

when i use DataTypes.DECIMAL in udaf
File "/home/ubuntu/pyflenv/lib/python3.7/site-packages/pyflink/table/types.py", line 2025, in _to_java_data_type
_to_java_data_type(data_type._element_type))
File "/home/ubuntu/pyflenv/lib/python3.7/site-packages/pyflink/table/types.py", line 1964, in _to_java_data_type
j_data_type = JDataTypes.Decimal(data_type.precision, data_type.scale)
File "/home/ubuntu/pyflenv/lib/python3.7/site-packages/py4j/java_gateway.py", line 1516, in _getattr_
"{0}.{1} does not exist in the JVM".format(self._fqn, name))
py4j.protocol.Py4JError: org.apache.flink.table.api.DataTypes.Decimal does not exist in the JVM

 

in pyflink\table\types.py

line 1963-1964

elif isinstance(data_type, DecimalType):
    j_data_type = JDataTypes.Decimal(data_type.precision, data_type.scale)

in java should be called "DECIMAL"

Issue Links

• links to: GitHub Pull Request #14973