resubmitStreamGraph

resubmitStreamGraph(name)

name is a string representing the name of the stream graph. You can provide either the fully qualified name (FQN), such as "catalog_name.orca_graph.graph_name", or just the graph name, like "factors". If only the name is given, the system will automatically complete it using the current catalog.

Resubmits a stream graph that is in one of the following states: failed, destroying, or destroyed.

Suppose we have a StreamGraph “demo.orca_graph.indicators”, which has been destroyed by dropStreamGraph. Resubmit it using:

resubmitStreamGraph("demo.orca_graph.indicators")
getStreamGraphMeta("demo.orca_graph.indicators")["status"]
// Output: ["running"]