diff --git a/Cargo.lock b/Cargo.lock
index 25555c82eba2f..9ce454688c384 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -2110,7 +2110,7 @@ dependencies = [
"bitflags 2.6.0",
"cexpr",
"clang-sys",
- "itertools 0.12.1",
+ "itertools 0.10.5",
"lazy_static",
"lazycell",
"log",
@@ -2897,7 +2897,7 @@ dependencies = [
"futures-core",
"prost 0.13.1",
"prost-types 0.13.1",
- "tonic 0.12.1",
+ "tonic 0.12.2",
"tracing-core",
]
@@ -2921,7 +2921,7 @@ dependencies = [
"thread_local",
"tokio",
"tokio-stream 0.1.15 (registry+https://github.com/rust-lang/crates.io-index)",
- "tonic 0.12.1",
+ "tonic 0.12.2",
"tracing",
"tracing-core",
"tracing-subscriber",
@@ -4513,7 +4513,7 @@ dependencies = [
"prost 0.13.1",
"tokio",
"tokio-stream 0.1.15 (registry+https://github.com/rust-lang/crates.io-index)",
- "tonic 0.12.1",
+ "tonic 0.12.2",
"tonic-build",
"tower",
"tower-service",
@@ -5464,7 +5464,7 @@ dependencies = [
"thiserror",
"tokio",
"tokio-retry",
- "tonic 0.12.1",
+ "tonic 0.12.2",
"tower",
"tracing",
]
@@ -5477,7 +5477,7 @@ checksum = "0ae8ab26ef7c7c3f7dfb9cc3982293d031d8e78c85d00ddfb704b5c35aeff7c8"
dependencies = [
"prost 0.13.1",
"prost-types 0.13.1",
- "tonic 0.12.1",
+ "tonic 0.12.2",
]
[[package]]
@@ -6055,7 +6055,7 @@ dependencies = [
"moka",
"murmur3",
"once_cell",
- "opendal 0.49.0",
+ "opendal",
"ordered-float 4.1.1",
"parquet 52.0.0",
"paste",
@@ -6113,7 +6113,7 @@ dependencies = [
[[package]]
name = "icelake"
version = "0.3.141592654"
-source = "git+https://github.com/risingwavelabs/icelake.git?rev=db4868f9a5de8ff8f6c04ec4c203bcbe59564cbe#db4868f9a5de8ff8f6c04ec4c203bcbe59564cbe"
+source = "git+https://github.com/risingwavelabs/icelake.git?rev=490e5af541edab0e9284ba19ddb56c8a16d1c36b#490e5af541edab0e9284ba19ddb56c8a16d1c36b"
dependencies = [
"anyhow",
"apache-avro 0.17.0 (git+https://github.com/apache/avro.git)",
@@ -6139,7 +6139,7 @@ dependencies = [
"log",
"murmur3",
"once_cell",
- "opendal 0.47.2",
+ "opendal",
"ordered-float 3.9.1",
"parquet 52.0.0",
"prometheus",
@@ -6987,7 +6987,7 @@ dependencies = [
"thiserror",
"tokio",
"toml 0.8.12",
- "tonic 0.12.1",
+ "tonic 0.12.2",
"tracing",
]
@@ -7049,7 +7049,7 @@ dependencies = [
"futures-util",
"madsim",
"tokio",
- "tonic 0.12.1",
+ "tonic 0.12.2",
"tower",
"tracing",
]
@@ -7911,9 +7911,9 @@ checksum = "c08d65885ee38876c4f86fa503fb49d7b507c2b62552df7c70b2fce627e06381"
[[package]]
name = "opendal"
-version = "0.47.2"
+version = "0.49.2"
source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "ff159a2da374ef2d64848a6547943cf1af7d2ceada5ae77be175e1389aa07ae3"
+checksum = "9b04d09b9822c2f75a1d2fc513a2c1279c70e91e7407936fffdf6a6976ec530a"
dependencies = [
"anyhow",
"async-trait",
@@ -7931,42 +7931,12 @@ dependencies = [
"once_cell",
"percent-encoding",
"prometheus",
- "quick-xml 0.31.0",
- "reqsign 0.15.2",
- "reqwest 0.12.4",
- "serde",
- "serde_json",
- "sha2",
- "tokio",
- "uuid",
-]
-
-[[package]]
-name = "opendal"
-version = "0.49.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "39d516adf7db912c38af382c3e92c27cd62fbbc240e630920555d784c2ab1494"
-dependencies = [
- "anyhow",
- "async-trait",
- "backon",
- "base64 0.22.0",
- "bytes",
- "chrono",
- "crc32c",
- "flagset",
- "futures",
- "getrandom",
- "http 1.1.0",
- "log",
- "md-5",
- "once_cell",
- "percent-encoding",
"quick-xml 0.36.1",
- "reqsign 0.16.0",
+ "reqsign",
"reqwest 0.12.4",
"serde",
"serde_json",
+ "sha2",
"tokio",
"uuid",
]
@@ -8076,7 +8046,7 @@ dependencies = [
"prost 0.13.1",
"thiserror",
"tokio",
- "tonic 0.12.1",
+ "tonic 0.12.2",
]
[[package]]
@@ -8088,7 +8058,7 @@ dependencies = [
"opentelemetry",
"opentelemetry_sdk",
"prost 0.13.1",
- "tonic 0.12.1",
+ "tonic 0.12.2",
]
[[package]]
@@ -8180,7 +8150,7 @@ dependencies = [
"serde",
"serde_json",
"tokio",
- "tonic 0.12.1",
+ "tonic 0.12.2",
"tonic-build",
"tracing",
]
@@ -9227,7 +9197,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "81bddcdb20abf9501610992b6759a4c888aef7d1a7247ef75e2404275ac24af1"
dependencies = [
"anyhow",
- "itertools 0.12.1",
+ "itertools 0.10.5",
"proc-macro2",
"quote",
"syn 2.0.66",
@@ -9419,7 +9389,7 @@ dependencies = [
"indoc",
"libc",
"memoffset",
- "parking_lot 0.12.1",
+ "parking_lot 0.11.2",
"portable-atomic",
"pyo3-build-config",
"pyo3-ffi",
@@ -9518,16 +9488,6 @@ dependencies = [
"serde",
]
-[[package]]
-name = "quick-xml"
-version = "0.31.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "1004a344b30a54e2ee58d66a71b32d2db2feb0a31f9a2d302bf0536f15de2a33"
-dependencies = [
- "memchr",
- "serde",
-]
-
[[package]]
name = "quick-xml"
version = "0.35.0"
@@ -9811,37 +9771,6 @@ dependencies = [
"bytecheck",
]
-[[package]]
-name = "reqsign"
-version = "0.15.2"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "70fe66d4cd0b5ed9b1abbfe639bf6baeaaf509f7da2d51b31111ba945be59286"
-dependencies = [
- "anyhow",
- "async-trait",
- "base64 0.22.0",
- "chrono",
- "form_urlencoded",
- "getrandom",
- "hex",
- "hmac",
- "home",
- "http 1.1.0",
- "jsonwebtoken",
- "log",
- "once_cell",
- "percent-encoding",
- "quick-xml 0.31.0",
- "rand",
- "reqwest 0.12.4",
- "rsa",
- "rust-ini",
- "serde",
- "serde_json",
- "sha1",
- "sha2",
-]
-
[[package]]
name = "reqsign"
version = "0.16.0"
@@ -9858,11 +9787,14 @@ dependencies = [
"hmac",
"home",
"http 1.1.0",
+ "jsonwebtoken",
"log",
+ "once_cell",
"percent-encoding",
"quick-xml 0.35.0",
"rand",
"reqwest 0.12.4",
+ "rsa",
"rust-ini",
"serde",
"serde_json",
@@ -10154,7 +10086,7 @@ dependencies = [
"madsim-tokio",
"madsim-tonic",
"memcomparable",
- "opendal 0.47.2",
+ "opendal",
"parking_lot 0.12.1",
"parquet 52.0.0",
"paste",
@@ -10435,6 +10367,7 @@ version = "2.1.0-alpha"
dependencies = [
"auto_impl",
"bytes",
+ "cfg-or-panic",
"clap",
"darwin-libproc",
"easy-ext",
@@ -10683,7 +10616,7 @@ dependencies = [
"mysql_common",
"nexmark",
"num-bigint",
- "opendal 0.47.2",
+ "opendal",
"openssl",
"parking_lot 0.12.1",
"parquet 52.0.0",
@@ -11444,7 +11377,7 @@ dependencies = [
"madsim",
"madsim-aws-sdk-s3",
"madsim-tokio",
- "opendal 0.47.2",
+ "opendal",
"prometheus",
"reqwest 0.12.4",
"risingwave_common",
@@ -14471,9 +14404,9 @@ dependencies = [
[[package]]
name = "tonic"
-version = "0.12.1"
+version = "0.12.2"
source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "38659f4a91aba8598d27821589f5db7dddd94601e7a01b1e485a50e5484c7401"
+checksum = "c6f6ba989e4b2c58ae83d862d3a3e27690b6e3ae630d0deb59f3697f32aa88ad"
dependencies = [
"async-stream",
"async-trait",
@@ -14505,9 +14438,9 @@ dependencies = [
[[package]]
name = "tonic-build"
-version = "0.12.1"
+version = "0.12.2"
source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "568392c5a2bd0020723e3f387891176aabafe36fd9fcd074ad309dfa0c8eb964"
+checksum = "fe4ee8877250136bd7e3d2331632810a4df4ea5e004656990d8d66d2f5ee8a67"
dependencies = [
"prettyplease 0.2.15",
"proc-macro2",
diff --git a/Cargo.toml b/Cargo.toml
index 456bf4bd1fbd1..148c8f64587a7 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -137,14 +137,14 @@ otlp-embedded = { git = "https://github.com/risingwavelabs/otlp-embedded", rev =
prost = { version = "0.13" }
prost-build = { version = "0.13" }
# branch rw_patch
-icelake = { git = "https://github.com/risingwavelabs/icelake.git", rev = "db4868f9a5de8ff8f6c04ec4c203bcbe59564cbe", features = [
+icelake = { git = "https://github.com/risingwavelabs/icelake.git", rev = "490e5af541edab0e9284ba19ddb56c8a16d1c36b", features = [
"prometheus",
] }
# 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"
+opendal = "0.49"
# used only by arrow-udf-flight
arrow-flight = "52"
arrow-udf-js = "0.4"
diff --git a/ci/scripts/backwards-compat-test.sh b/ci/scripts/backwards-compat-test.sh
index c077d3d360eb2..e7b857c339f04 100755
--- a/ci/scripts/backwards-compat-test.sh
+++ b/ci/scripts/backwards-compat-test.sh
@@ -102,9 +102,9 @@ setup_old_cluster() {
set -e
echo "Failed to download ${OLD_VERSION} from github releases, build from source later during \`risedev d\`"
configure_rw "$OLD_VERSION" true
- elif [[ $OLD_VERSION = '1.10.1' || $OLD_VERSION = '1.10.0' ]]; then
+ elif [[ $OLD_VERSION = '1.10.0' || $OLD_VERSION = '1.10.1' || $OLD_VERSION = '1.10.2' || $OLD_VERSION = '2.0.0' ]]; then
set -e
- echo "1.10.x has older openssl version, build from source later during \`risedev d\`"
+ echo "1.10.x, 2.0.0 have dynamically linked openssl, build from source later during \`risedev d\`"
configure_rw "$OLD_VERSION" true
else
set -e
diff --git a/ci/scripts/release.sh b/ci/scripts/release.sh
index c2f88521a5fc9..6ffafbb4a30dd 100755
--- a/ci/scripts/release.sh
+++ b/ci/scripts/release.sh
@@ -108,9 +108,9 @@ if [[ -n "${BUILDKITE_TAG}" ]]; then
echo "--- Release create"
set +e
- response=$(gh api repos/risingwavelabs/risingwave/releases/tags/"${BUILDKITE_TAG}" 2>&1)
+ response=$(gh release view -R risingwavelabs/risingwave "${BUILDKITE_TAG}" 2>&1)
set -euo pipefail
- if [[ $response == *"Not Found"* ]]; then
+ if [[ $response == *"not found"* ]]; then
echo "Tag ${BUILDKITE_TAG} does not exist. Creating release..."
gh release create "${BUILDKITE_TAG}" --notes "release ${BUILDKITE_TAG}" -d -p
else
diff --git a/ci/workflows/main-cron.yml b/ci/workflows/main-cron.yml
index d35803e02d758..a627c12dd88cd 100644
--- a/ci/workflows/main-cron.yml
+++ b/ci/workflows/main-cron.yml
@@ -529,7 +529,7 @@ steps:
retry: *auto-retry
- label: "S3 source and sink on parquet file"
- key: "s3-v2-source-check-parquet-file"
+ key: "s3-source-and-sink-parquet-encode"
command: "ci/scripts/s3-source-test.sh -p ci-release -s fs_parquet_source_and_sink.py"
if: |
!(build.pull_request.labels includes "ci/main-cron/run-selected") && build.env("CI_STEPS") == null
diff --git a/clippy.toml b/clippy.toml
index 21b972376b0ed..23134a6fe11f6 100644
--- a/clippy.toml
+++ b/clippy.toml
@@ -13,6 +13,8 @@ disallowed-methods = [
{ path = "speedate::DateTime::parse_bytes_with_config", reason = "Please use `parse_bytes_rfc3339_with_config` instead." },
{ path = "speedate::Date::parse_str", reason = "Please use `parse_str_rfc3339` instead." },
{ path = "speedate::Date::parse_bytes", reason = "Please use `parse_bytes_rfc3339` instead." },
+ { path = "tonic::transport::Endpoint::connect", reason = "Please use `EndpointExt::monitored_connect` instead." },
+ { path = "tonic::transport::Endpoint::connect_lazy", reason = "Please use `EndpointExt::monitored_connect_lazy` instead." },
]
disallowed-types = [
{ path = "num_traits::AsPrimitive", reason = "Please use `From` or `TryFrom` with `OrderedFloat` instead." },
diff --git a/dashboard/components/Layout.tsx b/dashboard/components/Layout.tsx
index f16270adb2f4f..2a1eaf488d12d 100644
--- a/dashboard/components/Layout.tsx
+++ b/dashboard/components/Layout.tsx
@@ -144,7 +144,7 @@ function Layout({ children }: { children: React.ReactNode }) {
Streaming
- Relation Graph
+ Relation Graph
Fragment Graph
diff --git a/dashboard/components/RelationDependencyGraph.tsx b/dashboard/components/RelationGraph.tsx
similarity index 99%
rename from dashboard/components/RelationDependencyGraph.tsx
rename to dashboard/components/RelationGraph.tsx
index 1ab2fc7839a81..a61a6924a370e 100644
--- a/dashboard/components/RelationDependencyGraph.tsx
+++ b/dashboard/components/RelationGraph.tsx
@@ -57,7 +57,7 @@ const rowMargin = 50
export const nodeRadius = 12
const layoutMargin = 50
-export default function RelationDependencyGraph({
+export default function RelationGraph({
nodes,
selectedId,
setSelectedId,
diff --git a/dashboard/components/Relations.tsx b/dashboard/components/Relations.tsx
index 49161feea908b..4636b3764947a 100644
--- a/dashboard/components/Relations.tsx
+++ b/dashboard/components/Relations.tsx
@@ -60,7 +60,7 @@ export const dependentsColumn: Column = {
name: "Depends",
width: 1,
content: (r) => (
-
+