[
https://issues.apache.org/jira/browse/FLINK-39122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18080249#comment-18080249
]
Timo Walther commented on FLINK-39122:
--------------------------------------
Hi Rion, I haven't checked this too deeply, but I would assume a type inference
problem. The engine should insert casts at the correct location that will take
care of casting the argument to the right type.
> 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
> Priority: Major
>
> 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)
