Fixes to get past code formatting issues

patch by Bret McGuire; reviewed by Bret McGuire for PR 1928

Author: absurdfarce

core/src/main/java/com/datastax/oss/driver/internal/core/metadata/MetadataManager.java

@@ -439,29 +439,29 @@ private void startSchemaRequest(CompletableFuture<RefreshSchemaResult> refreshFu
                   } else {
                     try {
                       schemaQueriesFactory
-                              .newInstance()
-                              .execute()
-                              .thenApplyAsync(this::parseAndApplySchemaRows, adminExecutor)
-                              .whenComplete(
-                                      (newMetadata, metadataError) -> {
-                                        if (metadataError != null) {
-                                          refreshFuture.completeExceptionally(metadataError);
-                                        } else {
-                                          refreshFuture.complete(
-                                                  new RefreshSchemaResult(newMetadata, schemaInAgreement));
-                                        }
-
-                                        firstSchemaRefreshFuture.complete(null);
-
-                                        currentSchemaRefresh = null;
-                                        // If another refresh was enqueued during this one, run it now
-                                        if (queuedSchemaRefresh != null) {
-                                          CompletableFuture<RefreshSchemaResult> tmp =
-                                                  this.queuedSchemaRefresh;
-                                          this.queuedSchemaRefresh = null;
-                                          startSchemaRequest(tmp);
-                                        }
-                                      });
+                          .newInstance()
+                          .execute()
+                          .thenApplyAsync(this::parseAndApplySchemaRows, adminExecutor)
+                          .whenComplete(
+                              (newMetadata, metadataError) -> {
+                                if (metadataError != null) {
+                                  refreshFuture.completeExceptionally(metadataError);
+                                } else {
+                                  refreshFuture.complete(
+                                      new RefreshSchemaResult(newMetadata, schemaInAgreement));
+                                }
+
+                                firstSchemaRefreshFuture.complete(null);
+
+                                currentSchemaRefresh = null;
+                                // If another refresh was enqueued during this one, run it now
+                                if (queuedSchemaRefresh != null) {
+                                  CompletableFuture<RefreshSchemaResult> tmp =
+                                      this.queuedSchemaRefresh;
+                                  this.queuedSchemaRefresh = null;
+                                  startSchemaRequest(tmp);
+                                }
+                              });
                     } catch (Throwable t) {
                       LOG.debug("[{}] Exception getting new metadata", logPrefix, t);
                       refreshFuture.completeExceptionally(t);

core/src/test/java/com/datastax/oss/driver/internal/core/metadata/MetadataManagerTest.java

@@ -295,14 +295,18 @@ public void refreshSchema_should_work() {
     // Given
     IllegalStateException expectedException = new IllegalStateException("Error we're testing");
     when(schemaQueriesFactory.newInstance()).thenThrow(expectedException);
-    when(topologyMonitor.refreshNodeList()).thenReturn(CompletableFuture.completedFuture(ImmutableList.of(mock(NodeInfo.class))));
-    when(topologyMonitor.checkSchemaAgreement()).thenReturn(CompletableFuture.completedFuture(Boolean.TRUE));
-    when(controlConnection.init(anyBoolean(), anyBoolean(), anyBoolean())).thenReturn(CompletableFuture.completedFuture(null));
+    when(topologyMonitor.refreshNodeList())
+        .thenReturn(CompletableFuture.completedFuture(ImmutableList.of(mock(NodeInfo.class))));
+    when(topologyMonitor.checkSchemaAgreement())
+        .thenReturn(CompletableFuture.completedFuture(Boolean.TRUE));
+    when(controlConnection.init(anyBoolean(), anyBoolean(), anyBoolean()))
+        .thenReturn(CompletableFuture.completedFuture(null));
     metadataManager.refreshNodes(); // required internal state setup for this
     waitForPendingAdminTasks(() -> metadataManager.refreshes.size() == 1); // sanity check
 
     // When
-    CompletionStage<MetadataManager.RefreshSchemaResult> result = metadataManager.refreshSchema("foo", true, true);
+    CompletionStage<MetadataManager.RefreshSchemaResult> result =
+        metadataManager.refreshSchema("foo", true, true);
 
     // Then
     waitForPendingAdminTasks(() -> result.toCompletableFuture().isDone());