-
Manager日志清单 - MapReduce服务 MRS
<时间>.txt,web_service_access_log.<时间>.txt,catalina.log,gc-update-service.log.0.current,update-manager.controller,update-web-service.controller,update-web-service
-
HetuEngine常用数据源语法兼容性说明 - MapReduce服务 MRS
HetuEngine常用数据源语法兼容性说明 语法 Hive MPPDB Elasticsearch HBase HetuEngine(跨域) ClickHouse Hudi MySQL 数据库的show schemas Y Y Y Y Y Y Y Y 数据库的create schema
-
Presto JDBC使用样例 - MapReduce服务 MRS
authentication disabled cluster presto service port is 7520, Kerberos * authentication enabled cluster presto service port is 7521 * The
-
Kafka企业级能力增强 - MapReduce服务 MRS
Kafka企业级能力增强 配置Kafka高可用和高可靠 配置Kafka数据安全传输协议 配置Kafka数据均衡工具 父主题: 使用Kafka
-
Kafka运维管理 - MapReduce服务 MRS
Kafka运维管理 Kafka常用配置参数 Kafka日志介绍 更改Broker的存储目录 迁移Kafka节点内数据 均衡Kafka扩容节点后数据 父主题: 使用Kafka
-
Kafka企业级能力增强 - MapReduce服务 MRS
Kafka企业级能力增强 配置Kafka高可用和高可靠 配置Kafka数据安全传输协议 配置Kafka数据均衡工具 配置外网客户端访问Kafka Broker 父主题: 使用Kafka
-
由于Timeout waiting for task异常导致Shuffle FetchFailed - MapReduce服务 MRS
关闭ShuffleService功能,即在“Spark-defaults.conf”配置文件中将配置项“spark.shuffle.service.enabled”配置为“false”。 父主题: Spark Core
-
Flume业务模型配置说明 - MapReduce服务 MRS
Group中所有Sink都处于活跃状态,每个Sink都会从Channel中去获取数据并进行处理,并且保证在运行过程中该Sink Group的所有Sink的负载是均衡的,多用于性能提升场景。 Load Balancing配置样例: client.sources = source1 client.sinks
-
访问组件WebUI页面报500异常 - MapReduce服务 MRS
访问组件WebUI页面报500异常。 问题现象 访问组件WebUI页面报500异常。报错如下: HTTP ERROR 500 java.io.IOException: Service connectivity error. 原因分析 出现该异常可能都是由于Knox线程数不足。 处理步骤 以root用户分别登录OMS主节点和备节点。
-
浮动IP不通导致DBService备份失败 - MapReduce服务 MRS
添加DBService浮动IP到ListenAdress或者注释掉ListenAdress配置项。 执行如下命令重启sshd服务。 service sshd restart 观察下次备份DBServie是否备份成功。 父主题: 使用DBservice
-
Flink Kafka样例程序(Java) - MapReduce服务 MRS
91.8.218:21007 --security.protocol SASL_PLAINTEXT --sasl.kerberos.service.name kafka"); System.out.println("************************
-
如何避免对历史数据进行minor compaction? - MapReduce服务 MRS
因此这些segments将会被压缩。 加载增量负载。 配置minor compaction参数的阈值:“compaction.level.threshold” = “6,6”。 运行minor compaction。此时只考虑增量负载。 父主题: CarbonData常见问题
-
Hive服务启动失败 - MapReduce服务 MRS
host "192.168.0.146", database "HIVEMETA"。 编辑“/srv/BigData/dbdata_service/data/pg_hba.conf”,在文件最后面追加host hivemeta hive 0.0.0.0/0 sha256配置。 执行source
-
增加Hive表字段超时 - MapReduce服务 MRS
metastore.client.socket.timeout”为“3600s”。 出现另一个报错: Error: org.apache.hive.service.cli.HiveSQLException: Error while processing statement: FAILED: Execution
-
如何避免对历史数据进行minor compaction? - MapReduce服务 MRS
因此这些segments将会被压缩。 加载增量负载。 配置minor compaction参数的阈值:“compaction.level.threshold” = “6,6”。 运行minor compaction。此时只考虑增量负载。 父主题: CarbonData常见问题
-
Structured Streaming的cluster模式,在数据处理过程中终止ApplicationManager,应用失败 - MapReduce服务 MRS
| INFO | main | client token: Token { kind: YARN_CLIENT_TOKEN, service: } diagnostics: User class threw exception: org.apache.spark.sql
-
Structured Streaming的cluster模式,在数据处理过程中终止ApplicationManager,应用失败 - MapReduce服务 MRS
| INFO | main | client token: Token { kind: YARN_CLIENT_TOKEN, service: } diagnostics: User class threw exception: org.apache.spark.sql
-
DBService日志介绍 - MapReduce服务 MRS
[<产生该日志的脚本名称:行号>]: <log中的message> [2020-12-19 15:56:42] INFO [postinstall.sh:653] Is cloud flag is false. (main) 审计日志 [<yyyy-MM-dd HH:mm:ss,SSS>] UserName:<用户名称>
-
beeline客户端报错“OutOfMemoryError” - MapReduce服务 MRS
at org.apache.hive.service.cli.thrift.TCLIService$Client.recv_FetchResults(TCLIService.java:505) at org.apache.hive.service.cli.thrift.TCLIService$Client
-
Flink Join样例程序(Scala) - MapReduce服务 MRS
xxx:21007 --security.protocol SASL_PLAINTEXT" + " --sasl.kerberos.service.name kafka") System.out.println("**************************