统计方法,根据自己内部的数据结构统计内存的使用和分配 动态调整参数
- spark 如何计算自己占用内存的大小?
- 如何用 scala 实现 dataframe 添加自增序号列,并且将序号列放在第一列?
- spark-sql -f aa.sql 执行 sql 文件为什么文件开头报错就直接退出来了,不能全部执行?
- sparksqlselect.join.group 是会对应生成什么样的 rdd.再划分 stage 的?
- Spark DataFrame 筛选数据问题?
- spark 数据倾斜疑惑:shuffle.partitions 与 不同 key 个数 之间关系?
- SparkSql 读取 JSON 格式的数据,做两张表左外连接?
-
信息被删除或无权限查看
- spring boot 集成阿里云的 kafka 消息服务,无法读取 jks 文件?
- kafka 如何删除 topic?
-
信息被删除或无权限查看
- 如何缓解 Kafka 集群在有大量 topic 时性能快速劣化的问题?
- kafka topic 数据如何写入 hdfs?
- kafka 发布消息如何达到不重不漏?
- kafka 0.9 之后的版本如何获取 offset 用于计算出 lag 呢?