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 <j...@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-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org