This is an automated email from the ASF dual-hosted git repository.
kishoreg pushed a commit to branch pinot-fs-bug-fix
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
The following commit(s) were added to refs/heads/pinot-fs-bug-fix by this push:
new 4c3eed8 Fixing code to fetch the fsConfig from the right parent
4c3eed8 is described below
commit 4c3eed8655a3b5d1cd6f702af2f7541b5c688ce1
Author: kishoreg <g.kish...@gmail.com>
AuthorDate: Wed Jul 8 17:34:23 2020 -0700
Fixing code to fetch the fsConfig from the right parent
---
.../java/org/apache/pinot/spi/filesystem/PinotFSFactory.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git
a/pinot-spi/src/main/java/org/apache/pinot/spi/filesystem/PinotFSFactory.java
b/pinot-spi/src/main/java/org/apache/pinot/spi/filesystem/PinotFSFactory.java
index 7003a77..eb5367c 100644
---
a/pinot-spi/src/main/java/org/apache/pinot/spi/filesystem/PinotFSFactory.java
+++
b/pinot-spi/src/main/java/org/apache/pinot/spi/filesystem/PinotFSFactory.java
@@ -60,19 +60,19 @@ public class PinotFSFactory {
}
}
- public static void init(PinotConfiguration fsConfig) {
+ public static void init(PinotConfiguration config) {
// Get schemes and their respective classes
- PinotConfiguration schemesConfiguration = fsConfig.subset(CLASS);
+ PinotConfiguration schemesConfiguration = config.subset(CLASS);
List<String> schemes = schemesConfiguration.getKeys();
if (!schemes.isEmpty()) {
LOGGER.info("Did not find any fs classes in the configuration");
}
for(String scheme : schemes){
- String fsClassName = (String) schemesConfiguration.getProperty(scheme);
-
- LOGGER.info("Got scheme {}, classname {}, starting to initialize",
scheme, fsClassName);
- register(scheme, fsClassName, schemesConfiguration.subset(scheme));
+ String fsClassName = schemesConfiguration.getProperty(scheme);
+ PinotConfiguration fsConfiguration = config.subset(scheme);
+ LOGGER.info("Got scheme {}, initializing class {} with config : {} ",
scheme, fsClassName, fsConfiguration.toMap());
+ register(scheme, fsClassName, fsConfiguration);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
