fys
fa4a497d75
feat: add cache for catalog kv backend ( #1592 )
...
* feat: add kvbackend cache
* fix: cargo fmt
2023-05-24 15:07:29 +08:00
JeremyHi
1225edb065
refactor: move rpc's commons to common-meta ( #1625 )
2023-05-23 10:07:24 +08:00
Lei, HUANG
8e7ec4626b
refactor: remove useless error ( #1624 )
...
* refactor: remove useless
* fix: remove useless error variant
2023-05-22 22:55:27 +08:00
QuenKar
edf6c0bf48
refactor: add "table engine" to datanode heartbeat. ( #1616 )
...
refactor:add "table engine" to datanode heartbeat.
2023-05-22 10:09:32 +08:00
Weny Xu
68dfea0cfd
fix: fix datanode cannot start while failing to open tables ( #1601 )
2023-05-17 20:56:13 +08:00
Yingwen
8d54d40b21
feat: Add FlushPicker to flush regions periodically ( #1559 )
...
* feat: Add FlushPicker
* feat(storage): Add close to StorageEngine
* style(storage): fix clippy
* feat(storage): Close regions in StorageEngine::close
* chore(storage): Clear requests on scheduler stop
* test(storage): Test flush picker
* feat(storage): Add metrics for auto flush
* feat(storage): Add flush reason and record it in metrics
* feat: Expose flush config
docs(config): Update config example
* refactor(storage): Run auto flush task in FlushScheduler
* refactor(storage): Add FlushItem trait to make FlushPicker easy to test
2023-05-15 17:29:28 +08:00
Weny Xu
66903d42e1
feat: implement OpenTableHandler ( #1567 )
...
* feat: implement OpenTableHandler
* chore: apply suggestion from CR
* chore: apply suggestion from CR
2023-05-15 10:47:28 +08:00
Ning Sun
4151d7a8ea
fix: allow cross-schema query on information_schema ( #1568 )
2023-05-11 16:54:28 +08:00
Ning Sun
8c85fdec29
fix: correct schema/table count in catalog metrics ( #1565 )
2023-05-11 14:20:42 +08:00
gitccl
fbf1ddd006
feat: open catalogs and schemas in parallel ( #1527 )
...
* feat: open catalogs and schemas in parallel
* fix: code review
2023-05-08 10:34:30 +08:00
Ning Sun
d679cfcb53
feat: add semantic_type to information_schema.columns ( #1530 )
2023-05-06 15:48:37 +08:00
discord9
2c82ded975
feat: table metrics ( #1469 )
...
* feat: Statistic
* add todo
* fmt: cargo fmt
* feat: some simple impl for MemTable
* chore: a try on adding statistics
* Update src/table/src/stats.rs
Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
* docs: fix typo
* newlines unnecessary
---------
Co-authored-by: Ruihang Xia <waynestxia@gmail.com >
Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
2023-05-06 14:59:49 +08:00
Ning Sun
b0ab641602
feat: add catalog/schema/table count as catalog metrics ( #1499 )
...
* feat: add catalog/schema/table count as catalog metrics
* test: add integration tests for catalog metrics
2023-05-05 05:54:12 +00:00
Huaijin
224ec9bd25
fix: wrong max_table_id log in remote catalog manager ( #1516 )
...
* fix: wrong max_table_id log in remote catalog manager
* chore: update link in CONTRIBUTING.md
* chore: add a new const MAX_SYS_TABLE_ID
2023-05-05 03:39:45 +00:00
Ning Sun
6e1bb9e458
feat: add support for information_schema.columns ( #1500 )
...
* feat: add support for information_schema.columns
* feat: remove information_schema from its view
* Update src/catalog/src/information_schema.rs
Co-authored-by: LFC <bayinamine@gmail.com >
* fix: error on table data type
* test: correct sqlness test for information schema
* test: add information_schema.columns sqlness tests
---------
Co-authored-by: LFC <bayinamine@gmail.com >
2023-05-04 14:29:38 +08:00
Lei, HUANG
fb9978e95d
refactor: catalog ( #1454 )
...
* wip
* add schema_async
* remove CatalogList
* remove catalog provider and schema provider
* fix
* fix: rename table
* fix: sqlness
* fix: ignore tonic error metadata
* fix: table engine name
* feat: rename catalog_async to catalog
* respect engine name in table regional value when deregistering tables
* fix: CR
2023-04-26 08:36:40 +00:00
discord9
ef4e473e6d
fix: recompile®ister scripts as UDF on reboot ( #1421 )
...
* fixme: recompile somewhere else
* feat: re-compile&re-register all scripts in table
* fix: allow empty scripts table
* chore: add non-blocking somewhere
* chore: PR advices
* chore: more PR advices
* style: remove useless join
* style: remove redunent code
* refactor: use `bg` runtime instead
* style: cargo fmt
2023-04-26 16:30:58 +08:00
Yingwen
eb50cee601
feat: Switch to the procedure framework ( #1448 )
...
* feat: Remove create_mock_sql_handler()
create_to_request() and alter_to_request() don't need `&self`, so
we don't need to mock the sql handler to test them
* feat: Enable procedure manager by default
* docs: Update config example
* test: Enable procedure framework in all tests
* refactor(datanode): rename methods using procedure
* test(catalog): Fix temp dir drops before test finishes
* tests: Enable procedure framework in sqlness
* test: Fix sqlness standalone rename test
* fix: Drop procedure allows table not in engine
* test: Change rename table test
* fix: add options to table meta when creating table by procedure
* test: adjust error message in schema test case
* test: Fix test_sql_api error message
2023-04-25 12:04:02 +08:00
fys
f2cfd8e608
refactor: default catalog and schema are created at Metasrv ( #1391 )
...
* refactor: default catalog and schema are created at Metasrv
* fix: unit test
* fix: add license
* simplify the meta mock
* cr
2023-04-20 17:58:37 +08:00
Hao
e4cd08c750
feat: add table id and engine to information_schema.TABLES ( #1407 )
...
* feat: add table id and engine to informatin_schema.TABLES
* Update src/catalog/src/information_schema/tables.rs
Co-authored-by: Yingwen <realevenyag@gmail.com >
* chore: change table_engine to engine
* test: update sqlness for information schema
* test: update information_schema test in frontend::tests::instance_test.rs
* fix: github action sqlness information_schema test fail
* test: ignore table_id in information_schema
* test: support distribute and standalone have different output
---------
Co-authored-by: Yingwen <realevenyag@gmail.com >
2023-04-19 10:52:02 +08:00
shuiyisong
145f8eb5a7
refactor: parallelize open table ( #1392 )
...
* refactor: change open_table to parallel on datanode startup
* chore: try move out register schema table
* chore: change mito engine to key lock
* chore: minor change
* chore: minor change
* chore: update error definition
* chore: remove rwlock on tables
* chore: try parallel register table on schema provider
* chore: add rt log
* chore: add region open rt log
* chore: add actual open region rt log
* chore: add recover rt log
* chore: divide to three part rt log
* chore: remove debug log
* chore: add replay rt log
* chore: update cargo lock
* chore: remove debug log
* chore: revert unused change
* chore: update err msg
Co-authored-by: dennis zhuang <killme2008@gmail.com >
* chore: fix cr issue
Co-authored-by: dennis zhuang <killme2008@gmail.com >
* chore: fix cr issue
* chore: fix cr issue
---------
Co-authored-by: dennis zhuang <killme2008@gmail.com >
2023-04-18 21:36:29 +08:00
Ruihang Xia
dc85a4b5bb
feat: migrate substrait to datafusion official implementation ( #1238 )
...
* some test cases will fail
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* revert version changes
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* update substrait-proto version
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* fix compile
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* update df again
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* clean up
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* Update src/common/substrait/Cargo.toml
Co-authored-by: dennis zhuang <killme2008@gmail.com >
* revert COPY FROM / COPY TO sqlness to standalone only
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
---------
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
Co-authored-by: dennis zhuang <killme2008@gmail.com >
2023-04-17 15:54:35 +08:00
LFC
0fc816fb0c
test: add "numbers" table in distributed mode ( #1374 )
2023-04-14 11:52:04 +08:00
Lei, HUANG
9fa871a3fa
fix: concurrent rename two table to same name may cause override ( #1368 )
...
* fix: concurrent rename two table to same name may cause override
* fix: concurrently update system catalog table
* fix: correctness
2023-04-13 11:53:02 +08:00
LFC
a3e47955b8
feat: information schema ( #1327 )
...
* feat: basic information schema
* show information schema only for current catalog
* fix: fragile tests
2023-04-07 16:50:14 +08:00
Ruihang Xia
da66138e80
refactor(error): remove backtrace, and introduce call-site location for debugging ( #1329 )
...
* wip: global replace
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* fix compile
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* fix warnings
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* remove unneeded tests of errors
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* fix ErrorExt trait implementator
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* fix warnings
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* fix format
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* fix pyo3 tests
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
---------
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
2023-04-06 04:06:00 +00:00
Weny Xu
451f9d2d4e
feat: support multi table engines ( #1277 )
...
* feat: support multi table engines
* refactor: adapt SqlHandler to support multiple table engines
* refactor: refactor TableEngineManager
* chore: apply review suggestions
* chore: apply review suggestions
* chore: apply review suggestions
* chore: snafu context styling
2023-04-03 14:49:12 +00:00
LFC
48c2841e4d
feat: execute python script in distributed mode ( #1264 )
...
* feat: execute python script in distributed mode
* fix: rebase develop
2023-04-02 20:36:48 +08:00
Ruihang Xia
b5e5f8e555
chore(deps): bump arrow and parquet to 36.0.0, and datafusion to the latest ( #1282 )
...
* chore: update arrow, parquet to 36.0 and datafusion
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* update deps
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
* Apply suggestions from code review
Co-authored-by: LFC <bayinamine@gmail.com >
* update sqlness result
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
---------
Signed-off-by: Ruihang Xia <waynestxia@gmail.com >
Co-authored-by: LFC <bayinamine@gmail.com >
2023-03-30 16:24:10 +08:00
Lei, HUANG
5edd2a3dbe
feat: upgrade opendal ( #1245 )
...
* chore: upgrade opendal
* chore: finish upgrading opendal
* fix: clippy complaints
* fix some tests
* fix: all unit tests
* chore: rebase develop
* fix: sqlness tests
* optimize imports
* chore: rebase develop
* doc: add todo
2023-03-28 09:47:33 +08:00
LFC
0f160a73be
feat: metasrv collects datanode heartbeats for region failure detection ( #1214 )
...
* feat: metasrv collects datanode heartbeats for region failure detection
* chore: change visibility
* fix: fragile tests
* Update src/meta-srv/src/handler/persist_stats_handler.rs
Co-authored-by: fys <40801205+Fengys123@users.noreply.github.com >
* Update src/meta-srv/src/handler/failure_handler.rs
Co-authored-by: fys <40801205+Fengys123@users.noreply.github.com >
* fix: resolve PR comments
* fix: resolve PR comments
* fix: resolve PR comments
---------
Co-authored-by: shuiyisong <xixing.sys@gmail.com >
Co-authored-by: fys <40801205+Fengys123@users.noreply.github.com >
2023-03-24 04:28:34 +00:00
fys
0596d20a3b
fix: can not create table in the local distributed environment ( #1207 )
...
fix: create table in local distribute env
2023-03-20 20:12:35 +08:00
Zheming Li
f712f978cf
feat: Report disk usage stats to metasrv thru heartbeat ( #1167 )
...
* feat: Report disk usage stats to metasrv thru heartbeat
Signed-off-by: Zheming Li <nkdudu@126.com >
* Update src/catalog/src/error.rs
Co-authored-by: fys <40801205+Fengys123@users.noreply.github.com >
* Update src/catalog/src/lib.rs
Co-authored-by: fys <40801205+Fengys123@users.noreply.github.com >
* Update src/mito/src/table.rs
Co-authored-by: fys <40801205+Fengys123@users.noreply.github.com >
---------
Signed-off-by: Zheming Li <nkdudu@126.com >
Co-authored-by: fys <40801205+Fengys123@users.noreply.github.com >
2023-03-15 03:11:32 +00:00
Weny Xu
8a83de4ea5
feat: add shutdown for datanode ( #1160 )
2023-03-13 17:49:26 +08:00
Eugene Tolbakov
b31a6cb506
refactor: replace tempdir with tempfile ( #1123 )
...
* refactor: replace tempdir with tempfile
* refactor(query): move tempfile dependency under the workspace's Cargo.toml
* refactor(tempfile): create common-test-util
* refactor(tempfile): fix toml format
* refactor(tempfile): remove tempfile out of dependencies
* refactor(tempfile): fix incorrect toml
2023-03-08 11:15:56 +08:00
fys
559880cb84
fix: can not find catalog when create table ( #1118 )
...
* fix: get catalog by name in RemoteCatalogManager
* cr
* cr
* cr
* fix: ut failed
2023-03-06 14:44:40 +08:00
shuiyisong
bd065ea6e8
fix: remove incorrect continue ( #1114 )
2023-03-02 19:52:17 +08:00
Ning Sun
d402f83442
ci: generate apidocs when pushing to default branch ( #1093 )
...
* ci: generate apidocs when pushing to default branch
* ci: require clippy before running tests
* fix: resolve new clippy warnings on primitive slice
* fix: resolve more clippy warnings
* Update .github/workflows/apidoc.yml
Co-authored-by: Ruihang Xia <waynestxia@gmail.com >
* ci: add an index html to redirect
---------
Co-authored-by: Ruihang Xia <waynestxia@gmail.com >
2023-03-01 13:18:26 +08:00
shuiyisong
50d2685365
fix: fix catalog parsing issue ( #1091 )
...
fix: try fix catalog parsing issue
2023-02-27 22:51:49 +08:00
LFC
11d45e2918
refactor: upgrade DataFusion, Arrow and Sqlparser ( #1074 )
...
* refactor: upgrade DataFusion, Arrow and Sqlparser
* fix: resolve PR comments
2023-02-27 22:20:08 +08:00
Xuanwo
fdd17c6eeb
refactor: Clean up re-export of opendal services ( #1067 )
...
Signed-off-by: Xuanwo <github@xuanwo.io >
2023-02-23 14:12:34 +08:00
Xuanwo
98ef74bff4
chore: Bump OpenDAL to v0.27 ( #1057 )
...
* Bump OpenDAL to v0.27
Signed-off-by: Xuanwo <github@xuanwo.io >
* Make cargo check happy
Signed-off-by: Xuanwo <github@xuanwo.io >
* Address comments
Signed-off-by: Xuanwo <github@xuanwo.io >
* Address comments
Signed-off-by: Xuanwo <github@xuanwo.io >
* Format toml
Signed-off-by: Xuanwo <github@xuanwo.io >
* Make taplo happy
Signed-off-by: Xuanwo <github@xuanwo.io >
---------
Signed-off-by: Xuanwo <github@xuanwo.io >
2023-02-23 11:20:45 +08:00
Lei, HUANG
f42acc90c2
fix: allow empty TableOptions ( #1063 )
...
fix: allow default TableOptions to avoid panic when upgrading from older versions
2023-02-22 19:19:13 +08:00
Xieqijun
390e9095f6
feat: admin http api ( #1026 )
...
* feat: catalog list
* feat: catalog list
* feat:api
* feat: leader info
* feat: use constant
* fix: ci
* feat: query heartbeat by ip
* ut: add test
* fix: cr
* fix: cr
* fix: cr
2023-02-22 14:18:37 +08:00
Lei, HUANG
e17d5a1c41
feat: support table options ( #1044 )
...
* feat: change table options from string map to a struct, add ttl and write_buffer_size
* fix: also pass table options to table meta
* feat: pass table options when opening/creating regions
* fix: CR comments
2023-02-21 08:10:23 +00:00
Eugene Tolbakov
7787cfdd42
refactor(datatypes): enhance MutableVector methods ( #987 )
...
* refactor(datatypes): enhance MutableVector methods
* refactor(datatypes): address code review issues
* refactor(datatypes): address more code review issues
* refactor(datatypes): fix merge conflicts
* refactor(datatypes): address code review issues
* refactor(datatypes): address more code review issues
* refactor(datatypes): update sql delete with the newly introduced method
2023-02-17 16:16:23 +08:00
Yingwen
ddbc97befb
refactor: changes CreateTableRequest::schema to RawSchema ( #1018 )
...
* refactor: changes CreateTableRequest::schema to RawSchema
* refactor(grpc-expr): create_table_schema returns RawSchema
2023-02-16 16:04:17 +08:00
Lei, HUANG
75b8afe043
feat: compaction integration ( #997 )
...
* feat: trigger compaction on flush
* chore: rebase develop
* feat: add config item max_file_in_level0 and remove compaction_after_flush
* fix: cr comments
* chore: add unit test to cover Timestamp::new_inclusive
* fix: workaround to fix future is not Sync
* fix: future is not sync
* fix: some cr comments
2023-02-15 14:14:07 +08:00
LFC
803b7f0633
feat: implement "drop table" in distributed mode (both in SQL and gRPC) ( #944 )
...
* feat: implement "drop table" in distributed mode (both in SQL and gRPC)
refactor: create distributed table
some details:
- set table global value in Meta, as well as table routes value. Datanode only set table regional value
- complete instance SQL tests both in standalone and distributed mode
* fix: rebase develop
* fix: resolve PR comments
2023-02-08 07:36:38 +00:00
Lei, HUANG
5d62e193bd
feat: support multi regions on datanode ( #653 )
...
* wip: fix compile errors
* chore: move splitter to partition crate
* fix: remove useless variants in frontend errors
* chore: move more partition related code to partition manager
* fix: license header
* wip: move WriteSplitter to PartitionRuleManager
* fix: clippy warnings
* chore: remove useless error variant and format toml
* fix: cr comments
* chore: resolve conflicts
* chore: rebase develop
* fix: cr comments
* feat: support multi regions on datanode
* chore: rebase onto develop
* chore: rebase develop
* chore: rebase develop
* wip
* fix: compile errors
* feat: multi region
* fix: CR comments
* feat: allow stat existing regions without actually open it
* fix: use table meta in manifest to recover region info
2023-02-07 10:46:18 +08:00