add more logs

ci/scripts/deterministic-recovery-test.sh

@@ -13,7 +13,9 @@ export RUST_LOG="risingwave_meta::barrier::recovery=debug,\
 risingwave_meta::manager::catalog=debug,\
 risingwave_meta::rpc::ddl_controller=debug,\
 risingwave_meta::barrier::mod=debug,\
-risingwave_simulation=debug"
+risingwave_simulation=debug,\
+risingwave_meta::stream::stream_manager=debug,\
+risingwave_meta::barrier::progress=debug"
 
 # Extra logs you can enable if the existing trace does not give enough info.
 #risingwave_stream::executor::backfill=trace,

src/meta/src/barrier/progress.rs

@@ -349,6 +349,7 @@ impl CreateMviewProgressTracker {
         let table_map: HashMap<_, HashSet<ActorId>> = table_map.into();
         for (creating_table_id, actors) in table_map {
             let mut states = HashMap::new();
+            tracing::debug!(?actors, "recover progress for actors");
             for actor in actors {
                 actor_map.insert(actor, creating_table_id);
                 states.insert(actor, BackfillState::ConsumingUpstream(Epoch(0), 0));

src/meta/src/stream/stream_manager.rs

@@ -483,6 +483,7 @@ impl GlobalStreamManager {
         tracing::debug!("sending Command::CreateStreamingJob");
         let result: MetaResult<NotificationVersion> = try {
             self.barrier_scheduler.run_command(command).await?;
+            tracing::debug!("first barrier collected for stream job");
             self.metadata_manager
                 .wait_streaming_job_finished(table_id)
                 .await?