Merge from main

.github/CODEOWNERS

@@ -79,7 +79,7 @@
 /speech                          @GoogleCloudPlatform/java-samples-reviewers @yoshi-approver @GoogleCloudPlatform/cloud-samples-reviewers
 /talent                          @GoogleCloudPlatform/java-samples-reviewers @yoshi-approver @GoogleCloudPlatform/cloud-samples-reviewers
 /texttospeech                    @GoogleCloudPlatform/java-samples-reviewers @yoshi-approver @GoogleCloudPlatform/cloud-samples-reviewers
-/translate                       @GoogleCloudPlatform/java-samples-reviewers @yoshi-approver @GoogleCloudPlatform/cloud-samples-reviewers
+/translate                       @GoogleCloudPlatform/java-samples-reviewers @yoshi-approver @GoogleCloudPlatform/cloud-samples-reviewers @GoogleCloudPlatform/cloud-ml-translate-dev
 /video                           @GoogleCloudPlatform/java-samples-reviewers @yoshi-approver @GoogleCloudPlatform/cloud-samples-reviewers
 /vision                          @GoogleCloudPlatform/java-samples-reviewers @yoshi-approver @GoogleCloudPlatform/cloud-samples-reviewers
 

.kokoro/tests/run_prptst_tests.sh

@@ -90,11 +90,4 @@ else
     echo -e "\n Testing completed.\n"
 fi
 
-# If this is a periodic build, send the test log to the FlakyBot except for Java 8
-# See https://github.com/googleapis/repo-automation-bots/tree/main/packages/flakybot.
-if [[ $JAVA_VERSION != "1.8" && $KOKORO_BUILD_ARTIFACTS_SUBDIR = *"periodic"* ]]; then
-    chmod +x $KOKORO_GFILE_DIR/linux_amd64/flakybot
-    $KOKORO_GFILE_DIR/linux_amd64/flakybot
-fi
-
 exit $RTN

.kokoro/tests/run_test_java.sh

