[pull] main from MaterializeInc:main

doc/user/data/examples/create_cluster.yml

@@ -1,6 +1,6 @@
 - name: "syntax"
   code: |
-    CREATE CLUSTER <cluster_name> (
+    CREATE CLUSTER [IF NOT EXISTS] <cluster_name> (
         SIZE = <text>
         [, REPLICATION FACTOR = <int>]
         [, MANAGED = <bool>]
@@ -12,6 +12,12 @@
         )]
     );
   syntax_elements:
+    - name: "**IF NOT EXISTS**"
+      description: |
+        *Optional.* If specified, do not throw an error if a cluster with the
+        same name already exists. Instead, issue a notice and skip the cluster
+        creation. Note that the existing cluster is left untouched, its
+        configuration is not updated to match the statement.
     - name: "`<cluster_name>`"
       description: |
         A name for the cluster.

doc/user/data/examples/create_cluster_replica.yml

@@ -1,9 +1,15 @@
 - name: "syntax"
   code: |
-    CREATE CLUSTER REPLICA <cluster_name>.<replica_name> (
+    CREATE CLUSTER REPLICA [IF NOT EXISTS] <cluster_name>.<replica_name> (
         SIZE = <text>
     );
   syntax_elements:
+    - name: "**IF NOT EXISTS**"
+      description: |
+        *Optional.* If specified, do not throw an error if a replica with the
+        same name already exists on the cluster. Instead, issue a notice and
+        skip the replica creation. Note that the existing replica is left
+        untouched, its configuration is not updated to match the statement.
     - name: "`<cluster_name>`"
       description: |
         The cluster you want to attach a replica to.

src/adapter/src/coord.rs

@@ -362,6 +362,8 @@ pub enum Message {
         responses: Vec<crate::util::CompletedClientTransmitter>,
         /// Statement executions associated with this commit.
         statement_logging_ids: Vec<StatementLoggingId>,
+        /// Frontend-sequenced writes to complete after local timestamp bookkeeping.
+        internal_results: Vec<crate::coord::appends::InternalWriteResponder>,
         /// The applied write timestamp.
         write_ts: Timestamp,
     },