检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
息页面。 在“节点管理”页签单击Master节点组中某一Master节点名称，登录到弹性云服务器管理控制台。 单击右上角的“远程登录”。 根据界面提示，输入Master节点的用户名和密码。 创建集群时登录方式选择了“密码”，如图1。此时，你需要输入的用户名、密码分别是root和创建集群时设置的密码。
”页面。 节点类型选择“Task”，“部署角色”参数默认选择“NM”部署NodeManager角色，则新增节点组为Task节点组，其他参数根据需要配置。 图1 添加Task节点组 非“自定义”类型集群添加Task节点操作步骤： 在集群详情页面，选择“节点管理”页签，单击“配置Ta
用户创建成功后，使用该用户登录FusionInsight Manager，根据界面提示修改初始密码。 获取样例工程 通过开源镜像站获取样例工程。 下载样例工程的Maven工程源码和配置文件，并在本地配置好相关开发工具，可参考通过开源镜像站获取样例工程。 根据集群版本选择对应的分支，下载并获取MRS相关样例工程。
写入失败。 图2 基于QJM的HDFS架构 HDFS可靠性 MRS使用HDFS的副本机制来保证数据的可靠性，HDFS中每保存一个文件则自动生成1个备份文件，即共2个副本。HDFS副本数可通过“dfs.replication”参数查询。 当MRS集群中Core节点规格选择为非本地盘
scala shell启动脚本 sh generate_keystore.sh - 用户调用“generate_keystore.sh”脚本工具生成“Security Cookie”、“flink.keystore”和“flink.truststore”。需要输入自定义密码（不能包含#）。
kafkaParams); //用brokers and topics新建direct kafka stream //从Kafka接收数据并生成相应的DStream。 JavaInputDStream<ConsumerRecord<String, String>> messages
override def cancel(): Unit = { running = false } } } 生成Table1和Table2，并使用Join对Table1和Table2进行联合查询，打印输出结果。 object SqlJoinWithSocket
scala shell启动脚本 sh generate_keystore.sh - 用户调用“generate_keystore.sh”脚本工具生成“Security Cookie”、“flink.keystore”和“flink.truststore”。需要输入自定义密码（不能包含#）。
le样例工程的“com.huawei.bigdata.hbase.examples”包的“HBaseRestTest”类中。 代码认证 请根据实际情况，修改“principal”为实际用户名，例如“developuser”。 //In Windows environment
FSGet继承自org.apache.hadoop.hbase.Get，新增如下接口 方法 说明 public FSGet(byte[] row) 构造函数。根据rowkey构造对象。 public void addFile(String fileName) 指定需要返回的文件。 public void
Execution,Deployment > Maven”，选择Maven home directory为本地安装的Maven版本。 然后根据实际情况设置好“User settings file”和“Local repository”参数，依次单击“Apply > OK”。 图13
heap中，当维表过大时heap中保存的维表数据过多，TM会不断GC导致作业性能下降。 流流关联中不能加入批Source算子 流流关联中不能加入批Source算子，根据业务情况将该Source算子调整为维表算子。 父主题： Flink SQL逻辑开发规范
info: *** 是，执行4。 否，执行7。 在FusionInsight Manager管理界面，选择“运维 >备份恢复 > 备份管理”。根据“任务名”查找对应备份任务，单击“操作”列的“配置”，检查配置项是否都配置正确。 是，执行7。 否，修改配置后保存，执行5。 选择“更多 >
Manager首页，选择“集群 > 待操作集群的名称 > 服务 > Yarn > 配置 > 全部配置 > NodeManager > 系统”。将“GC_OPTS”参数根据实际情况调大。 集群中的NodeManager实例数量和NodeManager内存大小的对应关系参考如下： 集群中的NodeManager
> 待操作集群的名称 > 服务 > Yarn > 配置 > 全部配置 > NodeManager > 系统”。将“GC_OPTS”参数的值根据实际情况调大。保存配置，并重启NodeManager实例。 NodeManager重启过程中，提交到该节点的Container可能会重试到其他节点。
> 配置”，单击“全部配置”，选择“JobHistory2x > 默认”，将“SPARK_DAEMON_MEMORY”参数的默认值为4G，可根据如下原则进行调整：若偶现告警，可以按0.5倍速率调大。若告警次数比较频繁，可以按1倍速率调大。 重启所有的JobHistory2x实例。
相邻2条数据的时间间隔，超过该时间间隔，OVER注册超期触发器，单位毫秒。 -1：不开启该功能。 0：每条数据都会注册超期触发器，但会加大对作业的压力，根据作业的具体情况可以适当调大over.window.interval间隔。 正数：相邻2条数据的时间间隔，超过该时间间隔，OVER注册超期触发器。
n的String格式，无需编写中间的执行代码，减少了代码编写量，简化了用户执行各类操作的步骤。 以上接口会返回请求对应的命令编号，方便用户根据命令编号查询命令执行的进度。 父主题： Manager应用开发常见问题
le样例工程的“com.huawei.bigdata.hbase.examples”包的“HBaseRestTest”类中。 代码认证 请根据实际情况，修改“principal”为实际用户名，例如“developuser”。 在Windows环境下和Linux环境下请使用对应的路径获取方式。
refused则表示失败，无法连接到相关端口。 如果相关端口打开，但是从别的节点无法连通到该端口，则需要排查下相关网络配置。 23662这个端口每次都是随机的，所以要根据自己启动任务打开的端口来测试。 父主题： 使用Spark
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
