diff --git a/airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresSource.java b/airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresSource.java index 01dfa386c703..bea9557ec1ae 100644 --- a/airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresSource.java +++ b/airbyte-integrations/connectors/source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresSource.java @@ -349,8 +349,12 @@ public Set getPrivilegesTableForCurrentUser(final JdbcDatabase .collect(toSet()); } + @VisibleForTesting static String getUsername(final JsonNode databaseConfig) { - final String host = databaseConfig.get("host").asText(); + final String host = databaseConfig.get("host") == null + // host can be null in test + ? "" + : databaseConfig.get("host").asText(); final String username = databaseConfig.get("username").asText(); // Azure Postgres server has this username pattern: @.