Merge branch 'main' into dylan/handle_watermark_for_mv_on_mv

Author: mergify[bot]

Cargo.lock

@@ -30,7 +30,7 @@ echo "--- deterministic simulation e2e, ci-3cn-2fe, batch"
 seq $TEST_NUM | parallel MADSIM_TEST_SEED={} './risingwave_simulation ./e2e_test/batch/\*\*/\*.slt 2> $LOGDIR/batch-{}.log && rm $LOGDIR/batch-{}.log'
 
 echo "--- deterministic simulation e2e, ci-3cn-2fe, kafka source"
-seq $TEST_NUM | parallel MADSIM_TEST_SEED={} './risingwave_simulation --kafka-datadir=./scripts/source/test_data ./e2e_test/source/basic/kafka.slt 2> $LOGDIR/source-{}.log && rm $LOGDIR/source-{}.log'
+seq $TEST_NUM | parallel MADSIM_TEST_SEED={} './risingwave_simulation --kafka-datadir=./scripts/source/test_data ./e2e_test/source/basic/kafka\*.slt 2> $LOGDIR/source-{}.log && rm $LOGDIR/source-{}.log'
 
 echo "--- deterministic simulation e2e, ci-3cn-2fe, parallel, streaming"
 seq $TEST_NUM | parallel MADSIM_TEST_SEED={} './risingwave_simulation -j 16 ./e2e_test/streaming/\*\*/\*.slt 2> $LOGDIR/parallel-streaming-{}.log && rm $LOGDIR/parallel-streaming-{}.log'

ci/scripts/deterministic-e2e-test.sh

@@ -1,5 +1,6 @@
 disallowed-methods = [
-    { path = "std::iter::Iterator::zip", reason = "Please use Itertools::zip_eq instead." },
+    { path = "std::iter::Iterator::zip", reason = "Please use `zip_eq_fast` if it's available. Otherwise use `zip_eq_debug`" },
+    { path = "itertools::Itertools::zip_eq", reason = "Please use `zip_eq_fast` if it's available. Otherwise use `zip_eq_debug`" },
     { path = "futures::stream::select_all", reason = "Please use `risingwave_common::util::select_all` instead." },
 ]
 doc-valid-idents = [

clippy.toml

@@ -0,0 +1,51 @@
+query R
+select pow(2.0, 3.0)
+----
+8
+
+query R
+select pow(2.0::decimal, 3.0::decimal)
+----
+8
+
+query R
+select pow(2.0::double, 3.0::double)
+----
+8
+
+query R
+select pow(2.0::smallint, 3.0::smallint)
+----
+8
+
+query R
+select pow(2.0::bigint, 3.0::bigint)
+----
+8
+
+query R
+select pow(2.0, -2);
+----
+0.25
+
+query R
+select pow(2.23, -2.33);
+----
+0.15432975583772085
+
+query R
+select pow(100000, 0);
+----
+1
+
+query R
+select pow(100000, -200000000000000);
+----
+0
+
+statement error QueryError: Expr error: Numeric out of range
+select pow(100000, 200000000000000);
+
+
+statement error QueryError: Expr error: Numeric out of range
+select pow(-100000, 200000000000001);

dashboard/proto/gen/ddl_service.ts

@@ -558,8 +558,8 @@ def section_compaction(outer_panels):
                     "num of compactions from each level to next level",
                     [
                         panels.target(
-                            f"sum({metric('storage_level_compact_frequency')}) by (compactor, group, result)",
-                            "{{result}} - group-{{group}} @ {{compactor}}",
+                            f"sum({metric('storage_level_compact_frequency')}) by (compactor, group, task_type, result)",
+                            "{{task_type}} - {{result}} - group-{{group}} @ {{compactor}}",
                         ),
                     ],
                 ),

dashboard/proto/gen/expr.ts

@@ -214,12 +214,12 @@ message ReplaceTablePlanResponse {
   uint64 version = 2;
 }
 
-message JavaGetTableRequest {
+message GetTableRequest {
   string database_name = 1;
   string table_name = 2;
 }
 
-message JavaGetTableResponse {
+message GetTableResponse {
   catalog.Table table = 1;
 }
 
@@ -244,5 +244,5 @@ service DdlService {
   rpc CreateFunction(CreateFunctionRequest) returns (CreateFunctionResponse);
   rpc DropFunction(DropFunctionRequest) returns (DropFunctionResponse);
   rpc ReplaceTablePlan(ReplaceTablePlanRequest) returns (ReplaceTablePlanResponse);
-  rpc JavaGetTable(JavaGetTableRequest) returns (JavaGetTableResponse);
+  rpc GetTable(GetTableRequest) returns (GetTableResponse);
 }