feat(streaming): source executor use table_id for keyspace prefix (#3010

)
risingwavelabs · Jun 7, 2022 · 87b9397 · 87b9397
1 parent 1fad3e9
commit 87b9397
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/stream/src/from_proto/source.rs b/src/stream/src/from_proto/source.rs
@@ -64,7 +64,7 @@ impl ExecutorBuilder for SourceExecutorBuilder {
             Field::with_name(column_desc.data_type.clone(), column_desc.name.clone())
         }));
         let schema = Schema::new(fields);
-        let keyspace = Keyspace::executor_root(store, params.executor_id);
+        let keyspace = Keyspace::table_root(store, &source_id);
 
         Ok(Box::new(SourceExecutor::new(
             params.actor_id,