Merge remote-tracking branch 'upstream/mvp_demo' into kafka-2

src/main/java/com/autotune/analyzer/workerimpl/BulkJobManager.java

@@ -173,7 +173,6 @@ public void run() {
                 if (null == metadataInfo) {
                     setFinalJobStatus(COMPLETED, String.valueOf(HttpURLConnection.HTTP_OK), NOTHING_INFO, datasource);
                 } else {
-
                     jobData.setMetadata(metadataInfo);
                     Map<String, CreateExperimentAPIObject> createExperimentAPIObjectMap = getExperimentMap(labelString, jobData, metadataInfo, datasource); //Todo Store this map in buffer and use it if BulkAPI pods restarts and support experiment_type
                     //  TODO: Remove getExperimentMap and instead collect all metadata, process it, and create experiments dynamically during metadata iteration.

src/main/java/com/autotune/common/data/dataSourceMetadata/DataSourceMetadataInfo.java

@@ -16,8 +16,6 @@ public class DataSourceMetadataInfo {
      * Key: Data Source name
      * Value: Associated DataSource object
      */
-    //@SerializedName(KruizeConstants.DataSourceConstants.DataSourceMetadataInfoJSONKeys.DATASOURCES)
-    //@JsonProperty(KruizeConstants.DataSourceConstants.DataSourceMetadataInfoJSONKeys.DATASOURCES)
     private HashMap<String, DataSource> datasources;
 
     public DataSourceMetadataInfo(HashMap<String, DataSource> datasources) {