ApacheBeamWriteToJdbc:java.lang.IllegalArgumentException:未知的CoderURNbeam:coder:pickled_python:v1
创始人
2024-09-05 12:00:31
0

这个问题通常出现在一个使用Python编写的Apache Beam管道尝试将数据写入JDBC数据库时。根据错误消息,似乎是因为写入到JDBC的数据使用了不支持的编码器(pickled_python)。要解决这个问题,您可以通过在管道中指定一种支持的编码器来更改编码器。

例如,如果您正在使用的是Avro格式,在WriteToJdbc()之前添加此代码行即可更改编码器:

from apache_beam.io.jdbc import WriteToJdbc
from apache_beam.coders.coders import AvroCoder

...
| 'Write to JDBC' >> WriteToJdbc(
  table='my_table',
  jdbc_driver_name='com.mysql.jdbc.Driver',
  jdbc_driver_url='jdbc:mysql://localhost/my_db',
  username='root',
  password='',
  coder=AvroCoder())

在本示例中,我们使用Avro编码器代替默认编码器(即pickled_python),从而解决了异常。

相关内容

热门资讯

透视教程!sohoo开挂辅助-... 透视教程!sohoo开挂辅助-专业开挂透视辅助软件(有挂攻略)运sohoo开挂辅助辅助工具,进入游戏...
揭秘真相“广东雀神智能插件免费... 揭秘真相“广东雀神智能插件免费”果然有开挂辅助挂(有挂秘笈);1、不需要AI权限,帮助你快速的进行广...
总算了解“九九联盟辅助在”一直... 总算了解“九九联盟辅助在”一直有开挂辅助脚本(有挂解惑)是一款可以让一直输的玩家,快速成为一个“必胜...
辅助透视!pokerworld... 辅助透视!pokerworld辅助器-关于开挂透视辅助插件(有挂功能)1、实时pokerworld辅...
实测交流“微信西楚辅助”本来有... 您好:微信西楚辅助这款游戏可以开挂的,确实是有挂的,很多玩家在这款游戏中打牌都会发现很多用户的牌特别...
透视玄学!wpk是真的还是假的... 透视玄学!wpk是真的还是假的-详细开挂透视辅助方法(有挂秘笈)wpk是真的还是假的软件透明挂微扑克...
重大推荐“赣牌圈挂可以安装”从... 重大推荐“赣牌圈挂可以安装”从前有开挂辅助插件(有挂辅助)是一款可以让一直输的玩家,快速成为一个“必...
透视规律!wpk透视挂是真的-... 透视规律!wpk透视挂是真的-分享开挂透视辅助技巧(有挂辅助)1、超多福利:超高返利,海量正版游戏,...
每日必看“werplan脚本”... 每日必看“werplan脚本”从前有开挂辅助工具(的确有挂);亲,有的,ai轻松简单,又可以获得无穷...
透视黑科技!大菠萝789辅助器... 透视黑科技!大菠萝789辅助器下载-了解开挂透视辅助技巧(新版有挂)在进入大菠萝789辅助器下载辅助...