Skip to content

Commit 9ba88f1

Browse files
committed
Add @ConfigDefault("null") to Optional<String> S3 fields
- Add @ConfigDefault("null") annotations to s3_bucket, s3_prefix, s3_region, s3_access_key_id, s3_secret_access_key - This is required for Embulk's config system to properly handle Optional fields with null defaults - Fixes 'Field is required but not set' error when S3 configuration is not provided
1 parent d4257ed commit 9ba88f1

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

src/main/java/org/embulk/output/SnowflakeOutputPlugin.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -98,18 +98,23 @@ public interface SnowflakePluginTask extends PluginTask {
9898
public boolean getUploadJdbcLogToS3();
9999

100100
@Config("s3_bucket")
101+
@ConfigDefault("null")
101102
public Optional<String> getS3Bucket();
102103

103104
@Config("s3_prefix")
105+
@ConfigDefault("null")
104106
public Optional<String> getS3Prefix();
105107

106108
@Config("s3_region")
109+
@ConfigDefault("null")
107110
public Optional<String> getS3Region();
108111

109112
@Config("s3_access_key_id")
113+
@ConfigDefault("null")
110114
public Optional<String> getS3AccessKeyId();
111115

112116
@Config("s3_secret_access_key")
117+
@ConfigDefault("null")
113118
public Optional<String> getS3SecretAccessKey();
114119

115120
public void setCopyIntoTableColumnNames(String[] columnNames);

0 commit comments

Comments
 (0)