检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
告警”,进入ZooKeeper服务概览页面,查看ZooKeeper服务是否故障。 是,执行2。 否,执行4。 根据ZooKeeper出现的相关报错信息和告警信息,参考对应的ZooKeeper帮助文档解决ZooKeeper故障问题。 当ZooKeeper服务正常后,等待60s观察告警是否消失。
TableName tableName = null; private Connection conn = null; public HBaseSample(Configuration conf) throws IOException { this.tableName
Consumer API线程run方法中的消费逻辑。 /** *启动执行Consumer,订阅Kafka上指定topic消息。 */ public void run() { LOG.info("Consumer: start."); Map<String, Integer>
TableName tableName = null; private Connection conn = null; public HBaseSample(Configuration conf) throws IOException { this.tableName
以下代码片段在com.huawei.bigdata.hbase.examples包的“HBaseSample”类的testModifyTable方法中 public void testModifyTable() { LOG.info("Entering testModifyTable.");
准备MapReduce应用开发环境 准备MapReduce开发和运行环境 导入并配置MapReduce样例工程 (可选)创建MapReduce样例工程 配置MapReduce应用安全认证 父主题: MapReduce开发指南(安全模式)
准备ClickHouse应用开发环境 准备ClickHouse应用开发和运行环境 导入并配置ClickHouse样例工程 导入并配置ClickHouse事务样例工程 导入并配置ClickHouse springboot样例工程 父主题: ClickHouse开发指南(安全模式)
MRS用户无法同步至Ranger管理界面 问题 在MRS Manager界面创建了一个账户,在Ranger管理界面无法查看到该用户,重启UserSync后,可以查看到该用户。 回答 需要修改UserSync进程的GC内存默认为“-Xms1G -Xmx1G”,需要根据业务实际情况调整该参数值:
Array[String]) { //配置Spark应用名称 val sparkConf = new SparkConf().setAppName("FemaleInfo") val sc = new SparkContext(sparkConf) val sqlContext
//配置Spark应用名称 val spark = SparkSession .builder() .appName("FemaleInfo") .config("spark.some.config.option", "some-value")
// clean和archive按时间策略执行 call run_table_service(table => 'hudi_table', clean_hours_retained => 1, archive_hours_retained => 1) // clean和archive按commits策略执行
6的补丁中修复,也可通过在MRS Manager页面给同步的提交作业用户赋予该目录“/mrs/job-properties”的写入权限进行处理。 父主题: 作业管理类
Connection reset by peer。 答: 修改作业提交参数,加上参数“executor.memoryOverhead”。 父主题: 作业管理类
SELECT查询表数据 ALTER TABLE修改表结构 ALTER TABLE修改表数据 DESC查询表结构 DROP删除表 SHOW显示数据库和表信息 父主题: 使用ClickHouse
//配置Spark应用名称 val spark = SparkSession .builder() .appName("FemaleInfo") .config("spark.some.config.option", "some-value")
UI页面无法跳转到Spark Web UI界面 HistoryServer缓存的应用被回收,导致此类应用页面访问时出错 加载空的part文件时,app无法显示在JobHistory的页面上 Spark导出带有相同字段名的表,结果导出失败 为什么多次运行Spark应用程序会引发致命JRE错误
--password 输入用户密码 ClickHouse实例IP获取方式:在集群详情页面,选择“组件管理 > ClickHouse > 实例”,获取ClickHouse的IP地址。 父主题: ClickHouse运维管理
retainedDeadExecutors Spark UI页面显示的Lost Executor的最大个数。 100 父主题: Spark运维管理
conf并设置相关认证属性即可。详情可参考样例工程com.huawei.bigdata.kafka.example.security包的Producer中认证样例代码。 public static Properties initProperties() { ............ props.put("sasl
组件数据库用户密码字符长度为8~32。 至少需要包含大写字母、小写字母、数字、特殊字符~`!@#$%^&*()-+_=\|[{}];",<.>/?中的3种类型字符。 不可和用户名相同或用户名的倒序字符相同。 不可与前20个历史密码相同。 勾选“我已阅读此信息并了解其影响”,单击“确定”。 密码修改完成后,选择“更多