240 发简信
IP属地:北京
  • 此简书博客不再在简书更新

    改版后的简书,变的越来越像 CSDN。 博客已迁移到 Github Pages - https://ohmysummer.github.io。 ...

  • the NTP socket is in use, exiting

    CDH 时钟偏差,将 nn02 的时钟同步为 nn01: 显示 socket 已被使用, 因为 ntpd 服务正在运行,先停掉再同步一次:

  • 广播变量

    从 mysql 读取数据作为广播变量时, 虽然有 checkpoint 但是 kill 掉任务后,重启程序会失败。

  • UTFDataFormatException

    https://stackoverflow.com/questions/41505599/task-not-serializable-in-sp...

  • This is because the DStream object is being referred to from within the closure

    昨天把项目代码重新整合了一下, 然后就报错了: 原因可能是 mysql 数据库配置的序列化问题: 但是我已经这么序列化了。 我在类里面添加了 M...

  • 用 parquet 数据模拟实时数据流

    用 parquet 数据模拟实时数据流 再将 JSON 数据逐行发到 Kafka 的不同 topic:

  • 使用 comb 过滤多个字段

    假设有如下数据: 要得到这样的结果: 使用 comb 很容易把你感兴趣的字段像梳子一样给梳下来: