diff --git a/pom.xml b/pom.xml index d24bb3d5d..427becfb1 100644 --- a/pom.xml +++ b/pom.xml @@ -65,7 +65,7 @@ net.snowflake.ingest.internal 1.7.36 1.1.10.4 - 3.14.4 + 3.14.3 0.13.0 diff --git a/src/test/java/net/snowflake/ingest/TestUtils.java b/src/test/java/net/snowflake/ingest/TestUtils.java index ba14ff610..cf588c35c 100644 --- a/src/test/java/net/snowflake/ingest/TestUtils.java +++ b/src/test/java/net/snowflake/ingest/TestUtils.java @@ -126,7 +126,7 @@ private static void init() throws Exception { KeyFactory kf = KeyFactory.getInstance("RSA"); PKCS8EncodedKeySpec keySpec = new PKCS8EncodedKeySpec(encoded); - privateKey = kf.generatePrivate(keySpec); + privateKey = Utils.parsePrivateKey(privateKeyPem); keyPair = Utils.createKeyPairFromPrivateKey(privateKey); } else { user = dummyUser; @@ -284,6 +284,7 @@ public static Connection getConnection(boolean isStreamingConnection) throws Exc props.put("warehouse", warehouse); props.put("client_session_keep_alive", "true"); props.put("privateKey", privateKey); + props.put("role", "ACCOUNTADMIN"); if (isStreamingConnection) { streamingConn = DriverManager.getConnection(connectString, props); diff --git a/src/test/java/net/snowflake/ingest/streaming/internal/datatypes/AbstractDataTypeTest.java b/src/test/java/net/snowflake/ingest/streaming/internal/datatypes/AbstractDataTypeTest.java index f449be2d5..24016fcc8 100644 --- a/src/test/java/net/snowflake/ingest/streaming/internal/datatypes/AbstractDataTypeTest.java +++ b/src/test/java/net/snowflake/ingest/streaming/internal/datatypes/AbstractDataTypeTest.java @@ -67,6 +67,7 @@ public void before() throws Exception { conn.createStatement().execute(String.format("use warehouse %s;", TestUtils.getWarehouse())); Properties props = TestUtils.getProperties(Constants.BdecVersion.THREE, false); + props.setProperty("url", "https://psaha_test.preprod5.us-west-2.aws.snowflakecomputing.com"); if (props.getProperty(ROLE).equals("DEFAULT_ROLE")) { props.setProperty(ROLE, "ACCOUNTADMIN"); }