GetRefPackageJob

请求头

您可以使用公共请求参数和该接口必填参数。公共请求参数请参见OpenAPI>调用方式>公共请求参数文档。

请求语法

GET /api/v2/projects/[projectName]/packages/[packageName]/jobs HTTPS

请求参数

返回数据

示例

请求示例

/api/v2/projects/project1/packages/package1.jar/jobs

正常返回示例

XML 格式

<TotalCount>1</TotalCount>
<TotalPage>1</TotalPage>
<PageSize>10</PageSize>
<RequestId>31FDAE27-F135-4DAB-9C75-FADD6B0C4D1D</RequestId>
<Jobs>
    <Job>
        <ModifyTime>1583722910000</ModifyTime>
        <Description/>
        <EngineVersion>blink-3.4.4</EngineVersion>
        <ProjectName>bayes_team</ProjectName>
        <ClusterId>et2cloud****</ClusterId>
        <PlanJson>{
  "nodes": [
    {
      "id": 1,
      "type": "Source: Custom Source",
      "pact": "Data Source",
      "contents": "Source: Custom Source",
      "parallelism": 1
    },
    {
      "id": 2,
      "type": "Timestamps/Watermarks",
      "pact": "Operator",
      "contents": "Timestamps/Watermarks",
      "parallelism": 1,
      "predecessors": [
        {
          "id": 1,
          "ship_strategy": "FORWARD",
          "side": "second"
        }
      ]
    },
    {
      "id": 4,
      "type": "TriggerWindow(GlobalWindows(), ListStateDescriptor{serializer=org.apache.flink.api.common.typeutils.base.ListSerializer@b2107f67}, DeltaTrigger(com.hjc.test.blink_test.ChinanTopSpeedWindowing$1@350aac89, 50.0), TimeEvictor(10000), WindowedStream.reduce(WindowedStream.java:258))",
      "pact": "Operator",
      "contents": "TriggerWindow(GlobalWindows(), ListStateDescriptor{serializer=org.apache.flink.api.common.typeutils.base.ListSerializer@b2107f67}, DeltaTrigger(com.hjc.test.blink_test.ChinanTopSpeedWindowing$1@350aac89, 50.0), TimeEvictor(10000), WindowedStream.reduce(WindowedStream.java:258))",
      "parallelism": 1,
      "predecessors": [
        {
          "id": 2,
          "ship_strategy": "KEY-GROUP",
          "side": "second"
        }
      ]
    },
    {
      "id": 5,
      "type": "Sink: Unnamed",
      "pact": "Data Sink",
      "contents": "Sink: Unnamed",
      "parallelism": 1,
      "predecessors": [
        {
          "id": 4,
          "ship_strategy": "FORWARD",
          "side": "second"
        }
      ]
    }
  ]
}</PlanJson>
        <CreateTime>1551161842000</CreateTime>
        <JobName>job1</JobName>
        <Creator>1709064687573327</Creator>
        <FolderId>10148</FolderId>
        <Properties>#checkpoint模式：EXACTLY_ONCE 或者 AT_LEAST_ONCE
#blink.checkpoint.mode=EXACTLY_ONCE

#checkpoint间隔时间，单位毫秒
#blink.checkpoint.interval.ms=180000

#rocksdb的数据生命周期，单位毫秒
#state.backend.rocksdb.ttl.ms=129600000
</Properties>
        <Code>blink.main.class=com.hjc.test.blink_test.ChinanTopSpeedWindowing2
blink.job.name=datastream_prestest</Code>
        <JobType>FLINK_STREAM</JobType>
        <Packages>blink_test_datastream.jar</Packages>
        <ApiType>DATASTREAM</ApiType>
        <IsCommitted>true</IsCommitted>
        <Modifier>1709064687573327</Modifier>
        <QueueName>root.bayes_team</QueueName>
        <JobId>9t9m6jfw8rb44iexhbpv3tnz</JobId>
    </Job>
