From 68e99c86610da19c3773e61fff93927f3a6bb00d Mon Sep 17 00:00:00 2001 From: msvinaykumar Date: Fri, 4 Oct 2024 19:00:29 +0530 Subject: [PATCH] 6. Bulk Api add sync to Partition Signed-off-by: msvinaykumar --- .../java/com/autotune/analyzer/workerimpl/BulkJobManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/autotune/analyzer/workerimpl/BulkJobManager.java b/src/main/java/com/autotune/analyzer/workerimpl/BulkJobManager.java index 9cd1a3ce2..c2e1d2d8c 100644 --- 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 recommendationsRequiredExperiments = new CopyOnWriteArrayList<>(); if (null == metadataInfo) {