Move exception checking before the SET CLUSTER calls

h2/src/main/org/h2/tools/CreateCluster.java

@@ -143,20 +143,19 @@ public class CreateCluster extends Tool {
             {
                 RunScript.execute(connTarget, pipeReader);
 
+                // Check if the writer encountered any exception
+                try {
+                    threadFuture.get();
+                } catch (ExecutionException ex) {
+                    throw new SQLException(ex.getCause());
+                } catch (InterruptedException ex) {
+                    throw new SQLException(ex);
+                }
+
                 // set the cluster to the serverList on both databases
                 statSource.executeUpdate("SET CLUSTER '" + serverList + "'");
                 statTarget.executeUpdate("SET CLUSTER '" + serverList + "'");
             }
-
-            // Check if the writer encountered any exception
-            try {
-                threadFuture.get();
-            } catch (ExecutionException ex) {
-                throw new SQLException(ex.getCause());
-            } catch (InterruptedException ex) {
-                throw new SQLException(ex);
-            }
-
         } catch (IOException ex) {
             throw new SQLException(ex);
         }