</Jobs>
<PageIndex>1</PageIndex>

JSON 格式

{
	"TotalCount": 1,
	"TotalPage": 1,
	"PageSize": 10,
	"RequestId": "31FDAE27-F135-4DAB-9C75-FADD6B0C4D1D",
	"Jobs": {
		"Job": [
			{
				"ModifyTime": 1583722910000,
				"Description": "",
				"EngineVersion": "blink-3.4.4",
				"ProjectName": "bayes_team",
				"ClusterId": "et2cloud****",
				"PlanJson": "{\n  \"nodes\": [\n    {\n      \"id\": 1,\n      \"type\": \"Source: Custom Source\",\n      \"pact\": \"Data Source\",\n      \"contents\": \"Source: Custom Source\",\n      \"parallelism\": 1\n    },\n    {\n      \"id\": 2,\n      \"type\": \"Timestamps/Watermarks\",\n      \"pact\": \"Operator\",\n      \"contents\": \"Timestamps/Watermarks\",\n      \"parallelism\": 1,\n      \"predecessors\": [\n        {\n          \"id\": 1,\n          \"ship_strategy\": \"FORWARD\",\n          \"side\": \"second\"\n        }\n      ]\n    },\n    {\n      \"id\": 4,\n      \"type\": \"TriggerWindow(GlobalWindows(), ListStateDescriptor{serializer=org.apache.flink.api.common.typeutils.base.ListSerializer@b2107f67}, DeltaTrigger(com.hjc.test.blink_test.ChinanTopSpeedWindowing$1@350aac89, 50.0), TimeEvictor(10000), WindowedStream.reduce(WindowedStream.java:258))\",\n      \"pact\": \"Operator\",\n      \"contents\": \"TriggerWindow(GlobalWindows(), ListStateDescriptor{serializer=org.apache.flink.api.common.typeutils.base.ListSerializer@b2107f67}, DeltaTrigger(com.hjc.test.blink_test.ChinanTopSpeedWindowing$1@350aac89, 50.0), TimeEvictor(10000), WindowedStream.reduce(WindowedStream.java:258))\",\n      \"parallelism\": 1,\n      \"predecessors\": [\n        {\n          \"id\": 2,\n          \"ship_strategy\": \"KEY-GROUP\",\n          \"side\": \"second\"\n        }\n      ]\n    },\n    {\n      \"id\": 5,\n      \"type\": \"Sink: Unnamed\",\n      \"pact\": \"Data Sink\",\n      \"contents\": \"Sink: Unnamed\",\n      \"parallelism\": 1,\n      \"predecessors\": [\n        {\n          \"id\": 4,\n          \"ship_strategy\": \"FORWARD\",\n          \"side\": \"second\"\n        }\n      ]\n    }\n  ]\n}",
				"CreateTime": 1551161842000,
				"JobName": "job1",
				"Creator": "1709064687573327",
				"FolderId": 10148,
				"Properties": "#checkpoint模式：EXACTLY_ONCE 或者 AT_LEAST_ONCE\n#blink.checkpoint.mode=EXACTLY_ONCE\n\n#checkpoint间隔时间，单位毫秒\n#blink.checkpoint.interval.ms=180000\n\n#rocksdb的数据生命周期，单位毫秒\n#state.backend.rocksdb.ttl.ms=129600000\n",
				"Code": "blink.main.class=com.hjc.test.blink_test.ChinanTopSpeedWindowing2\r\nblink.job.name=datastream_prestest",
				"JobType": "FLINK_STREAM",
				"Packages": "blink_test_datastream.jar",
				"ApiType": "DATASTREAM",
				"IsCommitted": true,
				"Modifier": "1709064687573327",
				"QueueName": "root.bayes_team",
				"JobId": "9t9m6jfw8rb44iexhbpv3tnz"
			}
		]
	},
	"PageIndex": 1
}