section> Computing
  • Auto Scaling
  • Bare Metal Server
  • Dedicated Host
  • Elastic Cloud Server
  • FunctionGraph
  • Image Management Service
Network
  • Direct Connect
  • Domain Name Service
  • Elastic IP
  • Elastic Load Balancing
  • Enterprise Router
  • NAT Gateway
  • Private Link Access Service
  • Secure Mail Gateway
  • Virtual Private Cloud
  • Virtual Private Network
  • VPC Endpoint
Storage
  • Cloud Backup and Recovery
  • Cloud Server Backup Service
  • Elastic Volume Service
  • Object Storage Service
  • Scalable File Service
  • Storage Disaster Recovery Service
  • Volume Backup Service
Application
  • API Gateway (APIG)
  • Application Operations Management
  • Application Performance Management
  • Distributed Message Service (for Kafka)
  • Simple Message Notification
Data Analysis
  • Cloud Search Service
  • Data Lake Insight
  • Data Warehouse Service
  • DataArts Studio
  • MapReduce Service
  • ModelArts
  • Optical Character Recognition
Container
  • Application Service Mesh
  • Cloud Container Engine
  • Cloud Container Instance
  • Software Repository for Containers
Databases
  • Data Replication Service
  • Distributed Cache Service
  • Distributed Database Middleware
  • Document Database Service
  • GeminiDB
  • Relational Database Service
  • TaurusDB
Management & Deployment
  • Cloud Create
  • Cloud Eye
  • Cloud Trace Service
  • Config
  • Log Tank Service
  • Resource Formation Service
  • Tag Management Service
Security Services
  • Anti-DDoS
  • Cloud Firewall
  • Database Security Service
  • Dedicated Web Application Firewall
  • Host Security Service
  • Identity and Access Management
  • Key Management Service
  • Web Application Firewall
Other
  • Enterprise Dashboard
  • Marketplace
  • Price Calculator
  • Status Dashboard
APIs
  • REST API
  • API Usage Guidelines
  • Endpoints
Development and Automation
  • SDKs
  • Drivers and Tools
  • Terraform
  • Ansible
  • Cloud Create
Architecture Center
  • Best Practices
  • Blueprints
IaaSComputingAuto ScalingBare Metal ServerDedicated HostElastic Cloud ServerFunctionGraphImage Management ServiceNetworkDirect ConnectDomain Name ServiceElastic IPElastic Load BalancingEnterprise RouterNAT GatewayPrivate Link Access ServiceSecure Mail GatewayVirtual Private CloudVirtual Private NetworkVPC EndpointStorageCloud Backup and RecoveryCloud Server Backup ServiceElastic Volume ServiceObject Storage ServiceScalable File ServiceStorage Disaster Recovery ServiceVolume Backup ServicePaaSApplicationAPI Gateway (APIG)Application Operations ManagementApplication Performance ManagementDistributed Message Service (for Kafka)Simple Message NotificationData AnalysisCloud Search ServiceData Lake InsightData Warehouse ServiceDataArts StudioMapReduce ServiceModelArtsOptical Character RecognitionContainerApplication Service MeshCloud Container EngineCloud Container InstanceSoftware Repository for ContainersDatabasesData Replication ServiceDistributed Cache ServiceDistributed Database MiddlewareDocument Database ServiceGeminiDBRelational Database ServiceTaurusDBManagementManagement & DeploymentCloud CreateCloud EyeCloud Trace ServiceConfigLog Tank ServiceResource Formation ServiceTag Management ServiceSecuritySecurity ServicesAnti-DDoSCloud FirewallDatabase Security ServiceDedicated Web Application FirewallHost Security ServiceIdentity and Access ManagementKey Management ServiceWeb Application FirewallOtherOtherEnterprise DashboardMarketplacePrice CalculatorStatus Dashboard

Data Lake Insight

  • API Usage Guidelines
  • Overview
  • Getting Started
  • Permission-related APIs
  • Global Variable-related APIs
  • APIs Related to Enhanced Datasource Connections
  • APIs Related to Elastic Resource Pools
  • Queue-related APIs (Recommended)
  • SQL Job-related APIs
  • Flink Job-related APIs
    • Creating a SQL Job
    • Updating a SQL Job
    • Creating a Flink Jar job
    • Updating a Flink Jar Job
    • Running Jobs in Batches
    • Listing Jobs
    • Querying Job Details
    • Querying the Job Execution Plan
    • Stopping Jobs in Batches
    • Deleting a Job
    • Deleting Jobs in Batches
    • Exporting a Flink Job
    • Importing a Flink Job
    • Generating a Static Stream Graph for a Flink SQL Job
  • APIs Related to Flink Job Templates
  • Spark Job-related APIs
  • Permissions Policies and Supported Actions
  • Out-of-Date APIs
  • Public Parameters
  • Change History
  • API Reference
  • Flink Job-related APIs
  • Exporting a Flink Job

Exporting a Flink Job¶

Function¶

This API is used to export Flink job data.

URI¶

  • URI format

    POST /v1.0/{project_id}/streaming/jobs/export

  • Parameter description

    Table 1 URI parameter¶

    Parameter

    Mandatory

    Type

    Description

    project_id

    Yes

    String

    Project ID, which is used for resource isolation. For details about how to obtain its value, see Obtaining a Project ID.

Request¶

Table 2 Request parameters¶

Parameter

Mandatory

Type

Description

obs_dir

Yes

String

OBS path for storing exported job files.

is_selected

Yes

Boolean

Whether to export a specified job.

job_selected

No

Array of Longs

This parameter indicates the ID set of jobs to be exported if is_selected is set to true.

Note

This parameter is mandatory when is_selected is set to true.

Response¶

Table 3 Response parameters¶

Parameter

Mandatory

Type

Description

is_success

No

String

Indicates whether the request is successfully executed. Value true indicates that the request is successfully executed.

message

No

String

System prompt. If execution succeeds, the parameter setting may be left blank.

zip_file

No

Array of Strings

Name of the ZIP package containing exported jobs. The ZIP package is stored on OBS.

Example Request¶

Export the job whose ID is 100 to OBS.

{
    "obs_dir": "obs-test",
    "is_selected": true,
    "job_selected": [100]
}

Example Response¶

{
    "is_success": true,
    "message": "The job is exported successfully.",
    "zip_file": ["obs-test/aggregate_1582677879475.zip"]
}

Status Codes¶

Table 4 describes status codes.

Table 4 Status codes¶

Status Code

Description

200

The job is exported successfully.

400

The input parameter is invalid.

Error Codes¶

If an error occurs when this API is invoked, the system does not return the result similar to the preceding example, but returns the error code and error information. For details, see Error Codes.

  • Prev
  • Next
last updated: 2025-06-16 14:07 UTC - commit: 2d6c283406071bb470705521bc41e86fa3400203
Edit pageReport Documentation Bug
Page Contents
  • Exporting a Flink Job
    • Function
    • URI
    • Request
    • Response
    • Example Request
    • Example Response
    • Status Codes
    • Error Codes
© T-Systems International GmbH
  • Contact
  • Data privacy
  • Disclaimer of Liabilities
  • Imprint