Verify JVM configuration in Snowflake connector

Snowflake connector uses Arrow which requires additional JVM arguments.
trinodb · Jan 15, 2025 · 8ef0ea9 · 8ef0ea9
1 parent ce3c487
commit 8ef0ea9
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/plugin/trino-snowflake/src/main/java/io/trino/plugin/snowflake/SnowflakeClientModule.java b/plugin/trino-snowflake/src/main/java/io/trino/plugin/snowflake/SnowflakeClientModule.java
@@ -13,12 +13,14 @@
  */
 package io.trino.plugin.snowflake;
 
+import com.google.common.collect.ImmutableMultimap;
 import com.google.inject.Binder;
 import com.google.inject.Module;
 import com.google.inject.Provides;
 import com.google.inject.Scopes;
 import com.google.inject.Singleton;
 import io.opentelemetry.api.OpenTelemetry;
+import io.trino.plugin.base.JdkCompatibilityChecks;
 import io.trino.plugin.jdbc.BaseJdbcConfig;
 import io.trino.plugin.jdbc.ConnectionFactory;
 import io.trino.plugin.jdbc.DriverConnectionFactory;
@@ -46,6 +48,11 @@ public class SnowflakeClientModule
     @Override
     public void configure(Binder binder)
     {
+        // Check reflective access allowed - required by Apache Arrow usage in Snowflake JDBC driver
+        JdkCompatibilityChecks.verifyConnectorAccessOpened(
+                binder,
+                "snowflake",
+                ImmutableMultimap.of("java.base", "java.nio"));
         binder.bind(JdbcClient.class).annotatedWith(ForBaseJdbc.class).to(SnowflakeClient.class).in(Scopes.SINGLETON);
         configBinder(binder).bindConfig(SnowflakeConfig.class);
         configBinder(binder).bindConfig(TypeHandlingJdbcConfig.class);