Skip to content

Commit eb5eb31

Browse files
authored
Merge pull request #47 from trocco-io/drop-stage-if-exists
Fix drop stage not exists
2 parents 3348555 + 3e9bee6 commit eb5eb31

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/org/embulk/output/snowflake/SnowflakeOutputConnection.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ protected String buildCreateStageSQL(StageIdentifier stageIdentifier) {
8585

8686
protected String buildDropStageSQL(StageIdentifier stageIdentifier) {
8787
StringBuilder sb = new StringBuilder();
88-
sb.append("DROP STAGE ");
88+
sb.append("DROP STAGE IF EXISTS ");
8989
quoteStageIdentifier(sb, stageIdentifier);
9090
sb.append(";");
9191
return sb.toString();

0 commit comments

Comments
 (0)