检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
s/map-reduce Java任务 客户端安装目录/Oozie/oozie-client-*/examples/apps/java-main Shell任务 客户端安装目录/Oozie/oozie-client-*/examples/apps/shell Streaming任务
的HiveServerAudit日志，下载的“开始时间”和“结束时间”分别为告警产生时间的前后10分钟。打开日志文件查找“Result=FAIL”关键字筛选执行错误语句的日志信息，再根据日志信息中的“UserName”查看执行错误语句的用户。 输入正确的HQL语句，观察命令是否正确执行。
x及之后版本）。 选择“集群 > 待操作集群的名称 > 概览 > 更多 > 下载客户端”。 下载集群客户端。 “选择客户端类型”选择“仅配置文件”，选择平台类型，单击“确定”开始生成客户端配置文件，文件生成后默认保存在主管理节点“/tmp/FusionInsight-Client/”。 登录Manager的主管理节点。
class FemaleInfo(name: String, gender: String, stayTime: Int) def main(args: Array[String]) { if (args.length < 1) { printUsage
zookeeperDefaultServerPrincipal = "zookeeper/hadoop." + KerberosUtil.getKrb5DomainRealm().toLowerCase(); LoginUtil.setZookeeperServerPrincipal
志收集到HDFS上以后由HistoryServer来进行统一的日志管理。LogAggregationService在收集日志时会把container产生的本地日志合并成一个日志文件上传到HDFS，在一定程度上可以减少日志文件的数量。但在规模较大且任务繁忙的集群上，经过长时间的运行
“权重”：在发生资源抢占时，权重越大则会优先抢占资源。（MRS 3.5.0之前版本） “优先级”：在发生资源抢占时，优先级越高则会优先抢占资源，但不确保所有的Container都会被启动。（MRS 3.5.0及之后版本） “最多核数”：表示用户最多可以使用的虚拟核数。 “最大内存”：表示用户最大可以使用的内存。
properties”文件，并放置到样例工程的conf下，即“hive-examples/conf”，即可在开发环境中（例如Eclipse中），右击“ExampleMain.java”，单击“Run as > Java Application”运行对应的应用程序工程。 使用windows访问MRS集群来操作Hive，有如下两种方式。
Base64.getEncoder().encodeToString(tokens); } public static void main(String[] args) throws SQLException { // set iotdb_ssl_enable
选择“集群 > 服务 > Kafka > 配置”，在搜索框中搜索“sasl.enabled.mechanisms”，为该参数值增加“PLAIN”，单击“保存”保存配置，并重启Kafka服务使配置生效： 再在CDL WebUI界面配置使用MRS Kafka作为源端的thirdpa
修改物化视图属性或状态 表的Alter权限 NA NA 使用物化视图重写查询语句 NA NA 对应列的查询权限 使用物化视图重写查询语句的执行计划（EXPLAIN） NA 对应列的查询权限 对应列的查询权限 查询物化视图 对应列的查询权限 NA NA 物化视图和非物化视图的物理表联合查询 对应列的查询权限
开启Kerberos认证集群开启“enable.advertised.listener”配置后，客户端只支持使用Kerberos认证，不支持使用Plain认证。 参数“advertised.broker.id.port.map”与参数“actual.broker.id.port.map”中的“Port”可以配置为相同端口。
-XX:+CMSParallelRemarkEnabled -XX:CMSInitiatingOccupancyFraction=65 -XX:+PrintGCDetails -Dsun.rmi.dgc.client.gcInterval=0x7FFFFFFFFFFFFFE -Dsun.rmi.dgc.server
'kafka', 'properties.security.protocol' = 'SASL_PLAINTEXT', 'properties.kerberos.domain.name' = 'hadoop.系统域名' ); CREATE TABLE cksink ( `pid`
若一个Store内的HStoreFile文件数量超过指定值，则针对此HRegion的更新将被锁定直到一个压缩完成或者base.hstore.blockingWaitTime被超过。每冲洗一次MemStore一个StoreFile文件被写入。在put高负载场景下可以适当调大。 15 Scan相关参数 表2
进程将会同时访问一个磁盘。这将会导致磁盘的IO性能非常低下。为了改善磁盘的性能，请确保客户端并发访问磁盘的数不大于3。 最大并发的container数量应该为[2.5 * Hadoop中磁盘配置数 ]。 mapreduce.map.memory.mb 参数解释：map任务的内存限制。单位：MB。
times 尝试连接服务端的最大次数。如果设置为负数或零，客户端将不会重新尝试连接服务端。 5 spark.thriftserver.retry.wait.time 重连服务端时的尝试时间间隔，单位秒。 10 表1中的参数应配置在客户端classpath下的“hive-site.xml”文件中，例：
进程将会同时访问一个磁盘。这将会导致磁盘的IO性能非常低下。为了改善磁盘的性能，请确保客户端并发访问磁盘的数不大于3。 最大并发的container数量应该为[2.5 * Hadoop中磁盘配置数 ]。 mapreduce.map.memory.mb 说明： 需要在客户端进行配置
如果一个Store内的HStoreFile文件数量超过指定值，则针对此HRegion的更新将被锁定直到一个压缩完成或者“base.hstore.blockingWaitTime”被超过。每冲洗一次MemStore一个StoreFile文件被写入。在Put高负载场景下可以适当调大。 15 Scan相关参数
insert、update、delete dbName Alias pgsqldb Schema pgschema Slot Name pg_slot Enable FailOver Slot 否 Slot Drop 否 Connect With Hudi 是 Use Exist Publication 否 Publication
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
