Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat(nimtable): merge main #18527

Closed
wants to merge 62 commits into from
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
62 commits
Select commit Hold shift + click to select a range
51d3c63
fix: `DROP DATABASE` doesn't clean up the source stream job (in v1) (…
xxchan Sep 3, 2024
c519f0d
feat(telemetry): add telemetry data point when checking license (#18371)
tabVersion Sep 3, 2024
c0ce8a8
feat(sink): support async for bigquery sink (#17488)
xxhZs Sep 3, 2024
c843edc
feat: support arrow map -> rw map (#18375)
xxchan Sep 3, 2024
e9d77a4
feat(streaming): add `must_output_per_barrier` flag for stream simple…
st1page Sep 3, 2024
847610a
refactor: use high watermark to finish backfill faster (#18342)
xxchan Sep 4, 2024
a7480e1
feat(risedev): attempt to kill existing session when launching `rised…
BugenZhao Sep 4, 2024
0a4ccde
fix(sqlparser): display create items with comma properly (#18393)
xiangjinwu Sep 4, 2024
c4b1dd4
feat(expr): support `jsonb_populate_map` (#18378)
xxchan Sep 4, 2024
6402328
refactor: add some comments for source splits (#18034)
xxchan Sep 4, 2024
ee33271
fix: parquet test missing comma (#18397)
tabVersion Sep 4, 2024
9923c3a
feat(risedev): support providing env var in yaml config (#18396)
xxchan Sep 4, 2024
0dd06ff
feat(snapshot-backfill): only receive mutation from barrier worker fo…
wenym1 Sep 4, 2024
670a94f
feat: variable vnode count support in table distribution (#18373)
BugenZhao Sep 5, 2024
3b98b71
fix(source): Protobuf `Any` as canonical JSON (#18380)
xiangjinwu Sep 5, 2024
f2f5827
fix(storage): fix assertion (#18413)
zwang28 Sep 5, 2024
cb29fe0
feat: support more SSL related configurations in Kafka connector (#18…
lmatz Sep 5, 2024
8a32a9b
feat: variable vnode count support in vnode structure (#18381)
BugenZhao Sep 5, 2024
1d220ee
fix(error): fix sinkError and connector error (#18425)
xxhZs Sep 5, 2024
0134191
fix(storage): fix correct_commit_ssts with sst table_ids (#18414)
Li0k Sep 5, 2024
79ba869
fix(backup): fix restore order (#18423)
zwang28 Sep 5, 2024
df7f54f
fix(meta): fix catalog ref count (#18427)
zwang28 Sep 5, 2024
6489e9a
feat: track progress for SourceBackfill (blocking DDL) (#18112)
xxchan Sep 6, 2024
5311069
fix(sink): set query timeout for jdbc sink to avoid stuck (#18430)
StrikeW Sep 6, 2024
b00d750
fix(storage): fix duplicated sst_id generated by split_sst function (…
Li0k Sep 6, 2024
4accc4a
feat: introduce cluster limit (#18383)
hzxa21 Sep 6, 2024
7d3f285
refactor: remove drop_actors rpc and simplify barrier worker state (#…
wenym1 Sep 6, 2024
3762877
fix(storage): fix commit_epoch new_sst_id_number (#18438)
Li0k Sep 6, 2024
e2c89f4
feat: support scale SourceBackfill executor (#16825)
xxchan Sep 6, 2024
71753f1
fix(meta): correctly update serving parallelism mapping (#18439)
zwang28 Sep 6, 2024
becb896
fix(iceberg): fix select empty iceberg table (#18449)
Li0k Sep 7, 2024
9a03718
doc(readme): update architecture image (#18418)
st1page Sep 9, 2024
8d5b62b
feat: variable vnode count support in batch/streaming scheduler (#18407)
BugenZhao Sep 9, 2024
462253e
chore: update image version to 2.0.0-rc.1 (#18460)
lmatz Sep 9, 2024
29d2e1e
refactor: track progress minor refactor (#18446)
xxchan Sep 9, 2024
8c7a364
refactor(frontend): extract filling fields in fragment graph (#18466)
BugenZhao Sep 10, 2024
2679396
fix: empty string as license key stuck docker compose (#18421)
tabVersion Sep 10, 2024
952962c
refactor: replace `RdKafkaStats` with Guarded metrics (#18462)
tabVersion Sep 10, 2024
99d6121
feat(compaction): support merge compaction group (#18188)
Li0k Sep 10, 2024
f970372
fix(metric): include table_change_log when calculating object size (#…
zwang28 Sep 10, 2024
dc07da0
feat(meta): support time travel query on a per-table basis (part1) (#…
zwang28 Sep 10, 2024
596138e
feat(source): configure whether to recursively scan file source (#18324)
wcy-fdu Sep 10, 2024
829bef3
feat(expr): support map keys/values/entries (#18480)
xxchan Sep 11, 2024
7833509
feat(sink): reimplement sink coordinator worker and support scale (#1…
wenym1 Sep 11, 2024
00150a3
fix(iceberg): fix map - arrow convert & fix sink nested types to iceb…
xxchan Sep 11, 2024
084bc6d
perf: optimize memory allocation on building object path (#18465)
MrCroxx Sep 11, 2024
6038298
refactor: bump toolchain to 2024-07-19 (#18470)
MrCroxx Sep 11, 2024
8e7b099
fix(source): parse protobuf into expected struct/array (#18419)
xiangjinwu Sep 11, 2024
23410f0
feat: allow customize pulsar subscription name (#18379)
tabVersion Sep 11, 2024
5065bb4
fix(sink): fix sink_decouple = false and commit_checkpoint_interval d…
xxhZs Sep 11, 2024
c882bda
refactor(storage): cache recent versions and unify batch query and ti…
wenym1 Sep 11, 2024
a9b1de3
feat: schemaless ingestion for `encode json` (`INCLUDE payload`) (#18…
tabVersion Sep 12, 2024
4afcd4d
refactor(storage): make HummockVersion a generic struct (#18478)
zwang28 Sep 12, 2024
317641f
refactor(batch): schedule with streaming mapping if serving is tempor…
BugenZhao Sep 12, 2024
34a2ad4
feat(iceberg): support create iceberg table w/ one layer nested type …
chenzl25 Sep 12, 2024
3627131
chore(deps): bump send and express in /dashboard (#18489)
dependabot[bot] Sep 12, 2024
6c3b68f
chore: make file sink publicly accessible (#18508)
lmatz Sep 12, 2024
b9ac1ac
fix(iceberg): fix decimal overflow for iceberg arrow (#18511)
chenzl25 Sep 12, 2024
9533cd9
feat(cdc): support for verify-ca and verify-full of Postgres SSL (#18…
StrikeW Sep 12, 2024
bc9c2ad
feat(streaming): introduce streaming AsOf JOIN executor (#18242)
yuhao-su Sep 13, 2024
f226e21
fix(udf): use a dedicated runtime to create udf flight client (#18461)
chenzl25 Sep 13, 2024
870bcde
feat(iceberg): support eq delete merge on read for iceberg (#18448)
xxhZs Sep 13, 2024
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
2 changes: 1 addition & 1 deletion .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -71,12 +71,12 @@ e2e_test/generated/*
scale-test.tar.zst
simulation-it-test.tar.zst


# hummock-trace
.trace

# spark binary
e2e_test/iceberg/spark-*-bin*
e2e_test/iceberg/metastore_db

**/poetry.lock

Expand Down
1 change: 1 addition & 0 deletions .typos.toml
Original file line number Diff line number Diff line change
Expand Up @@ -36,4 +36,5 @@ extend-exclude = [
# We don't want to fix "fals" here, but may want in other places.
# Ideally, we should just ignore that line: https://github.com/crate-ci/typos/issues/316
"src/common/src/cast/mod.rs",
"src/tests/simulation/tests/integration_tests/scale/shared_source.rs",
]
83 changes: 55 additions & 28 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

10 changes: 6 additions & 4 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -135,16 +135,18 @@ tonic-build = { package = "madsim-tonic-build", version = "0.5" }
otlp-embedded = { git = "https://github.com/risingwavelabs/otlp-embedded", rev = "e6cd165b9bc85783b42c106e99186b86b73e3507" }
prost = { version = "0.13" }
prost-build = { version = "0.13" }
icelake = { git = "https://github.com/risingwavelabs/icelake.git", rev = "1860eb315183a5f3f72b4097c1e40d49407f8373", features = [
# branch dylan/fix_parquet_nested_type_field_id
icelake = { git = "https://github.com/risingwavelabs/icelake.git", rev = "3f4724158acee37a4785f56670a1427993a58739", features = [
"prometheus",
] }
arrow-array-iceberg = { package = "arrow-array", version = "52" }
arrow-schema-iceberg = { package = "arrow-schema", version = "52" }
arrow-buffer-iceberg = { package = "arrow-buffer", version = "52" }
arrow-cast-iceberg = { package = "arrow-cast", version = "52" }
iceberg = "0.3.0"
iceberg-catalog-rest = "0.3.0"
iceberg-catalog-glue = "0.3.0"
# branch dev
iceberg = { git = "https://github.com/risingwavelabs/iceberg-rust.git", rev = "84bf51c9d0d5886e4ee306ca4f383f029e1767a4" }
iceberg-catalog-rest = { git = "https://github.com/risingwavelabs/iceberg-rust.git", rev = "84bf51c9d0d5886e4ee306ca4f383f029e1767a4" }
iceberg-catalog-glue = { git = "https://github.com/risingwavelabs/iceberg-rust.git", rev = "84bf51c9d0d5886e4ee306ca4f383f029e1767a4" }
opendal = "0.47"
arrow-array = "50"
arrow-arith = "50"
Expand Down
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ RisingWave is a Postgres-compatible SQL database engineered to provide the <i><b

RisingWave can <b>ingest</b> millions of events per second, continuously <b>join and analyze</b> live data streams with historical tables, <b>serve</b> ad-hoc queries in real-time, and <b>deliver</b> fresh, consistent results wherever needed.

![RisingWave](./docs/dev/src/images/architecture_20240814.png)
![RisingWave](./docs/dev/src/images/architecture_20240908.png)

## Try it out in 60 seconds

Expand Down
2 changes: 1 addition & 1 deletion ci/build-ci-image.sh
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ cat ../rust-toolchain
# shellcheck disable=SC2155

# REMEMBER TO ALSO UPDATE ci/docker-compose.yml
export BUILD_ENV_VERSION=v20240812
export BUILD_ENV_VERSION=v20240911

export BUILD_TAG="public.ecr.aws/w1p7b4n3/rw-build-env:${BUILD_ENV_VERSION}"

Expand Down
10 changes: 5 additions & 5 deletions ci/docker-compose.yml
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ services:
retries: 5

source-test-env:
image: public.ecr.aws/w1p7b4n3/rw-build-env:v20240812
image: public.ecr.aws/w1p7b4n3/rw-build-env:v20240911
depends_on:
- mysql
- sqlserver-server
Expand All @@ -85,7 +85,7 @@ services:
- ..:/risingwave

sink-test-env:
image: public.ecr.aws/w1p7b4n3/rw-build-env:v20240812
image: public.ecr.aws/w1p7b4n3/rw-build-env:v20240911
depends_on:
- mysql
- db
Expand All @@ -108,12 +108,12 @@ services:


rw-build-env:
image: public.ecr.aws/w1p7b4n3/rw-build-env:v20240812
image: public.ecr.aws/w1p7b4n3/rw-build-env:v20240911
volumes:
- ..:/risingwave

ci-flamegraph-env:
image: public.ecr.aws/w1p7b4n3/rw-build-env:v20240812
image: public.ecr.aws/w1p7b4n3/rw-build-env:v20240911
# NOTE(kwannoel): This is used in order to permit
# syscalls for `nperf` (perf_event_open),
# so it can do CPU profiling.
Expand All @@ -124,7 +124,7 @@ services:
- ..:/risingwave

regress-test-env:
image: public.ecr.aws/w1p7b4n3/rw-build-env:v20240812
image: public.ecr.aws/w1p7b4n3/rw-build-env:v20240911
depends_on:
db:
condition: service_healthy
Expand Down
2 changes: 1 addition & 1 deletion ci/rust-toolchain
Original file line number Diff line number Diff line change
Expand Up @@ -4,4 +4,4 @@
# 3. (optional) **follow the instructions in lints/README.md** to update the toolchain and dependencies for lints

[toolchain]
channel = "nightly-2024-06-06"
channel = "nightly-2024-07-19"
5 changes: 3 additions & 2 deletions ci/scripts/e2e-cassandra-sink-test.sh
Original file line number Diff line number Diff line change
Expand Up @@ -42,8 +42,9 @@ tar xfvz cassandra_latest.tar.gz
export LATEST_CASSANDRA_VERSION=$(get_latest_cassandra_version)
export CASSANDRA_DIR="./apache-cassandra-${LATEST_CASSANDRA_VERSION}"
# remove bundled packages, and use installed packages, because Python 3.12 has removed asyncore, but I failed to install libev support for bundled Python driver.
rm ${CASSANDRA_DIR}/lib/six-1.12.0-py2.py3-none-any.zip
rm ${CASSANDRA_DIR}/lib/cassandra-driver-internal-only-3.25.0.zip

rm ${CASSANDRA_DIR}/lib/futures-2.1.6-py2.py3-none-any.zip
rm ${CASSANDRA_DIR}/lib/cassandra-driver-internal-only-3.29.0.zip
apt-get install -y libev4 libev-dev
pip3 install --break-system-packages cassandra-driver
export CQLSH_HOST=cassandra-server
Expand Down
Loading
Loading