Skip to main content

​
Syntax

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

​
Parameters

ParameterDescription
schema_nameThe 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_nameThe name of the sink to remove.
CASCADE optionIf 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