-
Flink Kafka样例程序(Java) - MapReduce服务 MRS
91.8.218:21007 --security.protocol SASL_PLAINTEXT --sasl.kerberos.service.name kafka"); System.out.println("************************
-
Flink向Kafka生产并消费数据Java样例代码 - MapReduce服务 MRS
91.8.218:21007 --security.protocol SASL_PLAINTEXT --sasl.kerberos.service.name kafka"); System.out.println("*************************
-
Flink SQL语法增强 - MapReduce服务 MRS
'latest-offset', 'format' = 'csv', 'properties.sasl.kerberos.service.name' = 'kafka', 'properties.security.protocol' = 'SASL_PLAINTEXT'
-
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
-
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
-
查看Manager应用调测结果 - MapReduce服务 MRS
"createTime":"2020-10-15T19:16:37+08:00","defaultUser":false,"primaryGroup":"elasticsearch","locked":false,"userRoles":["System_administrator"],"indepdtType":"NONE"
-
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
-
如何避免对历史数据进行minor compaction? - MapReduce服务 MRS
因此这些segments将会被压缩。 加载增量负载。 配置minor compaction参数的阈值:“compaction.level.threshold” = “6,6”。 运行minor compaction。此时只考虑增量负载。 父主题: CarbonData常见问题
-
如何避免对历史数据进行minor compaction? - MapReduce服务 MRS
因此这些segments将会被压缩。 加载增量负载。 配置minor compaction参数的阈值:“compaction.level.threshold” = “6,6”。 运行minor compaction。此时只考虑增量负载。 父主题: CarbonData常见问题
-
Flink Join样例程序(Java) - MapReduce服务 MRS
91.8.218:21007 --security.protocol SASL_PLAINTEXT --sasl.kerberos.service.name kafka"); System.out.println("**********************
-
Flink Join样例程序(Scala) - MapReduce服务 MRS
xxx:21007 --security.protocol SASL_PLAINTEXT" + " --sasl.kerberos.service.name kafka") System.out.println("**************************
-
Flink Join样例程序(Scala) - MapReduce服务 MRS
xxx:21007 --security.protocol SASL_PLAINTEXT" + " --sasl.kerberos.service.name kafka") System.out.println("**************************
-
Flink Join样例程序(Java) - MapReduce服务 MRS
91.8.218:21007 --security.protocol SASL_PLAINTEXT --sasl.kerberos.service.name kafka"); System.out.println("**********************
-
执行Kafka Topic删除操作时提示“AdminOperationException” - MapReduce服务 MRS
principal: test@HADOOP.COM Valid starting Expires Service principal 01/25/17 11:06:48 01/26/17 11:06:45 krbtgt/HADOOP.COM@HADOOP
-
配置审计日志导出参数 - MapReduce服务 MRS
必选参数,用户的Access Key ID。 SK XXX(举例) 必选参数,用户的Secret Access Key。 审计日志在OBS的存储路径细分为service_auditlog和manager_auditlog,分别用于存储服务审计日志和管理审计日志。 父主题: 日志管理
-
HDFS应用开发建议 - MapReduce服务 MRS
HDFS中数据的备份数量3份即可 DataNode数据备份数量3份即可,增加备份数量不能提升系统效率,只会提升系统数据的安全系数;在某个节点损坏时,该节点上的数据会被均衡到其他节点上。 HDFS定期镜像备份 NameNode的镜像备份参数为“fs.namenode.image.backup.enable”,
-
Flink Join样例程序(Java) - MapReduce服务 MRS
91.8.218:21007 --security.protocol SASL_PLAINTEXT --sasl.kerberos.service.name kafka"); System.out.println("**********************
-
Flink Join样例程序(Java) - MapReduce服务 MRS
91.8.218:21007 --security.protocol SASL_PLAINTEXT --sasl.kerberos.service.name kafka"); System.out.println("***********************
-
有210000个map和10000个reduce的HBase BulkLoad任务运行失败 - MapReduce服务 MRS
eerType=observer来增加observer的数目。 通过控制单个任务并发的map数或减少每个节点下运行task的内存,降低节点负载。 升级ZooKeeper数据磁盘,如SSD等。 父主题: HBase故障排除