This is an automated email from the ASF dual-hosted git repository.
rongr 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 cf1e073bf1 default to TAR if push mode is not set (#9935)
cf1e073bf1 is described below
commit cf1e073bf1f5750befb4aa5534269f669cccfec4
Author: Xiaobing <[email protected]>
AuthorDate: Wed Dec 7 11:49:01 2022 -0800
default to TAR if push mode is not set (#9935)
---
.../plugin/minion/tasks/BaseMultipleSegmentsConversionExecutor.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git
a/pinot-plugins/pinot-minion-tasks/pinot-minion-builtin-tasks/src/main/java/org/apache/pinot/plugin/minion/tasks/BaseMultipleSegmentsConversionExecutor.java
b/pinot-plugins/pinot-minion-tasks/pinot-minion-builtin-tasks/src/main/java/org/apache/pinot/plugin/minion/tasks/BaseMultipleSegmentsConversionExecutor.java
index 810f07b6d8..c022c82ca2 100644
---
a/pinot-plugins/pinot-minion-tasks/pinot-minion-builtin-tasks/src/main/java/org/apache/pinot/plugin/minion/tasks/BaseMultipleSegmentsConversionExecutor.java
+++
b/pinot-plugins/pinot-minion-tasks/pinot-minion-builtin-tasks/src/main/java/org/apache/pinot/plugin/minion/tasks/BaseMultipleSegmentsConversionExecutor.java
@@ -254,7 +254,8 @@ public abstract class
BaseMultipleSegmentsConversionExecutor extends BaseTaskExe
new
BasicHeader(FileUploadDownloadClient.CustomHeaders.SEGMENT_ZK_METADATA_CUSTOM_MAP_MODIFIER,
segmentZKMetadataCustomMapModifier.toJsonString());
- String pushMode = configs.get(BatchConfigProperties.PUSH_MODE);
+ String pushMode =
+ configs.getOrDefault(BatchConfigProperties.PUSH_MODE,
BatchConfigProperties.SegmentPushType.TAR.name());
URI outputSegmentTarURI;
if
(BatchConfigProperties.SegmentPushType.valueOf(pushMode.toUpperCase())
!= BatchConfigProperties.SegmentPushType.TAR) {
@@ -301,7 +302,8 @@ public abstract class
BaseMultipleSegmentsConversionExecutor extends BaseTaskExe
private void pushSegment(String tableName, Map<String, String> taskConfigs,
URI outputSegmentTarURI,
List<Header> headers, List<NameValuePair> parameters,
SegmentConversionResult segmentConversionResult)
throws Exception {
- String pushMode = taskConfigs.get(BatchConfigProperties.PUSH_MODE);
+ String pushMode =
+ taskConfigs.getOrDefault(BatchConfigProperties.PUSH_MODE,
BatchConfigProperties.SegmentPushType.TAR.name());
LOGGER.info("Trying to push Pinot segment with push mode {} from {}",
pushMode, outputSegmentTarURI);
PushJobSpec pushJobSpec = new PushJobSpec();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
