godfrey he created FLINK-17996:
----------------------------------
Summary: NEP in
CatalogTableStatisticsConverter.convertToColumnStats method
Key: FLINK-17996
URL: https://issues.apache.org/jira/browse/FLINK-17996
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Affects Versions: 1.11.0
Reporter: godfrey he
Currently, hive catalog only supports a few kinds of statistics, otherwise
return null. (see HiveStatsUtil#createTableColumnStats). If there is a decimal
statistics, NEP will occur in
CatalogTableStatisticsConverter.convertToColumnStats method
Caused by: java.lang.NullPointerException
at
org.apache.flink.table.planner.utils.CatalogTableStatisticsConverter.convertToColumnStats(CatalogTableStatisticsConverter.java:77)
at
org.apache.flink.table.planner.utils.CatalogTableStatisticsConverter.convertToColumnStatsMap(CatalogTableStatisticsConverter.java:68)
at
org.apache.flink.table.planner.utils.CatalogTableStatisticsConverter.convertToTableStats(CatalogTableStatisticsConverter.java:57)
at
org.apache.flink.table.planner.catalog.DatabaseCalciteSchema.extractTableStats(DatabaseCalciteSchema.java:113)
at
org.apache.flink.table.planner.catalog.DatabaseCalciteSchema.getStatistic(DatabaseCalciteSchema.java:97)
at
org.apache.flink.table.planner.catalog.DatabaseCalciteSchema.lambda$getTable$0(DatabaseCalciteSchema.java:74)
at java.util.Optional.map(Optional.java:215)
at
org.apache.flink.table.planner.catalog.DatabaseCalciteSchema.getTable(DatabaseCalciteSchema.java:72)
at org.apache.calcite.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
