postgresql - Postgres 通过 Apache Beam 写入

Question

当尝试通过 Apache Beam 写入 postgres 时，我得到了
java.io.NotSerializableException: org.postgresql.jdbc.PgConnection.

正如文档中所建议的，我正在使用此代码，JdbcIO.DataSourceConfiguration.create("org.postgresql.Driver",connectionUrl);

我可以从 postgres 表中读取数据，但 write 抛出此错误，write 使用相同的配置。有什么建议么 ？

标签： postgresqlapache-beam