diff --git a/analytic_engine/src/sst/parquet/async_reader.rs b/analytic_engine/src/sst/parquet/async_reader.rs
index f8db79a332..d4d378adef 100644
--- a/analytic_engine/src/sst/parquet/async_reader.rs
+++ b/analytic_engine/src/sst/parquet/async_reader.rs
@@ -732,6 +732,7 @@ impl<'a> SstReader for ThreadedReader<'a> {
         );
 
         let channel_cap_per_sub_reader = self.channel_cap / sub_readers.len();
+        let channel_cap_per_sub_reader = channel_cap_per_sub_reader.max(1);
         let (tx_group, rx_group): (Vec<_>, Vec<_>) = (0..read_parallelism)
             .map(|_| mpsc::channel::<Result<RecordBatchWithKey>>(channel_cap_per_sub_reader))
             .unzip();
diff --git a/integration_tests/build_meta.sh b/integration_tests/build_meta.sh
index b75e36a0da..2f0330951c 100755
--- a/integration_tests/build_meta.sh
+++ b/integration_tests/build_meta.sh
@@ -8,7 +8,7 @@ META_BIN_PATH=${META_BIN_PATH:-""}
 
 if [[ -z "${META_BIN_PATH}" ]]; then
     echo "Fetch and install ceresmeta-server..."
-    go install -a github.com/CeresDB/horaemeta/cmd/ceresmeta-server@main
+    go install -v -a github.com/CeresDB/ceresmeta/cmd/ceresmeta-server@dev
     META_BIN_PATH="$(go env GOPATH)/bin/ceresmeta-server"
 fi