fix: use etcd

Signed-off-by: discord9 <discord9@163.com>
This commit is contained in:
discord9
2026-02-03 21:24:25 +08:00
parent 271fb1f73d
commit f6b7e5f415
7 changed files with 25 additions and 12 deletions

View File

@@ -1,5 +1,4 @@
-- SQLNESS ARG since=0.15.0
-- SQLNESS IGNORE_RESULT
CREATE TABLE granularity_and_false_positive_rate (
ts timestamp time index,
val double
@@ -8,5 +7,5 @@ CREATE TABLE granularity_and_false_positive_rate (
"index.false_positive_rate" = "0.01"
);
-- IGNORE_RESULT: Query executed successfully
Affected Rows: 0

View File

@@ -1,5 +1,4 @@
-- SQLNESS ARG since=0.15.0
-- SQLNESS IGNORE_RESULT
CREATE TABLE granularity_and_false_positive_rate (
ts timestamp time index,
val double

View File

@@ -1,4 +1,18 @@
SHOW CREATE TABLE granularity_and_false_positive_rate;
Error: 4001(TableNotFound), Table not found: granularity_and_false_positive_rate
+-------------------------------------+--------------------------------------------------------------------+
| Table | Create Table |
+-------------------------------------+--------------------------------------------------------------------+
| granularity_and_false_positive_rate | CREATE TABLE IF NOT EXISTS "granularity_and_false_positive_rate" ( |
| | "ts" TIMESTAMP(3) NOT NULL, |
| | "val" DOUBLE NULL, |
| | TIME INDEX ("ts") |
| | ) |
| | |
| | ENGINE=mito |
| | WITH( |
| | 'index.false_positive_rate' = '0.01', |
| | 'index.granularity' = '8192' |
| | ) |
+-------------------------------------+--------------------------------------------------------------------+

View File

@@ -5,7 +5,7 @@ heartbeat_interval = "1s"
store_addrs = [{store_addrs | unescaped}]
## The datastore for meta server.
backend = "EtcdStore"
backend = "etcd_store"
{{ endif }}
[wal]
{{ if is_raft_engine }}

View File

@@ -94,6 +94,8 @@ impl CompatCommand {
}
if !self.preserve_state {
println!("Stopping etcd");
crate::util::stop_rm_etcd();
tokio::fs::remove_dir_all(data_dir).await.unwrap();
}
}

View File

@@ -69,7 +69,7 @@ impl CompatibilityRunner {
},
wal_config: WalConfig::RaftEngine,
store_config: StoreConfig {
store_addrs: vec![],
store_addrs: vec!["127.0.0.1:2379".to_string()],
setup_etcd: false,
setup_pg: None,
setup_mysql: None,
@@ -100,13 +100,15 @@ impl CompatibilityRunner {
}
let bins_dir = Self::resolve_bins_dir(version).await?;
let mut store_config = self.store_config.clone();
store_config.setup_etcd = phase == "1.feature";
let env = Env::new_bare(
self.data_dir.clone(),
self.server_addr.clone(),
self.wal_config.clone(),
self.pull_version_on_need,
bins_dir.clone(),
self.store_config.clone(),
store_config,
self.extra_args.clone(),
);

View File

@@ -495,11 +495,8 @@ impl ServerMode {
metasrv_addr,
node_id,
} => {
let data_home = sqlness_home.join(format!(
"greptimedb_{}_datanode_{}_{node_id}",
id,
db_ctx.time()
));
let data_home =
sqlness_home.join(format!("greptimedb-{}-datanode-{}", id, node_id));
args.extend([
format!("--rpc-addr={rpc_bind_addr}"),
format!("--rpc-server-addr={rpc_server_addr}"),