检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
创建消息通知主题后,只有在订阅队列上创建的Spark作业失败时才会收到消息通知。 图2 创建主题成功 单击图2中“主题管理”,跳转至消息通知服务“主题管理”页面。 图3 主题管理 在对应主题的“操作”列中,单击“添加订阅”,选择“协议”,确定订阅方式。 如果选择“短信”协议,需要在“订阅终端”中填写接收确认短信的手机号码。
expired while fetching topic metadata怎么办? Flink JobManager提示 "Timeout expired while fetching topic metadata" ,说明Flink作业在尝试获取Kafka主题的元数据时超时了。 此时您需要先
怎样监控DLI队列上的作业异常? DLI为用户提供了作业失败的topic订阅功能。 登录DLI控制台。 单击左侧“队列管理”,进入队列管理页面。 在队列管理页面,单击左上角“创建消息通知主题”进行配置。详细操作请参考《数据湖探索用户指南》。 父主题: DLI弹性资源池和队列类
BY一起使用,为PARTITION进行单列或多列的局部排序。 注意事项 所排序的表必须是已经存在的,否则会出错。 示例 根据字段score对表student在Reducer中进行升序排序。 1 2 SELECT * FROM student SORT BY score; 父主题: 排序
on number num_buckets output_format_classname partition_col_name partition_col_value partition_specs property_name property_value regex_expression
properties.bootstrap.servers" = "xxxx:9092", "connector.topic" = "kafka_car_topic ", "connector.sink.ignore-retraction" = "true", "connector
别名SELECT 表别名 列别名 父主题: SELECT
集合运算SELECT UNION INTERSECT EXCEPT 父主题: SELECT
aggregate_func 格式 无。 说明 聚合函数。 父主题: 标示符
window_function 格式 无。 说明 分析窗口函数。 父主题: 标示符
hdfs_path 格式 无。 说明 HDFS的路径,如“hdfs:///tmp”。 父主题: 标示符
cte_name 格式 无。 说明 公共表达式的名字。 父主题: 标示符
file_path 格式 无。 说明 文件路径,该路径是OBS路径。 父主题: 标示符
non_equi_join_condition 格式 无。 说明 指不等式join条件。 父主题: 标示符
资源相关API(废弃) 数据库相关API(废弃) 表相关API(废弃) 父主题: 历史API
data_type 格式 无。 说明 数据类型,当前只支持原生数据类型。 父主题: 标示符
增强型跨源连接相关API(废弃) 创建路由(废弃) 删除路由(废弃) 父主题: 历史API
Hudi DDL语法说明 CREATE TABLE DROP TABLE SHOW TABLE TRUNCATE TABLE 父主题: DLI Hudi SQL语法参考
排序 ORDER BY SORT BY CLUSTER BY DISTRIBUTE BY 父主题: SELECT
CASE...WHEN 简单CASE函数 CASE搜索函数 父主题: SELECT