检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
History Server页面,用于展示已经完成的和未完成的Spark应用的运行情况。 页面包括了应用ID、应用名称、开始时间、结束时间、执行时间、所属用户等信息。单击应用ID,页面将跳转到该应用的SparkUI页面。 通过Spark日志获取应用程序运行情况。
cd /opt/client source bigdata_env kafka-console-consumer.sh --topic streams-wordcount-processor-output --bootstrap-server Broker实例IP地址:Kafka连接端口
History Server页面,用于展示已经完成的和未完成的Spark应用的运行情况。 页面包括了应用ID、应用名称、开始时间、结束时间、执行时间、所属用户等信息。单击应用ID,页面将跳转到该应用的SparkUI页面。 通过Spark日志获取应用程序运行情况。
cd /opt/client source bigdata_env kafka-console-consumer.sh --topic streams-wordcount-processor-output --bootstrap-server Broker实例IP地址:Kafka连接端口
cd /opt/client/Kafka/kafka/bin source /opt/client/bigdata_env sh kafka-console-consumer.sh --topic Topic名称 --bootstrap-server Broker角色实例所在节点的
cd ${BIGDATA_HOME}/om-server/om/tools 执行以下命令,更新集群密钥。 sh updateRootKey.sh 根据界面提示,输入y: The root key update is a critical operation.
cd ${BIGDATA_HOME}/om-server/om/sbin 执行以下命令,修改日志级别。 .
以omm用户登录主管理节点,执行以下命令更新域配置: sh ${BIGDATA_HOME}/om-server/om/sbin/restart-RealmConfig.sh 提示以下信息表示命令执行成功: Modify realm successfully.
进入“${BIGDATA_HOME}/om-server/om/sbin/”目录,然后执行.
zkCli.sh -server <任一ZooKeeper实例所在节点业务IP>:<clientPort> 执行以下命令删除无用数据。
将打包生成的jar包上传到Spark客户端所在服务器的任意目录(例如“ /opt” )下。
将打包生成的jar包上传到Spark客户端所在服务器的任意目录(例如“ /opt/female/” )下。
将打包生成的jar包上传到Spark客户端所在服务器的任意目录(例如“ /opt” )下。
将打包生成的jar包上传到Spark客户端所在服务器的任意目录(例如“ /opt” )下。
默认值:60s 取值范围:1~3600s proxy_connect_timeout 定义与代理服务器建立tcp连接的超时时间。使用数字和单位组合,m表示分钟,s表示秒。
IoTDBServer RPC端口可在参数“IOTDB_SERVER_RPC_PORT”中自行配置。
使用root用户在主备节点分别执行以下命令修改权限: cd ${BIGDATA_HOME}/FusionInsight_Porter_*/install/FusionInsight-Sqoop-1.99.3/FusionInsight-Sqoop-1.99.3/server/webapps
--bootstrap-server Kafka集群节点IP。获取方式如下: 登录FusionInsight Manager页面,选择“集群 > 服务 > Kafka > 实例”,查看Broker角色实例的业务IP地址。
--bootstrap-server Kafka集群节点IP。获取方式如下: 登录FusionInsight Manager页面,选择“集群 > 服务 > Kafka > 实例”,查看Broker角色实例的业务IP地址。
只有具有Tenant Administrator或同时具有Server Administrator、Tenant Guest、MRS Administrator角色才在MRS集群中拥有同步IAM用户的权限。