diff --git a/airbyte-integrations/connectors/source-postgres-singer/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/SingerPostgresSourceTest.java b/airbyte-integrations/connectors/source-postgres-singer/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/SingerPostgresSourceTest.java index 20daa950d071c..a52b569ec5989 100644 --- a/airbyte-integrations/connectors/source-postgres-singer/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/SingerPostgresSourceTest.java +++ b/airbyte-integrations/connectors/source-postgres-singer/src/test-integration/java/io/airbyte/integrations/io/airbyte/integration_tests/sources/SingerPostgresSourceTest.java @@ -92,7 +92,7 @@ public class SingerPostgresSourceTest { @BeforeEach public void init() throws IOException { - psqlDb = new PostgreSQLContainer(); + psqlDb = new PostgreSQLContainer("postgres:13-alpine"); psqlDb.start(); PostgreSQLContainerHelper.runSqlScript(MountableFile.forClasspathResource("init_ascii.sql"), psqlDb); @@ -150,7 +150,7 @@ private void assertMessagesEquivalent(List expectedMessage public void testCanReadUtf8() throws IOException, InterruptedException, WorkerException { // force the db server to start with sql_ascii encoding to verify the tap can read UTF8 even when // default settings are in another encoding - PostgreSQLContainer db = (PostgreSQLContainer) new PostgreSQLContainer().withCommand("postgres -c client_encoding=sql_ascii"); + PostgreSQLContainer db = (PostgreSQLContainer) new PostgreSQLContainer("postgres:13-alpine").withCommand("postgres -c client_encoding=sql_ascii"); db.start(); PostgreSQLContainerHelper.runSqlScript(MountableFile.forClasspathResource("init_utf8.sql"), db); diff --git a/airbyte-tests/src/acceptanceTests/java/io/airbyte/test/acceptance/AcceptanceTests.java b/airbyte-tests/src/acceptanceTests/java/io/airbyte/test/acceptance/AcceptanceTests.java index 54915e1e9165c..5b379f7400e49 100644 --- a/airbyte-tests/src/acceptanceTests/java/io/airbyte/test/acceptance/AcceptanceTests.java +++ b/airbyte-tests/src/acceptanceTests/java/io/airbyte/test/acceptance/AcceptanceTests.java @@ -104,8 +104,8 @@ public void init() { connectionIds = Lists.newArrayList(); destinationImplIds = Lists.newArrayList(); - sourcePsql = new PostgreSQLContainer(); - targetPsql = new PostgreSQLContainer(); + sourcePsql = new PostgreSQLContainer("postgres:13-alpine"); + targetPsql = new PostgreSQLContainer("postgres:13-alpine"); sourcePsql.start(); targetPsql.start();