检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
在MRS Manager界面选择“系统设置 > 用户管理”，在用户名中选择test，然后在右侧“操作”列中选择“更多 >下载认证凭据”下载，保存后解压得到用户的user.keytab文件与krb5.conf文件，用于在样例工程中进行安全认证，如5.2.6-准备kerberos认证所示。
Channel支持事务特性，可保证简易的顺序操作，同时可以配合任意数量的Source和Sink共同工作。 Sink Sink负责将数据传输到下一跳或最终目的，成功完成后将数据从Channel移除。 典型的Sink样例如下： 存储数据到最终目的终端Sink，比如：HDFS、Kafka 自动消耗的Sinks，比如：Null
左边菜单栏中选择所需修改的角色所对应的日志菜单。 选择所需修改的日志级别。 单击“保存”，在弹出窗口中单击“确定”使配置生效。 配置完成后立即生效，不需要重启服务。 日志格式 ZooKeeper的日志格式如下所示： 表3 日志格式 日志类型 组件 格式 示例 运行日志 zookeeper
可以在MRS Manager修改健康检查报告保存的文件数。健康检查报告保存的文件数不区分集群、服务或主机类型的健康检查报告。健康检查完成后，报告文件默认保存在主管理节点的“$BIGDATA_DATA_HOME/Manager/healthcheck”，备管理节点将自动同步。 选择“系统设置
kafka; 作业3：FlinkSQL流式读取MOR和COW表并合并数据输出到Kafka。注意作业3需要等待作业1和作业2均启动后，状态显示为“运行中”后再执行SQL校验和启动作业（否则SQL校验可能提示错误，找不到Hudi表目录）。 CREATE TABLE stream_mor(
1.0.1/ 上传完毕后删除本地的spark-archive-2x-arm.zip，spark-archive-2x-x86.zip文件。 对其他的SparkResource安装节点执行1~2。 进入WebUI重启Spark的JDBCServer实例。 重启后，需要更新客户端配置。
0.1/ 上传完毕后删除本地的spark-archive-2x-arm.zip，spark-archive-2x-x86.zip文件。 对其他的sparkResource安装节点执行1~2。 进入webUI重启spark2x的jdbcServer实例。 重启后，需要更新客户端配置
单击右上角的设置日志收集的“开始时间”和“结束时间”分别为告警产生时间的前后10分钟，单击“下载”。 请联系运维人员，并发送已收集的故障日志信息。 告警清除 此告警修复后，系统会自动清除此告警，无需手工清除。 参考信息 无 父主题： MRS集群告警处理参考
”，执行下列命令初始化环境变量。 source bigdata_env kinit 组件业务用户 kinit一次票据时效24小时。24小时后再次运行样例，需要重新kinit。 与HTTP服务访问相比，以HTTPS方式访问Yarn时，由于使用了SSL安全加密，需要确保Curl命令所
server.blockmanagement.AvailableSpaceBlockPlacementPolicy”。 保存修改的配置。保存完成后请重新启动配置过期的服务或实例以使配置生效。 父主题： HDFS企业级能力增强
server.blockmanagement.AvailableSpaceBlockPlacementPolicy”。 保存修改的配置。保存完成后请重新启动配置过期的服务或实例以使配置生效。 父主题： HDFS企业级能力增强
单击右上角的设置日志收集的“开始时间”和“结束时间”分别为告警产生时间的前后10分钟，单击“下载”。 请联系运维人员，并发送已收集的故障日志信息。 告警清除 此告警修复后，系统会自动清除此告警，无需手工清除。 参考信息 无。 父主题： MRS集群告警处理参考
S的资源计划特性。 MRS服务支持规则和时间计划两种弹性伸缩的策略： 弹性伸缩规则：根据集群实时负载对Task节点数量进行调整，数据量变化后触发扩缩容，有一定的延后性。 资源计划：若数据量变化存在周期性规律，则可通过资源计划在数据量变化前提前完成集群的扩缩容，避免出现增加或减少资源的延后。
streams-wordcount-processor-output --config cleanup.policy=compact Topic创建成功后，执行以下命令运行程序。 java -cp /opt/client/lib/*:/opt/client/src/main/resources
streams-wordcount-processor-output --config cleanup.policy=compact Topic创建成功后，执行以下命令运行程序。 java -cp /opt/client/lib/*:/opt/client/src/main/resources
JDK默认只支持TLS V1.0，若使用IBM JDK，请配置启动参数“com.ibm.jsse2.overrideDefaultTLS”为“true”，设置后可以同时支持TLS V1.0/V1.1/V1.2，详情参见https://www.ibm.com/support/knowledgecenter/zh/SSYKE2_8
在检索过程中可单击“停止”强制停止当前检索进度，并在列表中显示已检索出的结果。 单击“过滤”，可以针对界面上已经显示的日志信息进行二次筛选，具体字段如表3所示。填写完毕后，单击“过滤”进行检索，单击“重置”可清空已填写信息。 表3 过滤 参数名 说明 关键字 需要检索的日志关键字。 主机名称 需要检索的主机名。
Zone”。单击“Save”保存。如需添加多条策略有效期，可单击按钮添加。如需删除策略有效期，可单击按钮删除。 单击“Add”，在策略列表可查看策略的基本信息。等待策略生效后，验证相关权限是否正常。 如需禁用某条策略，可单击按钮编辑策略，设置策略开关为“Disabled”。 如果不再使用策略，可单击按钮删除策略。
send(ProducerRecord<K,V> record, Callback callback) 带回调函数的发送接口，通常用于异步发送后，通过回调函数实现对发送结果的处理。 void onCompletion(RecordMetadata metadata, Exception
范围为： 每天 每周 其他 开启“分级告警开关”后，仅支持“每天”。 每天 添加日期 仅在“日期”模式为“其他”时可见，设置规则运行的自定义日期，支持多选。 09-30 阈值设置 设置规则运行的具体时间范围。 开启“分级告警开关”后，不支持设置起止时间，默认为00:00-23:59。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
