fix LOG_CONNECTOR_MESSAGES when source has no state (#20606)

airbytehq · Dec 16, 2022 · 7dc3004 · 7dc3004
1 parent e92b47f
commit 7dc3004
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/airbyte-commons-worker/src/main/java/io/airbyte/workers/internal/DefaultAirbyteSource.java b/airbyte-commons-worker/src/main/java/io/airbyte/workers/internal/DefaultAirbyteSource.java
@@ -164,6 +164,11 @@ private void logInitialStateAsJSON(final WorkerSourceConfig sourceConfig) {
       return;
     }
 
+    if (sourceConfig.getState() == null) {
+      LOGGER.info("source starting state | empty");
+      return;
+    }
+
     LOGGER.info("source starting state | " + Jsons.serialize(sourceConfig.getState().getState()));
   }