minor fixes

Signed-off-by: Bugen Zhao <[email protected]>

Cargo.toml

@@ -13,6 +13,7 @@ members = [
   "src/connector",
   "src/connector/with_options",
   "src/ctl",
+  "src/dml",
   "src/error",
   "src/expr/core",
   "src/expr/impl",
@@ -33,7 +34,6 @@ members = [
   "src/risedevtool",
   "src/risedevtool/config",
   "src/rpc_client",
-  "src/dml",
   "src/sqlparser",
   "src/sqlparser/test_runner",
   "src/storage",

Makefile.toml

@@ -919,10 +919,10 @@ cargo build \
   -p risingwave_common \
   -p risingwave_compute \
   -p risingwave_connector \
+  -p risingwave_dml \
   -p risingwave_frontend \
   -p risingwave_meta \
   -p risingwave_object_store \
-  -p risingwave_dml \
   -p risingwave_storage \
   -p risingwave_stream \
   -p pgwire \
@@ -944,10 +944,10 @@ cargo nextest run \
   -p risingwave_common \
   -p risingwave_compute \
   -p risingwave_connector \
+  -p risingwave_dml \
   -p risingwave_frontend \
   -p risingwave_meta \
   -p risingwave_object_store \
-  -p risingwave_dml \
   -p risingwave_storage \
   -p risingwave_stream \
   -p pgwire \
@@ -1000,10 +1000,10 @@ cargo check \
   -p risingwave_common \
   -p risingwave_compute \
   -p risingwave_connector \
+  -p risingwave_dml \
   -p risingwave_frontend \
   -p risingwave_meta \
   -p risingwave_object_store \
-  -p risingwave_dml \
   -p risingwave_storage \
   -p risingwave_stream \
   -p pgwire \

docs/rustdoc/index.md

@@ -30,7 +30,7 @@ There's also a [Dash](https://kapeli.com/dash) docset feed containing all crate
   - [risingwave_hummock_sdk](risingwave_hummock_sdk/index.html)
   - [risingwave_object_store](risingwave_object_store/index.html)
 
-### Source and Connector
+### DML and Connectors (Source and Sink)
 
 - [risingwave_dml](risingwave_dml/index.html)
 - [risingwave_connector](risingwave_connector/index.html)

src/batch/Cargo.toml

@@ -31,11 +31,11 @@ paste = "1"
 prometheus = { version = "0.13", features = ["process"] }
 risingwave_common = { workspace = true }
 risingwave_connector = { workspace = true }
+risingwave_dml = { workspace = true }
 risingwave_expr = { workspace = true }
 risingwave_hummock_sdk = { workspace = true }
 risingwave_pb = { workspace = true }
 risingwave_rpc_client = { workspace = true }
-risingwave_dml = { workspace = true }
 risingwave_storage = { workspace = true }
 rw_futures_util = { workspace = true }
 scopeguard = "1"

src/compute/Cargo.toml

@@ -32,11 +32,11 @@ risingwave_common = { workspace = true }
 risingwave_common_heap_profiling = { workspace = true }
 risingwave_common_service = { workspace = true }
 risingwave_connector = { workspace = true }
+risingwave_dml = { workspace = true }
 risingwave_hummock_sdk = { workspace = true }
 risingwave_jni_core = { workspace = true }
 risingwave_pb = { workspace = true }
 risingwave_rpc_client = { workspace = true }
-risingwave_dml = { workspace = true }
 risingwave_storage = { workspace = true }
 risingwave_stream = { workspace = true }
 serde = { version = "1", features = ["derive"] }

src/connector/src/lib.rs

@@ -33,7 +33,7 @@
 #![feature(error_generic_member_access)]
 #![feature(register_tool)]
 #![register_tool(rw)]
-// #![allow(rw::format_error)] // TODO(error-handling): need further refactoring
+#![allow(rw::format_error)] // TODO(error-handling): need further refactoring
 
 use std::time::Duration;
 

src/frontend/Cargo.toml

@@ -57,12 +57,12 @@ risingwave_batch = { workspace = true }
 risingwave_common = { workspace = true }
 risingwave_common_service = { workspace = true }
 risingwave_connector = { workspace = true }
+risingwave_dml = { workspace = true }
 risingwave_expr = { workspace = true }
 risingwave_hummock_sdk = { workspace = true }
 risingwave_object_store = { workspace = true }
 risingwave_pb = { workspace = true }
 risingwave_rpc_client = { workspace = true }
-risingwave_dml = { workspace = true }
 risingwave_sqlparser = { workspace = true }
 risingwave_storage = { workspace = true }
 risingwave_udf = { workspace = true }

src/stream/Cargo.toml

@@ -48,11 +48,11 @@ prost = { workspace = true }
 rand = "0.8"
 risingwave_common = { workspace = true }
 risingwave_connector = { workspace = true }
+risingwave_dml = { workspace = true }
 risingwave_expr = { workspace = true }
 risingwave_hummock_sdk = { workspace = true }
 risingwave_pb = { workspace = true }
 risingwave_rpc_client = { workspace = true }
-risingwave_dml = { workspace = true }
 risingwave_storage = { workspace = true }
 rw_futures_util = { workspace = true }
 serde_json = "1"