Manage integration and computing task instances-Dataphin(Dataphin)-阿里云帮助中心

Prerequisites

To view Gantt charts, you must purchase the artificial intelligence for IT operations value-added service and enable the artificial intelligence for IT operations module for the current tenant.

Accessing the integration and compute task instances page

In the top menu bar of the Dataphin home page, choose Develop > O&M.
In the navigation pane on the left, choose Instance O&M > Recurring Instance.
In the top menu bar, select the production or development environment.
On the Recurring Instance page, click the Integration and Computing Task tab.

Operations supported in the integration and computing task instance list

Instances generated by auto-triggered integration and computing tasks are listed on the Integration and Computing Task tab. The list shows the instance object, instance ID, status, schedule cycle, data timestamp, scheduled run time, start time, end time, duration, retries/auto-retries, priority, owner, project, related baseline instances, schedule resource group, tags, and supported operations.

Instance Object: A recurring instance object is generated when an auto-triggered task runs. This column displays the name and ID of the instance object and identifies the schedule type of the task. Click the icon next to the column name to sort by object name in ascending or descending order. For more information, see and Description of recurring instance statuses.
Status: The current status of the instance. Possible values are Succeeded, Failed, Running, Waiting for Schedule Time, Throttled, Waiting for Schedule Resources, and Not Run. For more information about the status icons and their details, see Description of recurring instance statuses.
Start Running Time: The time when the instance starts running. Click the icon next to the column name to sort by start time in ascending or descending order.

Note
The start time of a logical table node is the time when the earliest internal materialization node of the instance object starts running.
End Running Time: The time when the instance stops running. Click the icon next to the column name to sort by end time in ascending or descending order.

Note
The end time of a logical table node is the time when the latest internal materialization node of the instance object stops running.
Retries/Auto-retries: The number of manual retries and automatic retries. Retries = Runs - 1.
Running Duration: The total time that the instance runs. Click the icon next to the column name to sort by duration in ascending or descending order.

Note
The duration of a logical table node is the time difference between the start time of the earliest internal materialization node and the end time of the latest internal materialization node.
Priority: The priority level of the instance.

Note
If the baseline feature is enabled, the priority of a baseline task is the highest priority among all its baselines. This overrides the original priority configured for the task.
Project: The project to which the task belongs. The project is displayed in the Project English Name (Project Chinese Name) format.
Related Baseline Instances: The baseline that the node guarantees, and any related baselines that have this node as an ancestor node.

Note
If the baseline feature is disabled, this field is not displayed.
Resource Group: The name of the schedule resource group that the instance uses at runtime.

If the custom resource group specified for the task is not active, the project's default resource group is used. If the project's default resource group is also not active, the tenant's default resource group is used. The priority order is: Custom resource group > Project default resource group > Tenant default resource group.

Note
When you change the project's default resource group, the change may not be immediately reflected in the UI. However, the modified resource group is used for the next run.

Tenant default resource group: This resource group does not belong to any project. Each Dataphin instance has only one default resource group. It is used to schedule a task if the task does not have a specified custom resource group or if the project does not have a specified project default resource group.

The following table describes the supported operations.

