Timo Walther created FLINK-39122:
------------------------------------
Summary: Decimals with incorrect precision lead to null value in
PTF
Key: FLINK-39122
URL: https://issues.apache.org/jira/browse/FLINK-39122
Project: Flink
Issue Type: Sub-task
Components: Table SQL / Planner
Reporter: Timo Walther
Instead of a type error the following call leads to a null value for the
decimal:
{code}
// execute a Flink SQL job and print the result locally
tableEnv.fromCall(RulePtf.class, new
BigDecimal("123.456")).execute().print();
}
/** A PTF that filters data based on a dynamic allowlist. */
public static class RulePtf extends ProcessTableFunction<String> {
public void eval(@DataTypeHint("DECIMAL(2, 2)") BigDecimal decimal)
throws Exception {
System.out.println(decimal);
}
}
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
