This is an automated email from the ASF dual-hosted git repository.
kharekartik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new c50cef11a7 Fix local segment tar copy (#10048)
c50cef11a7 is described below
commit c50cef11a79065acb6384336f9b7fb47524cf953
Author: Saurabh Dubey <saurabhd...@gmail.com>
AuthorDate: Wed Jan 4 10:44:08 2023 +0530
Fix local segment tar copy (#10048)
Co-authored-by: Saurabh Dubey <saurabh.dubey@Saurabhs-MacBook-Pro.local>
---
.../java/org/apache/pinot/segment/local/utils/SegmentPushUtils.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/utils/SegmentPushUtils.java
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/utils/SegmentPushUtils.java
index c64d9a1135..92832cf889 100644
---
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/utils/SegmentPushUtils.java
+++
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/utils/SegmentPushUtils.java
@@ -24,6 +24,7 @@ import java.io.InputStream;
import java.io.Serializable;
import java.net.URI;
import java.net.URISyntaxException;
+import java.net.URLDecoder;
import java.nio.file.FileSystems;
import java.nio.file.PathMatcher;
import java.nio.file.Paths;
@@ -384,7 +385,7 @@ public class SegmentPushUtils implements Serializable {
try {
if (fileSystem instanceof LocalPinotFS) {
// For local file system, we don't need to copy the tar file.
- tarFile = new File(tarFileURI);
+ tarFile = new File(URLDecoder.decode(tarFileURI.getRawPath(),
"UTF-8"));
} else {
// For other file systems, we need to download the file to local file
system
fileSystem.copyToLocalFile(tarFileURI, tarFile);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
