Skip to content

Commit c588db4

Browse files
committed
Fix path macro in gcs sink
1 parent 737ef07 commit c588db4

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/main/java/co/cask/gcp/gcs/sink/GCSBatchSink.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,10 @@ public static class GCSBatchSinkConfig extends GCPReferenceSinkConfig implements
116116
@Override
117117
public void validate() {
118118
super.validate();
119-
GCSConfigHelper.getPath(path);
119+
// validate that path is valid
120+
if (!containsMacro("path")) {
121+
GCSConfigHelper.getPath(path);
122+
}
120123
if (suffix != null && !containsMacro("suffix")) {
121124
new SimpleDateFormat(suffix);
122125
}

0 commit comments

Comments
 (0)