- Flink 消费 kafka 数据时,LAG 堆积严重?
- 注册类时同时跑代码还是串行跑?
- spark-submit 提交代码报错?
- 怎么给 hive 表 str 类型的 uid 映射成数值类型的唯一编号?
- flink 窗口消费 kafak 的数据 为什么数据能标准输出到控制台上,但是出不来 设置的时间窗口 60 秒?
- flink 消费 kafka 的数据存入 MySQL,怎么检验存入 MySQL 数据的正确性?
- 解析多层 JSON 嵌套数据的时候,某些字段混有 “” {}导致解析失败?
- flink Linux 上运行抱错?
- 本地跑 MR,配置都是为集群的,突然连不上?
- flume 往 hdfs 写日志时报错?
- Linux 上运行 python 脚本,模块都有,还报找不到模块的错误?
- 使用 hiveconf 传参时出现路劲错误问题?