维保任务列表：双击统计看板中的明细行，或单击维保日历，进入维保任务列表界面； 图3 维保任务列表 维保执行：双击维保任务列表明细，进入维保执行界面 -> 单击“开始维保”按钮，更新维保单状态为“执行中” -> 输入维保工时，选择是否停机，输入停机时间、异常记录 -> 选项型：选择维

查看更多 →

同步数据为必选项。 选择同步表结构的时候目标库不能有同名的表。 不选同步表结构的时候目标库必须有相应的表，且要保证表结构与所选表结构相同。 DML同步 选择需要同步的DML操作，默认都勾选。 不勾选Delete则不会同步源库增量数据中的Delete语句，可能会导致数据不一致，因此存在数据冲突或任务失败的风险。

查看更多 →

败或数据不一致。 对于一个DDL中存在一个rename的情况（例如：rename A TO B），只支持rename前后库表都在已选择库表中的rename操作（A和B都在已选择库表中），其他情况的rename DDL会被过滤； 对于一个DDL中存在多个rename的情况（例如：rename

查看更多 →

将接入数据导流至数据表中 监控服务已接入的数据，会保存在已创建或者系统自动创建的Kafka的Topic中，需要创建导流任务，将数据导流至ClickHouse或Influxdb数据表中。 将数据导流至ClickHouse/Influxdb表 进入AppStage运维中心。 在顶部导航栏选择服务。

查看更多 →

将Spark作业结果存储在MySQL数据库中，缺少pymysql模块，如何使用python脚本访问MySQL数据库？ 缺少pymysql模块，可以查看是否有对应的egg包，如果没有，在“程序包管理”页面上传pyFile。具体步骤参考如下： 将egg包上传到指定的OBS桶路径下。 登录 DLI 管理控制台，单击“数据管理

查看更多 →

整个迁移过程中，不允许对正在迁移中的目标数据库进行修改操作（包括但不限于DDL、DML操作）。 整个迁移过程中，不允许源库执行清除binlog的操作。 整个迁移过程中，不允许源端DDM正在迁移的表做改变拆分键的操作；也不允许将单表/广播表改为拆分表，拆分表改为单表/广播表。 全量迁移阶段：

查看更多 →

ce相当于将数据中不包含的列设置为null。 update writeMode 入库方式： auto：系统自动选择。 copy_merge：当存在主键时使用copy方式入临时表，从临时表merge至目标表；无主键时直接copy至目标表。 copy_upsert：当存在主键时使用c

查看更多 →

以配置为基于时间的方式往桶中写入数据，比如可以设置每个小时的数据写入一个新桶中。即桶中将包含一个小时间隔内接收到的记录。 桶目录中的数据被拆分成多个Part文件。对于相应的接收数据的桶的Sink的每个Subtask，每个桶将至少包含一个Part文件。将根据配置的滚动策略来创建其他Part文件。对于Row

查看更多 →

创建结果表 ClickHouse结果表 Kafka结果表 Upsert Kafka结果表 DIS结果表 JDBC结果表 DWS结果表 Redis结果表 SMN结果表 Hbase结果表 Elasticsearch结果表 OpenTSDB结果表 userDefined结果表 Print结果表

查看更多 →

DIS结果表 功能描述 DLI将Flink作业的输出数据写入 数据接入服务 （DIS）中。适用于将数据过滤后导入DIS通道，进行后续处理的场景。 数据接入服务（Data Ingestion Service，简称DIS）为处理或分析流数据的自定义应用程序构建数据流管道，主要解决云服务外

查看更多 →

若为true，则表示输出数据到taskmanager的error文件中。 若为false，则表示输出数据到taskmanager的out中。 示例 从kafka中读取数据输出到taskmanager的out文件中，可以在taskmanager的out文件中看到输出结果。 create table kafkaSource(

查看更多 →

FileSytem结果表 功能描述 FileSystem结果表用于将数据输出到分布式文件系统HDFS或者 对象存储服务 OBS等文件系统。数据生成后，可直接对生成的目录创建非DLI表，通过DLI SQL进行下一步处理分析，并且输出数据目录支持分区表结构。适用于数据转储、大数据分析、备份或活跃归档、深度或冷归档等场景。

查看更多 →

"user_name":"Alice", "area_id":"330106"} 查看表中数据，在MySQL中执行sql查询语句。 select * from orders； 其结果参考如下（注意，以下数据为从MySQL中复制的结果，并不是MySQL中的数据样式）。 202103241000000001,webShop

查看更多 →

创建结果表 ClickHouse结果表 Kafka结果表 Upsert Kafka结果表 DIS结果表 JDBC结果表 DWS结果表 Redis结果表 SMN结果表 Hbase结果表 Elasticsearch结果表 OpenTSDB结果表 userDefined结果表 Print结果表

查看更多 →

JDBC结果表 功能描述 DLI将Flink作业的输出数据输出到关系型数据库中。 前提条件 要与实例建立增强型跨源连接，且用户可以根据实际所需设置相应安全组规则。 如何建立增强型跨源连接，请参考《 数据湖探索 用户指南》中增强型跨源连接章节。 如何设置安全组规则，请参见《虚拟私有云用户指南》中“安全组”章节。

查看更多 →

DWS结果表 功能描述 DLI将Flink作业的输出数据输出到 数据仓库 服务（DWS）中。DWS数据库内核兼容PostgreSQL，PostgreSQL数据库可存储更加复杂类型的数据，支持空间信息服务、多版本并发控制（MVCC）、高并发，适用场景包括位置应用、金融保险、互联网电商等。

查看更多 →

跨源认证简介及操作方法请参考跨源认证简介。 注意事项 若需要使用upsert模式，则必须在DWS结果表和该结果表连接的DWS表都定义主键。 若DWS在不同的schema中存在相同名称的表，则在flink opensource sql中需要指定相应的schema。 提交Flink作业前，建议勾选“保存作业日

查看更多 →

Kafka结果表 功能描述 DLI通过Kafka结果表将Flink作业的输出数据输出到Kafka中。 Apache Kafka是一个快速、可扩展的、高吞吐、可容错的分布式发布订阅消息系统，具有高吞吐量、内置分区、支持数据副本和容错的特性，适合在大规模消息处理场景中使用。 前提条件

查看更多 →

若为true，则表示输出数据到taskmanager的error文件中。 若为false，则表示输出数据到taskmanager的out中。 示例 参考创建Flink OpenSource作业，创建flink opensource sql作业，运行如下作业脚本，通过DataGen表产生随机数据并输出到Print结果表中。

查看更多 →

（精度大于6位）和自定义类型。 不支持同步表结构中的partition，分区表在目的库同步为非分区表。 不支持默认值含有表达式的函数的表的同步。 不支持同步源库中的临时表。 不支持选择源数据库的空库进行同步。 不支持同步源库中有虚拟列的表。 注意事项 为保证任务的正常运行，DRS

查看更多 →

任务失败。 同步过程中，不允许删除和修改源库的用户名、密码、权限，或修改目标数据库的端口号。 当在同步过程中，对MyISAM表执行修改操作时，可能造成数据不一致。 选择表级对象同步时，同步过程中不建议对表进行重命名操作。 任务做库名映射时，同步的对象中如果存在存储过程、视图、函数对象，全量阶段这些对象不会同步。

查看更多 →