1{
2  "_db_jobMeta": {
3    "name": "dm_orders_to_iceberg_batch",
4    "description": "达梦 ORDERS 表离线同步到 Iceberg",
5    "parentFolderId": "project_91cc_799bd26eee94",
6    "type": "batch",
7    "mode": "script"
8  },
9  "env": {
10    "job.mode": "BATCH",
11    "parallelism": 1,
12    "checkpoint.interval": 30000
13  },
14  "source": [
15    {
16      "plugin_name": "Jdbc",
17      "_db_pluginId": "Jdbc-DM",
18      "plugin_output": "source_table",
19      "_db_connectionId": "dm-conn-001",
20      "_db_sourceDatabase": "DMDB",
21      "_db_sourceSchema": "SALES",
22      "_db_sourceTable": "ORDERS",
23      "_db_where": "ID > 0",
24      "partition_column": "ID",
25      "_db_sourceChange": {
26        "onDeleteColumn": "SKIP",
27        "onAddColumn": "SKIP",
28        "onDeleteSource": "PAUSE"
29      }
30    }
31  ],
32  "sink": [
33    {
34      "plugin_name": "Iceberg",
35      "_db_pluginId": "Iceberg-batch",
36      "plugin_input": "source_table",
37      "_db_sinkPath": "lake.default",
38      "_db_catalog": "lake",
39      "_db_schema": "default",
40      "iceberg.table.upsert-mode-enabled": false,
41      "data_save_mode": "APPEND_DATA",
42      "_db_isAutoCreated": true,
43      "_db_sinkTableType": "MANAGED",
44      "_db_sinkNameRule": "SAME",
45      "_db_comment": "订单表"
46    }
47  ]
48}