This is an automated email from the ASF dual-hosted git repository.
yashmayya 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 f44bdcd8a39 Fix typo: rename DEFUALT_PUSH_ATTEMPTS to
DEFAULT_PUSH_ATTEMPTS (#18801)
f44bdcd8a39 is described below
commit f44bdcd8a39b36f644ea16ad86e810667726828f
Author: Akanksha kedia <[email protected]>
AuthorDate: Fri Jun 19 01:52:15 2026 +0530
Fix typo: rename DEFUALT_PUSH_ATTEMPTS to DEFAULT_PUSH_ATTEMPTS (#18801)
---
.../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 9c71c50f6ec..cdafd771bc5 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
@@ -99,7 +99,7 @@ import org.slf4j.LoggerFactory;
public class SegmentGenerationAndPushTaskExecutor extends BaseTaskExecutor {
private static final Logger LOGGER =
LoggerFactory.getLogger(SegmentGenerationAndPushTaskExecutor.class);
- private static final int DEFUALT_PUSH_ATTEMPTS = 5;
+ private static final int DEFAULT_PUSH_ATTEMPTS = 5;
private static final int DEFAULT_PUSH_PARALLELISM = 1;
private static final long DEFAULT_PUSH_RETRY_INTERVAL_MILLIS = 1000L;
@@ -169,7 +169,7 @@ public class SegmentGenerationAndPushTaskExecutor extends
BaseTaskExecutor {
LOGGER.info("Trying to push Pinot segment with push mode {} from {}",
pushMode, outputSegmentTarURI);
PushJobSpec pushJobSpec = new PushJobSpec();
- pushJobSpec.setPushAttempts(DEFUALT_PUSH_ATTEMPTS);
+ pushJobSpec.setPushAttempts(DEFAULT_PUSH_ATTEMPTS);
pushJobSpec.setPushParallelism(DEFAULT_PUSH_PARALLELISM);
pushJobSpec.setPushRetryIntervalMillis(DEFAULT_PUSH_RETRY_INTERVAL_MILLIS);
pushJobSpec.setSegmentUriPrefix(taskConfigs.get(BatchConfigProperties.PUSH_SEGMENT_URI_PREFIX));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
