diff --git a/src/meta/src/hummock/manager/compaction_group_manager.rs b/src/meta/src/hummock/manager/compaction_group_manager.rs
index 44708d3bda624..a2cfb72526da6 100644
--- a/src/meta/src/hummock/manager/compaction_group_manager.rs
+++ b/src/meta/src/hummock/manager/compaction_group_manager.rs
@@ -1001,6 +1001,7 @@ mod tests {
     use crate::hummock::test_utils::setup_compute_env;
     use crate::hummock::HummockManager;
     use crate::model::TableFragments;
+    use crate::stream::CreateStreamingJobOption;
 
     #[tokio::test]
     async fn test_inner() {
@@ -1102,7 +1103,9 @@ mod tests {
             .register_table_fragments(
                 Some(table_fragment_1.table_id().table_id),
                 table_fragment_1.internal_table_ids(),
-                false,
+                CreateStreamingJobOption {
+                    new_independent_compaction_group: false,
+                },
             )
             .await
             .unwrap();
@@ -1111,7 +1114,9 @@ mod tests {
             .register_table_fragments(
                 Some(table_fragment_2.table_id().table_id),
                 table_fragment_2.internal_table_ids(),
-                false,
+                CreateStreamingJobOption {
+                    new_independent_compaction_group: false,
+                },
             )
             .await
             .unwrap();
@@ -1138,7 +1143,9 @@ mod tests {
             .register_table_fragments(
                 Some(table_fragment_1.table_id().table_id),
                 table_fragment_1.internal_table_ids(),
-                true,
+                CreateStreamingJobOption {
+                    new_independent_compaction_group: true,
+                },
             )
             .await
             .unwrap();
diff --git a/src/meta/src/stream/stream_manager.rs b/src/meta/src/stream/stream_manager.rs
index d2f5c6ca21f05..5889292756ca7 100644
--- a/src/meta/src/stream/stream_manager.rs
+++ b/src/meta/src/stream/stream_manager.rs
@@ -37,10 +37,9 @@ use crate::{MetaError, MetaResult};
 
 pub type GlobalStreamManagerRef = Arc<GlobalStreamManager>;
 
+#[derive(Default)]
 pub struct CreateStreamingJobOption {
-
     pub new_independent_compaction_group: bool,
-
 }
 
 /// [`CreateStreamingJobContext`] carries one-time infos for creating a streaming job.