unexpected failure when sink into table with watermark

[tabVersion]

Describe the bug

Am I doing something wrong?

dev=> CREATE TABLE t1 (id INT PRIMARY KEY, a INT, b CHARACTER VARYING, created_at timestamptz DEFAULT CURRENT_TIMESTAMP);

dev=> CREATE TABLE t2 (id INT, a INT, b CHARACTER VARYING, created_at timestamptz, WATERMARK FOR created_at AS created_at - INTERVAL '5' SECOND) APPEND ONLY;

dev=> create sink sink_t1_t2 into t2 from t2 with ( type = 'append-only', force_append_only = 'true' ) ;

ERROR:  Failed to run the query

Caused by these errors (recent errors listed first):
  1: gRPC request to meta service (call `/ddl_service.DdlService/CreateSink`) failed: Internal error
  2: failed to wait streaming job finish: database 1 reset, in worker node 1: status: Internal, message: "Actor 47 exited unexpectedly: Executor error: exchange channel from local upstream actor 25 closed unexpectedly", details: [], metadata: MetadataMap { headers: {} }

Error message/log

no panic shown in log

meta:

ERROR risingwave_meta::rpc::ddl_controller: failed to create streaming job id=15 error=failed to wait streaming job finish: database 1 reset, in worker node 1: status: Internal, message: "Actor 47 exited unexpectedly: Executor error: exchange channel from local upstream actor 25 closed unexpectedly", details: [], metadata: MetadataMap { headers: {} }

CN:

ERROR risingwave_stream::task::stream_manager: actor exit with error actor_id=33 error=Executor error: exchange channel from local upstream actor 26 closed unexpectedly
ERROR risingwave_stream::task::barrier_manager: suspend database on error database_id=1 failed_actor=Some(33) recv actor failure err=Actor 33 exited unexpectedly: Executor error: exchange channel from local upstream actor 26 closed unexpectedly

To Reproduce

No response

Expected behavior

No response

How did you deploy RisingWave?

No response

The version of RisingWave

No response

Additional context

No response

[hzxa21]

Found by @tabVersion when playing around RW. @shanicky Can you help take a look when you have time?

[shanicky]

Here, the sink is from t2 and then into t2. Theoretically, it shouldn't be created. I'll check the cycle check. 🤔