- 一个基于pySpark的简单nlp样例 一个基于pySpark的简单nlp样例
- 本文主要解析介绍Hive虚拟列INPUT__FILE__NAME相关源码 本文主要解析介绍Hive虚拟列INPUT__FILE__NAME相关源码
- 本文主要解析介绍Hive虚拟列相关源码 本文主要解析介绍Hive虚拟列相关源码
- 问题描述Flink业务一般在运行过程中默认加载的jar包路径为：xxx/Flink/flink/lib的目录下，如果添加其它路径的jar包会报错，如何添加其它外部依赖解决方案创建一个外部的lib目录，将部分依赖包放到外部lib目录下，如下图： 2. 修改启动脚本的参数配置脚本，sh将jar包路径传给环境变量中 3. 此时正常启动任务即可， 不需要加-C参数 HDFS上也能看到第三... 问题描述Flink业务一般在运行过程中默认加载的jar包路径为：xxx/Flink/flink/lib的目录下，如果添加其它路径的jar包会报错，如何添加其它外部依赖解决方案创建一个外部的lib目录，将部分依赖包放到外部lib目录下，如下图： 2. 修改启动脚本的参数配置脚本，sh将jar包路径传给环境变量中 3. 此时正常启动任务即可， 不需要加-C参数 HDFS上也能看到第三...
- 1.Flink对接kafka出现数据倾斜问题现象使用FlinkKafkaProducer进行数据生产过程中数据只写到了kafka的部分分区中，其它的分区没有数据写入。可能原因1：Flink写kafka使用的机制与原生接口的写入方式是有差别的，在默认情况下，Flink使用了并行度编号和分区数量做取模运算计算出来。那么会有以下两种场景： 1. 并行度%分区数量=0，表示并行度是kafk... 1.Flink对接kafka出现数据倾斜问题现象使用FlinkKafkaProducer进行数据生产过程中数据只写到了kafka的部分分区中，其它的分区没有数据写入。可能原因1：Flink写kafka使用的机制与原生接口的写入方式是有差别的，在默认情况下，Flink使用了并行度编号和分区数量做取模运算计算出来。那么会有以下两种场景： 1. 并行度%分区数量=0，表示并行度是kafk...
- 1.Flink架构（图-1 Flink Runtime 来自：https://ci.apache.org/projects/flink/flink-docs-release-1.6/concepts/runtime.html）2.基本原理2.1 JobmanagerJobManager（下称为JM）负责整个Flink集群任务的调度以及资源的管理，从客户端中获取提交的应用，然后根据集群中的ta... 1.Flink架构（图-1 Flink Runtime 来自：https://ci.apache.org/projects/flink/flink-docs-release-1.6/concepts/runtime.html）2.基本原理2.1 JobmanagerJobManager（下称为JM）负责整个Flink集群任务的调度以及资源的管理，从客户端中获取提交的应用，然后根据集群中的ta...
- 最近经常有人问到，map阶段container运行时怎么找到具体Task运行的JVM进程1.首先在任务页面点击map，点击log，可以找到对应的containerID2.在map界面，找到container运行的主机节点3.去相应的节点执行ps -ef|grep container_e02_1568949488640_0036_01_000002可以看出，结果有三个进程，那么哪个是对应执行t... 最近经常有人问到，map阶段container运行时怎么找到具体Task运行的JVM进程1.首先在任务页面点击map，点击log，可以找到对应的containerID2.在map界面，找到container运行的主机节点3.去相应的节点执行ps -ef|grep container_e02_1568949488640_0036_01_000002可以看出，结果有三个进程，那么哪个是对应执行t...
- 首先本篇不是讲数据被删除后如何恢复，而是讲表目录被删除，而表异常的处理方法误操作：删除hbase表，有的人不按照正常的处理方式（在hbase shell 先disable 再drop），而是直接在hbase目录下删除表目录的错误做法此种做法导致，shell中list能查到此表，实际上scan会报错，并且重启hbase后会导致region无法上线处理步骤：1.在任意RegionServer的目... 首先本篇不是讲数据被删除后如何恢复，而是讲表目录被删除，而表异常的处理方法误操作：删除hbase表，有的人不按照正常的处理方式（在hbase shell 先disable 再drop），而是直接在hbase目录下删除表目录的错误做法此种做法导致，shell中list能查到此表，实际上scan会报错，并且重启hbase后会导致region无法上线处理步骤：1.在任意RegionServer的目...
- 本文介绍如何使用永洪bi对接华为FusionInsight MRS ClickHouse 本文介绍如何使用永洪bi对接华为FusionInsight MRS ClickHouse
- 本文介绍如何使用永洪bi对接华为FusionInsight MRS HetuEngine 本文介绍如何使用永洪bi对接华为FusionInsight MRS HetuEngine
- 在服务器中，http 服务是最常用的。服务端：package mainimport ( "fmt" "net/http")func main() { http.HandleFunc("/go", myHandler) http.ListenAndServe("127.0.0.1:8000", nil)}func myHandler(w http.ResponseWriter, r *http... 在服务器中，http 服务是最常用的。服务端：package mainimport ( "fmt" "net/http")func main() { http.HandleFunc("/go", myHandler) http.ListenAndServe("127.0.0.1:8000", nil)}func myHandler(w http.ResponseWriter, r *http...
- 7月29日，在2021中国大数据生态产业大会上，由大数据产业生态联盟联合赛迪顾问共同完成的《2021中国大数据产业发展白皮书》正式发布，同时基于白皮书调研结果，组委会权威揭晓“2021中国大数据企业50强”榜单，华为大数据连续六年上榜。这也是业界对华为云FusionInsight在大数据领域持续技术创新、实践应用等方面成绩的再度肯定。 7月29日，在2021中国大数据生态产业大会上，由大数据产业生态联盟联合赛迪顾问共同完成的《2021中国大数据产业发展白皮书》正式发布，同时基于白皮书调研结果，组委会权威揭晓“2021中国大数据企业50强”榜单，华为大数据连续六年上榜。这也是业界对华为云FusionInsight在大数据领域持续技术创新、实践应用等方面成绩的再度肯定。
- Kafka内核对于请求处理各个环节都打了断点，通过断点可以清楚的看到，服务在处理请求各个阶段的耗时，继而指导服务端性能优化。通过Request类，可以详细查看服务端如何计算请求处理各个阶段耗时：// RequstChannel#Requestclass Request(val processor: Int, val context: RequestContext, ... Kafka内核对于请求处理各个环节都打了断点，通过断点可以清楚的看到，服务在处理请求各个阶段的耗时，继而指导服务端性能优化。通过Request类，可以详细查看服务端如何计算请求处理各个阶段耗时：// RequstChannel#Requestclass Request(val processor: Int, val context: RequestContext, ...
- 关系数据库的数据入湖，有多种场景、多种工具、多种入湖时效要求等，本文梳理相关场景，以及对应的建议方案。 关系数据库的数据入湖，有多种场景、多种工具、多种入湖时效要求等，本文梳理相关场景，以及对应的建议方案。
- 大数据集群的物理机部署形态，相对于公有云/混合云的云主机部署形态，在自动化发放集群、弹性伸缩等云化场景方面处于劣势，但物理机部署形态的大数据集群能够更加充分高效的利用服务器资源，不存在云化/虚拟化的开销，同时服务器的异构能力更强。 早期交付的很多大数据集群均是物理机部署形态。 针对这些存量大数据集群，以下介绍一种自动化运维管理办法，来提升运维效率、集群资源利用率，降低集群的资源消耗。 大数据集群的物理机部署形态，相对于公有云/混合云的云主机部署形态，在自动化发放集群、弹性伸缩等云化场景方面处于劣势，但物理机部署形态的大数据集群能够更加充分高效的利用服务器资源，不存在云化/虚拟化的开销，同时服务器的异构能力更强。 早期交付的很多大数据集群均是物理机部署形态。 针对这些存量大数据集群，以下介绍一种自动化运维管理办法，来提升运维效率、集群资源利用率，降低集群的资源消耗。
上滑加载中
推荐直播
-
HDC深度解读系列 - Serverless与MCP融合创新，构建AI应用全新智能中枢2025/08/20 周三 16:30-18:00
张昆鹏 HCDG北京核心组代表
HDC2025期间，华为云展示了Serverless与MCP融合创新的解决方案，本期访谈直播，由华为云开发者专家(HCDE)兼华为云开发者社区组织HCDG北京核心组代表张鹏先生主持，华为云PaaS服务产品部 Serverless总监Ewen为大家深度解读华为云Serverless与MCP如何融合构建AI应用全新智能中枢
回顾中 -
关于RISC-V生态发展的思考2025/09/02 周二 17:00-18:00
中国科学院计算技术研究所副所长包云岗教授
中科院包云岗老师将在本次直播中，探讨处理器生态的关键要素及其联系，分享过去几年推动RISC-V生态建设实践过程中的经验与教训。
回顾中 -
一键搞定华为云万级资源，3步轻松管理企业成本2025/09/09 周二 15:00-16:00
阿言 华为云交易产品经理
本直播重点介绍如何一键续费万级资源，3步轻松管理成本，帮助提升日常管理效率！
回顾中
热门标签