代码之家  ›  专栏  ›  技术社区  ›  lucky_start_izumi

需要在flink MapFunction中使用mysql连接

flink-streaming apache-flink
  •  0
  • lucky_start_izumi  · 技术社区  · 7 年前

    我们有一个flink任务,需要将kafka事件从type1转换为type2。但是在转换过程中,我需要调用querymysql来获取构造type2的附加信息。MysqlConnection是不可序列化的,有人能提出更好的方法吗?

    2 回复  |  直到 7 年前
        1
  •  0
  •   Georgy Gobozov    7 年前

    尝试使您的连接字段成为临时的,并在open方法或构造函数中初始化它。

        2
  •  0
  •   David Anderson    7 年前

    async i/o AsyncDatabaseRequest 例子。

    推荐文章
    关于   移动版
    代码之家 - 一站式码农服务社区
    沪ICP备11025650号