检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
elineServer HA来确保Yarn TimelineServer角色的高可用性。 TimelineServer会将数据保存到内存数据库LevelDB中,占用大量内存,安装TimelineServer的节点内存至少需要预留30GB。 该功能适用于MRS 3.2.0-LTS.1及之后版本。
insertTablet(单设备多行同列) > insertRecordsOfOneDevice (单设备多行不同列) > insertRecords(Object value) (多设备多行不同列) > insertRecords(String value) (多设备多行不同列) > insertRecord(单设备一行)
集群环境相对复杂,租户信息复杂,且要求将capacity调度器队列配置信息保留到Superior调度器,建议先执行模式1,将Capacity调度器配置信息转化成Superior配置信息,对转换过来的配置信息做检查后,再执行模式2,将Capacity调度器切换到Superior。 执行以下命令,将Capaci
delta_commits 选填 MOR表Compaction计划触发条件。 200 compaction.async.enabled 必填 是否开启在线压缩。将compaction操作转移到sparksql运行,提升写性能。 FALSE hive_sync.enable 选填 是否向Hive同步表信息。
常见概念名称 描述 云服务层 HetuEngine CLI/JDBC HetuEngine的客户端,使用者通过客户端向服务端提交查询请求,然后将执行结果取回并展示。 HSBroker HetuEngine的服务管理,用作计算实例的资源管理校验,健康监控与自动维护等。 HSConsole
aStore的方式,将全量元数据在Doris中呈现。 实时数据加载 对实时性要求较高的场景,可直接将实时流式数据通过FlinkSQL传入Doris中,在Doris中进行实时查询。如果数据在加载到Doris之前需要处理,可直接在FlinkSQL中进行数据加工,将加工后的数据实时写入Doris中。
对RDD中所有元素调用f方法,生成将满足条件数据集以RDD形式返回。 flatMap[U](f: (T) => TraversableOnce[U])(implicit arg0: ClassTag[U]): RDD[U] 先对RDD所有元素调用f方法,然后将结果扁平化,生成新的RDD。
对RDD中所有元素调用f方法,生成将满足条件数据集以RDD形式返回。 flatMap[U](f: (T) => TraversableOnce[U])(implicit arg0: ClassTag[U]): RDD[U] 先对RDD所有元素调用f方法,然后将结果扁平化,生成新的RDD。
ecurity-examples”中的OozieSparkHBaseExample和OozieSparkHiveExample样例工程。 将准备MRS应用开发用户时得到的keytab文件“user.keytab”和“krb5.conf”用户认证凭据文件复制到OozieSparkH
xml”文件中的<jar>标签和<spark-opts>标签路径一致。 src\main\resources\workflow.xml <jar> </jar> 将“OoizeSparkHBase-1.0.jar”修改成实际打包的jar包名称 <jar>${nameNode}/user/${userNa
xml”文件中的<jar>标签和<spark-opts>标签路径一致 src\main\resources\workflow.xml <jar> </jar> 将“OoizeSparkHBase-1.0.jar”修改成实际打包的jar包名称 <jar>${nameNode}/user/${userNa
ClickHouse集群规划 ClickHouse数据库设计 ClickHouse宽表设计 ClickHouse物化视图设计 ClickHouse逻辑视图设计 ClickHouse数据库开发 ClickHouse数据库调优 ClickHouse数据库运维
对RDD中所有元素调用f方法,生成将满足条件数据集以RDD形式返回。 flatMap[U](f: (T) => TraversableOnce[U])(implicit arg0: ClassTag[U]): RDD[U] 先对RDD所有元素调用f方法,然后将结果扁平化,生成新的RDD。
对RDD中所有元素调用f方法,生成将满足条件数据集以RDD形式返回。 flatMap[U](f: (T) => TraversableOnce[U])(implicit arg0: ClassTag[U]): RDD[U] 先对RDD所有元素调用f方法,然后将结果扁平化,生成新的RDD。
ecurity-examples”中的OozieSparkHBaseExample和OozieSparkHiveExample样例工程。 将准备MRS应用开发用户时得到的keytab文件“user.keytab”和“krb5.conf”用户认证凭据文件复制到OozieSparkH
Group”、“Select User”列选择已创建好的需要授予权限的Role、用户组或用户,单击“Add Conditions”,添加策略适用的IP地址范围,单击“Add Permissions”,添加对应权限。 submit-app:提交队列任务权限 admin-queue:管理队列任务权限
查看“附加信息”,获取告警附加信息。 告警附加信息中显示“CA Certificate”,以omm用户登录主OMS管理节点,执行2。 管理节点的主备状态及对应IP地址可在FusionInsight Manager主机管理界面查看。 告警附加信息中显示“HA root Certificate”,查看“定位
登录Oozie管理页面,查看运行情况。 使用oozieuser用户,登录Oozie WebUI页面:https://oozie角色的ip地址:21003/oozie 。 Oozie的WebUI界面中,可在页面表格根据jobid查看已提交的工作流信息。 父主题: 使用Oozie客户端提交作业
tion为“obs://obs-test/test/数据库名/表名”: create external table testspark(name string) location "obs://obs-test/test/数据库名/表名"; 配置Spark基于Hive MetaStore方式对接OBS:
待执行的SQL语句。目前仅支持执行单条语句,语句中不包含“;”。 约束限制: 不涉及 取值范围: 不涉及 默认取值: 不涉及 database 否 String 参数解释: 执行SQL所在的数据库。 约束限制: 不涉及 取值范围: 不涉及 默认取值: default archive_path 否 String