Operation	Description
DAG	Click the icon to view the Directed Acyclic Graph (DAG) of the recurring instance. For more information, see Recurring instance DAG.
View Operational Log	Click the icon to view the operational log of the recurring instance. Log content varies by instance type.
Rerun	Click the icon to rerun the recurring instance. You can rerun only integration and computing task instances that have succeeded or failed. When you rerun an instance, the system checks whether all its ancestor nodes have succeeded. If the check fails, the status of the current instance is set to Not Run. If your business scenario requires a rerun, you can perform a forced rerun.
View Gantt Chart	Click the icon and select View Gantt Chart. In the View Gantt Chart dialog box, configure the following parameters. Set Selected Node As: Set the current node as the Start Node or End Node. If you select Start node, the current node is selected by default in the Start node field and cannot be modified. The same rule applies if you select End node. Start Node: Select the start node of the Gantt chart. You can search for nodes by keyword. The nodes in the list are displayed in the `{Node Name}({Node ID, {Instance Scheduled Run Time}})` format. If you set the selected node as the end node, the start node defaults to the tenant root node. Note Hourly and minute tasks have multiple nodes. Each instance is a node. The nodes are distinguished by the instance scheduled run time. End Node: Select the end node of the Gantt chart. You can search for nodes by keyword. The nodes in the list are displayed in the `{Node Name}({Node ID, {Instance Scheduled Run Time}})` format. Note If you select a logical table as the end node, you cannot select a field because the logical table is treated as a whole. For more information about the Gantt chart, see View the Gantt chart of a critical path.
Download Ancestor and Descendant Nodes	Downloads a list of the upstream and downstream nodes for the current node. The list includes all columns (including list items that are not displayed). Click Download Ancestor And Descendant Nodes. In the Download Ancestor And Descendant Nodes dialog box, select the levels for the ancestor and descendant nodes. You can select from Layer 1 to Layer 10 or Unlimited Layers, with Layer 1 being the default for both. After you select the layers, click OK to download the Excel file, which is named `{task_name}_ancestor_and_descendant_nodes_{timestamp}.xlsx`.
View Node Code	Click the icon, select View Node Code to view the node code of the current instance. For Flink_SQL integration and computing task instances, you can click to switch between the logical code and the physical code. Logical Code: The task code that you write. Physical Code: The compiled code that can run on the Flink engine.
Recurring Task	Click the icon and select Recurring Task to view the auto triggered task to which the current instance belongs.
Edit Development Node	Click the icon and select Edit Development Node to go to the development page of the instance. On this page, you can modify the instance. Note You can edit development nodes only for integration and computing task instances in Dev-Prod mode projects.
View Production Node	Click the icon and select Edit Production Node to go to the production page of the instance. Note You can view development nodes only for integration and computing task instances in Dev-Prod mode projects.
Edit Node	Click the icon and select Edit Node. From the instance list or the DAG, go to the Basic project to edit the integration or computing task that generates the instance. Note You can edit nodes only for integration and computing task instances in Basic mode projects.
Rerun Downstream	Click the icon and select Rerun Downstream to rerun the descendant nodes of the instance. You can rerun only the descendant nodes of integration and computing task instances that have succeeded or failed. You cannot rerun descendant nodes that are in the Waiting (Waiting for Schedule Time or Waiting for Schedule Resources) or Running state. For more information, see Rerun downstream. To rerun the entire dependency chain, we recommend that you force a rerun of the downstream instances. For more information, see Force a rerun of downstream instances. The rerun downstream operation is often used in the following scenarios: After the data of the current instance node is updated, you need to synchronize the data of its descendant nodes. After a descendant node of an instance fails to run, you need to rerun the descendant node.
Set To Success & Resume	Click the icon and select Set To Success & Resume. This manually sets the status of a failed or not run instance to Succeeded and allows it to participate in scheduling. Click Set To Success & Resume, and then click OK in the Set To Success & Resume confirmation dialog box.
Stop	Click the icon and select Stop to stop the running instance. The instance status changes to Failed. After the instance is stopped, its descendant nodes do not run. Note You cannot stop instances that are in the Succeeded, Failed, or Not Run state. You can stop instances in any other state. The stop operation is often used in the following scenarios: You need to stop an integration or computing task instance due to a Dataphin error or an operational mistake. An integration or computing task instance is in the Running state, but no data is generated. You can manually stop the instance and check the operational log for errors.
Forced Rerun	Click the icon and select Forced Rerun. Then, select Force Rerun Current Instance or Force Rerun Downstream Instances. Force Rerun Current Instance: A forced rerun does not check the status of ancestor nodes. If not all ancestor nodes have succeeded, the current instance may fail to rerun or may have data errors. Proceed with caution. After you force a rerun of the current integration or computing task instance, the data of the instance is updated. Force Rerun Downstream Instances: After you perform this operation, all instances are first set to Not Run. This prevents data inconsistencies that can occur if downstream instances run while upstream instances are being rerun. The check on upstream dependencies and the scheduled run time is skipped only for the start node. Descendant nodes must still follow the dependency rules and instance triggering conditions. For more information, see Force a rerun of downstream instances. For more information about instance triggering conditions, see Dependencies and run rules. Important A forced rerun does not check whether all upstream instances have run successfully or whether the scheduled run time of the current instance has been reached. This can lead to run failures or data quality issues. Before you proceed, make sure that the operation does not affect downstream data.
Remove Upstream Dependencies	Click the icon and select Remove Upstream Dependencies to remove the upstream dependencies of an integration or computing task instance, regardless of its status. Important You must keep at least one upstream instance.
Pause	Click the icon and select Pause to pause the running instance. Pausing the current instance does not affect other instances of the same task. After you pause an instance, the instance and its descendant nodes are not scheduled. Note You can pause only instances that are in the Not Run, Waiting for Schedule Time, or Throttled state. The pause operation is often used when resources are limited. You can pause low-priority instances to ensure that high-priority tasks run first.
Resume	Click the icon and select Resume to resume a paused instance. After you resume the instance, the instance and its descendant nodes are scheduled as normal.
Modify Schedule Resource Group	Click the icon and select Modify Schedule Resource Group to change the schedule resource group that the instance uses at runtime. Note If you select tasks from multiple projects, only the schedule resource groups that are authorized to all selected projects are listed. We recommend that you filter by a single project before you perform batch settings. The modification affects only the current instance and does not affect other instances of the task.
Modify Priority	Click the icon and select Modify Priority. In the Modify Priority dialog box, change the priority of the current task. You can select Highest, High, Medium, Low, or Lowest.

