diff --git a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/program/FlinkRecomputeStatisticsProgram.java b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/program/FlinkRecomputeStatisticsProgram.java index 8d6bebc5af44a..31d02c2c89c48 100644 --- a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/program/FlinkRecomputeStatisticsProgram.java +++ b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/program/FlinkRecomputeStatisticsProgram.java @@ -181,8 +181,10 @@ private TableStats getPartitionsTableStats( for (CatalogPartitionSpec partitionSpec : catalogPartitionSpecs) { partitionList.add(partitionSpec.getPartitionSpec()); } - } catch (TableNotExistException | TableNotPartitionedException e) { + } catch (TableNotExistException e) { throw new TableException("Table not exists!", e); + } catch (TableNotPartitionedException e) { + return TableStats.UNKNOWN; } } else { partitionList = partitionPushDownSpec.getPartitions();