diff --git a/src/main/java/org/embulk/output/SnowflakeOutputPlugin.java b/src/main/java/org/embulk/output/SnowflakeOutputPlugin.java index 7f34019..aeae0d2 100644 --- a/src/main/java/org/embulk/output/SnowflakeOutputPlugin.java +++ b/src/main/java/org/embulk/output/SnowflakeOutputPlugin.java @@ -167,8 +167,12 @@ protected JdbcOutputConnector getConnector(PluginTask task, boolean retryableMet throw new ConfigException(e); } } + if (t.getWarehouse().startsWith("\"") && t.getWarehouse().endsWith("\"")) { + props.setProperty("warehouse", t.getWarehouse()); + } else { + props.setProperty("warehouse", "\"" + t.getWarehouse() + "\""); + } - props.setProperty("warehouse", t.getWarehouse()); props.setProperty("db", t.getDatabase()); props.setProperty("schema", t.getSchema()); if (!t.getRole().isEmpty()) {