检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
该API属于DLI服务,描述: This API is used to delete jobs in any status in batches.接口URL: "/v1.0/{project_id}/streaming/jobs/delete"
该API属于DLI服务,描述: 对DLI服务中已有的Flink作业模板进行更新。接口URL: "/v1.0/{project_id}/streaming/job-templates/{template_id}"
该API属于DLI服务,描述: 触发批量运行Flink作业。接口URL: "/v1.0/{project_id}/streaming/jobs/run"
该API属于DLI服务,描述: This API is used to query the list of the current user's jobs. You can set the job ID as the ID and query jobs whose IDs are
该API属于DLI服务,描述: This API is used to view details about a Flink job.接口URL: "/v1.0/{project_id}/streaming/jobs/{job_id}"
该API属于DLI服务,描述: This API is used to query Flink job templates. Currently, only user-defined templates can be queried.接口URL: "/v1.0/{project_id
该API属于DLI服务,描述: This API is used to update user-defined jobs, which currently support the Jar format and run in exclusive clusters.接口URL: "/v1.0
该API属于DLI服务,描述: 在DLI服务中新建一个Flink作业模板,最多100个。接口URL: "/v1.0/{project_id}/streaming/job-templates"
该API属于DLI服务,描述: Importing a Flink Job Savepoint接口URL: "/v1.0/{project_id}/streaming/jobs/{job_id}/import-savepoint"
该API属于DLI服务,描述: 通过POST方式,提交流式SQL作业,请求体为JSON格式。接口URL: "/v1.0/{project_id}/streaming/sql-jobs"
Flink Jar作业提交SQL样例程序开发思路 本场景适用于MRS 3.2.1及以后版本。 场景说明 当作业的SQL语句修改频繁时,可使用Flink Jar的方式提交Flink SQL语句,以减少用户工作量。 开发思路 使用当前样例提交并执行指定的SQL语句,多个语句之间使用分号分割
Flink对接云搜索服务(CSS)样例程序(Java) 功能介绍 当前基于随机数生成器实现了一个持续产生长度为4字符串的数据源用于写入数据。 样例代码 下面代码片段仅为演示,具体代码参见:com.huawei.bigdata.flink.examples。 public class
Flink向Kafka生产并消费数据应用开发思路 假定某个Flink业务每秒就会收到1个消息记录。 基于某些业务要求,开发的Flink应用程序实现功能:实时输出带有前缀的消息内容。 数据规划 Flink样例工程的数据存储在Kafka组件中。Flink向Kafka组件发送数据(需要有
Flink Opensource SQL如何解析复杂嵌套 JSON? kafka message { "id": 1234567890, "name": "swq", "date": "1997-04-25", "obj": { "time1": "12:12
ALM-45639 Flink作业checkpoint完成时间超过阈值 本章节适用于MRS 3.1.5及以后版本。 告警解释 系统每30秒为周期检查Flink作业CheckPoint完成时间是否超过阈值(默认值:600秒),如果超过阈值则产生告警。作业CheckPoint完成时间小于或等于阈值
开发实时处理单任务MRS Flink SQL作业 对已新建的作业进行开发和配置。 开发单任务模式的实时处理Flink SQL作业,请您参考开发SQL脚本、配置作业参数、保存作业和模板章节。 前提条件 已新建作业。 当前用户已锁定该作业,否则需要通过“抢锁”锁定作业后才能继续开发作业
Flink Jar作业提交SQL样例程序开发思路 本场景适用于MRS 3.2.1及以后版本。 场景说明 当作业的SQL语句修改频繁时,可使用Flink Jar的方式提交Flink SQL语句,以减少用户工作量。 开发思路 使用当前样例提交并执行指定的SQL语句,多个语句之间使用分号分割
Flink作业高可靠推荐配置指导(异常自动重启) 操作场景 本节操作介绍创建Flink作业时,配置流应用实现高可靠性能的操作方法。 操作步骤 用户在消息通知服务(SMN)中提前创建一个“主题”,并将其指定的邮箱或者手机号添加至主题订阅中。此时指定的邮箱或者手机会收到请求订阅的通知,
DLI Flink 1.7版本停止服务(EOS)公告 公告说明 华为云于2022年12月31 00:00(北京时间)将DLI Flink 1.7版本停止服务(EOS)。 影响 DLI Flink 1.7版本停止服务(EOS)后,不再提供该软件版本相关的任何技术服务支持。建议您在执行作业时选择新版本的
ALM-45638 Flink作业失败重启次数超阈值 本章节仅适用于MRS 3.2.0及以后版本。 告警解释 系统以用户配置的告警周期检查Flink作业重启次数,如果重启次数超过用户配置的阈值,则发送告警。当作业重启成功,则告警恢复。 告警属性 告警ID 告警级别 是否自动清除 45638