(pinot) branch master updated: Fixed the typo in segment file existence check in deepstore (#15248)

[manishswaminathan]

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

manishswaminathan 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 49a5aad4af Fixed the typo in segment file existence check in deepstore 
(#15248)
49a5aad4af is described below

commit 49a5aad4af4b754394e913f282d366616d8ed66f
Author: Ragesh Rajagopalan <ragesh.rajagopa...@gmail.com>
AuthorDate: Wed Mar 12 21:20:41 2025 -0700

    Fixed the typo in segment file existence check in deepstore (#15248)
    
    * Fixed the typo in segment file existence check in deepstore
    
    * trigger_build_1
---
 .../SegmentGenerationAndPushTaskExecutor.java                         | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pinot-plugins/pinot-minion-tasks/pinot-minion-builtin-tasks/src/main/java/org/apache/pinot/plugin/minion/tasks/segmentgenerationandpush/SegmentGenerationAndPushTaskExecutor.java
 
b/pinot-plugins/pinot-minion-tasks/pinot-minion-builtin-tasks/src/main/java/org/apache/pinot/plugin/minion/tasks/segmentgenerationandpush/SegmentGenerationAndPushTaskExecutor.java
index eb14fb590b..0a800f3f64 100644
--- 
a/pinot-plugins/pinot-minion-tasks/pinot-minion-builtin-tasks/src/main/java/org/apache/pinot/plugin/minion/tasks/segmentgenerationandpush/SegmentGenerationAndPushTaskExecutor.java
+++ 
b/pinot-plugins/pinot-minion-tasks/pinot-minion-builtin-tasks/src/main/java/org/apache/pinot/plugin/minion/tasks/segmentgenerationandpush/SegmentGenerationAndPushTaskExecutor.java
@@ -241,8 +241,8 @@ public class SegmentGenerationAndPushTaskExecutor extends 
BaseTaskExecutor {
     try (PinotFS outputFileFS = MinionTaskUtils.getOutputPinotFS(taskConfigs, 
outputSegmentDirURI)) {
       URI outputSegmentTarURI = URI.create(outputSegmentDirURI + 
localSegmentTarFile.getName());
       if 
(!Boolean.parseBoolean(taskConfigs.get(BatchConfigProperties.OVERWRITE_OUTPUT)) 
&& outputFileFS.exists(
-          outputSegmentDirURI)) {
-        LOGGER.warn("Not overwrite existing output segment tar file: {}", 
outputFileFS.exists(outputSegmentDirURI));
+          outputSegmentTarURI)) {
+        LOGGER.warn("Not overwrite existing output segment tar file: {}", 
outputFileFS.exists(outputSegmentTarURI));
       } else {
         outputFileFS.copyFromLocalFile(localSegmentTarFile, 
outputSegmentTarURI);
       }


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