changed get for granularity

linkedin · Sep 20, 2024 · b0fa196 · b0fa196
1 parent 779a46b
commit b0fa196
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/apps/spark/src/main/java/com/linkedin/openhouse/jobs/util/TableStatsCollectorUtil.java b/apps/spark/src/main/java/com/linkedin/openhouse/jobs/util/TableStatsCollectorUtil.java
@@ -275,7 +275,7 @@ private static RetentionStatsSchema buildRetentionStats(Map<String, Object> rete
             retentionPolicy.containsKey("count")
                 ? Integer.valueOf((String) retentionPolicy.get("count"))
                 : 0)
-        .granularity((String) retentionPolicy.get("granularity"))
+        .granularity((String) retentionPolicy.getOrDefault("granularity", null))
         .columnPattern((String) retentionPolicy.getOrDefault("pattern", null))
         .columnName((String) retentionPolicy.getOrDefault("columnName", null))
         .build();