fix: handle case where no stream stats are present for the stream (#1…

…2860)
Schub-cloud · Jun 18, 2024 · 07e415a · 07e415a
1 parent 7ad6444
commit 07e415a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...e-commons-server/src/main/java/io/airbyte/commons/server/handlers/ConnectionsHandler.java b/...e-commons-server/src/main/java/io/airbyte/commons/server/handlers/ConnectionsHandler.java
@@ -1284,7 +1284,7 @@ private ConnectionLastJobPerStreamReadItem buildLastJobPerStreamReadItem(
     memo.putIfAbsent(jobRead.getId(), buildStreamStatsMap(jobRead));
 
     // retrieve the stat for the stream of interest from the memo
-    final Optional<StreamStats> statsForThisStream = Optional.of(memo.get(jobRead.getId()).get(streamDescriptor));
+    final Optional<StreamStats> statsForThisStream = Optional.ofNullable(memo.get(jobRead.getId()).get(streamDescriptor));
 
     return new ConnectionLastJobPerStreamReadItem()
         .streamName(streamDescriptor.getName())