6. Bulk Api add sync to Partition

Signed-off-by: msvinaykumar <[email protected]>
shreyabiradar07 · Oct 8, 2024 · 68e99c8 · 68e99c8
1 parent 750407d
commit 68e99c8
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/com/autotune/analyzer/workerimpl/BulkJobManager.java b/src/main/java/com/autotune/analyzer/workerimpl/BulkJobManager.java
@@ -139,10 +139,10 @@ public void run() {
                 Timestamp interval_start_time = Timestamp.from(localDateTime.toInstant(ZoneOffset.UTC));
                 int steps = CREATE_EXPERIMENT_CONFIG_BEAN.getMeasurementDuration() * KruizeConstants.TimeConv.NO_OF_SECONDS_PER_MINUTE; // todo fetch experiment recommendations setting measurement
                 //Get metaData
-                //example metadataInfo = dataSourceManager.importMetadataFromDataSource(datasource, uniqueKey, interval_start_time_epoc, interval_end_time_epoc, steps);
+                metadataInfo = dataSourceManager.importMetadataFromDataSource(datasource, uniqueKey, interval_start_time_epoc, interval_end_time_epoc, steps);
             } else {
                 //Get metaData
-                //metadataInfo = dataSourceManager.importMetadataFromDataSource(datasource, uniqueKey, 0, 0, 0);
+                metadataInfo = dataSourceManager.importMetadataFromDataSource(datasource, uniqueKey, 0, 0, 0);
             }
             List<String> recommendationsRequiredExperiments = new CopyOnWriteArrayList<>();
             if (null == metadataInfo) {