响应示例

{    "message": "",    "is_success": true,    "error_code": "",    "stream_graph": "{\n  \"jid\" : \"44334c4259f6714bddef1ac525364052\",\n  \"name\" : \"InternalJob_1715392878428\",\n  \"nodes\" : [ {\n    \"id\" : \"0a448493b4782967b150582570326227\",\n    \"parallelism\" : 1,\n    \"operator\" : \"\",\n    \"operator_strategy\" : \"\",\n    \"description\" : \"Sink: Sink(table=[default_catalog.default_database.sink_table], fields=[name, num])\",\n    \"chain_operators_id\" : [ \"0a448493b4782967b150582570326227\" ],\n    \"inputs\" : [ {\n      \"num\" : 0,\n      \"id\" : \"bc764cd8ddf7a0cff126f51c16239658\",\n      \"ship_strategy\" : \"FORWARD\",\n      \"exchange\" : \"pipelined_bounded\"\n    } ],\n    \"optimizer_properties\" : {}\n  }, {\n    \"id\" : \"bc764cd8ddf7a0cff126f51c16239658\",\n    \"parallelism\" : 2,\n    \"operator\" : \"\",\n    \"operator_strategy\" : \"\",\n    \"description\" : \"Source: TableSourceScan(table=[[default_catalog, default_database, orders]], fields=[name, num])\",\n    \"chain_operators_id\" : [ \"bc764cd8ddf7a0cff126f51c16239658\" ],\n    \"optimizer_properties\" : {}\n  } ],\n  \"operator_list\" : [ {\n    \"id\" : \"0a448493b4782967b150582570326227\",\n    \"name\" : \"Sink: Sink(table=[default_catalog.default_database.sink_table], fields=[name, num])\",\n    \"type\" : \"Sink\",\n    \"contents\" : \"Sink(table=[default_catalog.default_database.sink_table], fields=[name, num])\",\n    \"parallelism\" : 1,\n    \"tags\" : \"[SINK]\",\n    \"input_operators_id\" : [ \"bc764cd8ddf7a0cff126f51c16239658\" ]\n  }, {\n    \"id\" : \"bc764cd8ddf7a0cff126f51c16239658\",\n    \"name\" : \"Source: TableSourceScan(table=[[default_catalog, default_database, orders]], fields=[name, num])\",\n    \"type\" : \"Source\",\n    \"contents\" : \"TableSourceScan(table=[[default_catalog, default_database, orders]], fields=[name, num])\",\n    \"parallelism\" : 2,\n    \"tags\" : \"[PRO CES S, UDF]\",\n    \"input_operators_id\" : [ ]\n  } ]\n}"}

为了便于查看返回体信息，我们将stream_graph格式化后如下所示：

    "jid": "65b6a7b0c1ad95b1722a92b49d2f6eba",    "name": "InternalJob_1715392245413",    "nodes": [        {            "id": "0a448493b4782967b150582570326227",            "parallelism": 1,            "operator": "",            "operator_strategy": "",            "description": "Sink: Sink(table=[default_catalog.default_database.sink_table], fields=[name, num])",            "chain_operators_id": [                "0a448493b4782967b150582570326227"            ],            "inputs": [                {                    "num": 0,                    "id": "bc764cd8ddf7a0cff126f51c16239658",                    "ship_strategy": "FORWARD",                    "exchange": "pipelined_bounded"                }            ],            "optimizer_properties": {            }        },        {            "id": "bc764cd8ddf7a0cff126f51c16239658",            "parallelism": 2,            "operator": "",            "operator_strategy": "",            "description": "Source: TableSourceScan(table=[[default_catalog, default_database, orders]], fields=[name, num])",            "chain_operators_id": [                "bc764cd8ddf7a0cff126f51c16239658"            ],            "optimizer_properties": {            }        }    ],    "operator_list": [        {            "id": "0a448493b4782967b150582570326227",            "name": "Sink: Sink(table=[default_catalog.default_database.sink_table], fields=[name, num])",            "type": "Sink",            "contents": "Sink(table=[default_catalog.default_database.sink_table], fields=[name, num])",            "parallelism": 1,            "tags": "[SINK]",            "input_operators_id": [                "bc764cd8ddf7a0cff126f51c16239658"            ]        },        {            "id": "bc764cd8ddf7a0cff126f51c16239658",            "name": "Source: TableSourceScan(table=[[default_catalog, default_database, orders]], fields=[name, num])",            "type": "Source",            "contents": "TableSourceScan(table=[[default_catalog, default_database, orders]], fields=[name, num])",            "parallelism": 2,            "tags": "[PROCESS, UDF]",            "input_operators_id": [            ]        }    ]}