Operations supported for DAG nodes of integration and computing task instances

The Directed Acyclic Graph (DAG) shows the upstream and downstream dependencies of instance nodes and lets you perform O&M on them. By default, the DAG displays the selected node and its immediate ancestor and descendant nodes.

Dataphin supports cross-project instance O&M. To operate on an instance in another project, you must have the required view and operation permissions for that project.

Operations supported in the DAG

Operation	Description
Expand Parent Nodes	Expand the dependency nodes at different levels of the main node in the DAG.
Expand Child Nodes
View Task	Go to the DAG of the task node that generates the current instance node. You can view the task node details, information about its upstream and downstream nodes, and perform O&M on the task node. For more information, see auto triggered tasks.
View Operation Logs	View the logs of operations performed on the instance.

Operations supported for DAG nodes

Hover over a DAG node to view its name, type, schedule cycle, owner, and description. The operations supported for DAG nodes are the same as those supported in the instance list. For more information, see Operations supported in the integration and computing task instance list.

Batch operations for integration and computing task instances

The following table describes the supported batch operations.

Operation	Description
Rerun	You can rerun only instances that are in the Succeeded or Failed state. If none of the selected instances are in the Succeeded or Failed state, the batch rerun operation is not supported. If you select instances in the Succeeded or Failed state and instances in other states, the system reruns only the instances that are in the Succeeded or Failed state.
Stop	You cannot stop instances that are in the Succeeded, Failed, or Not Run state. You can stop instances in any other state. If all selected instances are in the Succeeded, Failed, or Not Run state, the batch stop operation is not supported. If you select instances in these states and instances in other states, the system does not stop the instances that are in the Succeeded, Failed, or Not Run state.
Set To Success & Resume	Select multiple instances to manually set the status of failed or not run instances to Succeeded in a batch. This allows them to participate in scheduling.
Pause	You can pause only instances that are in the Not Run, Waiting for Schedule Time, or Throttled state. If none of the selected instances are in the Not Run, Waiting for Schedule Time, or Throttled state, the batch pause operation is not supported. If you select instances in these states and instances in other states, the system pauses only the instances that are in the Not Run, Waiting for Schedule Time, or Throttled state.
Resume	Resume paused recurring instances in a batch.
Modify Schedule Resource Group	Modify the schedule resource group that instances use at runtime. Note You can modify the schedule resource group only for instances in a production environment project. The modification affects only the current instance and does not affect other instances of the task.
Modify Priority	Modify the priority of the selected instances in a batch. You can select Highest, High, Medium, Low, or Lowest.
Download All	Download the data of all recurring instances, including integration, computing, and modeling task instances, to your computer. The downloaded file is in the .xlsx format. The file is named in the `Dataphin_recurring_instance_{timestamp}.xlsx` format. The table contains the following information: instance object, instance ID, status, schedule cycle, data timestamp, priority, owner, project (if a logical aggregate table belongs to multiple projects, the project names are separated by commas (`, `)), scheduled run time, start time, end time, duration, retries/auto-retries, related baseline instances (if an instance is associated with multiple baselines, the baseline names are separated by commas (`, `)), and schedule resource group (this parameter is empty for modeling task instances).

Rerun downstream

In the Rerun Downstream dialog box, configure the parameters.

Note

You cannot rerun descendant nodes that have a Waiting or Running status. To rerun the entire dependency chain, we recommend that you force a rerun of the downstream instances. For more information, see Force a rerun of downstream instances.

Parameter

Description

Start Node Run Mode

Define the run mode of the start node. You can select Dry-run or Normal run.

Dry-run: The status of a dry-run instance is Succeeded (Normal). The operational log is empty, no duration is recorded, and no data is processed.
Normal Run: The instance is scheduled as normal.

Downstream Rerun Scope

Select the scope of descendant nodes to rerun.

All Failed Instances: The list of descendant nodes is not displayed. The system automatically selects all descendant instances that have failed and reruns them.
Custom: If you want to specify the descendant instances to rerun, select this option. You can search for nodes by name or ID, or filter them by status, owner, or project.

Click OK.
After you rerun the downstream nodes, the data of the descendant instances is updated.

Force a rerun of downstream instances

In the Force Rerun Downstream dialog box, configure the rerun parameters.

Parameter

Description

Start Node Run Mode

Define the run mode of the start node. You can select Dry-run or Normal run.

Dry-run: The status of a dry-run instance is Succeeded (Normal). The operational log is empty, no duration is recorded, and no data is processed.
Normal Run: The instance is scheduled as normal.

Downstream Forced Rerun Scope

Select the scope of descendant nodes to force a rerun.

All Instances: Select all descendant instance nodes of the start node.
Custom: If you want to specify the descendant instances to rerun, select this option. You can search for nodes by name or ID, or filter them by status, owner, or project.

Click OK.