diff --git a/java-aiplatform/google-cloud-aiplatform/src/test/java/com/google/cloud/aiplatform/v1beta1/JobServiceClientTest.java b/java-aiplatform/google-cloud-aiplatform/src/test/java/com/google/cloud/aiplatform/v1beta1/JobServiceClientTest.java
index 23f08574e58b..2fdc4bde2013 100644
--- a/java-aiplatform/google-cloud-aiplatform/src/test/java/com/google/cloud/aiplatform/v1beta1/JobServiceClientTest.java
+++ b/java-aiplatform/google-cloud-aiplatform/src/test/java/com/google/cloud/aiplatform/v1beta1/JobServiceClientTest.java
@@ -1567,6 +1567,8 @@ public void createBatchPredictionJobTest() throws Exception {
             .putAllLabels(new HashMap<String, String>())
             .setEncryptionSpec(EncryptionSpec.newBuilder().build())
             .setModelMonitoringConfig(ModelMonitoringConfig.newBuilder().build())
+            .addAllModelMonitoringStatsAnomalies(new ArrayList<ModelMonitoringStatsAnomalies>())
+            .setModelMonitoringStatus(Status.newBuilder().build())
             .build();
     mockJobService.addResponse(expectedResponse);
 
@@ -1636,6 +1638,8 @@ public void createBatchPredictionJobTest2() throws Exception {
             .putAllLabels(new HashMap<String, String>())
             .setEncryptionSpec(EncryptionSpec.newBuilder().build())
             .setModelMonitoringConfig(ModelMonitoringConfig.newBuilder().build())
+            .addAllModelMonitoringStatsAnomalies(new ArrayList<ModelMonitoringStatsAnomalies>())
+            .setModelMonitoringStatus(Status.newBuilder().build())
             .build();
     mockJobService.addResponse(expectedResponse);
 
@@ -1705,6 +1709,8 @@ public void getBatchPredictionJobTest() throws Exception {
             .putAllLabels(new HashMap<String, String>())
             .setEncryptionSpec(EncryptionSpec.newBuilder().build())
             .setModelMonitoringConfig(ModelMonitoringConfig.newBuilder().build())
+            .addAllModelMonitoringStatsAnomalies(new ArrayList<ModelMonitoringStatsAnomalies>())
+            .setModelMonitoringStatus(Status.newBuilder().build())
             .build();
     mockJobService.addResponse(expectedResponse);
 
@@ -1773,6 +1779,8 @@ public void getBatchPredictionJobTest2() throws Exception {
             .putAllLabels(new HashMap<String, String>())
             .setEncryptionSpec(EncryptionSpec.newBuilder().build())
             .setModelMonitoringConfig(ModelMonitoringConfig.newBuilder().build())
+            .addAllModelMonitoringStatsAnomalies(new ArrayList<ModelMonitoringStatsAnomalies>())
+            .setModelMonitoringStatus(Status.newBuilder().build())
             .build();
     mockJobService.addResponse(expectedResponse);
 
diff --git a/java-aiplatform/proto-google-cloud-aiplatform-v1beta1/src/main/java/com/google/cloud/aiplatform/v1beta1/BatchPredictionJob.java b/java-aiplatform/proto-google-cloud-aiplatform-v1beta1/src/main/java/com/google/cloud/aiplatform/v1beta1/BatchPredictionJob.java
index b0f14ec5a75d..251b287d7eae 100644
--- a/java-aiplatform/proto-google-cloud-aiplatform-v1beta1/src/main/java/com/google/cloud/aiplatform/v1beta1/BatchPredictionJob.java
+++ b/java-aiplatform/proto-google-cloud-aiplatform-v1beta1/src/main/java/com/google/cloud/aiplatform/v1beta1/BatchPredictionJob.java
@@ -48,6 +48,7 @@ private BatchPredictionJob() {
     serviceAccount_ = "";
     state_ = 0;
     partialFailures_ = java.util.Collections.emptyList();
+    modelMonitoringStatsAnomalies_ = java.util.Collections.emptyList();
   }
 
   @java.lang.Override
@@ -428,6 +429,35 @@ private BatchPredictionJob(
               java.lang.String s = input.readStringRequireUtf8();
 
               modelVersionId_ = s;
+              break;
+            }
+          case 250:
+            {
+              if (!((mutable_bitField0_ & 0x00000004) != 0)) {
+                modelMonitoringStatsAnomalies_ =
+                    new java.util.ArrayList<
+                        com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies>();
+                mutable_bitField0_ |= 0x00000004;
+              }
+              modelMonitoringStatsAnomalies_.add(
+                  input.readMessage(
+                      com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies.parser(),
+                      extensionRegistry));
+              break;
+            }
+          case 258:
+            {
+              com.google.rpc.Status.Builder subBuilder = null;
+              if (modelMonitoringStatus_ != null) {
+                subBuilder = modelMonitoringStatus_.toBuilder();
+              }
+              modelMonitoringStatus_ =
+                  input.readMessage(com.google.rpc.Status.parser(), extensionRegistry);
+              if (subBuilder != null) {
+                subBuilder.mergeFrom(modelMonitoringStatus_);
+                modelMonitoringStatus_ = subBuilder.buildPartial();
+              }
+
               break;
             }
           default:
@@ -449,6 +479,10 @@ private BatchPredictionJob(
       if (((mutable_bitField0_ & 0x00000001) != 0)) {
         partialFailures_ = java.util.Collections.unmodifiableList(partialFailures_);
       }
+      if (((mutable_bitField0_ & 0x00000004) != 0)) {
+        modelMonitoringStatsAnomalies_ =
+            java.util.Collections.unmodifiableList(modelMonitoringStatsAnomalies_);
+      }
       this.unknownFields = unknownFields.build();
       makeExtensionsImmutable();
     }
@@ -6894,6 +6928,144 @@ public com.google.cloud.aiplatform.v1beta1.ModelMonitoringConfig getModelMonitor
     return getModelMonitoringConfig();
   }
 
+  public static final int MODEL_MONITORING_STATS_ANOMALIES_FIELD_NUMBER = 31;
+  private java.util.List<com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies>
+      modelMonitoringStatsAnomalies_;
+  /**
+   *
+   *
+   * <pre>
+   * Get batch prediction job monitoring statistics.
+   * </pre>
+   *
+   * <code>
+   * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+   * </code>
+   */
+  @java.lang.Override
+  public java.util.List<com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies>
+      getModelMonitoringStatsAnomaliesList() {
+    return modelMonitoringStatsAnomalies_;
+  }
+  /**
+   *
+   *
+   * <pre>
+   * Get batch prediction job monitoring statistics.
+   * </pre>
+   *
+   * <code>
+   * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+   * </code>
+   */
+  @java.lang.Override
+  public java.util.List<
+          ? extends com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomaliesOrBuilder>
+      getModelMonitoringStatsAnomaliesOrBuilderList() {
+    return modelMonitoringStatsAnomalies_;
+  }
+  /**
+   *
+   *
+   * <pre>
+   * Get batch prediction job monitoring statistics.
+   * </pre>
+   *
+   * <code>
+   * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+   * </code>
+   */
+  @java.lang.Override
+  public int getModelMonitoringStatsAnomaliesCount() {
+    return modelMonitoringStatsAnomalies_.size();
+  }
+  /**
+   *
+   *
+   * <pre>
+   * Get batch prediction job monitoring statistics.
+   * </pre>
+   *
+   * <code>
+   * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+   * </code>
+   */
+  @java.lang.Override
+  public com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies
+      getModelMonitoringStatsAnomalies(int index) {
+    return modelMonitoringStatsAnomalies_.get(index);
+  }
+  /**
+   *
+   *
+   * <pre>
+   * Get batch prediction job monitoring statistics.
+   * </pre>
+   *
+   * <code>
+   * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+   * </code>
+   */
+  @java.lang.Override
+  public com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomaliesOrBuilder
+      getModelMonitoringStatsAnomaliesOrBuilder(int index) {
+    return modelMonitoringStatsAnomalies_.get(index);
+  }
+
+  public static final int MODEL_MONITORING_STATUS_FIELD_NUMBER = 32;
+  private com.google.rpc.Status modelMonitoringStatus_;
+  /**
+   *
+   *
+   * <pre>
+   * Output only. The running status of the model monitoring pipeline.
+   * </pre>
+   *
+   * <code>
+   * .google.rpc.Status model_monitoring_status = 32 [(.google.api.field_behavior) = OUTPUT_ONLY];
+   * </code>
+   *
+   * @return Whether the modelMonitoringStatus field is set.
+   */
+  @java.lang.Override
+  public boolean hasModelMonitoringStatus() {
+    return modelMonitoringStatus_ != null;
+  }
+  /**
+   *
+   *
+   * <pre>
+   * Output only. The running status of the model monitoring pipeline.
+   * </pre>
+   *
+   * <code>
+   * .google.rpc.Status model_monitoring_status = 32 [(.google.api.field_behavior) = OUTPUT_ONLY];
+   * </code>
+   *
+   * @return The modelMonitoringStatus.
+   */
+  @java.lang.Override
+  public com.google.rpc.Status getModelMonitoringStatus() {
+    return modelMonitoringStatus_ == null
+        ? com.google.rpc.Status.getDefaultInstance()
+        : modelMonitoringStatus_;
+  }
+  /**
+   *
+   *
+   * <pre>
+   * Output only. The running status of the model monitoring pipeline.
+   * </pre>
+   *
+   * <code>
+   * .google.rpc.Status model_monitoring_status = 32 [(.google.api.field_behavior) = OUTPUT_ONLY];
+   * </code>
+   */
+  @java.lang.Override
+  public com.google.rpc.StatusOrBuilder getModelMonitoringStatusOrBuilder() {
+    return getModelMonitoringStatus();
+  }
+
   private byte memoizedIsInitialized = -1;
 
   @java.lang.Override
@@ -6985,6 +7157,12 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
     if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(modelVersionId_)) {
       com.google.protobuf.GeneratedMessageV3.writeString(output, 30, modelVersionId_);
     }
+    for (int i = 0; i < modelMonitoringStatsAnomalies_.size(); i++) {
+      output.writeMessage(31, modelMonitoringStatsAnomalies_.get(i));
+    }
+    if (modelMonitoringStatus_ != null) {
+      output.writeMessage(32, getModelMonitoringStatus());
+    }
     unknownFields.writeTo(output);
   }
 
@@ -7084,6 +7262,15 @@ public int getSerializedSize() {
     if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(modelVersionId_)) {
       size += com.google.protobuf.GeneratedMessageV3.computeStringSize(30, modelVersionId_);
     }
+    for (int i = 0; i < modelMonitoringStatsAnomalies_.size(); i++) {
+      size +=
+          com.google.protobuf.CodedOutputStream.computeMessageSize(
+              31, modelMonitoringStatsAnomalies_.get(i));
+    }
+    if (modelMonitoringStatus_ != null) {
+      size +=
+          com.google.protobuf.CodedOutputStream.computeMessageSize(32, getModelMonitoringStatus());
+    }
     size += unknownFields.getSerializedSize();
     memoizedSize = size;
     return size;
@@ -7178,6 +7365,12 @@ public boolean equals(final java.lang.Object obj) {
     if (hasModelMonitoringConfig()) {
       if (!getModelMonitoringConfig().equals(other.getModelMonitoringConfig())) return false;
     }
+    if (!getModelMonitoringStatsAnomaliesList()
+        .equals(other.getModelMonitoringStatsAnomaliesList())) return false;
+    if (hasModelMonitoringStatus() != other.hasModelMonitoringStatus()) return false;
+    if (hasModelMonitoringStatus()) {
+      if (!getModelMonitoringStatus().equals(other.getModelMonitoringStatus())) return false;
+    }
     if (!unknownFields.equals(other.unknownFields)) return false;
     return true;
   }
@@ -7279,6 +7472,14 @@ public int hashCode() {
       hash = (37 * hash) + MODEL_MONITORING_CONFIG_FIELD_NUMBER;
       hash = (53 * hash) + getModelMonitoringConfig().hashCode();
     }
+    if (getModelMonitoringStatsAnomaliesCount() > 0) {
+      hash = (37 * hash) + MODEL_MONITORING_STATS_ANOMALIES_FIELD_NUMBER;
+      hash = (53 * hash) + getModelMonitoringStatsAnomaliesList().hashCode();
+    }
+    if (hasModelMonitoringStatus()) {
+      hash = (37 * hash) + MODEL_MONITORING_STATUS_FIELD_NUMBER;
+      hash = (53 * hash) + getModelMonitoringStatus().hashCode();
+    }
     hash = (29 * hash) + unknownFields.hashCode();
     memoizedHashCode = hash;
     return hash;
@@ -7444,6 +7645,7 @@ private Builder(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
     private void maybeForceBuilderInitialization() {
       if (com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders) {
         getPartialFailuresFieldBuilder();
+        getModelMonitoringStatsAnomaliesFieldBuilder();
       }
     }
 
@@ -7573,6 +7775,18 @@ public Builder clear() {
         modelMonitoringConfig_ = null;
         modelMonitoringConfigBuilder_ = null;
       }
+      if (modelMonitoringStatsAnomaliesBuilder_ == null) {
+        modelMonitoringStatsAnomalies_ = java.util.Collections.emptyList();
+        bitField0_ = (bitField0_ & ~0x00000004);
+      } else {
+        modelMonitoringStatsAnomaliesBuilder_.clear();
+      }
+      if (modelMonitoringStatusBuilder_ == null) {
+        modelMonitoringStatus_ = null;
+      } else {
+        modelMonitoringStatus_ = null;
+        modelMonitoringStatusBuilder_ = null;
+      }
       return this;
     }
 
@@ -7704,6 +7918,21 @@ public com.google.cloud.aiplatform.v1beta1.BatchPredictionJob buildPartial() {
       } else {
         result.modelMonitoringConfig_ = modelMonitoringConfigBuilder_.build();
       }
+      if (modelMonitoringStatsAnomaliesBuilder_ == null) {
+        if (((bitField0_ & 0x00000004) != 0)) {
+          modelMonitoringStatsAnomalies_ =
+              java.util.Collections.unmodifiableList(modelMonitoringStatsAnomalies_);
+          bitField0_ = (bitField0_ & ~0x00000004);
+        }
+        result.modelMonitoringStatsAnomalies_ = modelMonitoringStatsAnomalies_;
+      } else {
+        result.modelMonitoringStatsAnomalies_ = modelMonitoringStatsAnomaliesBuilder_.build();
+      }
+      if (modelMonitoringStatusBuilder_ == null) {
+        result.modelMonitoringStatus_ = modelMonitoringStatus_;
+      } else {
+        result.modelMonitoringStatus_ = modelMonitoringStatusBuilder_.build();
+      }
       onBuilt();
       return result;
     }
