自定义运营看板提高篇 我的卡片界面介绍 新建卡片分类 新建项目 使用在线构建新建表单卡片 使用卡片模板新建卡片 使用离线构建新建卡片 管理卡片 使用模板构建新建屏幕 父主题： 看板管理

查看更多 →

dws-connector-flink仅发布Scala2.11 Flink 1.12版本 1.0.2 dwsclient优化异常重试逻辑，由所有异常重试修改为只重试：连接异常、数据库只读、超时、连接数过多、加锁异常五类异常。 dws-connector-flink支持版本： Scala2

查看更多 →

context.getJobParameter("url","jdbc:mysql://xx.xx.xx.xx:3306/table"); context.getJobParameter("driver","com.mysql.jdbc.Driver"); context.getJobParameter("user"

查看更多 →

context.getJobParameter("url","jdbc:mysql://xx.xx.xx.xx:3306/table"); context.getJobParameter("driver","com.mysql.jdbc.Driver"); context.getJobParameter("user"

查看更多 →

在 DLI 管理控制台，单击“作业管理 > Flink作业”，在Flink作业管理界面，单击“创建作业”。 在创建作业界面，作业类型选择“Flink OpenSource SQL”，名称填写为：FlinkKafkaRds。单击“确定”，跳转到Flink作业编辑界面。 在Flink OpenSource

查看更多 →

Flink作业输出流写入数据到OBS，通过该OBS文件路径创建的DLI表查询无数据 问题现象 使用Flink作业输出流写入数据到了OBS中，通过该OBS文件路径创建的DLI表进行数据查询时，无法查询到数据。 例如，使用如下Flink结果表将数据写入到OBS的“obs://obs-sink/car_infos”路径下。

查看更多 →

Flink SQL作业相关问题 Flink SQL作业的消费能力如何，即一天可以处理多大的数据量？ Flink SQL中的temp流中数据是否需要定期清理，如何清理？ Flink SQL作业将OBS表映射为DLI的分区表 Flink SQL作业Kafka分区数增加或减少，不用停止Flink作业，实现动态感知

查看更多 →

确认当前用户所属用户组下的权限是否包含OBS写入的权限，比如“OBS OperateAccess”。如果没有OBS写入权限，则给对应的用户组进行授权。 授权完成后，等待5到10分钟等待权限生效。再次运行失败的Flink SQL作业，查看作业运行状态。 父主题： Flink SQL作业相关问题

查看更多 →

、访问人数等等指标，从而能在显示大屏上实时展示相关数据。电商平台可以通过将每个商品的订单信息实时写入Kafka中或将业务数据表上传至对象存储 OBS桶中从而触发 函数工作流 自动将数据写入Kafka中，DLI根据当前可以获取到的业务数据，实时统计每种渠道的相关指标，输出存储到数据库中

查看更多 →

RDS for MySQL备份任务失败分析思路 场景描述 客户使用RDS for MySQL数据库服务，使用自有备份脚本，通过mysqldump命令进行异机备份。备份数据到一台与RDS在不同子网的E CS 主机，但备份任务运行300秒后就会中断，无法完成备份任务。 原因分析 为了排除

查看更多 →

Maxwell应用允许将每个变动消息精确地传递一次。在这种情况下，Flink在消费Maxwell生成的消息时处理得很好。如果Maxwell应用程序在at-least-once模式处理，它可能向Kafka写入重复的改动消息，Flink将获得重复的消息。这可能会导致Flink查询得到错误的结果或意外的异常。因此，在这种情况下，建议将作业配置table

查看更多 →

本实践演示通过华为云 数据复制服务 DRS完成MySQL数据实时同步到 GaussDB (DWS)的基本过程。 通过DLI Flink作业将Kafka数据实时写入DWS 本实践演示通过 数据湖探索 服务DLI Flink作业将分布式消息服务Kafka的消费数据实时同步至DWS 数据仓库 ，实现Kafka实时入库到DWS的过程。

查看更多 →

Flink作业相关 前提条件 已参考Java SDK概述配置Java SDK环境。 已参考初始化DLI客户端完成客户端DLIClient的初始化，参考队列相关完成队列创建等操作。 新建SQL作业 DLI提供新建Flink SQL作业的接口。您可以使用该接口新建Flink SQL作业并提交到DLI，示例代码如下：

查看更多 →

作业管理”>“Flink作业”，进入Flink作业管理页面。 在需要编辑作业对应的“操作”列中，单击“编辑”，进入作业编辑页面。 根据实际需求编辑作业。 对于Flink SQL类型作业，编辑页面详情请参见创建Flink SQL作业中的步骤5~步骤7。 对于Flink自定义类型作业，编辑页面详情请参见创建Flink

查看更多 →

展示用户Flink作业字节的输入总数。单位：字节。 Flink作业字节输出总数 展示用户Flink作业字节的输出总数。单位：字节。 Flink作业CPU使用率 展示用户Flink作业的CPU使用率。单位：%。 Flink作业内存使用率 展示用户Flink作业的内存使用率。单位：%。

查看更多 →

Flink日志介绍 日志描述 日志存储路径： Flink作业运行日志：“${BIGDATA_DATA_HOME}/hadoop/data${i}/nm/containerlogs/application_${appid}/container_{$contid}”。 运行中的任务日

查看更多 →

开发Flink应用 Flink DataStream样例程序 Flink Kafka样例程序 Flink开启Checkpoint样例程序 Flink Job Pipeline样例程序 Flink Join样例程序 Flink对接 云搜索服务 （ CSS ）样例程序 父主题： Flink开发指南（普通模式）

查看更多 →

开发Flink应用 Flink DataStream样例程序 Flink Kafka样例程序 Flink开启Checkpoint样例程序 Flink Job Pipeline样例程序 Flink Join样例程序 父主题： Flink开发指南（安全模式）

查看更多 →

导入Flink作业 功能介绍 该API用于导入Flink作业数据。 调试 您可以在 API Explorer 中调试该接口。 URI URI格式 POST /v1.0/{project_id}/streaming/jobs/import 参数说明 表1 URI参数说明 参数名称 是否必选

查看更多 →

MySQL到MySQL 支持的源和目标数据库 表1 支持的数据库 源数据库 目标数据库 RDS for MySQL RDS for MySQL 数据库账号权限要求 使用DRS创建录制回放任务时，连接源和目标数据库账号的权限建议保持一致，再启动任务。 使用须知 为了确保录制回放任务

查看更多 →

MySQL到MySQL 支持的源和目标数据库 表1 支持的数据库 源数据库 目标数据库 ECS自建MySQL 5.6、5.7、8.0版本 本地自建MySQL 5.6、5.7、8.0版本 其他云上MySQL 5.6、5.7、8.0版本 RDS for MySQL 数据库账号权限要求

查看更多 →