You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by je...@apache.org on 2018/11/26 22:42:38 UTC

[incubator-pinot] 01/01: Cleaning data dir so URI construction works as expected

This is an automated email from the ASF dual-hosted git repository.

jenniferdai pushed a commit to branch slashdata
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git

commit 255a4abbc07db08282ac8d7cffb836c085f4048e
Author: Jennifer Dai <jd...@linkedin.com>
AuthorDate: Mon Nov 26 14:42:25 2018 -0800

    Cleaning data dir so URI construction works as expected
---
 .../controller/api/resources/FileUploadPathProvider.java  | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/pinot-controller/src/main/java/com/linkedin/pinot/controller/api/resources/FileUploadPathProvider.java b/pinot-controller/src/main/java/com/linkedin/pinot/controller/api/resources/FileUploadPathProvider.java
index c761b65..cba311a 100644
--- a/pinot-controller/src/main/java/com/linkedin/pinot/controller/api/resources/FileUploadPathProvider.java
+++ b/pinot-controller/src/main/java/com/linkedin/pinot/controller/api/resources/FileUploadPathProvider.java
@@ -47,6 +47,7 @@ public class FileUploadPathProvider {
 
   public FileUploadPathProvider(ControllerConf controllerConf) throws InvalidControllerConfigException {
     String dataDir = controllerConf.getDataDir();
+    dataDir = cleanDataDir(dataDir);
     try {
       // URIs that are allowed to be remote
       _baseDataDirURI = ControllerConf.getUriFromPath(dataDir);
@@ -134,4 +135,18 @@ public class FileUploadPathProvider {
   public File getSchemasTmpDir() {
     return new File(_schemasTmpDirURI);
   }
+
+  /**
+   * Cleans dataDir by getting rid of unnecessary slashes at the end of dataDir. Needed so other URIs are constructed
+   * as expected.
+   * @param dataDir data directory of pinot segments
+   * @return cleaned data directory
+   */
+  private String cleanDataDir(String dataDir) {
+    if (dataDir != null && dataDir.endsWith("/")) {
+      return dataDir.substring(0, dataDir.length() - 1);
+    } else {
+      return dataDir;
+    }
+  }
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org