@@ -7859,6 +8088,37 @@ public Builder mergeFrom(com.google.cloud.aiplatform.v1beta1.BatchPredictionJob
       if (other.hasModelMonitoringConfig()) {
         mergeModelMonitoringConfig(other.getModelMonitoringConfig());
       }
+      if (modelMonitoringStatsAnomaliesBuilder_ == null) {
+        if (!other.modelMonitoringStatsAnomalies_.isEmpty()) {
+          if (modelMonitoringStatsAnomalies_.isEmpty()) {
+            modelMonitoringStatsAnomalies_ = other.modelMonitoringStatsAnomalies_;
+            bitField0_ = (bitField0_ & ~0x00000004);
+          } else {
+            ensureModelMonitoringStatsAnomaliesIsMutable();
+            modelMonitoringStatsAnomalies_.addAll(other.modelMonitoringStatsAnomalies_);
+          }
+          onChanged();
+        }
+      } else {
+        if (!other.modelMonitoringStatsAnomalies_.isEmpty()) {
+          if (modelMonitoringStatsAnomaliesBuilder_.isEmpty()) {
+            modelMonitoringStatsAnomaliesBuilder_.dispose();
+            modelMonitoringStatsAnomaliesBuilder_ = null;
+            modelMonitoringStatsAnomalies_ = other.modelMonitoringStatsAnomalies_;
+            bitField0_ = (bitField0_ & ~0x00000004);
+            modelMonitoringStatsAnomaliesBuilder_ =
+                com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders
+                    ? getModelMonitoringStatsAnomaliesFieldBuilder()
+                    : null;
+          } else {
+            modelMonitoringStatsAnomaliesBuilder_.addAllMessages(
+                other.modelMonitoringStatsAnomalies_);
+          }
+        }
+      }
+      if (other.hasModelMonitoringStatus()) {
+        mergeModelMonitoringStatus(other.getModelMonitoringStatus());
+      }
       this.mergeUnknownFields(other.unknownFields);
       onChanged();
       return this;
@@ -13011,6 +13271,617 @@ public Builder clearModelMonitoringConfig() {
       return modelMonitoringConfigBuilder_;
     }
 
+    private java.util.List<com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies>
+        modelMonitoringStatsAnomalies_ = java.util.Collections.emptyList();
+
+    private void ensureModelMonitoringStatsAnomaliesIsMutable() {
+      if (!((bitField0_ & 0x00000004) != 0)) {
+        modelMonitoringStatsAnomalies_ =
+            new java.util.ArrayList<
+                com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies>(
+                modelMonitoringStatsAnomalies_);
+        bitField0_ |= 0x00000004;
+      }
+    }
+
+    private com.google.protobuf.RepeatedFieldBuilderV3<
+            com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies,
+            com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies.Builder,
+            com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomaliesOrBuilder>
+        modelMonitoringStatsAnomaliesBuilder_;
+
+    /**
+     *
+     *
+     * <pre>
+     * Get batch prediction job monitoring statistics.
+     * </pre>
+     *
+     * <code>
+     * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+     * </code>
+     */
+    public java.util.List<com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies>
+        getModelMonitoringStatsAnomaliesList() {
+      if (modelMonitoringStatsAnomaliesBuilder_ == null) {
+        return java.util.Collections.unmodifiableList(modelMonitoringStatsAnomalies_);
+      } else {
+        return modelMonitoringStatsAnomaliesBuilder_.getMessageList();
+      }
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Get batch prediction job monitoring statistics.
+     * </pre>
+     *
+     * <code>
+     * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+     * </code>
+     */
+    public int getModelMonitoringStatsAnomaliesCount() {
+      if (modelMonitoringStatsAnomaliesBuilder_ == null) {
+        return modelMonitoringStatsAnomalies_.size();
+      } else {
+        return modelMonitoringStatsAnomaliesBuilder_.getCount();
+      }
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Get batch prediction job monitoring statistics.
+     * </pre>
+     *
+     * <code>
+     * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+     * </code>
+     */
+    public com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies
+        getModelMonitoringStatsAnomalies(int index) {
+      if (modelMonitoringStatsAnomaliesBuilder_ == null) {
+        return modelMonitoringStatsAnomalies_.get(index);
+      } else {
+        return modelMonitoringStatsAnomaliesBuilder_.getMessage(index);
+      }
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Get batch prediction job monitoring statistics.
+     * </pre>
+     *
+     * <code>
+     * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+     * </code>
+     */
+    public Builder setModelMonitoringStatsAnomalies(
+        int index, com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies value) {
+      if (modelMonitoringStatsAnomaliesBuilder_ == null) {
+        if (value == null) {
+          throw new NullPointerException();
+        }
+        ensureModelMonitoringStatsAnomaliesIsMutable();
+        modelMonitoringStatsAnomalies_.set(index, value);
+        onChanged();
+      } else {
+        modelMonitoringStatsAnomaliesBuilder_.setMessage(index, value);
+      }
+      return this;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Get batch prediction job monitoring statistics.
+     * </pre>
+     *
+     * <code>
+     * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+     * </code>
+     */
+    public Builder setModelMonitoringStatsAnomalies(
+        int index,
+        com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies.Builder builderForValue) {
+      if (modelMonitoringStatsAnomaliesBuilder_ == null) {
+        ensureModelMonitoringStatsAnomaliesIsMutable();
+        modelMonitoringStatsAnomalies_.set(index, builderForValue.build());
+        onChanged();
+      } else {
+        modelMonitoringStatsAnomaliesBuilder_.setMessage(index, builderForValue.build());
+      }
+      return this;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Get batch prediction job monitoring statistics.
+     * </pre>
+     *
+     * <code>
+     * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+     * </code>
+     */
+    public Builder addModelMonitoringStatsAnomalies(
+        com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies value) {
+      if (modelMonitoringStatsAnomaliesBuilder_ == null) {
+        if (value == null) {
+          throw new NullPointerException();
+        }
+        ensureModelMonitoringStatsAnomaliesIsMutable();
+        modelMonitoringStatsAnomalies_.add(value);
+        onChanged();
+      } else {
+        modelMonitoringStatsAnomaliesBuilder_.addMessage(value);
+      }
+      return this;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Get batch prediction job monitoring statistics.
+     * </pre>
+     *
+     * <code>
+     * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+     * </code>
+     */
+    public Builder addModelMonitoringStatsAnomalies(
+        int index, com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies value) {
+      if (modelMonitoringStatsAnomaliesBuilder_ == null) {
+        if (value == null) {
+          throw new NullPointerException();
+        }
+        ensureModelMonitoringStatsAnomaliesIsMutable();
+        modelMonitoringStatsAnomalies_.add(index, value);
+        onChanged();
+      } else {
+        modelMonitoringStatsAnomaliesBuilder_.addMessage(index, value);
+      }
+      return this;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Get batch prediction job monitoring statistics.
+     * </pre>
+     *
+     * <code>
+     * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+     * </code>
+     */
+    public Builder addModelMonitoringStatsAnomalies(
+        com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies.Builder builderForValue) {
+      if (modelMonitoringStatsAnomaliesBuilder_ == null) {
+        ensureModelMonitoringStatsAnomaliesIsMutable();
+        modelMonitoringStatsAnomalies_.add(builderForValue.build());
+        onChanged();
+      } else {
+        modelMonitoringStatsAnomaliesBuilder_.addMessage(builderForValue.build());
+      }
+      return this;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Get batch prediction job monitoring statistics.
+     * </pre>
+     *
+     * <code>
+     * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+     * </code>
+     */
+    public Builder addModelMonitoringStatsAnomalies(
+        int index,
+        com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies.Builder builderForValue) {
+      if (modelMonitoringStatsAnomaliesBuilder_ == null) {
+        ensureModelMonitoringStatsAnomaliesIsMutable();
+        modelMonitoringStatsAnomalies_.add(index, builderForValue.build());
+        onChanged();
+      } else {
+        modelMonitoringStatsAnomaliesBuilder_.addMessage(index, builderForValue.build());
+      }
+      return this;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Get batch prediction job monitoring statistics.
+     * </pre>
+     *
+     * <code>
+     * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+     * </code>
+     */
+    public Builder addAllModelMonitoringStatsAnomalies(
+        java.lang.Iterable<
+                ? extends com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies>
+            values) {
+      if (modelMonitoringStatsAnomaliesBuilder_ == null) {
+        ensureModelMonitoringStatsAnomaliesIsMutable();
+        com.google.protobuf.AbstractMessageLite.Builder.addAll(
+            values, modelMonitoringStatsAnomalies_);
+        onChanged();
+      } else {
+        modelMonitoringStatsAnomaliesBuilder_.addAllMessages(values);
+      }
+      return this;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Get batch prediction job monitoring statistics.
+     * </pre>
+     *
+     * <code>
+     * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+     * </code>
+     */
+    public Builder clearModelMonitoringStatsAnomalies() {
+      if (modelMonitoringStatsAnomaliesBuilder_ == null) {
+        modelMonitoringStatsAnomalies_ = java.util.Collections.emptyList();
+        bitField0_ = (bitField0_ & ~0x00000004);
+        onChanged();
+      } else {
+        modelMonitoringStatsAnomaliesBuilder_.clear();
+      }
+      return this;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Get batch prediction job monitoring statistics.
+     * </pre>
+     *
+     * <code>
+     * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+     * </code>
+     */
+    public Builder removeModelMonitoringStatsAnomalies(int index) {
+      if (modelMonitoringStatsAnomaliesBuilder_ == null) {
+        ensureModelMonitoringStatsAnomaliesIsMutable();
+        modelMonitoringStatsAnomalies_.remove(index);
+        onChanged();
+      } else {
+        modelMonitoringStatsAnomaliesBuilder_.remove(index);
+      }
+      return this;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Get batch prediction job monitoring statistics.
+     * </pre>
+     *
+     * <code>
+     * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+     * </code>
+     */
+    public com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies.Builder
+        getModelMonitoringStatsAnomaliesBuilder(int index) {
+      return getModelMonitoringStatsAnomaliesFieldBuilder().getBuilder(index);
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Get batch prediction job monitoring statistics.
+     * </pre>
+     *
+     * <code>
+     * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+     * </code>
+     */
+    public com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomaliesOrBuilder
+        getModelMonitoringStatsAnomaliesOrBuilder(int index) {
+      if (modelMonitoringStatsAnomaliesBuilder_ == null) {
+        return modelMonitoringStatsAnomalies_.get(index);
+      } else {
+        return modelMonitoringStatsAnomaliesBuilder_.getMessageOrBuilder(index);
+      }
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Get batch prediction job monitoring statistics.
+     * </pre>
+     *
+     * <code>
+     * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+     * </code>
+     */
+    public java.util.List<
+            ? extends com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomaliesOrBuilder>
+        getModelMonitoringStatsAnomaliesOrBuilderList() {
+      if (modelMonitoringStatsAnomaliesBuilder_ != null) {
+        return modelMonitoringStatsAnomaliesBuilder_.getMessageOrBuilderList();
+      } else {
+        return java.util.Collections.unmodifiableList(modelMonitoringStatsAnomalies_);
+      }
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Get batch prediction job monitoring statistics.
+     * </pre>
+     *
+     * <code>
+     * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+     * </code>
+     */
+    public com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies.Builder
+        addModelMonitoringStatsAnomaliesBuilder() {
+      return getModelMonitoringStatsAnomaliesFieldBuilder()
+          .addBuilder(
+              com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies
+                  .getDefaultInstance());
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Get batch prediction job monitoring statistics.
+     * </pre>
+     *
+     * <code>
+     * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+     * </code>
+     */
+    public com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies.Builder
+        addModelMonitoringStatsAnomaliesBuilder(int index) {
+      return getModelMonitoringStatsAnomaliesFieldBuilder()
+          .addBuilder(
+              index,
+              com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies
+                  .getDefaultInstance());
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Get batch prediction job monitoring statistics.
+     * </pre>
+     *
+     * <code>
+     * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+     * </code>
+     */
+    public java.util.List<com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies.Builder>
+        getModelMonitoringStatsAnomaliesBuilderList() {
+      return getModelMonitoringStatsAnomaliesFieldBuilder().getBuilderList();
+    }
+
+    private com.google.protobuf.RepeatedFieldBuilderV3<
+            com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies,
+            com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies.Builder,
+            com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomaliesOrBuilder>
+        getModelMonitoringStatsAnomaliesFieldBuilder() {
+      if (modelMonitoringStatsAnomaliesBuilder_ == null) {
+        modelMonitoringStatsAnomaliesBuilder_ =
+            new com.google.protobuf.RepeatedFieldBuilderV3<
+                com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies,
+                com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies.Builder,
+                com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomaliesOrBuilder>(
+                modelMonitoringStatsAnomalies_,
+                ((bitField0_ & 0x00000004) != 0),
+                getParentForChildren(),
+                isClean());
+        modelMonitoringStatsAnomalies_ = null;
+      }
+      return modelMonitoringStatsAnomaliesBuilder_;
+    }
+
+    private com.google.rpc.Status modelMonitoringStatus_;
+    private com.google.protobuf.SingleFieldBuilderV3<
+            com.google.rpc.Status, com.google.rpc.Status.Builder, com.google.rpc.StatusOrBuilder>
+        modelMonitoringStatusBuilder_;
+    /**
+     *
+     *
+     * <pre>
+     * Output only. The running status of the model monitoring pipeline.
+     * </pre>
+     *
+     * <code>
+     * .google.rpc.Status model_monitoring_status = 32 [(.google.api.field_behavior) = OUTPUT_ONLY];
+     * </code>
+     *
+     * @return Whether the modelMonitoringStatus field is set.
+     */
+    public boolean hasModelMonitoringStatus() {
+      return modelMonitoringStatusBuilder_ != null || modelMonitoringStatus_ != null;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Output only. The running status of the model monitoring pipeline.
+     * </pre>
+     *
+     * <code>
+     * .google.rpc.Status model_monitoring_status = 32 [(.google.api.field_behavior) = OUTPUT_ONLY];
+     * </code>
+     *
+     * @return The modelMonitoringStatus.
+     */
+    public com.google.rpc.Status getModelMonitoringStatus() {
+      if (modelMonitoringStatusBuilder_ == null) {
+        return modelMonitoringStatus_ == null
+            ? com.google.rpc.Status.getDefaultInstance()
+            : modelMonitoringStatus_;
+      } else {
+        return modelMonitoringStatusBuilder_.getMessage();
+      }
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Output only. The running status of the model monitoring pipeline.
+     * </pre>
+     *
+     * <code>
+     * .google.rpc.Status model_monitoring_status = 32 [(.google.api.field_behavior) = OUTPUT_ONLY];
+     * </code>
+     */
+    public Builder setModelMonitoringStatus(com.google.rpc.Status value) {
+      if (modelMonitoringStatusBuilder_ == null) {
+        if (value == null) {
+          throw new NullPointerException();
+        }
+        modelMonitoringStatus_ = value;
+        onChanged();
+      } else {
+        modelMonitoringStatusBuilder_.setMessage(value);
+      }
+
+      return this;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Output only. The running status of the model monitoring pipeline.
+     * </pre>
+     *
+     * <code>
+     * .google.rpc.Status model_monitoring_status = 32 [(.google.api.field_behavior) = OUTPUT_ONLY];
+     * </code>
+     */
+    public Builder setModelMonitoringStatus(com.google.rpc.Status.Builder builderForValue) {
+      if (modelMonitoringStatusBuilder_ == null) {
+        modelMonitoringStatus_ = builderForValue.build();
+        onChanged();
+      } else {
+        modelMonitoringStatusBuilder_.setMessage(builderForValue.build());
+      }
+
+      return this;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Output only. The running status of the model monitoring pipeline.
+     * </pre>
+     *
+     * <code>
+     * .google.rpc.Status model_monitoring_status = 32 [(.google.api.field_behavior) = OUTPUT_ONLY];
+     * </code>
+     */
+    public Builder mergeModelMonitoringStatus(com.google.rpc.Status value) {
+      if (modelMonitoringStatusBuilder_ == null) {
+        if (modelMonitoringStatus_ != null) {
+          modelMonitoringStatus_ =
+              com.google.rpc.Status.newBuilder(modelMonitoringStatus_)
+                  .mergeFrom(value)
+                  .buildPartial();
+        } else {
+          modelMonitoringStatus_ = value;
+        }
+        onChanged();
+      } else {
+        modelMonitoringStatusBuilder_.mergeFrom(value);
+      }
+
+      return this;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Output only. The running status of the model monitoring pipeline.
+     * </pre>
+     *
+     * <code>
+     * .google.rpc.Status model_monitoring_status = 32 [(.google.api.field_behavior) = OUTPUT_ONLY];
+     * </code>
+     */
+    public Builder clearModelMonitoringStatus() {
+      if (modelMonitoringStatusBuilder_ == null) {
+        modelMonitoringStatus_ = null;
+        onChanged();
+      } else {
+        modelMonitoringStatus_ = null;
+        modelMonitoringStatusBuilder_ = null;
+      }
+
+      return this;
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Output only. The running status of the model monitoring pipeline.
+     * </pre>
+     *
+     * <code>
+     * .google.rpc.Status model_monitoring_status = 32 [(.google.api.field_behavior) = OUTPUT_ONLY];
+     * </code>
+     */
+    public com.google.rpc.Status.Builder getModelMonitoringStatusBuilder() {
+
+      onChanged();
+      return getModelMonitoringStatusFieldBuilder().getBuilder();
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Output only. The running status of the model monitoring pipeline.
+     * </pre>
+     *
+     * <code>
+     * .google.rpc.Status model_monitoring_status = 32 [(.google.api.field_behavior) = OUTPUT_ONLY];
+     * </code>
+     */
+    public com.google.rpc.StatusOrBuilder getModelMonitoringStatusOrBuilder() {
+      if (modelMonitoringStatusBuilder_ != null) {
+        return modelMonitoringStatusBuilder_.getMessageOrBuilder();
+      } else {
+        return modelMonitoringStatus_ == null
+            ? com.google.rpc.Status.getDefaultInstance()
+            : modelMonitoringStatus_;
+      }
+    }
+    /**
+     *
+     *
+     * <pre>
+     * Output only. The running status of the model monitoring pipeline.
+     * </pre>
+     *
+     * <code>
+     * .google.rpc.Status model_monitoring_status = 32 [(.google.api.field_behavior) = OUTPUT_ONLY];
+     * </code>
+     */
+    private com.google.protobuf.SingleFieldBuilderV3<
+            com.google.rpc.Status, com.google.rpc.Status.Builder, com.google.rpc.StatusOrBuilder>
+        getModelMonitoringStatusFieldBuilder() {
+      if (modelMonitoringStatusBuilder_ == null) {
+        modelMonitoringStatusBuilder_ =
+            new com.google.protobuf.SingleFieldBuilderV3<
+                com.google.rpc.Status,
+                com.google.rpc.Status.Builder,
+                com.google.rpc.StatusOrBuilder>(
+                getModelMonitoringStatus(), getParentForChildren(), isClean());
+        modelMonitoringStatus_ = null;
+      }
+      return modelMonitoringStatusBuilder_;
+    }
+
     @java.lang.Override
     public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {
       return super.setUnknownFields(unknownFields);
diff --git a/java-aiplatform/proto-google-cloud-aiplatform-v1beta1/src/main/java/com/google/cloud/aiplatform/v1beta1/BatchPredictionJobOrBuilder.java b/java-aiplatform/proto-google-cloud-aiplatform-v1beta1/src/main/java/com/google/cloud/aiplatform/v1beta1/BatchPredictionJobOrBuilder.java
index 2181a752e4a3..b50354c86f04 100644
--- a/java-aiplatform/proto-google-cloud-aiplatform-v1beta1/src/main/java/com/google/cloud/aiplatform/v1beta1/BatchPredictionJobOrBuilder.java
+++ b/java-aiplatform/proto-google-cloud-aiplatform-v1beta1/src/main/java/com/google/cloud/aiplatform/v1beta1/BatchPredictionJobOrBuilder.java
@@ -1147,4 +1147,111 @@ java.lang.String getLabelsOrDefault(
    */
   com.google.cloud.aiplatform.v1beta1.ModelMonitoringConfigOrBuilder
       getModelMonitoringConfigOrBuilder();
+
+  /**
+   *
+   *
+   * <pre>
+   * Get batch prediction job monitoring statistics.
+   * </pre>
+   *
+   * <code>
+   * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+   * </code>
+   */
+  java.util.List<com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies>
+      getModelMonitoringStatsAnomaliesList();
+  /**
+   *
+   *
+   * <pre>
+   * Get batch prediction job monitoring statistics.
+   * </pre>
+   *
+   * <code>
+   * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+   * </code>
+   */
+  com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies
+      getModelMonitoringStatsAnomalies(int index);
+  /**
+   *
+   *
+   * <pre>
+   * Get batch prediction job monitoring statistics.
+   * </pre>
+   *
+   * <code>
+   * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+   * </code>
+   */
+  int getModelMonitoringStatsAnomaliesCount();
+  /**
+   *
+   *
+   * <pre>
+   * Get batch prediction job monitoring statistics.
+   * </pre>
+   *
+   * <code>
+   * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+   * </code>
+   */
+  java.util.List<
+          ? extends com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomaliesOrBuilder>
+      getModelMonitoringStatsAnomaliesOrBuilderList();
+  /**
+   *
+   *
+   * <pre>
+   * Get batch prediction job monitoring statistics.
+   * </pre>
+   *
+   * <code>
+   * repeated .google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+   * </code>
+   */
+  com.google.cloud.aiplatform.v1beta1.ModelMonitoringStatsAnomaliesOrBuilder
+      getModelMonitoringStatsAnomaliesOrBuilder(int index);
+
+  /**
+   *
+   *
+   * <pre>
+   * Output only. The running status of the model monitoring pipeline.
+   * </pre>
+   *
+   * <code>
+   * .google.rpc.Status model_monitoring_status = 32 [(.google.api.field_behavior) = OUTPUT_ONLY];
+   * </code>
+   *
+   * @return Whether the modelMonitoringStatus field is set.
+   */
+  boolean hasModelMonitoringStatus();
+  /**
+   *
+   *
+   * <pre>
+   * Output only. The running status of the model monitoring pipeline.
+   * </pre>
+   *
+   * <code>
+   * .google.rpc.Status model_monitoring_status = 32 [(.google.api.field_behavior) = OUTPUT_ONLY];
+   * </code>
+   *
+   * @return The modelMonitoringStatus.
+   */
+  com.google.rpc.Status getModelMonitoringStatus();
+  /**
+   *
+   *
+   * <pre>
+   * Output only. The running status of the model monitoring pipeline.
+   * </pre>
+   *
+   * <code>
+   * .google.rpc.Status model_monitoring_status = 32 [(.google.api.field_behavior) = OUTPUT_ONLY];
+   * </code>
+   */
+  com.google.rpc.StatusOrBuilder getModelMonitoringStatusOrBuilder();
 }
diff --git a/java-aiplatform/proto-google-cloud-aiplatform-v1beta1/src/main/java/com/google/cloud/aiplatform/v1beta1/BatchPredictionJobProto.java b/java-aiplatform/proto-google-cloud-aiplatform-v1beta1/src/main/java/com/google/cloud/aiplatform/v1beta1/BatchPredictionJobProto.java
index 37ca9b46d464..7f78cef8e1e7 100644
--- a/java-aiplatform/proto-google-cloud-aiplatform-v1beta1/src/main/java/com/google/cloud/aiplatform/v1beta1/BatchPredictionJobProto.java
+++ b/java-aiplatform/proto-google-cloud-aiplatform-v1beta1/src/main/java/com/google/cloud/aiplatform/v1beta1/BatchPredictionJobProto.java
@@ -69,79 +69,85 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
           + ".proto\0327google/cloud/aiplatform/v1beta1/"
           + "machine_resources.proto\032Dgoogle/cloud/ai"
           + "platform/v1beta1/manual_batch_tuning_par"
-          + "ameters.proto\0326google/cloud/aiplatform/v"
-          + "1beta1/model_monitoring.proto\032?google/cl"
-          + "oud/aiplatform/v1beta1/unmanaged_contain"
-          + "er_model.proto\032\034google/protobuf/struct.p"
-          + "roto\032\037google/protobuf/timestamp.proto\032\027g"
-          + "oogle/rpc/status.proto\"\373\022\n\022BatchPredicti"
-          + "onJob\022\021\n\004name\030\001 \001(\tB\003\340A\003\022\031\n\014display_name"
-          + "\030\002 \001(\tB\003\340A\002\0223\n\005model\030\003 \001(\tB$\372A!\n\037aiplatf"
-          + "orm.googleapis.com/Model\022\035\n\020model_versio"
-          + "n_id\030\036 \001(\tB\003\340A\003\022[\n\031unmanaged_container_m"
-          + "odel\030\034 \001(\01328.google.cloud.aiplatform.v1b"
-          + "eta1.UnmanagedContainerModel\022Z\n\014input_co"
-          + "nfig\030\004 \001(\0132?.google.cloud.aiplatform.v1b"
-          + "eta1.BatchPredictionJob.InputConfigB\003\340A\002"
-          + "\0220\n\020model_parameters\030\005 \001(\0132\026.google.prot"
-          + "obuf.Value\022\\\n\routput_config\030\006 \001(\0132@.goog"
-          + "le.cloud.aiplatform.v1beta1.BatchPredict"
-          + "ionJob.OutputConfigB\003\340A\002\022U\n\023dedicated_re"
-          + "sources\030\007 \001(\01328.google.cloud.aiplatform."
-          + "v1beta1.BatchDedicatedResources\022\027\n\017servi"
-          + "ce_account\030\035 \001(\t\022i\n\036manual_batch_tuning_"
-          + "parameters\030\010 \001(\0132<.google.cloud.aiplatfo"
-          + "rm.v1beta1.ManualBatchTuningParametersB\003"
-          + "\340A\005\022\034\n\024generate_explanation\030\027 \001(\010\022J\n\020exp"
-          + "lanation_spec\030\031 \001(\01320.google.cloud.aipla"
-          + "tform.v1beta1.ExplanationSpec\022X\n\013output_"
-          + "info\030\t \001(\0132>.google.cloud.aiplatform.v1b"
-          + "eta1.BatchPredictionJob.OutputInfoB\003\340A\003\022"
-          + "=\n\005state\030\n \001(\0162).google.cloud.aiplatform"
-          + ".v1beta1.JobStateB\003\340A\003\022&\n\005error\030\013 \001(\0132\022."
-          + "google.rpc.StatusB\003\340A\003\0221\n\020partial_failur"
-          + "es\030\014 \003(\0132\022.google.rpc.StatusB\003\340A\003\022S\n\022res"
-          + "ources_consumed\030\r \001(\01322.google.cloud.aip"
-          + "latform.v1beta1.ResourcesConsumedB\003\340A\003\022O"
-          + "\n\020completion_stats\030\016 \001(\01320.google.cloud."
-          + "aiplatform.v1beta1.CompletionStatsB\003\340A\003\022"
-          + "4\n\013create_time\030\017 \001(\0132\032.google.protobuf.T"
-          + "imestampB\003\340A\003\0223\n\nstart_time\030\020 \001(\0132\032.goog"
-          + "le.protobuf.TimestampB\003\340A\003\0221\n\010end_time\030\021"
-          + " \001(\0132\032.google.protobuf.TimestampB\003\340A\003\0224\n"
-          + "\013update_time\030\022 \001(\0132\032.google.protobuf.Tim"
-          + "estampB\003\340A\003\022O\n\006labels\030\023 \003(\0132?.google.clo"
-          + "ud.aiplatform.v1beta1.BatchPredictionJob"
-          + ".LabelsEntry\022H\n\017encryption_spec\030\030 \001(\0132/."
-          + "google.cloud.aiplatform.v1beta1.Encrypti"
-          + "onSpec\022W\n\027model_monitoring_config\030\032 \001(\0132"
-          + "6.google.cloud.aiplatform.v1beta1.ModelM"
-          + "onitoringConfig\032\304\001\n\013InputConfig\022@\n\ngcs_s"
-          + "ource\030\002 \001(\0132*.google.cloud.aiplatform.v1"
-          + "beta1.GcsSourceH\000\022J\n\017bigquery_source\030\003 \001"
-          + "(\0132/.google.cloud.aiplatform.v1beta1.Big"
-          + "QuerySourceH\000\022\035\n\020instances_format\030\001 \001(\tB"
-          + "\003\340A\002B\010\n\006source\032\340\001\n\014OutputConfig\022J\n\017gcs_d"
-          + "estination\030\002 \001(\0132/.google.cloud.aiplatfo"
-          + "rm.v1beta1.GcsDestinationH\000\022T\n\024bigquery_"
-          + "destination\030\003 \001(\01324.google.cloud.aiplatf"
-          + "orm.v1beta1.BigQueryDestinationH\000\022\037\n\022pre"
-          + "dictions_format\030\001 \001(\tB\003\340A\002B\r\n\013destinatio"
-          + "n\032\220\001\n\nOutputInfo\022#\n\024gcs_output_directory"
-          + "\030\001 \001(\tB\003\340A\003H\000\022&\n\027bigquery_output_dataset"
-          + "\030\002 \001(\tB\003\340A\003H\000\022\"\n\025bigquery_output_table\030\004"
-          + " \001(\tB\003\340A\003B\021\n\017output_location\032-\n\013LabelsEn"
-          + "try\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001:\206\001\352A"
-          + "\202\001\n,aiplatform.googleapis.com/BatchPredi"
-          + "ctionJob\022Rprojects/{project}/locations/{"
-          + "location}/batchPredictionJobs/{batch_pre"
-          + "diction_job}B\364\001\n#com.google.cloud.aiplat"
-          + "form.v1beta1B\027BatchPredictionJobProtoP\001Z"
-          + "Igoogle.golang.org/genproto/googleapis/c"
-          + "loud/aiplatform/v1beta1;aiplatform\252\002\037Goo"
-          + "gle.Cloud.AIPlatform.V1Beta1\312\002\037Google\\Cl"
-          + "oud\\AIPlatform\\V1beta1\352\002\"Google::Cloud::"
-          + "AIPlatform::V1beta1b\006proto3"
+          + "ameters.proto\032Egoogle/cloud/aiplatform/v"
+          + "1beta1/model_deployment_monitoring_job.p"
+          + "roto\0326google/cloud/aiplatform/v1beta1/mo"
+          + "del_monitoring.proto\032?google/cloud/aipla"
+          + "tform/v1beta1/unmanaged_container_model."
+          + "proto\032\034google/protobuf/struct.proto\032\037goo"
+          + "gle/protobuf/timestamp.proto\032\027google/rpc"
+          + "/status.proto\"\237\024\n\022BatchPredictionJob\022\021\n\004"
+          + "name\030\001 \001(\tB\003\340A\003\022\031\n\014display_name\030\002 \001(\tB\003\340"
+          + "A\002\0223\n\005model\030\003 \001(\tB$\372A!\n\037aiplatform.googl"
+          + "eapis.com/Model\022\035\n\020model_version_id\030\036 \001("
+          + "\tB\003\340A\003\022[\n\031unmanaged_container_model\030\034 \001("
+          + "\01328.google.cloud.aiplatform.v1beta1.Unma"
+          + "nagedContainerModel\022Z\n\014input_config\030\004 \001("
+          + "\0132?.google.cloud.aiplatform.v1beta1.Batc"
+          + "hPredictionJob.InputConfigB\003\340A\002\0220\n\020model"
+          + "_parameters\030\005 \001(\0132\026.google.protobuf.Valu"
+          + "e\022\\\n\routput_config\030\006 \001(\0132@.google.cloud."
+          + "aiplatform.v1beta1.BatchPredictionJob.Ou"
+          + "tputConfigB\003\340A\002\022U\n\023dedicated_resources\030\007"
+          + " \001(\01328.google.cloud.aiplatform.v1beta1.B"
+          + "atchDedicatedResources\022\027\n\017service_accoun"
+          + "t\030\035 \001(\t\022i\n\036manual_batch_tuning_parameter"
+          + "s\030\010 \001(\0132<.google.cloud.aiplatform.v1beta"
+          + "1.ManualBatchTuningParametersB\003\340A\005\022\034\n\024ge"
+          + "nerate_explanation\030\027 \001(\010\022J\n\020explanation_"
+          + "spec\030\031 \001(\01320.google.cloud.aiplatform.v1b"
+          + "eta1.ExplanationSpec\022X\n\013output_info\030\t \001("
+          + "\0132>.google.cloud.aiplatform.v1beta1.Batc"
+          + "hPredictionJob.OutputInfoB\003\340A\003\022=\n\005state\030"
+          + "\n \001(\0162).google.cloud.aiplatform.v1beta1."
+          + "JobStateB\003\340A\003\022&\n\005error\030\013 \001(\0132\022.google.rp"
+          + "c.StatusB\003\340A\003\0221\n\020partial_failures\030\014 \003(\0132"
+          + "\022.google.rpc.StatusB\003\340A\003\022S\n\022resources_co"
+          + "nsumed\030\r \001(\01322.google.cloud.aiplatform.v"
+          + "1beta1.ResourcesConsumedB\003\340A\003\022O\n\020complet"
+          + "ion_stats\030\016 \001(\01320.google.cloud.aiplatfor"
+          + "m.v1beta1.CompletionStatsB\003\340A\003\0224\n\013create"
+          + "_time\030\017 \001(\0132\032.google.protobuf.TimestampB"
+          + "\003\340A\003\0223\n\nstart_time\030\020 \001(\0132\032.google.protob"
+          + "uf.TimestampB\003\340A\003\0221\n\010end_time\030\021 \001(\0132\032.go"
+          + "ogle.protobuf.TimestampB\003\340A\003\0224\n\013update_t"
+          + "ime\030\022 \001(\0132\032.google.protobuf.TimestampB\003\340"
+          + "A\003\022O\n\006labels\030\023 \003(\0132?.google.cloud.aiplat"
+          + "form.v1beta1.BatchPredictionJob.LabelsEn"
+          + "try\022H\n\017encryption_spec\030\030 \001(\0132/.google.cl"
+          + "oud.aiplatform.v1beta1.EncryptionSpec\022W\n"
+          + "\027model_monitoring_config\030\032 \001(\01326.google."
+          + "cloud.aiplatform.v1beta1.ModelMonitoring"
+          + "Config\022h\n model_monitoring_stats_anomali"
+          + "es\030\037 \003(\0132>.google.cloud.aiplatform.v1bet"
+          + "a1.ModelMonitoringStatsAnomalies\0228\n\027mode"
+          + "l_monitoring_status\030  \001(\0132\022.google.rpc.S"
+          + "tatusB\003\340A\003\032\304\001\n\013InputConfig\022@\n\ngcs_source"
+          + "\030\002 \001(\0132*.google.cloud.aiplatform.v1beta1"
+          + ".GcsSourceH\000\022J\n\017bigquery_source\030\003 \001(\0132/."
+          + "google.cloud.aiplatform.v1beta1.BigQuery"
+          + "SourceH\000\022\035\n\020instances_format\030\001 \001(\tB\003\340A\002B"
+          + "\010\n\006source\032\340\001\n\014OutputConfig\022J\n\017gcs_destin"
+          + "ation\030\002 \001(\0132/.google.cloud.aiplatform.v1"
+          + "beta1.GcsDestinationH\000\022T\n\024bigquery_desti"
+          + "nation\030\003 \001(\01324.google.cloud.aiplatform.v"
+          + "1beta1.BigQueryDestinationH\000\022\037\n\022predicti"
+          + "ons_format\030\001 \001(\tB\003\340A\002B\r\n\013destination\032\220\001\n"
+          + "\nOutputInfo\022#\n\024gcs_output_directory\030\001 \001("
+          + "\tB\003\340A\003H\000\022&\n\027bigquery_output_dataset\030\002 \001("
+          + "\tB\003\340A\003H\000\022\"\n\025bigquery_output_table\030\004 \001(\tB"
+          + "\003\340A\003B\021\n\017output_location\032-\n\013LabelsEntry\022\013"
+          + "\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001:\206\001\352A\202\001\n,a"
+          + "iplatform.googleapis.com/BatchPrediction"
+          + "Job\022Rprojects/{project}/locations/{locat"
+          + "ion}/batchPredictionJobs/{batch_predicti"
+          + "on_job}B\364\001\n#com.google.cloud.aiplatform."
+          + "v1beta1B\027BatchPredictionJobProtoP\001ZIgoog"
+          + "le.golang.org/genproto/googleapis/cloud/"
+          + "aiplatform/v1beta1;aiplatform\252\002\037Google.C"
+          + "loud.AIPlatform.V1Beta1\312\002\037Google\\Cloud\\A"
+          + "IPlatform\\V1beta1\352\002\"Google::Cloud::AIPla"
+          + "tform::V1beta1b\006proto3"
     };
     descriptor =
         com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(
@@ -156,6 +162,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
               com.google.cloud.aiplatform.v1beta1.JobStateProto.getDescriptor(),
               com.google.cloud.aiplatform.v1beta1.MachineResourcesProto.getDescriptor(),
               com.google.cloud.aiplatform.v1beta1.ManualBatchTuningParametersProto.getDescriptor(),
+              com.google.cloud.aiplatform.v1beta1.ModelDeploymentMonitoringJobProto.getDescriptor(),
               com.google.cloud.aiplatform.v1beta1.ModelMonitoringProto.getDescriptor(),
               com.google.cloud.aiplatform.v1beta1.UnmanagedContainerModelProto.getDescriptor(),
               com.google.protobuf.StructProto.getDescriptor(),
@@ -194,6 +201,8 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
               "Labels",
               "EncryptionSpec",
               "ModelMonitoringConfig",
+              "ModelMonitoringStatsAnomalies",
+              "ModelMonitoringStatus",
             });
     internal_static_google_cloud_aiplatform_v1beta1_BatchPredictionJob_InputConfig_descriptor =
         internal_static_google_cloud_aiplatform_v1beta1_BatchPredictionJob_descriptor
@@ -254,6 +263,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
     com.google.cloud.aiplatform.v1beta1.JobStateProto.getDescriptor();
     com.google.cloud.aiplatform.v1beta1.MachineResourcesProto.getDescriptor();
     com.google.cloud.aiplatform.v1beta1.ManualBatchTuningParametersProto.getDescriptor();
+    com.google.cloud.aiplatform.v1beta1.ModelDeploymentMonitoringJobProto.getDescriptor();
     com.google.cloud.aiplatform.v1beta1.ModelMonitoringProto.getDescriptor();
     com.google.cloud.aiplatform.v1beta1.UnmanagedContainerModelProto.getDescriptor();
     com.google.protobuf.StructProto.getDescriptor();
diff --git a/java-aiplatform/proto-google-cloud-aiplatform-v1beta1/src/main/proto/google/cloud/aiplatform/v1beta1/batch_prediction_job.proto b/java-aiplatform/proto-google-cloud-aiplatform-v1beta1/src/main/proto/google/cloud/aiplatform/v1beta1/batch_prediction_job.proto
index 50b05edac2c0..5141dfa27410 100644
--- a/java-aiplatform/proto-google-cloud-aiplatform-v1beta1/src/main/proto/google/cloud/aiplatform/v1beta1/batch_prediction_job.proto
+++ b/java-aiplatform/proto-google-cloud-aiplatform-v1beta1/src/main/proto/google/cloud/aiplatform/v1beta1/batch_prediction_job.proto
@@ -25,6 +25,7 @@ import "google/cloud/aiplatform/v1beta1/io.proto";
 import "google/cloud/aiplatform/v1beta1/job_state.proto";
 import "google/cloud/aiplatform/v1beta1/machine_resources.proto";
 import "google/cloud/aiplatform/v1beta1/manual_batch_tuning_parameters.proto";
+import "google/cloud/aiplatform/v1beta1/model_deployment_monitoring_job.proto";
 import "google/cloud/aiplatform/v1beta1/model_monitoring.proto";
 import "google/cloud/aiplatform/v1beta1/unmanaged_container_model.proto";
 import "google/protobuf/struct.proto";
@@ -304,4 +305,10 @@ message BatchPredictionJob {
   // the input and output to the batch prediction job, as well as the provided
   // training dataset.
   ModelMonitoringConfig model_monitoring_config = 26;
+
+  // Get batch prediction job monitoring statistics.
+  repeated ModelMonitoringStatsAnomalies model_monitoring_stats_anomalies = 31;
+
+  // Output only. The running status of the model monitoring pipeline.
+  google.rpc.Status model_monitoring_status = 32 [(google.api.field_behavior) = OUTPUT_ONLY];
 }