update get method

airbytehq · Sep 14, 2022 · 9345169 · 9345169
1 parent bd7fab1
commit 9345169
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/...ler-persistence/src/main/java/io/airbyte/scheduler/persistence/DefaultJobPersistence.java b/...ler-persistence/src/main/java/io/airbyte/scheduler/persistence/DefaultJobPersistence.java
@@ -408,16 +408,16 @@ private static RecordMapper<Record, SyncStats> getSyncStatsRecordMapper() {
   }
 
   private static RecordMapper<Record, NormalizationSummary> getNormalizationSummaryRecordMapper() {
-    return record -> {
+    final RecordMapper<Record, NormalizationSummary> recordMapper = record -> {
       try {
-        new NormalizationSummary().withStartTime(record.get(NORMALIZATION_SUMMARIES.START_TIME).toInstant().toEpochMilli())
-            .withEndTime(record.get(NORMALIZATION_SUMMARIES.END_TIME).toInstant().toEpochMilli())
-            .withFailures(record.get(NORMALIZATION_SUMMARIES.FAILURES, String.class) == null ? null : deserializeFailureReasons(record));
+        return new NormalizationSummary().withStartTime(record.get(NORMALIZATION_SUMMARIES.START_TIME).toInstant().toEpochMilli())
+              .withEndTime(record.get(NORMALIZATION_SUMMARIES.END_TIME).toInstant().toEpochMilli())
+              .withFailures(record.get(NORMALIZATION_SUMMARIES.FAILURES, String.class) == null ? null : deserializeFailureReasons(record));
       } catch (final JsonProcessingException e) {
         throw new RuntimeException(e);
       }
-      return null;
     };
+    return recordMapper;
   }
 
   private static List<FailureReason> deserializeFailureReasons(final Record record) throws JsonProcessingException {