检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
配置作业残留信息自动清理步骤 登录Manager页面。 选择“集群 > 服务 > Flink > 配置 > 全部配置”，搜索参数“ClearUpEnabled”并将值设置为“true”开启目录残留清理功能，相关参数详情请见表1。 表1 FlinkServer目录残留清理参数 参数 描述 默认值 取值范围 ClearUpEnabled
配置文件和目录数量配额。 存储空间配额 配置当前租户使用的HDFS存储空间配额。 取值范围：当存储空间配额单位设置为MB时，范围为1～8796093022208。当存储空间配额单位设置为GB时，范围为1～8589934592。 此参数值表示租户可使用的HDFS存储空间上限，不代表一定使用了这么多空间。
证，如果是首次认证，需要输入默认密码，并修改密码： kinit hbase 如果集群未启用Kerberos认证（普通模式），则执行以下命令设置Hadoop用户名： export HADOOP_USER_NAME=hbase 执行以下命令创建一个HDFS中不存在的备份目录，例如“/tmp/hbase_bak”：
当发生故障，将另一个NameNode切换为活动状态时，缓存的详细信息将被更新为当前活动的NameNode的信息。 本章节适用于MRS 3.x及后续版本。 操作步骤 设置参数的路径如下： 在FusionInsight Manager页面中，选择“集群 > 服务 > HDFS > 配置”，选择“全部配置”，并在搜索框中输入参数名称。
rogramming-guide.html 配置自动广播阈值的方法： 在Spark的配置文件“spark-defaults.conf”中，设置“spark.sql.autoBroadcastJoinThreshold”的值。其中，<size>根据场景而定，但要求该值至少比其中一个表大。
对Kafka的性能调优，有以下几个点： 使用Kafka-0.8.2以后版本，可以使用异步模式的新Producer接口。 配置多个Broker的目录，设置多个IO线程，配置Topic合理的Partition个数。 详情请参见Kafka开源文档中的“性能调优”部分：http://kafka.apache
split(",").map(_.trim) assert(filePaths.length > 0) // windowTime设置窗口时间大小，默认2分钟一个窗口足够读取文本内的所有数据了 val windowTime = ParameterTool.fromArgs(args)
当发生故障，将另一个NameNode切换为活动状态时，缓存的详细信息将被更新为当前活动的NameNode的信息。 本章节适用于MRS 3.x及后续版本。 操作步骤 设置参数的路径如下： 在FusionInsight Manager页面中，选择“集群 > 服务 > HDFS > 配置”，选择“全部配置”，并在搜索框中输入参数名称。
在Mac应用中选择钥匙串访问。 “钥匙串”选择“登录”，“种类”选择“证书”。 将步骤3获得的证书拖动到钥匙串列表中。 双击证书将该证书设置为“始终信任”并关闭弹窗。 在出现的确认框中输入登录密码，此时在Chrome中即可访问MRS Manager。 父主题： 登录集群Manager常见异常问题
writer_open_rpc_timeout_sec”，参数值为RPC超时时间，默认值为“60”，可适当调大该参数值，例如，可将该参数值设置为“300”。 单击“实例”，勾选所有的BE实例，选择“更多 > 重启实例”，重启BE实例。 父主题： Doris常见问题
") val ssc = new StreamingContext(sparkConf, Seconds(5)) // 设置Streaming的CheckPoint目录 if (!"nocp".equals(checkPointDir)) {
服务名 产生告警的服务名称。 角色名 产生告警的角色名称。 主机名 产生告警的主机名。 附加信息 触发条件 系统当前指标取值满足自定义的告警设置条件。 对系统的影响 NameNode进入安全模式后，该NameNode不可写入。 可能原因 用户手动进入安全模式或重启NameNode时存在丢块。
产生告警的服务名称。 角色名 产生告警的角色名称。 主机名 产生告警的主机名。 Trigger Condition 系统当前指标取值满足自定义的告警设置条件。 对系统的影响 RegionServer RPC响应时间的P99超过阈值，会影响RegionServer对外提供服务的能力。对于时延
html。 代码样例 下面代码片段仅为演示，具体代码请参见获取样例代码解压目录中“hdfs-c-example/hdfs_test.c”文件。 设置HDFS NameNode参数，建立HDFS文件系统连接。 hdfsFS fs = hdfsConnect("default", 0); fprintf(stderr
码。 加强环境管理面账户密码管控，确保不泄露不扩散。 部分安全厂商已经提供了针对该漏洞的预防措施，您可联系对应的安全厂商，通过在安全设备上设置拦截规则来预防此类攻击。 父主题： MRS Fastjson漏洞修复指导
by的情况下使用having，会导致编译报错，版本间存在差异。因此，建议如下： 整改SQL命令，用where代替having规范使用。 Spark 2.4版本，设置参数“spark.sql.legacy.parser.havingWithoutGroupByAsWhere”的值为“true”。 父主题：
如下是代码片段，详细代码请参考com.huawei.bigdata.hdfs.examples中的HdfsExample类。 /** * 设置存储策略 * @param policyName * 策略名称能够被接受: * <li>HOT * <li>WARM
如下是代码片段，详细代码请参考com.huawei.bigdata.hdfs.examples中的HdfsExample类。 /** * 设置存储策略 * @param policyName * 策略名称能够被接受: * <li>HOT * <li>WARM
如下是代码片段，详细代码请参考com.huawei.bigdata.hdfs.examples中的HdfsExample类。 /** * 设置存储策略 * @param policyName * 策略名称能够被接受: * <li>HOT * <li>WARM
支持界面执行分区重新分配（基于生成的分区方案） 支持界面选择配置创建主题（支持多种Kafka版本集群） 支持界面删除主题（仅0.8.2版本并设置参数“delete.topic.enable = true”的集群支持） 支持批量生成多个主题的分区分配，并可选择要使用的分区方案 支持批量运行重新分配多个主题的分区
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
