代码之家 › 专栏 › 技术社区 › 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 例子。