Skip to content

Commit 1822791

Browse files
author
teo
committed
[#6523] fix(core): Filter null prop when init properties
1 parent fb3d900 commit 1822791

File tree

3 files changed

+3
-0
lines changed

3 files changed

+3
-0
lines changed

core/src/main/java/org/apache/gravitino/catalog/EntityCombinedFileset.java

+1
Original file line numberDiff line numberDiff line change
@@ -77,6 +77,7 @@ public String storageLocation() {
7777
public Map<String, String> properties() {
7878
return fileset.properties().entrySet().stream()
7979
.filter(p -> !hiddenProperties.contains(p.getKey()))
80+
.filter(entry -> entry.getKey() != null && entry.getValue() != null)
8081
.collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
8182
}
8283

core/src/main/java/org/apache/gravitino/catalog/EntityCombinedTable.java

+1
Original file line numberDiff line numberDiff line change
@@ -96,6 +96,7 @@ public Column[] columns() {
9696
public Map<String, String> properties() {
9797
return table.properties().entrySet().stream()
9898
.filter(p -> !hiddenProperties.contains(p.getKey()))
99+
.filter(entry -> entry.getKey() != null && entry.getValue() != null)
99100
.collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
100101
}
101102

core/src/main/java/org/apache/gravitino/catalog/EntityCombinedTopic.java

+1
Original file line numberDiff line numberDiff line change
@@ -84,6 +84,7 @@ public String comment() {
8484
public Map<String, String> properties() {
8585
return topic.properties().entrySet().stream()
8686
.filter(p -> !hiddenProperties.contains(p.getKey()))
87+
.filter(entry -> entry.getKey() != null && entry.getValue() != null)
8788
.collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
8889
}
8990

0 commit comments

Comments
 (0)