检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
在管理控制台选择页面上方的“费用 > 费用账单”,进入费用中心,在“账单管理”页面将生成如下三条账单信息: 按需:2023/06/18 15:00:00 ~ 2023/06/18 16:00:00,在15:29:16 ~ 16:00:00间产生费用 按需:2023/06/18 16
步骤2:准备样例程序和数据:创建OBS并行文件系统,并将Spark2x样例程序和样例数据上传到OBS并行文件系统中。 步骤3:创建作业:在MRS管理控制台创建SparkSubmit作业并运行。 步骤4:查看作业执行结果:作业执行完成后在OBS路径中获取日志文件并查看执行结果。
RetryingBlockFetcher.java:170) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run
JobManager Flink系统的管理节点,管理所有的TaskManager,并决策用户任务在哪些Taskmanager执行。JobManager在HA模式下可以有多个,但只有一个主JobManager。 Flink系统提供的关键能力: 低时延 提供ms级时延的处理能力。
名称> bin/kafka-topics.sh --describe --bootstrap-server <Kafka集群IP:21007> --command-config config/client.properties --topic <Topic名称> 删除Topic,由管理员用户操作
名称> bin/kafka-topics.sh --describe --bootstrap-server <Kafka集群IP:21007> --command-config config/client.properties --topic <Topic名称> 删除Topic,由管理员用户操作
检查系统中是否有不需要的文件。 以root用户登录HDFS客户端,用户密码为安装前用户自定义,请咨询系统管理员。执行cd命令进入客户端安装目录,然后执行source bigdata_env命令设置环境变量。 如果集群采用安全版本,要进行安全认证。
前提条件 系统管理员已明确业务需求,并准备一个Kafka管理员用户(属于kafkaadmin组)。 已安装Kafka客户端。 操作步骤 以客户端安装用户,登录安装Kafka客户端的节点。 切换到Kafka客户端安装目录,例如“/opt/kafkaclient”。
main(String[] args) throws IOException{ if (args.length < 1) { System.out.println("JavaHBaseDistributedScan {tableName}"); return
main(String[] args) throws IOException{ if (args.length < 1) { System.out.println("JavaHBaseDistributedScan {tableName}"); return
检查所有节点管理平面网络是否互通 登录FusionInsight Manager界面,选择“运维 > 告警 > 告警”。 查看当前集群是否存在“ALM-12089 节点间网络互通异常”或“节点故障”等告警。 是,节点间网络不互通,请联系运维人员修复。
因为操作系统用户组个数限制,导致Hive不能创建超过32个角色,开启此功能后,Hive将支持创建超过32个角色。 开启本功能并对表库等授权后,对表库目录具有相同权限的角色将会用“|”合并。查询acl权限时,将显示合并后的结果,与开启该功能前的显示会有区别。
以root用户登录HDFS客户端,用户密码为安装前用户自定义,请咨询系统管理员。执行cd命令进入客户端安装目录,然后执行source bigdata_env。 如果集群采用安全版本,要进行安全认证。 执行kinit hdfs命令,按提示输入密码。向MRS集群管理员获取密码。
登录主管理节点。 执行以下命令,查询当前HA管理的OLdap资源状态是否正常。
选择“系统设置 > 用户组管理 > 添加用户组”,为样例工程创建一个用户组,例如flinkgroup。选择“系统设置 > 用户管理 > 添加用户”,为样例工程创建一个用户。
进入该逻辑集群页面,选择“查询管理 > 已经结束的查询”页签。 界面的参数说明参考表1,过滤条件说明参考表2说明。 父主题: ClickHouse企业级能力增强
carbon.input.segments.default.carbon_table_MulTI_THread", "1,3"); 在多线程环境中使用CarbonSession.threadSet查询段示例如下(以Scala代码为例): def main(args: Array[String]) { Future
在MRS Manager界面选择“系统设置>用户管理>添加用户”,为样例工程创建一个用户。
登录MRS集群详情页面,选择“告警管理”。 选中“告警ID”为“43010”的告警,查看“定位信息”中的实例的IP地址及角色名。 单击“组件管理 > Spark > 实例 > JDBCServer(对应上报告警实例IP地址) > 定制 >JDBCServer进程的堆内存统计”。
图3 单击“Attempt ID”列的ID 图4 单击“Logs” 使用具有当前Flink作业的管理操作权限的用户登录Manager,选择“集群 > 服务 > Flink”,单击“Flink WebUI”后的链接,单击“作业管理”,在作业的“操作”列选择“更多 > 作业详情”也可查看