Skip to content
Permalink

Comparing changes

This is a direct comparison between two commits made in this repository or its related repositories. View the default comparison for this range or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: risingwavelabs/risingwave
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: b1921dad57f0e3e2a7992d2dd6820b382bbd0fe2
Choose a base ref
..
head repository: risingwavelabs/risingwave
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: 4308eb2fb6b9bc108f523f64e68ff20c2c3cfffe
Choose a head ref
Showing with 3,394 additions and 1,539 deletions.
  1. +0 −4 .config/nextest.toml
  2. +223 −225 Cargo.lock
  3. +14 −15 Cargo.toml
  4. +0 −11 ci/scripts/build.sh
  5. +11 −0 ci/scripts/check.sh
  6. +0 −1 e2e_test/source_inline/cdc/mysql/mysql_create_drop.slt.serial
  7. +73 −0 e2e_test/source_inline/tvf/mysql_query.slt
  8. +1 −1 e2e_test/source_legacy/basic/ddl.slt
  9. +3 −3 e2e_test/source_legacy/cdc_inline/auto_schema_map_mysql.slt
  10. +96 −0 e2e_test/streaming/temporal_join/append_only/nested_loop.slt
  11. +12 −0 proto/batch_plan.proto
  12. +2 −0 proto/expr.proto
  13. +1 −1 proto/meta.proto
  14. +2 −0 proto/stream_plan.proto
  15. +19 −0 risedev.yml
  16. +3 −0 src/batch/Cargo.toml
  17. +6 −3 src/batch/src/error.rs
  18. +3 −0 src/batch/src/executor/mod.rs
  19. +170 −0 src/batch/src/executor/mysql_query.rs
  20. +5 −1 src/batch/src/executor/postgres_query.rs
  21. +1 −1 src/common/common_service/Cargo.toml
  22. +1 −0 src/common/src/lib.rs
  23. +2 −4 src/connector/Cargo.toml
  24. +20 −15 src/connector/src/connector_common/common.rs
  25. +2 −2 src/connector/src/connector_common/iceberg/storage_catalog.rs
  26. +3 −3 src/connector/src/connector_common/mod.rs
  27. +3 −0 src/connector/src/error.rs
  28. +1 −1 src/connector/src/parser/mod.rs
  29. +171 −98 src/connector/src/parser/mysql.rs
  30. +1 −1 src/connector/src/parser/plain_parser.rs
  31. +11 −5 src/connector/src/parser/unified/kv_event.rs
  32. +9 −3 src/connector/src/parser/upsert_parser.rs
  33. +10 −6 src/connector/src/sink/kafka.rs
  34. +19 −2 src/connector/src/sink/starrocks.rs
  35. +22 −2 src/connector/src/source/cdc/external/mysql.rs
  36. +11 −9 src/connector/src/source/iceberg/parquet_file_reader.rs
  37. +68 −32 src/connector/src/source/kafka/enumerator/client.rs
  38. +4 −1 src/connector/src/source/kafka/mod.rs
  39. +3 −3 src/connector/src/source/kafka/source/reader.rs
  40. +9 −0 src/connector/src/with_options.rs
  41. +6 −6 src/connector/with_options_sink.yaml
  42. +6 −6 src/connector/with_options_source.yaml
  43. +1 −1 src/error/src/anyhow.rs
  44. +47 −24 src/expr/impl/src/window_function/aggregate.rs
  45. +21 −0 src/expr/impl/src/window_function/buffer.rs
  46. +3 −0 src/frontend/Cargo.toml
  47. +68 −0 src/frontend/planner_test/tests/testdata/input/nested_loop_temporal_join.yaml
  48. +112 −0 src/frontend/planner_test/tests/testdata/output/nested_loop_temporal_join.yaml
  49. +3 −3 src/frontend/planner_test/tests/testdata/output/nexmark.yaml
  50. +1 −1 src/frontend/planner_test/tests/testdata/output/temporal_filter.yaml
  51. +19 −19 src/frontend/planner_test/tests/testdata/output/temporal_join.yaml
  52. +11 −0 src/frontend/src/binder/expr/function/mod.rs
  53. +161 −2 src/frontend/src/expr/table_function.rs
  54. +9 −0 src/frontend/src/handler/create_source.rs
  55. +7 −1 src/frontend/src/handler/flush.rs
  56. +5 −3 src/frontend/src/meta_client.rs
  57. +11 −0 src/frontend/src/optimizer/logical_optimization.rs
  58. +96 −0 src/frontend/src/optimizer/plan_node/batch_mysql_query.rs
  59. +3 −0 src/frontend/src/optimizer/plan_node/generic/mod.rs
  60. +67 −0 src/frontend/src/optimizer/plan_node/generic/mysql_query.rs
  61. +155 −65 src/frontend/src/optimizer/plan_node/logical_join.rs
  62. +115 −0 src/frontend/src/optimizer/plan_node/logical_mysql_query.rs
  63. +2 −2 src/frontend/src/optimizer/plan_node/logical_postgres_query.rs
  64. +10 −0 src/frontend/src/optimizer/plan_node/mod.rs
  65. +33 −5 src/frontend/src/optimizer/plan_node/stream_temporal_join.rs
  66. +3 −0 src/frontend/src/optimizer/rule/mod.rs
  67. +91 −0 src/frontend/src/optimizer/rule/table_function_to_mysql_query_rule.rs
  68. +1 −1 src/frontend/src/test_utils.rs
  69. +5 −2 src/meta/Cargo.toml
  70. +2 −4 src/meta/model/migration/Cargo.toml
  71. +1 −13 src/meta/model/migration/src/lib.rs
  72. +60 −25 src/meta/model/migration/src/m20230908_072257_init.rs
  73. +10 −11 src/meta/model/migration/src/m20231008_020431_hummock.rs
  74. +11 −2 src/meta/model/migration/src/m20240304_074901_subscription.rs
  75. +11 −2 src/meta/model/migration/src/m20240506_112555_subscription_partial_ckpt.rs
  76. +4 −3 src/meta/model/migration/src/m20240525_090457_secret.rs
  77. +3 −1 src/meta/model/migration/src/m20240617_070131_index_column_properties.rs
  78. +2 −1 src/meta/model/migration/src/m20240617_071625_sink_into_table_column.rs
  79. +4 −8 src/meta/model/migration/src/m20240618_072634_function_compressed_binary.rs
  80. +6 −1 src/meta/model/migration/src/m20240630_131430_remove_parallel_unit.rs
  81. +9 −7 src/meta/model/migration/src/m20240701_060504_hummock_time_travel.rs
  82. +17 −0 src/meta/model/migration/src/utils.rs
  83. +1 −1 src/meta/model/src/actor.rs
  84. +1 −1 src/meta/model/src/actor_dispatcher.rs
  85. +1 −1 src/meta/model/src/catalog_version.rs
  86. +1 −1 src/meta/model/src/fragment.rs
  87. +1 −1 src/meta/model/src/function.rs
  88. +2 −2 src/meta/model/src/lib.rs
  89. +1 −1 src/meta/model/src/object.rs
  90. +0 −1 src/meta/model/src/secret.rs
  91. +1 −1 src/meta/model/src/sink.rs
  92. +2 −2 src/meta/model/src/table.rs
  93. +1 −1 src/meta/model/src/user_privilege.rs
  94. +2 −2 src/meta/model/src/worker.rs
  95. +48 −41 src/meta/service/src/scale_service.rs
  96. +26 −10 src/meta/service/src/stream_service.rs
  97. +17 −20 src/meta/src/barrier/command.rs
  98. +2 −2 src/meta/src/barrier/creating_job/mod.rs
  99. +17 −6 src/meta/src/barrier/info.rs
  100. +57 −25 src/meta/src/barrier/mod.rs
  101. +6 −2 src/meta/src/barrier/progress.rs
  102. +6 −3 src/meta/src/barrier/rpc.rs
  103. +40 −70 src/meta/src/barrier/schedule.rs
  104. +24 −13 src/meta/src/barrier/state.rs
  105. +31 −1 src/meta/src/controller/catalog.rs
  106. +18 −0 src/meta/src/controller/fragment.rs
  107. +13 −8 src/meta/src/controller/streaming_job.rs
  108. +43 −1 src/meta/src/manager/metadata.rs
  109. +8 −27 src/meta/src/rpc/ddl_controller.rs
  110. +20 −22 src/meta/src/stream/scale.rs
  111. +17 −8 src/meta/src/stream/source_manager.rs
  112. +60 −28 src/meta/src/stream/stream_manager.rs
  113. +2 −2 src/rpc_client/src/meta_client.rs
  114. +1 −0 src/stream/src/executor/mod.rs
  115. +0 −1 src/stream/src/executor/nested_loop_temporal_join.rs
  116. +44 −43 src/stream/src/executor/over_window/frame_finder.rs
  117. +32 −39 src/stream/src/executor/over_window/over_partition.rs
  118. +37 −14 src/stream/src/executor/project.rs
  119. +35 −14 src/stream/src/executor/project_set.rs
  120. +18 −3 src/stream/src/executor/watermark_filter.rs
  121. +157 −80 src/stream/src/from_proto/temporal_join.rs
  122. +3 −0 src/stream/tests/integration_tests/project_set.rs
  123. +371 −369 src/utils/delta_btree_map/src/lib.rs
4 changes: 0 additions & 4 deletions .config/nextest.toml
Original file line number Diff line number Diff line change
@@ -34,7 +34,3 @@ test-group = 'failpoint-limited'
[[profile.ci-sim.overrides]]
filter = 'test(failpoint_limited::)'
test-group = 'failpoint-limited'

[[profile.ci.junit.overrides]]
filter = 'test(failpoint_limited::)'
test-group = 'failpoint-limited'
Loading