This is an automated email from the ASF dual-hosted git repository. xiangfu pushed a commit to branch fixing_segment_name_with_space in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
commit 56021ec2cc6b5ce75da3a7ca19a53d454c968df7 Author: Xiang Fu <fx19880...@gmail.com> AuthorDate: Thu Feb 11 00:50:25 2021 -0800 Replace generated segment name with space to underscore --- .../plugin/ingestion/batch/standalone/SegmentGenerationJobRunner.java | 1 + 1 file changed, 1 insertion(+) diff --git a/pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-standalone/src/main/java/org/apache/pinot/plugin/ingestion/batch/standalone/SegmentGenerationJobRunner.java b/pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-standalone/src/main/java/org/apache/pinot/plugin/ingestion/batch/standalone/SegmentGenerationJobRunner.java index 67c4471..d9cb654 100644 --- a/pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-standalone/src/main/java/org/apache/pinot/plugin/ingestion/batch/standalone/SegmentGenerationJobRunner.java +++ b/pinot-plugins/pinot-batch-ingestion/pinot-batch-ingestion-standalone/src/main/java/org/apache/pinot/plugin/ingestion/batch/standalone/SegmentGenerationJobRunner.java @@ -199,6 +199,7 @@ public class SegmentGenerationJobRunner implements IngestionJobRunner { // Tar segment directory to compress file localSegmentDir = new File(localOutputTempDir, segmentName); String segmentTarFileName = segmentName + Constants.TAR_GZ_FILE_EXT; + segmentTarFileName = segmentTarFileName.replace(' ', '_'); localSegmentTarFile = new File(localOutputTempDir, segmentTarFileName); LOGGER.info("Tarring segment from: {} to: {}", localSegmentDir, localSegmentTarFile); TarGzCompressionUtils.createTarGzFile(localSegmentDir, localSegmentTarFile); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org