This is an automated email from the ASF dual-hosted git repository.
xiangfu 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 70412e624e allow to set segment when use SegmentProcessorFramework
(#13341)
70412e624e is described below
commit 70412e624ef734e3e07a7ea6b9e3bece00a243a3
Author: Xiaobing <61892277+klsi...@users.noreply.github.com>
AuthorDate: Sat Jun 8 01:28:54 2024 -0700
allow to set segment when use SegmentProcessorFramework (#13341)
---
.../core/segment/processing/framework/SegmentProcessorFramework.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/segment/processing/framework/SegmentProcessorFramework.java
b/pinot-core/src/main/java/org/apache/pinot/core/segment/processing/framework/SegmentProcessorFramework.java
index def4f75b29..4b166b934a 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/segment/processing/framework/SegmentProcessorFramework.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/segment/processing/framework/SegmentProcessorFramework.java
@@ -265,6 +265,7 @@ public class SegmentProcessorFramework {
// SegmentNameGenerator will be inferred by the SegmentGeneratorConfig.
generatorConfig.setSegmentNamePrefix(segmentNamePrefix);
generatorConfig.setSegmentNamePostfix(segmentNamePostfix);
+ generatorConfig.setSegmentName(fixedSegmentName);
}
for (Map.Entry<String, GenericRowFileManager> entry :
partitionToFileManagerMap.entrySet()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
