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 2019/03/14 04:22:06 UTC

[incubator-pinot] branch remotefiles updated: Changing segment generator config to not assume file abstraction for input file paths

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

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


The following commit(s) were added to refs/heads/remotefiles by this push:
     new ef6b912  Changing segment generator config to not assume file abstraction for input file paths
ef6b912 is described below

commit ef6b9126737e569c1a1e231778d16e3e7b0079c4
Author: Jennifer Dai <jd...@linkedin.com>
AuthorDate: Wed Mar 13 21:21:53 2019 -0700

    Changing segment generator config to not assume file abstraction for input file paths
---
 .../core/indexsegment/generator/SegmentGeneratorConfig.java      | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/pinot-core/src/main/java/org/apache/pinot/core/indexsegment/generator/SegmentGeneratorConfig.java b/pinot-core/src/main/java/org/apache/pinot/core/indexsegment/generator/SegmentGeneratorConfig.java
index a43691c..50cb0f2 100644
--- a/pinot-core/src/main/java/org/apache/pinot/core/indexsegment/generator/SegmentGeneratorConfig.java
+++ b/pinot-core/src/main/java/org/apache/pinot/core/indexsegment/generator/SegmentGeneratorConfig.java
@@ -312,11 +312,14 @@ public class SegmentGeneratorConfig {
 
   public void setInputFilePath(String inputFilePath, boolean isLocalPath) {
     Preconditions.checkNotNull(inputFilePath);
-    File inputFile = new File(inputFilePath);
     if (isLocalPath) {
-    Preconditions.checkState(inputFile.exists(), "Input path {} does not exist.", inputFilePath);
+      File inputFile = new File(inputFilePath);
+      Preconditions.checkState(inputFile.exists(), "Input path {} does not exist.", inputFilePath);
+      _inputFilePath = inputFile.getAbsolutePath();
+    } else {
+      // Remote path
+      _inputFilePath = inputFilePath;
     }
-    _inputFilePath = inputFile.getAbsolutePath();
   }
 
   public FileFormat getFormat() {


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