For installation and running instructions, see Get started.
Main changes
SQL features
- Query syntax:
- Supports non-append-only temporal joins, where the outer side is not required to be append-only. #16286
- SQL commands:
- Supports
DISCARD ALL
command for Npgsql compatibility. #16432 - Supports creating, dropping, altering, and showing subscriptions. #14831
- Supports cursors for subscription queues. #15180
- Supports altering stream rate limit for sources and tables with a source. #16399
- Supports
RECOVER
command to trigger an ad-hoc recovery. #16259
- Supports
- SQL functions & operators:
- System catalog:
Connectors
- Provides stable support for SQLAlchemy 2.0. risingwavelabs/sqlalchemy-risingwave#29
- Deprecates
s3
connector. #16337 - Supports generated columns for non-shared CDC tables. #16522
- Supports time travel for Iceberg sources. #15866
- Blocks sink creation until backfill is completed by default. #16249
- Supports Kafka connector parameter
properties.request.required.acks
. #16482 - Adds connector parameter
ssl.mode
for PostgreSQL and Neon source connector. #15690 - Adds connector parameter
ssl.mode
for MySQL source connector. #16579 - Supports parameters
snapshot.interval
andsnapshot.batch_size
underWITH
options when creating a table from a CDC source. #16426 - Supports implicitly converting
numeric
types from PostgreSQL sources intorw_int256
orvarchar
. #16346 - Supports configuring the timeout of CDC sources. #16598
- Supports
timestamptz.handling.mode
formatting option when creating a source withPLAIN
,UPSERT
, orDEBEZIUM JSON
formats. #16265 - Only uses fragment ID as group ID for Kafka sources. #16111
- Supports cluster URLs for Redis sink connector. #16034
- Supports creating Delta sinks with GCS. #16182
- Supports Snowflake sink connector. #15429
- Supports creating
upsert
type BigQuery sinks. #15780
Installation and deployment
- Sets PostgreSQL as the default meta store when deploying with Docker Compose. #16724
Cluster configuration changes
- Supports using
ALTER SYSTEM
to set a system-wide default value for a session parameter. #16062 - Supports setting
streaming_rate_limit
to zero. #16333 - Supports configuring the reserved memory bytes of the compute node by using
RW_RESERVED_MEMORY_BYTES
runtime parameter andreserved-memory-bytes
startup option. #16433 - Introduce new timeout and retry configurations for ObjectStore and deprecate ambiguous timeout configurations. #16231
Fixes
- Properly convert
-inf
,+inf
, andnan
types tonull
for JDBC sinks. #16230 - Handles sinking
-inf
,+inf
, andnan
types for ClickHouse, Doris, and StarRocks sink connectors. #15664 - Fixes an issue where
DELETE
events could not be sinked if the primary key isuuid
type for JDBC sinks.#16447 - Fixes an issue where
enum
types from PostgreSQL could not be ingested asvarchar
types. #16423 - Fixes sources with
encode avro
on decimal ingesting. #16202 - Fixes sources with
encode avro
on bytes/fixed/decimal default value. #16414
Full Changelog: v1.8.0...v1.9.1