This repository was archived by the owner on Jun 1, 2023. It is now read-only.

Description
测试代码
from pyspark.sql import SparkSession
from rocketmq.client import Producer, Message
import json
import uuid
spark = SparkSession.builder.getOrCreate()
df = spark.range(10).toJSON().collect()
producer = Producer('xxxxx')
producer.set_namesrv_addr('192.168.7.160:9876')
producer.start()
msg = Message("SparkPlan")
msg.set_body(json.dumps(str(df)))
msg.set_tags("tag")
producer.send_sync(msg)
producer.shutdown()
spark.stop()
报错:
![Uploading image.png…]()