From 7cfffda02d0118f41bdf35bc3103cce32a337210 Mon Sep 17 00:00:00 2001 From: Noel Kwan Date: Wed, 25 Oct 2023 09:24:15 +0800 Subject: [PATCH] pass internal tables --- src/meta/src/manager/catalog/mod.rs | 2 +- src/meta/src/rpc/ddl_controller.rs | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/src/meta/src/manager/catalog/mod.rs b/src/meta/src/manager/catalog/mod.rs index c71cc14a67353..2dce191d5f0b8 100644 --- a/src/meta/src/manager/catalog/mod.rs +++ b/src/meta/src/manager/catalog/mod.rs @@ -647,7 +647,7 @@ impl CatalogManager { self.start_create_table_procedure_with_source(source, table) .await } else { - self.start_create_table_procedure(table, vec![]).await + self.start_create_table_procedure(table, internal_tables).await } } } diff --git a/src/meta/src/rpc/ddl_controller.rs b/src/meta/src/rpc/ddl_controller.rs index 04b9729c5a5b8..54e64fe419093 100644 --- a/src/meta/src/rpc/ddl_controller.rs +++ b/src/meta/src/rpc/ddl_controller.rs @@ -429,6 +429,7 @@ impl DdlController { let env = StreamEnvironment::from_protobuf(fragment_graph.get_env().unwrap()); + // Persist tables tracing::debug!(id = stream_job.id(), "preparing stream job"); let fragment_graph = self .prepare_stream_job(&mut stream_job, fragment_graph)