DROP SINK

Use the DROP SINK command to remove a sink if you no longer need to deliver data to the sink.

Syntax

DROP SINK [ IF EXISTS ] [schema_name.]sink_name [ CASCADE ];

Parameters

Parameter	Description
schema_name	The schema of the sink that you want to remove. You can use SHOW SCHEMAS to get a list of all available schemas. If you don’t specify a schema, the specified sink in the default schema public will be removed.
sink_name	The name of the sink to remove.
CASCADE option	If this option is specified, all objects (such as materialized views) that depend on the sink, and in turn all objects that depend on those objects will be dropped.

Examples

This statement removes the sink rw_sink in the default schema public from the database:

DROP SINK rw_sink;

This statement removes the sink rw_sink in the schema rw_schema from the database:

DROP SINK IF EXISTS rw_schema.rw_sink;

Hanging or long running DROP SINK

If your DROP SINK command takes a long time to run, it could be due to high barrier latency. DROP commands need to be synchronized with barriers currently. To let DROP take effect immediately, you can use the RECOVER command in a separate session.

See also

CREATE SINK

Create a sink