Fix Parallelizable Tests for DSE 6.8

 - Add checklogerror output to CcmBridge
 - Move DefaultReactiveGraphResultSetIT to serial ITs
 - Adjust SASI tests for 6.8.0

Author: emerkle826

integration-tests/src/test/java/com/datastax/dse/driver/api/core/graph/reactive/DefaultReactiveGraphResultSetIT.java

@@ -26,7 +26,6 @@
 import com.datastax.oss.driver.api.testinfra.DseRequirement;
 import com.datastax.oss.driver.api.testinfra.ccm.CustomCcmRule;
 import com.datastax.oss.driver.api.testinfra.session.SessionRule;
-import com.datastax.oss.driver.categories.ParallelizableTests;
 import com.tngtech.java.junit.dataprovider.DataProvider;
 import com.tngtech.java.junit.dataprovider.DataProviderRunner;
 import io.reactivex.Flowable;
@@ -36,14 +35,12 @@
 import org.junit.BeforeClass;
 import org.junit.ClassRule;
 import org.junit.Test;
-import org.junit.experimental.categories.Category;
 import org.junit.rules.RuleChain;
 import org.junit.rules.TestRule;
 import org.junit.runner.RunWith;
 
 @DseRequirement(min = "6.8.0", description = "Graph paging requires DSE 6.8+")
 @RunWith(DataProviderRunner.class)
-@Category(ParallelizableTests.class)
 public class DefaultReactiveGraphResultSetIT {
 
   private static CustomCcmRule ccmRule = CustomCcmRule.builder().withDseWorkloads("graph").build();

integration-tests/src/test/java/com/datastax/oss/driver/mapper/InventoryITBase.java

@@ -24,6 +24,7 @@
 import com.datastax.oss.driver.shaded.guava.common.collect.ImmutableList;
 import java.util.List;
 import java.util.Objects;
+import java.util.Optional;
 import java.util.UUID;
 
 /** Factors common code for mapper tests that rely on a simple inventory model. */
@@ -66,7 +67,7 @@ protected static List<String> createStatements(CcmRule ccmRule) {
                 "CREATE TABLE product_sale(id uuid, day text, ts uuid, customer_id int, price "
                     + "double, count int, PRIMARY KEY ((id, day), customer_id, ts))");
 
-    if (supportsSASI(ccmRule)) {
+    if (supportsSASI(ccmRule) && !isSasiBroken(ccmRule)) {
       builder.add(
           "CREATE CUSTOM INDEX product_description ON product(description) "
               + "USING 'org.apache.cassandra.index.sasi.SASIIndex' "
@@ -85,6 +86,13 @@ protected static List<String> createStatements(CcmRule ccmRule) {
   }
 
   private static final Version MINIMUM_SASI_VERSION = Version.parse("3.4.0");
+  private static final Version BROKEN_SASI_VERSION = Version.parse("6.8.0");
+
+  protected static boolean isSasiBroken(CcmRule ccmRule) {
+    Optional<Version> dseVersion = ccmRule.getDseVersion();
+    // creating SASI indexes is broken in DSE 6.8.0
+    return dseVersion.isPresent() && dseVersion.get().compareTo(BROKEN_SASI_VERSION) == 0;
+  }
 
   protected static boolean supportsSASI(CcmRule ccmRule) {
     return ccmRule.getCassandraVersion().compareTo(MINIMUM_SASI_VERSION) >= 0;

integration-tests/src/test/java/com/datastax/oss/driver/mapper/SelectCustomWhereClauseIT.java

@@ -16,6 +16,7 @@
 package com.datastax.oss.driver.mapper;
 
 import static com.datastax.oss.driver.assertions.Assertions.assertThat;
+import static org.junit.Assume.assumeFalse;
 
 import com.datastax.oss.driver.api.core.CqlIdentifier;
 import com.datastax.oss.driver.api.core.CqlSession;
@@ -58,6 +59,10 @@ public class SelectCustomWhereClauseIT extends InventoryITBase {
 
   @BeforeClass
   public static void setup() {
+    // SASI index creation is broken in DSE 6.8.0
+    // All tests in this class require SASI, so ensure it's working
+    assumeFalse(InventoryITBase.isSasiBroken(CCM_RULE));
+
     CqlSession session = SESSION_RULE.session();
 
     for (String query : createStatements(CCM_RULE)) {

test-infra/src/main/java/com/datastax/oss/driver/api/testinfra/ccm/CcmBridge.java

@@ -262,7 +262,13 @@ public void reloadCore(int node, String keyspace, String table, boolean reindex)
 
   public void start() {
     if (started.compareAndSet(false, true)) {
-      execute("start", jvmArgs, "--wait-for-binary-proto");
+      try {
+        execute("start", jvmArgs, "--wait-for-binary-proto");
+      } catch (RuntimeException re) {
+        // if something went wrong starting CCM, see if we can also dump the error
+        executeCheckLogError();
+        throw re;
+      }
     }
   }
 
@@ -315,13 +321,31 @@ synchronized void executeUnsanitized(String... args) {
   }
 
   private void execute(CommandLine cli) {
-    logger.debug("Executing: " + cli);
+    execute(cli, false);
+  }
+
+  private void executeCheckLogError() {
+    String command = "ccm checklogerror --config-dir=" + configDirectory.toFile().getAbsolutePath();
+    // force all logs to be error logs
+    execute(CommandLine.parse(command), true);
+  }
+
+  private void execute(CommandLine cli, boolean forceErrorLogging) {
+    if (forceErrorLogging) {
+      logger.error("Executing: " + cli);
+    } else {
+      logger.debug("Executing: " + cli);
+    }
     ExecuteWatchdog watchDog = new ExecuteWatchdog(TimeUnit.MINUTES.toMillis(10));
     try (LogOutputStream outStream =
             new LogOutputStream() {
               @Override
               protected void processLine(String line, int logLevel) {
-                logger.debug("ccmout> {}", line);
+                if (forceErrorLogging) {
+                  logger.error("ccmout> {}", line);
+                } else {
+                  logger.debug("ccmout> {}", line);
+                }
               }
             };
         LogOutputStream errStream =