在RabbitMq中通过RPC在Pyspark通信中解决错误

作者: 哎？小查查
发布时间: 2023-12-19 12:18:48 (6月前)
转自：

2 条回复

0#
回复此人
仙风道骨刘憨 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 你传递的是不兼容的类型（看起来像 <code> bytes </code> 要么 <code> bytearray </code> ）哪里 <code> str </code> 是期待。 </p> <P> 你应该 <code> decode </code> 首先要串起来的内容。 </p> <pre> <code> def queryBuilder(sqlval, enc): ... df = spark.sql(sqlval.decode(enc)) df.show() ... </code> </pre> </DIV>

编辑

登录后才能参与评论