diff --git a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/it/BigtableCmekIT.java b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/it/BigtableCmekIT.java index 2f219257c..60af52d6b 100644 --- a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/it/BigtableCmekIT.java +++ b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/it/BigtableCmekIT.java @@ -70,6 +70,7 @@ public class BigtableCmekIT { private static String instanceId; private static String clusterId1; private static String clusterId2; + private static String clusterId3; private static String kmsKeyName; private static List zones; private static String otherZone; @@ -91,6 +92,7 @@ public static void validatePlatform() throws IOException { instanceId = AbstractTestEnv.TEST_INSTANCE_PREFIX + Instant.now().getEpochSecond(); clusterId1 = instanceId + "-c1"; clusterId2 = instanceId + "-c2"; + clusterId3 = instanceId + "-c3"; zones = testEnvRule.env().getMultipleZonesInSameRegion(); otherZone = Sets.difference( @@ -110,6 +112,7 @@ public static void validatePlatform() throws IOException { .setInstanceId(instanceId) .build()); + LOGGER.info("Creating cluster in zone: " + zones.get(0)); instanceAdmin.createInstance( CreateInstanceRequest.of(instanceId) .addCmekCluster(clusterId1, zones.get(0), 1, StorageType.SSD, kmsKeyName)); @@ -137,6 +140,7 @@ public void instanceAndClusterTest() { Cluster cluster = instanceAdmin.getCluster(instanceId, clusterId1); assertThat(cluster.getKmsKeyName()).isEqualTo(kmsKeyName); + LOGGER.info("Creating cluster in zone: " + zones.get(1)); instanceAdmin.createCluster( CreateClusterRequest.of(instanceId, clusterId2) .setZone(zones.get(1)) @@ -147,9 +151,10 @@ public void instanceAndClusterTest() { Cluster secondCluster = instanceAdmin.getCluster(instanceId, clusterId2); assertThat(secondCluster.getKmsKeyName()).isEqualTo(kmsKeyName); + LOGGER.info("Trying to create cluster in zone: " + otherZone); try { instanceAdmin.createCluster( - CreateClusterRequest.of(instanceId, clusterId2) + CreateClusterRequest.of(instanceId, clusterId3) .setZone(otherZone) .setServeNodes(1) .setStorageType(StorageType.SSD)