samples: fix: small updates to dataproc sample, test and pom (#1738)

* refactored and added tags to infinite speech streaming sample (#1605)

* Changed 'main' region tag

* Removed extra lines around tags and changed client import to v1

* Create dataproc directory and add CreateCluster sample

* reverting changes to speech infinite streaming sample

* Added java versions to pom

* Several changes to file formatting as per request in the PR

* Added comments to exceptions in  CreateCluster, expanded exceptions and femoved endpoint configuring in CreateClusterTest.java

* Fixed version for parent config

* Added clarity to futures requests by expanding variables

* Fixed linting errors

* Fixed import ordering

* Moved exceptions to function level in dataproc create cluster sample + test

* Re-added endpoint to test, changed region tags to include 'dataproc', slight mod to pom

* fix to pom

dataproc/snippets/src/main/java/CreateCluster.java

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-// [START create_cluster]
+// [START dataproc_create_cluster]
 import com.google.api.gax.longrunning.OperationFuture;
 import com.google.cloud.dataproc.v1.Cluster;
 import com.google.cloud.dataproc.v1.ClusterConfig;
@@ -23,7 +23,6 @@
 import com.google.cloud.dataproc.v1.ClusterOperationMetadata;
 import com.google.cloud.dataproc.v1.InstanceGroupConfig;
 import java.io.IOException;
-import java.io.InterruptedIOException;
 import java.util.concurrent.ExecutionException;
 
 public class CreateCluster {
@@ -60,12 +59,12 @@ public static void createCluster(String projectId, String region, String cluster
           .setConfig(clusterConfig)
           .build();
 
-      // Send a request to create a Dataproc cluster.
+      // Create the Cloud Dataproc cluster
       OperationFuture<Cluster, ClusterOperationMetadata> createClusterAsyncRequest =
           clusterControllerClient.createClusterAsync(projectId, region, cluster);
       Cluster response = createClusterAsyncRequest.get();
 
-      // Print out the response
+      // Print out a success message
       System.out.println(
           String.format("Cluster created successfully: %s", response.getClusterName())
       );
@@ -81,4 +80,4 @@ public static void createCluster(String projectId, String region, String cluster
     }
   }
 }
-// [END create_cluster]
+// [END dataproc_create_cluster]

dataproc/snippets/src/test/java/CreateClusterTest.java

@@ -19,6 +19,7 @@
 
 import com.google.api.gax.longrunning.OperationFuture;
 import com.google.cloud.dataproc.v1.ClusterControllerClient;
+import com.google.cloud.dataproc.v1.ClusterControllerSettings;
 import com.google.cloud.dataproc.v1.ClusterOperationMetadata;
 import com.google.protobuf.Empty;
 import java.io.ByteArrayOutputStream;
@@ -75,8 +76,13 @@ public void createClusterTest() throws IOException, InterruptedException {
 
   @After
   public void tearDown() throws IOException, InterruptedException {
+    String myEndpoint = String.format("%s-dataproc.googleapis.com:443", REGION);
+
+    ClusterControllerSettings clusterControllerSettings =
+        ClusterControllerSettings.newBuilder().setEndpoint(myEndpoint).build();
+
     try (ClusterControllerClient clusterControllerClient = ClusterControllerClient
-        .create()) {
+        .create(clusterControllerSettings)) {
       OperationFuture<Empty, ClusterOperationMetadata> deleteClusterAsyncRequest =
           clusterControllerClient.deleteClusterAsync(projectId, REGION, clusterName);
       deleteClusterAsyncRequest.get();