Skip to content

Commit 8754263

Browse files
authored
Merge pull request #55 from data-integrations/bugfix_release/CDAP-14531-bigquery-npe
CDAP-14522 fix warn message in gcs plugins
2 parents 2210652 + 1e0f4f7 commit 8754263

File tree

3 files changed

+3
-0
lines changed

3 files changed

+3
-0
lines changed

src/main/java/co/cask/gcp/gcs/GCSConfigHelper.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
*/
2424
public final class GCSConfigHelper {
2525

26+
public static final String ROOT_DIR = "/";
2627
private static final String FILE_SYSTEM_PATH_PREFIX = "gs://";
2728

2829
/**

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,7 @@ protected Map<String, String> getFileSystemProperties(BatchSinkContext context)
7070
String projectId = config.getProject();
7171
properties.put("fs.gs.project.id", projectId);
7272
properties.put("fs.gs.system.bucket", GCSConfigHelper.getBucket(config.path));
73+
properties.put("fs.gs.working.dir", GCSConfigHelper.ROOT_DIR);
7374
properties.put("fs.gs.impl.disable.cache", "true");
7475
return properties;
7576
}

src/main/java/co/cask/gcp/gcs/source/GCSSource.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -77,6 +77,7 @@ protected Map<String, String> getFileSystemProperties(BatchSourceContext context
7777
String projectId = config.getProject();
7878
properties.put("fs.gs.project.id", projectId);
7979
properties.put("fs.gs.system.bucket", GCSConfigHelper.getBucket(config.path));
80+
properties.put("fs.gs.working.dir", GCSConfigHelper.ROOT_DIR);
8081
properties.put("fs.gs.impl.disable.cache", "true");
8182
if (config.copyHeader) {
8283
properties.put(PathTrackingInputFormat.COPY_HEADER, "true");

0 commit comments

Comments
 (0)