[
https://issues.apache.org/jira/browse/FLINK-36654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee updated FLINK-36654:
--------------------------------
Fix Version/s: 1.20.1
> Decimal divide Integer reports Null pointer exception
> -----------------------------------------------------
>
> Key: FLINK-36654
> URL: https://issues.apache.org/jira/browse/FLINK-36654
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Affects Versions: 1.20.0, 2.0-preview
> Reporter: Shuai Xu
> Assignee: Shuai Xu
> Priority: Major
> Labels: pull-request-available
> Fix For: 2.0.0, 1.20.1
>
>
> paste the test code in SqlExpressionTest.
>
> {code:java}
> // code placeholder
> // Decimal(2,1) / Integer => Decimal(13,12)
> testSqlApi("1.0/400", "0.002500000000")
> // Decimal(2,1) / BigInteger => Decimal(22,21)
> testSqlApi("1.0/100000000000", "0.000000000010000000000")
> // Decimal(2,1) / TinyInt => Decimal(7,6)
> testSqlApi("1.0/cast(100 as TINYINT)", "0.010000")
> // Decimal(2,1) / SmallInt => Decimal(8,7)
> testSqlApi("1.0/cast(10000 as SMALLINT)", "0.0001000") {code}
> and get exception
> {code:java}
> at
> org.apache.flink.table.planner.expressions.utils.ExpressionTestBase.evaluateFunctionResult(ExpressionTestBase.scala:285)
>
> at
> org.apache.flink.table.planner.expressions.utils.ExpressionTestBase.evaluateGivenExprs(ExpressionTestBase.scala:346)
>
> at
> org.apache.flink.table.planner.expressions.utils.ExpressionTestBase.evaluateExprs(ExpressionTestBase.scala:141)
>
> at java.base/java.lang.reflect.Method.invoke(Method.java:566) at
> java.base/java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:189)
> at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
>
> at
> java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
>
> at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
> at
> java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
>
> at
> java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:177)
> Caused by: java.lang.NullPointerException
> at
> org.apache.flink.table.data.DecimalDataUtils.divide(DecimalDataUtils.java:146)
>
> at TestFunction$20.mapImpl_split2(Unknown Source)
> at TestFunction$20.mapImpl(Unknown Source)
> at TestFunction$20.map(Unknown Source)
> at
> org.apache.flink.table.planner.expressions.utils.ExpressionTestBase.evaluateFunctionResult(ExpressionTestBase.scala:260)
> ... 9 more {code}
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
