[FLINK-21412][python] Fix Decimal type which doesn't work in UDAF and…

… expression DSL This closes apache#14973.
deepfield · Feb 22, 2021 · d86cf91 · d86cf91
1 parent 86015c7
commit d86cf91
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink-python/pyflink/table/types.py b/flink-python/pyflink/table/types.py
@@ -1961,7 +1961,7 @@ def _to_java_data_type(data_type: DataType):
  elif isinstance(data_type, BinaryType):
  j_data_type = JDataTypes.BINARY(data_type.length)
  elif isinstance(data_type, DecimalType):
- j_data_type = JDataTypes.Decimal(data_type.precision, data_type.scale)
+ j_data_type = JDataTypes.DECIMAL(data_type.precision, data_type.scale)
  elif isinstance(data_type, DateType):
  j_data_type = JDataTypes.DATE()
  elif isinstance(data_type, TimeType):