flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java [913:929]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    .stream()
                    .map(
                            p ->
                                    HivePartitionUtils.createPartitionSpec(
                                            p,
                                            getHiveConf()
                                                    .getVar(
                                                            HiveConf.ConfVars
                                                                    .DEFAULTPARTITIONNAME)))
                    .collect(Collectors.toList());
        } catch (TException e) {
            throw new CatalogException(
                    String.format("Failed to list partitions of table %s", tablePath), e);
        }
    }

    @Override
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java [956:972]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    .stream()
                    .map(
                            p ->
                                    HivePartitionUtils.createPartitionSpec(
                                            p,
                                            getHiveConf()
                                                    .getVar(
                                                            HiveConf.ConfVars
                                                                    .DEFAULTPARTITIONNAME)))
                    .collect(Collectors.toList());
        } catch (TException e) {
            throw new CatalogException(
                    String.format("Failed to list partitions of table %s", tablePath), e);
        }
    }

    @Override
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -