diff --git a/core/src/main/java/org/apache/gravitino/catalog/EntityCombinedFileset.java b/core/src/main/java/org/apache/gravitino/catalog/EntityCombinedFileset.java index c7b847fc9c6..9b7fc8bd358 100644 --- a/core/src/main/java/org/apache/gravitino/catalog/EntityCombinedFileset.java +++ b/core/src/main/java/org/apache/gravitino/catalog/EntityCombinedFileset.java @@ -77,6 +77,7 @@ public String storageLocation() { public Map properties() { return fileset.properties().entrySet().stream() .filter(p -> !hiddenProperties.contains(p.getKey())) + .filter(entry -> entry.getKey() != null && entry.getValue() != null) .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue)); } diff --git a/core/src/main/java/org/apache/gravitino/catalog/EntityCombinedTable.java b/core/src/main/java/org/apache/gravitino/catalog/EntityCombinedTable.java index 70cbd0ace4a..a70699ac7f9 100644 --- a/core/src/main/java/org/apache/gravitino/catalog/EntityCombinedTable.java +++ b/core/src/main/java/org/apache/gravitino/catalog/EntityCombinedTable.java @@ -96,6 +96,7 @@ public Column[] columns() { public Map properties() { return table.properties().entrySet().stream() .filter(p -> !hiddenProperties.contains(p.getKey())) + .filter(entry -> entry.getKey() != null && entry.getValue() != null) .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue)); } diff --git a/core/src/main/java/org/apache/gravitino/catalog/EntityCombinedTopic.java b/core/src/main/java/org/apache/gravitino/catalog/EntityCombinedTopic.java index 972df622b3d..6193fadacf3 100644 --- a/core/src/main/java/org/apache/gravitino/catalog/EntityCombinedTopic.java +++ b/core/src/main/java/org/apache/gravitino/catalog/EntityCombinedTopic.java @@ -84,6 +84,7 @@ public String comment() { public Map properties() { return topic.properties().entrySet().stream() .filter(p -> !hiddenProperties.contains(p.getKey())) + .filter(entry -> entry.getKey() != null && entry.getValue() != null) .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue)); }