diff --git a/src/main/java/net/snowflake/client/jdbc/DefaultSFConnectionHandler.java b/src/main/java/net/snowflake/client/jdbc/DefaultSFConnectionHandler.java index 6bb62c82f..b1c6c1cbb 100644 --- a/src/main/java/net/snowflake/client/jdbc/DefaultSFConnectionHandler.java +++ b/src/main/java/net/snowflake/client/jdbc/DefaultSFConnectionHandler.java @@ -306,6 +306,9 @@ private void checkLogFolderPermissions(Path path) throws SnowflakeSQLLoggedExcep private void initSessionProperties(SnowflakeConnectString conStr, String appID, String appVersion) throws SFException { Map properties = mergeProperties(conStr); + properties.put("ENABLE_PRE_EXEC_RESULT_STAGE_VOLUME", false); + properties.put("ENABLE_PARAMETRIZE_RESULT_COMPRESSION_TYPE", true); + properties.put("JDBC_QUERY_RESULT_COMPRESSION_TYPE", "ZSTD"); for (Map.Entry property : properties.entrySet()) { if ("CLIENT_SESSION_KEEP_ALIVE_HEARTBEAT_FREQUENCY".equals(property.getKey())) { @@ -340,6 +343,9 @@ private void initSessionProperties(SnowflakeConnectString conStr, String appID, // populate app id and version sfSession.addProperty(SFSessionProperty.APP_ID, appID); sfSession.addProperty(SFSessionProperty.APP_VERSION, appVersion); + properties.put("ENABLE_PRE_EXEC_RESULT_STAGE_VOLUME", false); + properties.put("ENABLE_PARAMETRIZE_RESULT_COMPRESSION_TYPE", true); + properties.put("JDBC_QUERY_RESULT_COMPRESSION_TYPE", "ZSTD"); // Set the corresponding session parameters to the JVM properties for (Map.Entry entry : JVM_PARAMS_TO_PARAMS.entrySet()) {