From 066d925aa06bd939f41cfcc0fa0c5e3feba496ef Mon Sep 17 00:00:00 2001 From: Harnoor7 Date: Wed, 18 Dec 2024 23:26:15 +0530 Subject: [PATCH] nit --- .../RealtimeToOfflineSegmentsTaskExecutor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pinot-plugins/pinot-minion-tasks/pinot-minion-builtin-tasks/src/main/java/org/apache/pinot/plugin/minion/tasks/realtimetoofflinesegments/RealtimeToOfflineSegmentsTaskExecutor.java b/pinot-plugins/pinot-minion-tasks/pinot-minion-builtin-tasks/src/main/java/org/apache/pinot/plugin/minion/tasks/realtimetoofflinesegments/RealtimeToOfflineSegmentsTaskExecutor.java index e4d8636a9af4..c91ec7e56022 100644 --- a/pinot-plugins/pinot-minion-tasks/pinot-minion-builtin-tasks/src/main/java/org/apache/pinot/plugin/minion/tasks/realtimetoofflinesegments/RealtimeToOfflineSegmentsTaskExecutor.java +++ b/pinot-plugins/pinot-minion-tasks/pinot-minion-builtin-tasks/src/main/java/org/apache/pinot/plugin/minion/tasks/realtimetoofflinesegments/RealtimeToOfflineSegmentsTaskExecutor.java @@ -165,7 +165,7 @@ protected List convert(PinotTaskConfig pinotTaskConfig, // Since multiple subtasks run in parallel, there shouldn't be a name conflict. // Append uuid segmentProcessorConfigBuilder.setSegmentNameGenerator( - new SimpleSegmentNameGenerator(offlineTableName, null, true, false)); + new SimpleSegmentNameGenerator(rawTableName, null, true, false)); // Progress observer segmentProcessorConfigBuilder.setProgressObserver(p -> _eventObserver.notifyProgress(_pinotTaskConfig, p));