Merge pull request #1392 from kruize/mvp_demo

Merge 0.2 bug fix to master

.github/workflows/test-on-push.yaml

@@ -46,56 +46,6 @@ jobs:
           docker tag autotune_operator:pr_${{ env.PR_NUMBER }} kruize/autotune_operator:pr_${{ env.PR_NUMBER }}
           docker push kruize/autotune_operator:pr_${{ env.PR_NUMBER }}
 
-  deploy_autotune:
-    # The type of runner that the job will run on
-    needs: [build_job, get_pr]
-
-    runs-on: ubuntu-20.04
-
-    steps:
-      # Checks-out your repository under $GITHUB_WORKSPACE, so your job can access it
-      - uses: actions/checkout@v3
-      - name: Get PR number
-        run: |
-          echo "PR_NUMBER=${{ needs.get_pr.outputs.pr_number }}" >> $GITHUB_ENV
-      - name: Setup Minikube
-        uses: manusa/[email protected]
-        with:
-          minikube version: 'v1.16.0'
-          kubernetes version: 'v1.19.2'
-      - name: Display cluster info
-        run: |
-          kubectl cluster-info
-          kubectl get pods -n kube-system
-      - name: Install Prometheus on minikube
-        run: |
-          echo Install Prometheus on minikube
-          cd scripts
-          ./prometheus_on_minikube.sh -as    
-      - name: Deploy kruize in experiment mode
-        run: |
-          echo Deploy Kruize in experiment mode
-          echo "PR_NUMBER = ${{ env.PR_NUMBER }}"
-          ./deploy.sh -c minikube -i kruize/autotune_operator:pr_${{ env.PR_NUMBER }}
-          sleep 20
-      - name: Capture ffdc logs
-        if: always()
-        run: |
-          ./scripts/ffdc.sh -d ${GITHUB_WORKSPACE}
-      - name: Archive results
-        if: always()
-        run: |
-          cd ${GITHUB_WORKSPACE}
-          tar cvf autotune_results.tar kruize_*log.txt
-
-      - name: Upload results
-        if: always()
-        uses: actions/upload-artifact@v3
-        with:
-          name: autotune-results
-          path: ./autotune_results.tar
-          retention-days: 2
-
   deploy_crc:
     # The type of runner that the job will run on
     needs: [build_job, get_pr]

src/main/java/com/autotune/analyzer/serviceObjects/BulkJobStatus.java

@@ -41,7 +41,7 @@ public class BulkJobStatus {
     private String jobID;
     private String status;
     private int total_experiments;
-    private int processed_experiments;
+    private int processed_experiments;  //todo : If the primary operations are increments or simple atomic updates, use AtomicInteger. It is designed for lock-free thread-safe access
     @JsonProperty("job_start_time")
     private String startTime; // Change to String to store formatted time
     @JsonProperty("job_end_time")
@@ -144,11 +144,11 @@ public void setTotal_experiments(int total_experiments) {
         this.total_experiments = total_experiments;
     }
 
-    public int getProcessed_experiments() {
+    public synchronized int getProcessed_experiments() {
         return processed_experiments;
     }
 
-    public void setProcessed_experiments(int processed_experiments) {
+    public synchronized void setProcessed_experiments(int processed_experiments) {
         this.processed_experiments = processed_experiments;
     }