检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
通过HBase shell命令查看应用程序运行情况。可参见“更多信息 > 对外接口 > Shell ”。 各样例程序运结果如下： 通过运行日志可查看应用提交后的执行详情，例如，hbase-example样例运行成功后，显示信息如下： 2280 [main] INFOcom.huawei.hadoop
卸载前请将此参数值改回“false”），将配置项“spark.inputFormat.cache.enabled”设置为“false”。 提交命令 假设用例代码打包后的jar包名为spark-hbaseContext-test-1.0.jar，并将jar包放在客户端“$SPARK
apache.org/confluence/display/Hive/HiveServer2+Clients。 指定租户 一般情况下，某用户提交的客户端会连接到该用户默认所属租户的JDBCServer上，若需要连接客户端到指定租户的JDBCServer上，可以通过添加--hiveconf
usters/{cluster_id}/sql-execution/{sql_id}/cancel mrs:sql:cancel √ √ 提交SQL语句 POST/v2/{project_id}/clusters/{cluster_id}/sql-execution mrs:sql:execute
根据安全需求，FlinkServer界面回显FlinkSQL时，SQL中的“password”字段将显示为空，在回显状态下需要将密码信息补齐后再提交作业。 本章节仅适用于MRS 3.2.0至MRS 3.3.1版本及集群，MRS 3.3.1及之后的版本请参考6.5.6-创建FlinkSe
百分比超过阈值 ALM-16052 MetaStore创建表时访问元数据库时延超过阈值 ALM-16053 Hive的HQL最近5分钟平均提交时间超过阈值 ALM-17003 Oozie服务不可用 ALM-17004 Oozie堆内存使用率超过阈值 ALM-17005 Oozie非堆内存使用率超过阈值
服务配置”中“templeton.protocol.type”配置。 mapreduce/streaming(POST) 描述 以Streaming方式提交MR任务 URL http://www.myserver.com/templeton/v1/mapreduce/streaming 参数 参数
异步Checkpoint机制程序 flink-dist_*.jar 可在Flink的客户端或者服务端安装路径的lib目录下获取。 使用Flink Jar提交SQL作业程序 FlinkServer REST API程序 flink-dist_*.jar flink-table_*.jar 可在F
创建一个新的python3任务，使用Spark读取文件。 图4 创建Python任务 登录到集群Manager界面，在Yarn的WebUI页面上查看提交的pyspark应用。 图5 查看任务运行情况 验证pandas库调用。 图6 验证pandas 对接Jupyter常见问题 pandas本地import使用时，报错如下：
applicationlist array application ID数组。 queue String application队列名称。 user String 提交application的用户名称。 resource_request object 当前所需要的资源，包括vcores、内存等。 resource_inuse
applicationlist array applicationID的数组。 queue String application队列名称。 user String 提交application的用户名称。 resource_request object 当前所需要的资源，包括vcores、内存等。 resource_inuse
applicationlist array application ID数组。 queue String application队列名称。 user String 提交application的用户名称。 resource_request object 当前所需要的资源，包括vcores、内存等。 resource_inuse
applicationlist array applicationID的数组。 queue String application队列名称。 user String 提交application的用户名称。 resource_request object 当前所需要的资源，包括vcores、内存等。 resource_inuse
wordCounts.print(); env.execute("Word Count Example"); 客户端层次 并行度可以在客户端将job提交到Flink时设定。对于CLI客户端，可以通过“-p”参数指定并行度。例如： ./bin/flink run -p 10 ../examp
定义 sql：DDL操作的SQL语句 def：表创建与表修改的结构定义 xid：事务唯一ID commit：数据增加/删除/修改操作是否已提交 父主题： Kafka常见问题
应用完成后将Container日志一次性收集到HDFS。 应用运行过程中周期性收集Container输出的日志片段到HDFS。 配置描述 参数入口： 参考修改集群服务配置参数进入Yarn服务参数“全部配置”界面，在搜索框中输入表1中参数名称，修改并保存配置。然后在Yarn服务“概览”页面选择“更多
定义 sql：DDL操作的SQL语句 def：表创建与表修改的结构定义 xid：事务唯一ID commit：数据增加/删除/修改操作是否已提交 父主题： Kafka常见问题
每一个主题，Kafka集群保留一个用于缩放、并行化和容错性的分区（Partition）。每个分区是一个有序、不可变的消息序列，并不断追加到提交日志文件。分区的消息每个也被赋值一个称为偏移顺序（Offset）的序列化编号。 图1 Kafka结构 操作流程 本实践操作流程如下所示：
填写角色的名称，例如developrole。 在“配置资源权限”的表格中选择“待操作集群的名称 > Yarn > 调度队列 > root”，勾选“default”的“提交”和“管理”，单击“确定”保存。 若在对数据库/表进行相关操作时指定了HDFS路径，需参考表2在Manager中给用户添加HDFS路径的相关权限。
update(RocksDBValueState.java:103) 通过开启火焰图（自定义配置rest.flamegraph.enabled=true打开火焰图）重新提交作业查看算子热点，如下图所示算子热点达到100%。 图1 通过火焰图查看算子热点 当发生RocksDB读写延迟大时，可开启RocksDB监
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
