diff --git a/src/common/arrow/tests/it/main.rs b/src/common/arrow/tests/it/main.rs index 47a98a06567c..83c1d406d287 100644 --- a/src/common/arrow/tests/it/main.rs +++ b/src/common/arrow/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/base/tests/it/fixed_heap.rs b/src/common/base/tests/it/fixed_heap.rs index a9e47d148d1f..5f3536e8138a 100644 --- a/src/common/base/tests/it/fixed_heap.rs +++ b/src/common/base/tests/it/fixed_heap.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/base/tests/it/main.rs b/src/common/base/tests/it/main.rs index 34da796e0cb4..5f0df1b3c283 100644 --- a/src/common/base/tests/it/main.rs +++ b/src/common/base/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/base/tests/it/pool.rs b/src/common/base/tests/it/pool.rs index 4e12964ac11a..50490cb2972b 100644 --- a/src/common/base/tests/it/pool.rs +++ b/src/common/base/tests/it/pool.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/base/tests/it/progress.rs b/src/common/base/tests/it/progress.rs index af9d66222809..95c80bb88de6 100644 --- a/src/common/base/tests/it/progress.rs +++ b/src/common/base/tests/it/progress.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/base/tests/it/runtime.rs b/src/common/base/tests/it/runtime.rs index 91cfaaa17ccf..9067e5945d1e 100644 --- a/src/common/base/tests/it/runtime.rs +++ b/src/common/base/tests/it/runtime.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/base/tests/it/stoppable.rs b/src/common/base/tests/it/stoppable.rs index be6179c1200e..25d33e6c3cf3 100644 --- a/src/common/base/tests/it/stoppable.rs +++ b/src/common/base/tests/it/stoppable.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/cache/tests/it/cache.rs b/src/common/cache/tests/it/cache.rs index ff36463970ea..ac9d154e44ff 100644 --- a/src/common/cache/tests/it/cache.rs +++ b/src/common/cache/tests/it/cache.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/cache/tests/it/cache/lru.rs b/src/common/cache/tests/it/cache/lru.rs index 84453349948f..ae9956afd1d7 100644 --- a/src/common/cache/tests/it/cache/lru.rs +++ b/src/common/cache/tests/it/cache/lru.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/cache/tests/it/main.rs b/src/common/cache/tests/it/main.rs index 0f9ba048238f..e3ddf0b21724 100644 --- a/src/common/cache/tests/it/main.rs +++ b/src/common/cache/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/grpc/tests/it/dns_resolver.rs b/src/common/grpc/tests/it/dns_resolver.rs index 47c9a2cdb385..078625c56059 100644 --- a/src/common/grpc/tests/it/dns_resolver.rs +++ b/src/common/grpc/tests/it/dns_resolver.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/grpc/tests/it/grpc_token.rs b/src/common/grpc/tests/it/grpc_token.rs index 3dc6bb40b2ea..11e18184bd26 100644 --- a/src/common/grpc/tests/it/grpc_token.rs +++ b/src/common/grpc/tests/it/grpc_token.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/grpc/tests/it/main.rs b/src/common/grpc/tests/it/main.rs index a70c89f02763..3eb53699d934 100644 --- a/src/common/grpc/tests/it/main.rs +++ b/src/common/grpc/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/hashtable/tests/it/main.rs b/src/common/hashtable/tests/it/main.rs index 8d6f461bbbd7..897587bffdd8 100644 --- a/src/common/hashtable/tests/it/main.rs +++ b/src/common/hashtable/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/http/tests/it/health.rs b/src/common/http/tests/it/health.rs index 8742268304e8..e8a5c9241819 100644 --- a/src/common/http/tests/it/health.rs +++ b/src/common/http/tests/it/health.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/http/tests/it/main.rs b/src/common/http/tests/it/main.rs index 6a23fe192ec8..be1339915b5e 100644 --- a/src/common/http/tests/it/main.rs +++ b/src/common/http/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/io/tests/it/binary_read.rs b/src/common/io/tests/it/binary_read.rs index ed66f2b363a6..040fa2ce6196 100644 --- a/src/common/io/tests/it/binary_read.rs +++ b/src/common/io/tests/it/binary_read.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/io/tests/it/binary_write.rs b/src/common/io/tests/it/binary_write.rs index 1c10f8e13467..02bb0f8e2405 100644 --- a/src/common/io/tests/it/binary_write.rs +++ b/src/common/io/tests/it/binary_write.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/io/tests/it/bincode_serialization.rs b/src/common/io/tests/it/bincode_serialization.rs index 7a47860ad26d..04e5ad4e329e 100644 --- a/src/common/io/tests/it/bincode_serialization.rs +++ b/src/common/io/tests/it/bincode_serialization.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/io/tests/it/borsh_serialization.rs b/src/common/io/tests/it/borsh_serialization.rs index f1a43b72f740..37010700561e 100644 --- a/src/common/io/tests/it/borsh_serialization.rs +++ b/src/common/io/tests/it/borsh_serialization.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/io/tests/it/cursor_ext/mod.rs b/src/common/io/tests/it/cursor_ext/mod.rs index a27c5b550190..8a2e0c122484 100644 --- a/src/common/io/tests/it/cursor_ext/mod.rs +++ b/src/common/io/tests/it/cursor_ext/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/io/tests/it/escape.rs b/src/common/io/tests/it/escape.rs index 3eb122976b45..42bb5552a6d1 100644 --- a/src/common/io/tests/it/escape.rs +++ b/src/common/io/tests/it/escape.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/io/tests/it/main.rs b/src/common/io/tests/it/main.rs index 9ef129835d91..9fe0f545ec1b 100644 --- a/src/common/io/tests/it/main.rs +++ b/src/common/io/tests/it/main.rs @@ -1,5 +1,5 @@ #![feature(cursor_remaining)] -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/metrics/tests/it/main.rs b/src/common/metrics/tests/it/main.rs index 152f46c1ef47..de0370d388c6 100644 --- a/src/common/metrics/tests/it/main.rs +++ b/src/common/metrics/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/common/storage/tests/it/main.rs b/src/common/storage/tests/it/main.rs index cee81879f7fa..befc896345aa 100644 --- a/src/common/storage/tests/it/main.rs +++ b/src/common/storage/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/api/src/schema_api_impl.rs b/src/meta/api/src/schema_api_impl.rs index 12304837afc4..93ed01d4ef2a 100644 --- a/src/meta/api/src/schema_api_impl.rs +++ b/src/meta/api/src/schema_api_impl.rs @@ -14,6 +14,8 @@ use std::cmp::min; use std::collections::BTreeMap; +use std::collections::HashMap; +use std::collections::HashSet; use std::fmt::Display; use std::sync::Arc; @@ -485,6 +487,28 @@ impl + ?Sized> SchemaApi for KV { if_then.push(txn_op_put(&db_id_key, serialize_struct(&db_meta)?)); // (db_id) -> db_meta } + + // add DbIdListKey if not exists + let dbid_idlist = DbIdListKey { + tenant: tenant_dbname.tenant.clone(), + db_name: tenant_dbname.db_name.clone(), + }; + let (db_id_list_seq, db_id_list_opt): (_, Option) = + get_pb_value(self, &dbid_idlist).await?; + + if db_id_list_seq == 0 || db_id_list_opt.is_none() { + warn!( + "drop db:{:?}, db_id:{:?} has no DbIdListKey", + tenant_dbname, db_id + ); + + let mut db_id_list = DbIdList::new(); + db_id_list.append(db_id); + + condition.push(txn_cond_seq(&dbid_idlist, Eq, db_id_list_seq)); + // _fd_db_id_list// -> db_id_list + if_then.push(txn_op_put(&dbid_idlist, serialize_struct(&db_id_list)?)); + }; } let txn_req = TxnRequest { @@ -795,7 +819,7 @@ impl + ?Sized> SchemaApi for KV { // List tables by tenant, db_id, table_name. let dbid_tbname_idlist = DbIdListKey { - tenant: req.tenant, + tenant: req.tenant.clone(), // Using a empty db to to list all db_name: "".to_string(), }; @@ -868,6 +892,77 @@ impl + ?Sized> SchemaApi for KV { } } + // `list_database` can list db which has no `DbIdListKey` + if include_drop_db { + // if `include_drop_db` is true, return all db info which not exist in db_info_list + let db_id_set: HashSet = db_info_list + .iter() + .map(|db_info| db_info.ident.db_id) + .collect(); + + let all_dbs = self.list_databases(req).await?; + for db_info in all_dbs { + if !db_id_set.contains(&db_info.ident.db_id) { + warn!( + "get db history db:{:?}, db_id:{:?} has no DbIdListKey", + db_info.name_ident, db_info.ident.db_id + ); + db_info_list.push(db_info); + } + } + } else { + // if `include_drop_db` is false, filter out db which drop_on time out of retention time + let db_id_set: HashSet = db_info_list + .iter() + .map(|db_info| db_info.ident.db_id) + .collect(); + + let all_dbs = self.list_databases(req).await?; + let mut add_dbinfo_map = HashMap::new(); + let mut db_id_list = Vec::new(); + for db_info in all_dbs { + if !db_id_set.contains(&db_info.ident.db_id) { + warn!( + "get db history db:{:?}, db_id:{:?} has no DbIdListKey", + db_info.name_ident, db_info.ident.db_id + ); + db_id_list.push(DatabaseId { + db_id: db_info.ident.db_id, + }); + add_dbinfo_map.insert(db_info.ident.db_id, db_info); + } + } + let inner_keys: Vec = db_id_list + .iter() + .map(|db_id| db_id.to_string_key()) + .collect(); + let mut db_id_list_iter = db_id_list.into_iter(); + for c in inner_keys.chunks(DEFAULT_MGET_SIZE) { + let db_meta_seq_meta_vec: Vec<(u64, Option)> = + mget_pb_values(self, c).await?; + + for (db_meta_seq, db_meta) in db_meta_seq_meta_vec { + let db_id = db_id_list_iter.next().unwrap().db_id; + if db_meta_seq == 0 || db_meta.is_none() { + error!("get_database_history cannot find {:?} db_meta", db_id); + continue; + } + let db_meta = db_meta.unwrap(); + // if include drop db, then no need to fill out of retention time db + if is_drop_time_out_of_retention_time(&db_meta.drop_on, &now) { + continue; + } + if let Some(db_info) = add_dbinfo_map.get(&db_id) { + warn!( + "get db history db:{:?}, db_id:{:?} has no DbIdListKey", + db_info.name_ident, db_info.ident.db_id + ); + db_info_list.push(db_info.clone()); + } + } + } + } + return Ok(db_info_list); } @@ -2524,6 +2619,31 @@ impl + ?Sized> SchemaApi for KV { } } + // add TableIdListKey if not exist + { + // get table id list from _fd_table_id_list/db_id/table_name + let dbid_tbname_idlist = TableIdListKey { + db_id, + table_name: dbid_tbname.table_name.clone(), + }; + let (tb_id_list_seq, _tb_id_list_opt): (_, Option) = + get_pb_value(self, &dbid_tbname_idlist).await?; + if tb_id_list_seq == 0 { + let mut tb_id_list = TableIdList::new(); + tb_id_list.append(table_id); + + warn!( + "drop table:{:?}, table_id:{:?} has no TableIdList", + dbid_tbname, table_id + ); + + condition.push(txn_cond_seq(&dbid_tbname_idlist, Eq, tb_id_list_seq)); + if_then.push(txn_op_put( + &dbid_tbname_idlist, + serialize_struct(&tb_id_list)?, + )); + } + } let txn_req = TxnRequest { condition, if_then, diff --git a/src/meta/api/src/schema_api_test_suite.rs b/src/meta/api/src/schema_api_test_suite.rs index 02e6fd8c6266..5e11cb977b1b 100644 --- a/src/meta/api/src/schema_api_test_suite.rs +++ b/src/meta/api/src/schema_api_test_suite.rs @@ -124,6 +124,7 @@ use databend_common_meta_types::UpsertKV; use log::debug; use log::info; +use crate::deserialize_struct; use crate::is_all_db_data_removed; use crate::kv_app_error::KVAppError; use crate::serialize_struct; @@ -286,6 +287,10 @@ impl SchemaApiTestSuite { suite .table_drop_without_db_id_to_name(&b.build().await) .await?; + suite.list_db_without_db_id_list(&b.build().await).await?; + suite + .drop_table_without_table_id_list(&b.build().await) + .await?; suite.table_rename(&b.build().await).await?; suite.table_update_meta(&b.build().await).await?; suite.table_update_mask_policy(&b.build().await).await?; @@ -1910,6 +1915,118 @@ impl SchemaApiTestSuite { Ok(()) } + #[minitrace::trace] + async fn list_db_without_db_id_list(&self, mt: &MT) -> anyhow::Result<()> + where MT: SchemaApi + kvapi::AsKVApi { + // test drop a db without db_id_list + { + let tenant = "tenant1"; + let db = "db1"; + let mut util = Util::new(mt, tenant, db, "tb2", "JSON"); + util.create_db().await?; + + // remove db id list + let dbid_idlist = DbIdListKey { + tenant: tenant.to_string(), + db_name: db.to_string(), + }; + util.mt + .as_kv_api() + .upsert_kv(UpsertKV::delete(dbid_idlist.to_string_key())) + .await?; + + // drop db + util.drop_db().await?; + + // after drop db, check if db id list has been added + let value = util + .mt + .as_kv_api() + .get_kv(&dbid_idlist.to_string_key()) + .await?; + + assert!(value.is_some()); + let seqv = value.unwrap(); + let db_id_list: DbIdList = deserialize_struct(&seqv.data)?; + assert_eq!(db_id_list.id_list[0], util.db_id); + } + // test get_database_history can return db without db_id_list + { + let tenant = "tenant2"; + let db = "db2"; + let mut util = Util::new(mt, tenant, db, "tb2", "JSON"); + util.create_db().await?; + + // remove db id list + let dbid_idlist = DbIdListKey { + tenant: tenant.to_string(), + db_name: db.to_string(), + }; + util.mt + .as_kv_api() + .upsert_kv(UpsertKV::delete(dbid_idlist.to_string_key())) + .await?; + + let res = mt + .get_database_history(ListDatabaseReq { + tenant: tenant.to_string(), + filter: None, + }) + .await?; + + // check if get_database_history return db_id + let mut found = false; + for db_info in res { + if db_info.ident.db_id == util.db_id { + found = true; + break; + } + } + + assert!(found); + } + Ok(()) + } + + #[minitrace::trace] + async fn drop_table_without_table_id_list(&self, mt: &MT) -> anyhow::Result<()> + where MT: SchemaApi + kvapi::AsKVApi { + // test drop a table without table_id_list + let tenant = "tenant1"; + let db = "db1"; + let table = "tb1"; + let mut util = Util::new(mt, tenant, db, table, "JSON"); + util.create_db().await?; + let (tid, _table_meta) = util.create_table().await?; + + // remove db id list + let table_id_idlist = TableIdListKey { + db_id: util.db_id, + table_name: table.to_string(), + }; + util.mt + .as_kv_api() + .upsert_kv(UpsertKV::delete(table_id_idlist.to_string_key())) + .await?; + + // drop table + util.drop_table_by_id().await?; + + // after drop table, check if table id list has been added + let value = util + .mt + .as_kv_api() + .get_kv(&table_id_idlist.to_string_key()) + .await?; + + assert!(value.is_some()); + let seqv = value.unwrap(); + let id_list: TableIdList = deserialize_struct(&seqv.data)?; + assert_eq!(id_list.id_list[0], tid); + + Ok(()) + } + #[minitrace::trace] async fn table_rename(&self, mt: &MT) -> anyhow::Result<()> { let tenant = "tenant1"; diff --git a/src/meta/app/tests/it/user_grant.rs b/src/meta/app/tests/it/user_grant.rs index c133ac072b58..e5d1f60364cf 100644 --- a/src/meta/app/tests/it/user_grant.rs +++ b/src/meta/app/tests/it/user_grant.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/app/tests/it/user_info.rs b/src/meta/app/tests/it/user_info.rs index 28da573b9dae..287e8fd8ca85 100644 --- a/src/meta/app/tests/it/user_info.rs +++ b/src/meta/app/tests/it/user_info.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/app/tests/it/user_privilege.rs b/src/meta/app/tests/it/user_privilege.rs index 0085ca59110e..0966a669b4a0 100644 --- a/src/meta/app/tests/it/user_privilege.rs +++ b/src/meta/app/tests/it/user_privilege.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/app/tests/it/user_quota.rs b/src/meta/app/tests/it/user_quota.rs index 83e54a795754..dfa6c045c7cb 100644 --- a/src/meta/app/tests/it/user_quota.rs +++ b/src/meta/app/tests/it/user_quota.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/client/tests/it/grpc_client.rs b/src/meta/client/tests/it/grpc_client.rs index 1892a8e26abe..3faab69b6880 100644 --- a/src/meta/client/tests/it/grpc_client.rs +++ b/src/meta/client/tests/it/grpc_client.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/client/tests/it/grpc_server.rs b/src/meta/client/tests/it/grpc_server.rs index 978dfeec4e85..380d313fe6d1 100644 --- a/src/meta/client/tests/it/grpc_server.rs +++ b/src/meta/client/tests/it/grpc_server.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/client/tests/it/main.rs b/src/meta/client/tests/it/main.rs index c9240fc5616e..72f514b886c9 100644 --- a/src/meta/client/tests/it/main.rs +++ b/src/meta/client/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/embedded/tests/it/kv_api_impl.rs b/src/meta/embedded/tests/it/kv_api_impl.rs index 9e69a02ab0b6..32806e2ae458 100644 --- a/src/meta/embedded/tests/it/kv_api_impl.rs +++ b/src/meta/embedded/tests/it/kv_api_impl.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/embedded/tests/it/schema_api_impl.rs b/src/meta/embedded/tests/it/schema_api_impl.rs index b699188d22ae..452d24546a9c 100644 --- a/src/meta/embedded/tests/it/schema_api_impl.rs +++ b/src/meta/embedded/tests/it/schema_api_impl.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/proto-conv/tests/it/main.rs b/src/meta/proto-conv/tests/it/main.rs index 85990b0026a4..3bdd6e8eafa8 100644 --- a/src/meta/proto-conv/tests/it/main.rs +++ b/src/meta/proto-conv/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/proto-conv/tests/it/proto_conv.rs b/src/meta/proto-conv/tests/it/proto_conv.rs index f2916f13aefe..d9f82e6695a2 100644 --- a/src/meta/proto-conv/tests/it/proto_conv.rs +++ b/src/meta/proto-conv/tests/it/proto_conv.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/proto-conv/tests/it/user_proto_conv.rs b/src/meta/proto-conv/tests/it/user_proto_conv.rs index 9d2a151bb795..856f9ff5d1f5 100644 --- a/src/meta/proto-conv/tests/it/user_proto_conv.rs +++ b/src/meta/proto-conv/tests/it/user_proto_conv.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/proto-conv/tests/it/v037_index_meta.rs b/src/meta/proto-conv/tests/it/v037_index_meta.rs index c98030bc8e2d..984ff23489d7 100644 --- a/src/meta/proto-conv/tests/it/v037_index_meta.rs +++ b/src/meta/proto-conv/tests/it/v037_index_meta.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/proto-conv/tests/it/v041_virtual_column.rs b/src/meta/proto-conv/tests/it/v041_virtual_column.rs index 174133133269..314bb6cdd94c 100644 --- a/src/meta/proto-conv/tests/it/v041_virtual_column.rs +++ b/src/meta/proto-conv/tests/it/v041_virtual_column.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/proto-conv/tests/it/v044_table_meta.rs b/src/meta/proto-conv/tests/it/v044_table_meta.rs index 7b13f5751611..5d21bf64542a 100644 --- a/src/meta/proto-conv/tests/it/v044_table_meta.rs +++ b/src/meta/proto-conv/tests/it/v044_table_meta.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/proto-conv/tests/it/v046_index_meta.rs b/src/meta/proto-conv/tests/it/v046_index_meta.rs index 0249f695db1b..ed6ba10110b8 100644 --- a/src/meta/proto-conv/tests/it/v046_index_meta.rs +++ b/src/meta/proto-conv/tests/it/v046_index_meta.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/proto-conv/tests/it/v047_catalog_meta.rs b/src/meta/proto-conv/tests/it/v047_catalog_meta.rs index 1395c3b31b7a..56ada7bc2425 100644 --- a/src/meta/proto-conv/tests/it/v047_catalog_meta.rs +++ b/src/meta/proto-conv/tests/it/v047_catalog_meta.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/proto-conv/tests/it/v052_hive_catalog_config.rs b/src/meta/proto-conv/tests/it/v052_hive_catalog_config.rs index 112f22355e9b..4cc6947937f6 100644 --- a/src/meta/proto-conv/tests/it/v052_hive_catalog_config.rs +++ b/src/meta/proto-conv/tests/it/v052_hive_catalog_config.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/proto-conv/tests/it/v054_index_meta.rs b/src/meta/proto-conv/tests/it/v054_index_meta.rs index dcb7bbc70f45..95ffcd1d7189 100644 --- a/src/meta/proto-conv/tests/it/v054_index_meta.rs +++ b/src/meta/proto-conv/tests/it/v054_index_meta.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/protos/proto/index.proto b/src/meta/protos/proto/index.proto index cb3fb0c90b99..ca5228bb12cd 100644 --- a/src/meta/protos/proto/index.proto +++ b/src/meta/protos/proto/index.proto @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/protos/proto/lock.proto b/src/meta/protos/proto/lock.proto index a79390ab3612..58c93339dcc1 100644 --- a/src/meta/protos/proto/lock.proto +++ b/src/meta/protos/proto/lock.proto @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/protos/proto/virtual_column.proto b/src/meta/protos/proto/virtual_column.proto index ad89a2960f6c..32407d53eab9 100644 --- a/src/meta/protos/proto/virtual_column.proto +++ b/src/meta/protos/proto/virtual_column.proto @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/protos/tests/it/main.rs b/src/meta/protos/tests/it/main.rs index 598edffcf3f6..4ca041965967 100644 --- a/src/meta/protos/tests/it/main.rs +++ b/src/meta/protos/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/raft-store/tests/it/config.rs b/src/meta/raft-store/tests/it/config.rs index 05eb8a9e7f98..c424c91e360e 100644 --- a/src/meta/raft-store/tests/it/config.rs +++ b/src/meta/raft-store/tests/it/config.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/raft-store/tests/it/log.rs b/src/meta/raft-store/tests/it/log.rs index a221ad65ab3d..0cfb4fbd0345 100644 --- a/src/meta/raft-store/tests/it/log.rs +++ b/src/meta/raft-store/tests/it/log.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/raft-store/tests/it/state.rs b/src/meta/raft-store/tests/it/state.rs index 3128f62f5051..39efcf706f36 100644 --- a/src/meta/raft-store/tests/it/state.rs +++ b/src/meta/raft-store/tests/it/state.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/raft-store/tests/it/state_machine/mod.rs b/src/meta/raft-store/tests/it/state_machine/mod.rs index 2e054343c0eb..41b569af60df 100644 --- a/src/meta/raft-store/tests/it/state_machine/mod.rs +++ b/src/meta/raft-store/tests/it/state_machine/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/raft-store/tests/it/state_machine/schema_api_impl.rs b/src/meta/raft-store/tests/it/state_machine/schema_api_impl.rs index 2616da905302..182102685596 100644 --- a/src/meta/raft-store/tests/it/state_machine/schema_api_impl.rs +++ b/src/meta/raft-store/tests/it/state_machine/schema_api_impl.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/raft-store/tests/it/testing.rs b/src/meta/raft-store/tests/it/testing.rs index 9aeaccad9c78..038951181936 100644 --- a/src/meta/raft-store/tests/it/testing.rs +++ b/src/meta/raft-store/tests/it/testing.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/raft-store/tests/it/types.rs b/src/meta/raft-store/tests/it/types.rs index 8cb8e142c2d4..6d0dfb6ff701 100644 --- a/src/meta/raft-store/tests/it/types.rs +++ b/src/meta/raft-store/tests/it/types.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/api/http/mod.rs b/src/meta/service/tests/it/api/http/mod.rs index f676f46d463a..a93f18165c8d 100644 --- a/src/meta/service/tests/it/api/http/mod.rs +++ b/src/meta/service/tests/it/api/http/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/api/http_service.rs b/src/meta/service/tests/it/api/http_service.rs index 4c482faaf772..8cf08014941f 100644 --- a/src/meta/service/tests/it/api/http_service.rs +++ b/src/meta/service/tests/it/api/http_service.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/api/mod.rs b/src/meta/service/tests/it/api/mod.rs index 46c7f0efae5e..06be9cdd30d4 100644 --- a/src/meta/service/tests/it/api/mod.rs +++ b/src/meta/service/tests/it/api/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/configs.rs b/src/meta/service/tests/it/configs.rs index 8403dcac7613..19c18203ef27 100644 --- a/src/meta/service/tests/it/configs.rs +++ b/src/meta/service/tests/it/configs.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/grpc/metasrv_connection_error.rs b/src/meta/service/tests/it/grpc/metasrv_connection_error.rs index bae768343b97..61a7632d0ef6 100644 --- a/src/meta/service/tests/it/grpc/metasrv_connection_error.rs +++ b/src/meta/service/tests/it/grpc/metasrv_connection_error.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/grpc/metasrv_grpc_api.rs b/src/meta/service/tests/it/grpc/metasrv_grpc_api.rs index d7a4d3dfd13a..17561ae0f3bb 100644 --- a/src/meta/service/tests/it/grpc/metasrv_grpc_api.rs +++ b/src/meta/service/tests/it/grpc/metasrv_grpc_api.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/grpc/metasrv_grpc_export.rs b/src/meta/service/tests/it/grpc/metasrv_grpc_export.rs index 58d1f9bbfa12..474e56a2657e 100644 --- a/src/meta/service/tests/it/grpc/metasrv_grpc_export.rs +++ b/src/meta/service/tests/it/grpc/metasrv_grpc_export.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/grpc/metasrv_grpc_handshake.rs b/src/meta/service/tests/it/grpc/metasrv_grpc_handshake.rs index 5f006daf3e2e..9a154470d540 100644 --- a/src/meta/service/tests/it/grpc/metasrv_grpc_handshake.rs +++ b/src/meta/service/tests/it/grpc/metasrv_grpc_handshake.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/grpc/metasrv_grpc_kv_api.rs b/src/meta/service/tests/it/grpc/metasrv_grpc_kv_api.rs index a17d2b0347ee..0b51b6922e31 100644 --- a/src/meta/service/tests/it/grpc/metasrv_grpc_kv_api.rs +++ b/src/meta/service/tests/it/grpc/metasrv_grpc_kv_api.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/grpc/metasrv_grpc_kv_api_restart_cluster.rs b/src/meta/service/tests/it/grpc/metasrv_grpc_kv_api_restart_cluster.rs index d1b55091eb1c..999991182c04 100644 --- a/src/meta/service/tests/it/grpc/metasrv_grpc_kv_api_restart_cluster.rs +++ b/src/meta/service/tests/it/grpc/metasrv_grpc_kv_api_restart_cluster.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/grpc/metasrv_grpc_kv_read_v1.rs b/src/meta/service/tests/it/grpc/metasrv_grpc_kv_read_v1.rs index 2cc106df3e2e..d4dd239b143d 100644 --- a/src/meta/service/tests/it/grpc/metasrv_grpc_kv_read_v1.rs +++ b/src/meta/service/tests/it/grpc/metasrv_grpc_kv_read_v1.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/grpc/metasrv_grpc_schema_api.rs b/src/meta/service/tests/it/grpc/metasrv_grpc_schema_api.rs index 693ff5c9b5fb..f0bfe26db237 100644 --- a/src/meta/service/tests/it/grpc/metasrv_grpc_schema_api.rs +++ b/src/meta/service/tests/it/grpc/metasrv_grpc_schema_api.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/grpc/metasrv_grpc_schema_api_follower_follower.rs b/src/meta/service/tests/it/grpc/metasrv_grpc_schema_api_follower_follower.rs index d505cef152d6..cd3e1ec8fb15 100644 --- a/src/meta/service/tests/it/grpc/metasrv_grpc_schema_api_follower_follower.rs +++ b/src/meta/service/tests/it/grpc/metasrv_grpc_schema_api_follower_follower.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/grpc/metasrv_grpc_schema_api_leader_follower.rs b/src/meta/service/tests/it/grpc/metasrv_grpc_schema_api_leader_follower.rs index 9fb32feed888..9ef4319638b9 100644 --- a/src/meta/service/tests/it/grpc/metasrv_grpc_schema_api_leader_follower.rs +++ b/src/meta/service/tests/it/grpc/metasrv_grpc_schema_api_leader_follower.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/grpc/metasrv_grpc_tls.rs b/src/meta/service/tests/it/grpc/metasrv_grpc_tls.rs index 5b17b8704d7a..fa30fd404a24 100644 --- a/src/meta/service/tests/it/grpc/metasrv_grpc_tls.rs +++ b/src/meta/service/tests/it/grpc/metasrv_grpc_tls.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/grpc/metasrv_grpc_watch.rs b/src/meta/service/tests/it/grpc/metasrv_grpc_watch.rs index e8b4c6009bb3..871546115df4 100644 --- a/src/meta/service/tests/it/grpc/metasrv_grpc_watch.rs +++ b/src/meta/service/tests/it/grpc/metasrv_grpc_watch.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/grpc/mod.rs b/src/meta/service/tests/it/grpc/mod.rs index 8984498127b0..55692e705c3d 100644 --- a/src/meta/service/tests/it/grpc/mod.rs +++ b/src/meta/service/tests/it/grpc/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/main.rs b/src/meta/service/tests/it/main.rs index a755dd2617a9..fe25f6346e52 100644 --- a/src/meta/service/tests/it/main.rs +++ b/src/meta/service/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/meta_node/meta_node_lifecycle.rs b/src/meta/service/tests/it/meta_node/meta_node_lifecycle.rs index b74fd70e79ea..f50406139a32 100644 --- a/src/meta/service/tests/it/meta_node/meta_node_lifecycle.rs +++ b/src/meta/service/tests/it/meta_node/meta_node_lifecycle.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/meta_node/mod.rs b/src/meta/service/tests/it/meta_node/mod.rs index 7e3fe788e2e5..0469da7482fc 100644 --- a/src/meta/service/tests/it/meta_node/mod.rs +++ b/src/meta/service/tests/it/meta_node/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/store.rs b/src/meta/service/tests/it/store.rs index d958a41ec1b8..0be7168d1ebe 100644 --- a/src/meta/service/tests/it/store.rs +++ b/src/meta/service/tests/it/store.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/testing.rs b/src/meta/service/tests/it/testing.rs index 05af62b21c89..39437c67cbd6 100644 --- a/src/meta/service/tests/it/testing.rs +++ b/src/meta/service/tests/it/testing.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/tests/mod.rs b/src/meta/service/tests/it/tests/mod.rs index 691b1a6c12a2..0703956184fa 100644 --- a/src/meta/service/tests/it/tests/mod.rs +++ b/src/meta/service/tests/it/tests/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/tests/service.rs b/src/meta/service/tests/it/tests/service.rs index 025f2e667e54..14689da1542e 100644 --- a/src/meta/service/tests/it/tests/service.rs +++ b/src/meta/service/tests/it/tests/service.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/service/tests/it/tests/tls_constants.rs b/src/meta/service/tests/it/tests/tls_constants.rs index 86cb480f6d6d..f9a6bcd54588 100644 --- a/src/meta/service/tests/it/tests/tls_constants.rs +++ b/src/meta/service/tests/it/tests/tls_constants.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/sled-store/tests/it/sled_tree.rs b/src/meta/sled-store/tests/it/sled_tree.rs index e42af93d3a8e..7141d0b2bc93 100644 --- a/src/meta/sled-store/tests/it/sled_tree.rs +++ b/src/meta/sled-store/tests/it/sled_tree.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/sled-store/tests/it/sled_txn_tree.rs b/src/meta/sled-store/tests/it/sled_txn_tree.rs index 08d1991d2aa1..e3b9b1920a83 100644 --- a/src/meta/sled-store/tests/it/sled_txn_tree.rs +++ b/src/meta/sled-store/tests/it/sled_txn_tree.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/sled-store/tests/it/testing/fake_key_spaces.rs b/src/meta/sled-store/tests/it/testing/fake_key_spaces.rs index 9b2f7ba9789d..529c40ebc619 100644 --- a/src/meta/sled-store/tests/it/testing/fake_key_spaces.rs +++ b/src/meta/sled-store/tests/it/testing/fake_key_spaces.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/sled-store/tests/it/testing/fake_state_machine_meta.rs b/src/meta/sled-store/tests/it/testing/fake_state_machine_meta.rs index 57d0571da4ee..d2f3b2330409 100644 --- a/src/meta/sled-store/tests/it/testing/fake_state_machine_meta.rs +++ b/src/meta/sled-store/tests/it/testing/fake_state_machine_meta.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/sled-store/tests/it/testing/mod.rs b/src/meta/sled-store/tests/it/testing/mod.rs index 0aedf9246e4b..3e4daa66f889 100644 --- a/src/meta/sled-store/tests/it/testing/mod.rs +++ b/src/meta/sled-store/tests/it/testing/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/types/proto/meta.proto b/src/meta/types/proto/meta.proto index 90be9481d16a..1f5db90387c7 100644 --- a/src/meta/types/proto/meta.proto +++ b/src/meta/types/proto/meta.proto @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/types/proto/request.proto b/src/meta/types/proto/request.proto index e2b21862dbcd..41f76d64a759 100644 --- a/src/meta/types/proto/request.proto +++ b/src/meta/types/proto/request.proto @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/meta/types/tests/it/cluster.rs b/src/meta/types/tests/it/cluster.rs index b829c5b19a08..8ba2e3b62867 100644 --- a/src/meta/types/tests/it/cluster.rs +++ b/src/meta/types/tests/it/cluster.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/ast/tests/it/main.rs b/src/query/ast/tests/it/main.rs index 32f7b0515470..9565dfc9d3ea 100644 --- a/src/query/ast/tests/it/main.rs +++ b/src/query/ast/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/expression/src/schema.rs b/src/query/expression/src/schema.rs index 8372513718af..e3f5b802f782 100644 --- a/src/query/expression/src/schema.rs +++ b/src/query/expression/src/schema.rs @@ -102,6 +102,13 @@ pub fn is_internal_column(column_name: &str) -> bool { | BASE_BLOCK_IDS_COL_NAME | ROW_NUMBER_COL_NAME | PREDICATE_COLUMN_NAME + | CHANGE_ACTION_COL_NAME + | CHANGE_IS_UPDATE_COL_NAME + | CHANGE_ROW_ID_COL_NAME + // change$row_id might be expended + // to the computation of the two following internal columns + | ORIGIN_BLOCK_ROW_NUM_COL_NAME + | BASE_ROW_ID_COL_NAME ) } diff --git a/src/query/expression/tests/it/fill_field_default_value.rs b/src/query/expression/tests/it/fill_field_default_value.rs index 55c750c8d806..aa97039257c6 100644 --- a/src/query/expression/tests/it/fill_field_default_value.rs +++ b/src/query/expression/tests/it/fill_field_default_value.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/formats/tests/it/output_format_tcsv.rs b/src/query/formats/tests/it/output_format_tcsv.rs index a49936898af8..41f6b2cc9cd6 100644 --- a/src/query/formats/tests/it/output_format_tcsv.rs +++ b/src/query/formats/tests/it/output_format_tcsv.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/formats/tests/it/output_format_utils.rs b/src/query/formats/tests/it/output_format_utils.rs index a735aa7d6063..4c6b0fc43dd4 100644 --- a/src/query/formats/tests/it/output_format_utils.rs +++ b/src/query/formats/tests/it/output_format_utils.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/functions/tests/it/scalars/comparison.rs b/src/query/functions/tests/it/scalars/comparison.rs index 8131a5f17a7f..c93cc6046858 100644 --- a/src/query/functions/tests/it/scalars/comparison.rs +++ b/src/query/functions/tests/it/scalars/comparison.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/management/tests/it/cluster.rs b/src/query/management/tests/it/cluster.rs index 2f58c8a2c3a5..aacffb4a4d4a 100644 --- a/src/query/management/tests/it/cluster.rs +++ b/src/query/management/tests/it/cluster.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/management/tests/it/main.rs b/src/query/management/tests/it/main.rs index 50bef4be9db6..44a778974380 100644 --- a/src/query/management/tests/it/main.rs +++ b/src/query/management/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/management/tests/it/stage.rs b/src/query/management/tests/it/stage.rs index 44ba0e1437ee..86f4c0da35b1 100644 --- a/src/query/management/tests/it/stage.rs +++ b/src/query/management/tests/it/stage.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/management/tests/it/udf.rs b/src/query/management/tests/it/udf.rs index d685aecbe011..5adafd95d0f1 100644 --- a/src/query/management/tests/it/udf.rs +++ b/src/query/management/tests/it/udf.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/management/tests/it/user.rs b/src/query/management/tests/it/user.rs index 9d448800a276..869f992291d4 100644 --- a/src/query/management/tests/it/user.rs +++ b/src/query/management/tests/it/user.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/pipeline/core/tests/it/main.rs b/src/query/pipeline/core/tests/it/main.rs index f3a88f12ffad..1d3dd8d9e131 100644 --- a/src/query/pipeline/core/tests/it/main.rs +++ b/src/query/pipeline/core/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/pipeline/core/tests/it/pipelines/mod.rs b/src/query/pipeline/core/tests/it/pipelines/mod.rs index 128562d08891..b8457fa84088 100644 --- a/src/query/pipeline/core/tests/it/pipelines/mod.rs +++ b/src/query/pipeline/core/tests/it/pipelines/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/api/http/cluster.rs b/src/query/service/tests/it/api/http/cluster.rs index 39c7edba60d8..f1fc5f355665 100644 --- a/src/query/service/tests/it/api/http/cluster.rs +++ b/src/query/service/tests/it/api/http/cluster.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/api/http/logs.rs b/src/query/service/tests/it/api/http/logs.rs index 95f6ee8d9f70..ad1e3759fa45 100644 --- a/src/query/service/tests/it/api/http/logs.rs +++ b/src/query/service/tests/it/api/http/logs.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/api/http/mod.rs b/src/query/service/tests/it/api/http/mod.rs index de6ab219ecaa..54e2d417b9ab 100644 --- a/src/query/service/tests/it/api/http/mod.rs +++ b/src/query/service/tests/it/api/http/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/api/http/status.rs b/src/query/service/tests/it/api/http/status.rs index 7fec056ef6dd..b5b5db2d3ff2 100644 --- a/src/query/service/tests/it/api/http/status.rs +++ b/src/query/service/tests/it/api/http/status.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/api/http_service.rs b/src/query/service/tests/it/api/http_service.rs index c85f7e42e30c..8e4ee445bf39 100644 --- a/src/query/service/tests/it/api/http_service.rs +++ b/src/query/service/tests/it/api/http_service.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/api/mod.rs b/src/query/service/tests/it/api/mod.rs index 8be25df45d09..0dc75928aaa5 100644 --- a/src/query/service/tests/it/api/mod.rs +++ b/src/query/service/tests/it/api/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/api/rpc_service.rs b/src/query/service/tests/it/api/rpc_service.rs index cd8f95b02228..f7b9a0018bae 100644 --- a/src/query/service/tests/it/api/rpc_service.rs +++ b/src/query/service/tests/it/api/rpc_service.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/clusters.rs b/src/query/service/tests/it/clusters.rs index e9242b7a747d..8bb4ca7e1425 100644 --- a/src/query/service/tests/it/clusters.rs +++ b/src/query/service/tests/it/clusters.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/configs.rs b/src/query/service/tests/it/configs.rs index f91df5f9f4f5..7318f861aaad 100644 --- a/src/query/service/tests/it/configs.rs +++ b/src/query/service/tests/it/configs.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/distributed/mod.rs b/src/query/service/tests/it/distributed/mod.rs index 6ed56a78dfd8..dff132cb3a8a 100644 --- a/src/query/service/tests/it/distributed/mod.rs +++ b/src/query/service/tests/it/distributed/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/interpreters/mod.rs b/src/query/service/tests/it/interpreters/mod.rs index 5dcc67376db7..dc94aeb01fff 100644 --- a/src/query/service/tests/it/interpreters/mod.rs +++ b/src/query/service/tests/it/interpreters/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/interpreters/union.rs b/src/query/service/tests/it/interpreters/union.rs index 24fb475a3aaa..f5f42b168c2a 100644 --- a/src/query/service/tests/it/interpreters/union.rs +++ b/src/query/service/tests/it/interpreters/union.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/main.rs b/src/query/service/tests/it/main.rs index bfdad79af04c..d87af79b7c01 100644 --- a/src/query/service/tests/it/main.rs +++ b/src/query/service/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/metrics.rs b/src/query/service/tests/it/metrics.rs index f2ecb8a798b1..7b9291b1d77a 100644 --- a/src/query/service/tests/it/metrics.rs +++ b/src/query/service/tests/it/metrics.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/pipelines/mod.rs b/src/query/service/tests/it/pipelines/mod.rs index 82232659ef94..b5bc5a74e475 100644 --- a/src/query/service/tests/it/pipelines/mod.rs +++ b/src/query/service/tests/it/pipelines/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/servers/flight_sql/flight_sql_server.rs b/src/query/service/tests/it/servers/flight_sql/flight_sql_server.rs index 44612a7b443b..6173f412da36 100644 --- a/src/query/service/tests/it/servers/flight_sql/flight_sql_server.rs +++ b/src/query/service/tests/it/servers/flight_sql/flight_sql_server.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/servers/http/http_query_handlers.rs b/src/query/service/tests/it/servers/http/http_query_handlers.rs index d2db0f123046..2a8b05da1c92 100644 --- a/src/query/service/tests/it/servers/http/http_query_handlers.rs +++ b/src/query/service/tests/it/servers/http/http_query_handlers.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/servers/http/json_block.rs b/src/query/service/tests/it/servers/http/json_block.rs index 9e0858873893..e855a8aeb25f 100644 --- a/src/query/service/tests/it/servers/http/json_block.rs +++ b/src/query/service/tests/it/servers/http/json_block.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/servers/http/mod.rs b/src/query/service/tests/it/servers/http/mod.rs index 7af083933e5d..33de44308ec6 100644 --- a/src/query/service/tests/it/servers/http/mod.rs +++ b/src/query/service/tests/it/servers/http/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/servers/mod.rs b/src/query/service/tests/it/servers/mod.rs index 74339ff35cd8..5541b9c7536f 100644 --- a/src/query/service/tests/it/servers/mod.rs +++ b/src/query/service/tests/it/servers/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/sessions/mod.rs b/src/query/service/tests/it/sessions/mod.rs index 74ed817c4cdc..b53dd14deca9 100644 --- a/src/query/service/tests/it/sessions/mod.rs +++ b/src/query/service/tests/it/sessions/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/sessions/session.rs b/src/query/service/tests/it/sessions/session.rs index 5ac30b5b1dec..e67ac0baf98b 100644 --- a/src/query/service/tests/it/sessions/session.rs +++ b/src/query/service/tests/it/sessions/session.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/sessions/session_setting.rs b/src/query/service/tests/it/sessions/session_setting.rs index db70998c797c..96ff582ed7a4 100644 --- a/src/query/service/tests/it/sessions/session_setting.rs +++ b/src/query/service/tests/it/sessions/session_setting.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/sql/mod.rs b/src/query/service/tests/it/sql/mod.rs index 560e3ef26068..6e3bdf945074 100644 --- a/src/query/service/tests/it/sql/mod.rs +++ b/src/query/service/tests/it/sql/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/storages/mod.rs b/src/query/service/tests/it/storages/mod.rs index 32442574f0bb..1086efea7dd1 100644 --- a/src/query/service/tests/it/storages/mod.rs +++ b/src/query/service/tests/it/storages/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/storages/system.rs b/src/query/service/tests/it/storages/system.rs index 3bd176d0d7e7..6f9b0c909dca 100644 --- a/src/query/service/tests/it/storages/system.rs +++ b/src/query/service/tests/it/storages/system.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/tests/catalog.rs b/src/query/service/tests/it/tests/catalog.rs index 06dcdbe85eb6..4cf83524348b 100644 --- a/src/query/service/tests/it/tests/catalog.rs +++ b/src/query/service/tests/it/tests/catalog.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/tests/mod.rs b/src/query/service/tests/it/tests/mod.rs index 0ca0e832d0e1..cc437ec230e1 100644 --- a/src/query/service/tests/it/tests/mod.rs +++ b/src/query/service/tests/it/tests/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/service/tests/it/tests/tls_constants.rs b/src/query/service/tests/it/tests/tls_constants.rs index a306027f7141..40a0b85c643b 100644 --- a/src/query/service/tests/it/tests/tls_constants.rs +++ b/src/query/service/tests/it/tests/tls_constants.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/settings/tests/it/main.rs b/src/query/settings/tests/it/main.rs index c6ec4929b099..d31368b4c7e3 100644 --- a/src/query/settings/tests/it/main.rs +++ b/src/query/settings/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/storages/common/index/tests/it/filters/xor8.rs b/src/query/storages/common/index/tests/it/filters/xor8.rs index d9774b52d905..7a874833f452 100644 --- a/src/query/storages/common/index/tests/it/filters/xor8.rs +++ b/src/query/storages/common/index/tests/it/filters/xor8.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/storages/hive/hive/tests/it/hive_file_splitter.rs b/src/query/storages/hive/hive/tests/it/hive_file_splitter.rs index e1363039aaff..cf77bcf40614 100644 --- a/src/query/storages/hive/hive/tests/it/hive_file_splitter.rs +++ b/src/query/storages/hive/hive/tests/it/hive_file_splitter.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/storages/hive/hive/tests/it/main.rs b/src/query/storages/hive/hive/tests/it/main.rs index 820e5c5d9ed4..78f1d926806f 100644 --- a/src/query/storages/hive/hive/tests/it/main.rs +++ b/src/query/storages/hive/hive/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/storages/parquet/tests/it/main.rs b/src/query/storages/parquet/tests/it/main.rs index d7d81a7f1655..fc3a852d1f51 100644 --- a/src/query/storages/parquet/tests/it/main.rs +++ b/src/query/storages/parquet/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/storages/parquet/tests/it/merge_io.rs b/src/query/storages/parquet/tests/it/merge_io.rs index 209ae5447b1f..b4bda7900b31 100644 --- a/src/query/storages/parquet/tests/it/merge_io.rs +++ b/src/query/storages/parquet/tests/it/merge_io.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/users/tests/it/main.rs b/src/query/users/tests/it/main.rs index da88bc961f50..db79f359c4e4 100644 --- a/src/query/users/tests/it/main.rs +++ b/src/query/users/tests/it/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/users/tests/it/mod.rs b/src/query/users/tests/it/mod.rs index 7caa6d969b7c..3050ad50e21f 100644 --- a/src/query/users/tests/it/mod.rs +++ b/src/query/users/tests/it/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. @@ -12,9 +12,9 @@ // See the License for the specific language governing permissions and // limitations under the License. +mod jwt; mod network_policy; mod role_cache_mgr; mod role_mgr; mod user_mgr; mod user_udf; -mod jwt; diff --git a/src/query/users/tests/it/network_policy.rs b/src/query/users/tests/it/network_policy.rs index 346dcc722731..e1879ab70533 100644 --- a/src/query/users/tests/it/network_policy.rs +++ b/src/query/users/tests/it/network_policy.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/users/tests/it/role_util.rs b/src/query/users/tests/it/role_util.rs index 3faaaf2e65b1..b9124c40b2c2 100644 --- a/src/query/users/tests/it/role_util.rs +++ b/src/query/users/tests/it/role_util.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/users/tests/it/user_mgr.rs b/src/query/users/tests/it/user_mgr.rs index ca63a187a08a..46adbced2ac7 100644 --- a/src/query/users/tests/it/user_mgr.rs +++ b/src/query/users/tests/it/user_mgr.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/src/query/users/tests/it/user_udf.rs b/src/query/users/tests/it/user_udf.rs index efca38c1a987..62158c7b5bae 100644 --- a/src/query/users/tests/it/user_udf.rs +++ b/src/query/users/tests/it/user_udf.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/tests/sqllogictests/src/arg.rs b/tests/sqllogictests/src/arg.rs index f4546368c051..d6534a6336bd 100644 --- a/tests/sqllogictests/src/arg.rs +++ b/tests/sqllogictests/src/arg.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/tests/sqllogictests/src/client/http_client.rs b/tests/sqllogictests/src/client/http_client.rs index 3256cb0d7657..4c6857615440 100644 --- a/tests/sqllogictests/src/client/http_client.rs +++ b/tests/sqllogictests/src/client/http_client.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/tests/sqllogictests/src/client/mod.rs b/tests/sqllogictests/src/client/mod.rs index d25522d1ed28..439bfb5e3ddc 100644 --- a/tests/sqllogictests/src/client/mod.rs +++ b/tests/sqllogictests/src/client/mod.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/tests/sqllogictests/src/client/mysql_client.rs b/tests/sqllogictests/src/client/mysql_client.rs index 8bfc6bb1d136..b821e760f320 100644 --- a/tests/sqllogictests/src/client/mysql_client.rs +++ b/tests/sqllogictests/src/client/mysql_client.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/tests/sqllogictests/src/error.rs b/tests/sqllogictests/src/error.rs index 3e9fa5e3a45a..1ef95b60062b 100644 --- a/tests/sqllogictests/src/error.rs +++ b/tests/sqllogictests/src/error.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/tests/sqllogictests/src/main.rs b/tests/sqllogictests/src/main.rs index 7ee2eb48095c..d85af5cf7e2c 100644 --- a/tests/sqllogictests/src/main.rs +++ b/tests/sqllogictests/src/main.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/tests/sqllogictests/src/util.rs b/tests/sqllogictests/src/util.rs index 3fc0b6eaed05..df1bd2f1f338 100644 --- a/tests/sqllogictests/src/util.rs +++ b/tests/sqllogictests/src/util.rs @@ -1,4 +1,4 @@ -// Copyright 2021 Datafuse Labs. +// Copyright 2021 Datafuse Labs // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. diff --git a/tests/sqllogictests/suites/ee/01_ee_system/01_0003_stream.test b/tests/sqllogictests/suites/ee/01_ee_system/01_0003_stream.test index 1406a8919cc4..dcb8b8f53695 100644 --- a/tests/sqllogictests/suites/ee/01_ee_system/01_0003_stream.test +++ b/tests/sqllogictests/suites/ee/01_ee_system/01_0003_stream.test @@ -223,5 +223,36 @@ drop table s2 statement ok drop stream s2 +############### +# issue 14062 # +############### + +statement ok +create table t_14062 (c int); + +statement ok +create stream s_14062 on table t_14062 ; + +statement ok +insert into t_14062 values(1); + +query T +select * from s_14062 where change$action = 'INSERT'; +---- +1 + +query T +select * from s_14062 where change$is_update = false; +---- +1 + +query T +select * from s_14062 where change$row_id = '1'; +---- + +###################### +# end of issue 14062 # +###################### + statement ok DROP DATABASE IF EXISTS test_stream