diff --git a/.gitignore b/.gitignore index 5222879eb6173..79afa9b710794 100644 --- a/.gitignore +++ b/.gitignore @@ -8,7 +8,7 @@ # many different editing tools: # # https://github.com/github/gitignore/tree/master/Global - +.idea/ /target /target-ra /target-xcompile diff --git a/src/adapter/src/coord/sequencer/linked_cluster.rs b/src/adapter/src/coord/sequencer/linked_cluster.rs index 15a9230e01c59..e0638dc3e21ee 100644 --- a/src/adapter/src/coord/sequencer/linked_cluster.rs +++ b/src/adapter/src/coord/sequencer/linked_cluster.rs @@ -19,12 +19,14 @@ use mz_repr::GlobalId; use mz_sql::catalog::CatalogCluster; use mz_sql::names::QualifiedItemName; use mz_sql::plan::SourceSinkClusterConfig; +use tracing::{event, warn, Level}; use crate::catalog::{self, ClusterConfig, ClusterVariant, LINKED_CLUSTER_REPLICA_NAME}; use crate::coord::Coordinator; use crate::error::AdapterError; use crate::session::Session; + impl Coordinator { /// Generates the catalog operations to create a linked cluster for the /// source or sink with the given name. @@ -202,6 +204,7 @@ impl Coordinator { // `catalog_transact`, both from the catalog state and from the // controller. The new replicas will be in the catalog state, and // need to be recreated in the controller. + let replicas: Vec<_> = cluster .replicas() .map(|r| (r.cluster_id, r.replica_id)) @@ -209,4 +212,22 @@ impl Coordinator { self.create_cluster_replicas(&replicas).await; } } + + pub fn my_func_test( + scx: &StatementContext + ) -> Result { + //warn!("Logging test"); + scx.require_feature_flag(&crate::session::vars::ENABLE_ASSERT_NOT_NULL)?; + Ok() + } } + +#[cfg(test)] +mod tests { + use super::*; + + #[mz_ore::test] + fn simple_test() { + assert_eq!(2 + 2, 4); + } +} \ No newline at end of file diff --git a/test/restart/mzcompose.py b/test/restart/mzcompose.py index 52ad7b7186454..647cb29cf1db1 100644 --- a/test/restart/mzcompose.py +++ b/test/restart/mzcompose.py @@ -371,10 +371,10 @@ def workflow_bound_size_mz_status_history(c: Composition) -> None: service="testdrive_no_reset", input=dedent( """ - > SELECT COUNT(*) > 7 FROM mz_internal.mz_source_status_history + > SELECT COUNT(*) > 8 FROM mz_internal.mz_source_status_history true - > SELECT COUNT(*) > 7 FROM mz_internal.mz_sink_status_history + > SELECT COUNT(*) > 8 FROM mz_internal.mz_sink_status_history true """ ),