@@ -96,11 +96,4 @@ if [[ "$file" == *"run/"* && ("$file" != *"run/filesystem"* && "$file" != *"run/
     fi
 fi
 
-# If this is a periodic build, send the test log to the FlakyBot except for Java 8
-# See https://github.com/googleapis/repo-automation-bots/tree/main/packages/flakybot.
-if [[ $JAVA_VERSION != "1.8" && $KOKORO_BUILD_ARTIFACTS_SUBDIR = *"periodic"* ]]; then
-    chmod +x $KOKORO_GFILE_DIR/linux_amd64/flakybot
-    $KOKORO_GFILE_DIR/linux_amd64/flakybot
-fi
-
 exit $RTN

compute/cloud-client/src/main/java/compute/CreateInstanceWithRegionalDiskFromSnapshot.java

@@ -0,0 +1,109 @@
+/*
+ * Copyright 2024 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package compute;
+
+// [START compute_instance_create_replicated_boot_disk]
+import com.google.cloud.compute.v1.AttachedDisk;
+import com.google.cloud.compute.v1.AttachedDiskInitializeParams;
+import com.google.cloud.compute.v1.Instance;
+import com.google.cloud.compute.v1.InstancesClient;
+import com.google.cloud.compute.v1.NetworkInterface;
+import com.google.cloud.compute.v1.Operation;
+import com.google.cloud.compute.v1.Operation.Status;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
+
+public class CreateInstanceWithRegionalDiskFromSnapshot {
+
+  public static void main(String[] args) throws IOException, ExecutionException,
+          InterruptedException, TimeoutException {
+    // TODO(developer): Replace these variables before running the sample
+    // Project ID or project number of the Cloud project you want to use.
+    String projectId = "YOUR_PROJECT_ID";
+    // Name of the zone in which you want to create the instance.
+    String zone = "us-central1-a";
+    // Name of the instance you want to create.
+    String instanceName = "YOUR_INSTANCE_NAME";
+    // Name for the replicated disk.
+    String diskName = "YOUR_REPLICATED_DISK_NAME";
+    String region = zone.substring(0, zone.length() - 2);
+    // Type of the disk.
+    String diskType = String.format(
+            "projects/%s/regions/%s/diskTypes/pd-standard", projectId, region);
+    // The full path and name of the snapshot that you want to use as the source for the new disk.
+    String snapshotLink = String.format("projects/%s/global/snapshots/%s", projectId,
+            "SNAPSHOT_NAME");
+    // An iterable collection of zone names in which you want to keep
+    // the new disks' replicas. One of the replica zones of the clone must match
+    // the zone of the source disk.
+    List<String> replicaZones = new ArrayList<>();
+
+    createInstanceWithRegionalDiskFromSnapshot(projectId, zone, instanceName, diskName, diskType,
+            snapshotLink, replicaZones);
+  }
+
+  // Creates a new VM instance with regional disk from a snapshot and specifies replica zones.
+  public static Status createInstanceWithRegionalDiskFromSnapshot(
+      String projectId, String zone, String instanceName, String diskName,
+      String diskType, String snapshotLink, List<String> replicaZones)
+          throws IOException, ExecutionException, InterruptedException, TimeoutException {
+    // Initialize client that will be used to send requests. This client only needs to be created
+    // once, and can be reused for multiple requests.
+    try (InstancesClient instancesClient = InstancesClient.create()) {
+      AttachedDiskInitializeParams initializeParams = AttachedDiskInitializeParams.newBuilder()
+              .setSourceSnapshot(snapshotLink)
+              .setDiskType(diskType)
+              .setDiskName(diskName)
+              .addAllReplicaZones(replicaZones)
+              .build();
+
+      // Boot disk configuration
+      AttachedDisk bootDisk = AttachedDisk.newBuilder()
+              .setBoot(true)
+              .setAutoDelete(true)  // Optional: Delete disk when instance is deleted.
+              .setType(AttachedDisk.Type.PERSISTENT.toString())
+              .setInitializeParams(initializeParams)
+              .build();
+
+      // Network interface configuration (using the default network)
+      NetworkInterface networkInterface = NetworkInterface.newBuilder()
+              .setNetwork("global/networks/default")
+              .build();
+
+      // Create the instance resource
+      Instance instanceResource = Instance.newBuilder()
+              .setName(instanceName)
+              .setMachineType(String.format("zones/%s/machineTypes/n1-standard-1", zone))
+              .addDisks(bootDisk)
+              .addNetworkInterfaces(networkInterface)
+              .build();
+
+      Operation response = instancesClient.insertAsync(projectId, zone, instanceResource).get(3,
+              TimeUnit.MINUTES);
+
+      if (response.hasError()) {
+        throw new Error("Error creating instance! " + response.getError());
+      }
+      return response.getStatus();
+    }
+  }
+}
+// [END compute_instance_create_replicated_boot_disk]

compute/cloud-client/src/main/java/compute/disks/AttachRegionalDiskForce.java

@@ -0,0 +1,81 @@
+/*
+ * Copyright 2024 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package compute.disks;
+
+// [START compute_instance_attach_regional_disk_force]
+import com.google.cloud.compute.v1.AttachDiskInstanceRequest;
+import com.google.cloud.compute.v1.AttachedDisk;
+import com.google.cloud.compute.v1.InstancesClient;
+import com.google.cloud.compute.v1.Operation;
+import com.google.cloud.compute.v1.Operation.Status;
+import java.io.IOException;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
+
+public class AttachRegionalDiskForce {
+  public static void main(String[] args)
+          throws IOException, InterruptedException, ExecutionException, TimeoutException {
+    // TODO(developer): Replace these variables before running the sample.
+    // Project ID or project number of the Cloud project you want to use.
+    String projectId = "YOUR_PROJECT_ID";
+    // Name of the zone of your compute instance.
+    String zone = "us-central1-a";
+    // The name of the compute instance where you are adding the replicated disk.
+    String instanceName = "YOUR_INSTANCE_NAME";
+    // The region where your replicated disk is located.
+    String region = "us-central1";
+    // The name of the replicated disk.
+    String diskName = "YOUR_DISK_NAME";
+
+    attachRegionalDiskForce(projectId, zone, instanceName, region, diskName);
+  }
+
+  // Attaches a regional disk to the instance,
+  // forcing the attachment even if other VMs are using the disk.
+  public static Status attachRegionalDiskForce(String projectId,
+         String zone, String instanceName, String region, String diskName)
+          throws IOException, InterruptedException, ExecutionException, TimeoutException {
+    String diskLink = String.format("projects/%s/regions/%s/disks/%s",
+            projectId, region, diskName);
+    // Initialize client that will be used to send requests. This client only needs to be created
+    // once, and can be reused for multiple requests.
+    try (InstancesClient instancesClient = InstancesClient.create()) {
+      AttachedDisk attachedDisk = AttachedDisk.newBuilder()
+              .setSource(diskLink)
+              .setMode(AttachedDisk.Mode.READ_WRITE.toString())
+              .build();
+
+      AttachDiskInstanceRequest attachDiskRequest = AttachDiskInstanceRequest.newBuilder()
+              .setProject(projectId)
+              .setZone(zone)
+              .setInstance(instanceName)
+              .setAttachedDiskResource(attachedDisk)
+              .setForceAttach(true) // Force the attachment
+              .build();
+
+      Operation response = instancesClient.attachDiskAsync(attachDiskRequest)
+              .get(3, TimeUnit.MINUTES);
+
+      if (response.hasError()) {
+        throw new Error("Error attaching regional disk! " + response);
+      }
+      return response.getStatus();
+    }
+  }
+}
+// [END compute_instance_attach_regional_disk_force]

compute/cloud-client/src/main/java/compute/disks/CreateDiskSecondaryRegional.java

@@ -0,0 +1,103 @@
+/*
+ * Copyright 2024 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package compute.disks;
+
+// [START compute_disk_create_secondary_regional]
+import com.google.cloud.compute.v1.Disk;
+import com.google.cloud.compute.v1.DiskAsyncReplication;
+import com.google.cloud.compute.v1.Operation;
+import com.google.cloud.compute.v1.Operation.Status;
+import com.google.cloud.compute.v1.RegionDisksClient;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.List;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.TimeoutException;
+
+public class CreateDiskSecondaryRegional {
+  public static void main(String[] args)
+      throws IOException, ExecutionException, InterruptedException, TimeoutException {
+    // TODO(developer): Replace these variables before running the sample.
+    // The project that contains the primary disk.
+    String primaryProjectId = "PRIMARY_PROJECT_ID";
+    // The project that contains the secondary disk.
+    String secondaryProjectId = "SECONDARY_PROJECT_ID";
+    // Name of the primary disk you want to use.
+    String primaryDiskName = "PRIMARY_DISK_NAME";
+    // Name of the disk you want to create.
+    String secondaryDiskName = "SECONDARY_DISK_NAME";
+    // Name of the region in which your primary disk is located.
+    // Learn more about zones and regions:
+    // https://cloud.google.com/compute/docs/disks/async-pd/about#supported_region_pairs
+    String primaryDiskRegion = "us-central1";
+    // Name of the region in which you want to create the secondary disk.
+    String secondaryDiskRegion = "us-east1";
+    // Size of the new disk in gigabytes.
+    // Learn more about disk requirements:
+    // https://cloud.google.com/compute/docs/disks/async-pd/configure?authuser=0#disk_requirements
+    long diskSizeGb = 30L;
+    // The type of the disk you want to create. This value uses the following format:
+    // "projects/{projectId}/zones/{zone}/diskTypes/
+    // (pd-standard|pd-ssd|pd-balanced|pd-extreme)".
+    String diskType = String.format(
+        "projects/%s/regions/%s/diskTypes/pd-balanced", secondaryProjectId, secondaryDiskRegion);
+
+    createDiskSecondaryRegional(primaryProjectId, secondaryProjectId, primaryDiskName,
+        secondaryDiskName, primaryDiskRegion, secondaryDiskRegion, diskSizeGb, diskType);
+  }
+
+  // Creates a secondary disk in a specified region.
+  public static Status createDiskSecondaryRegional(String projectId,
+       String secondaryProjectId, String primaryDiskName, String secondaryDiskName,
+       String primaryDiskRegion, String secondaryDiskRegion, long diskSizeGb, String diskType)
+      throws IOException, ExecutionException, InterruptedException, TimeoutException {
+    List<String> replicaZones = Arrays.asList(
+        String.format("projects/%s/zones/%s-c", secondaryProjectId, secondaryDiskRegion),
+        String.format("projects/%s/zones/%s-b", secondaryProjectId, secondaryDiskRegion));
+
+    String primaryDiskSource = String.format("projects/%s/regions/%s/disks/%s",
+        projectId, primaryDiskRegion, primaryDiskName);
+
+    // Initialize client that will be used to send requests. This client only needs to be created
+    // once, and can be reused for multiple requests.
+    try (RegionDisksClient disksClient = RegionDisksClient.create()) {
+      DiskAsyncReplication asyncReplication = DiskAsyncReplication.newBuilder()
+          .setDisk(primaryDiskSource)
+          .build();
+
+      Disk disk = Disk.newBuilder()
+          .addAllReplicaZones(replicaZones)
+          .setName(secondaryDiskName)
+          .setSizeGb(diskSizeGb)
+          .setType(diskType)
+          .setRegion(secondaryDiskRegion)
+          .setAsyncPrimaryDisk(asyncReplication)
+          .build();
+
+      // Wait for the create disk operation to complete.
+      Operation response = disksClient.insertAsync(secondaryProjectId, secondaryDiskRegion, disk)
+          .get(3, TimeUnit.MINUTES);
+
+      if (response.hasError()) {
+        throw new Error("Error creating secondary disks! " + response.getError());
+      }
+      return response.getStatus();
+    }
+  }
+}
+// [END compute_disk_create_secondary_regional]