Skip to content
This repository has been archived by the owner on Jun 1, 2023. It is now read-only.

使用dhfs创建用户会创建失败 #64

Open
o-hat opened this issue Sep 3, 2020 · 2 comments
Open

使用dhfs创建用户会创建失败 #64

o-hat opened this issue Sep 3, 2020 · 2 comments

Comments

@o-hat
Copy link

o-hat commented Sep 3, 2020

测试代码

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…

@o-hat
Copy link
Author

o-hat commented Sep 3, 2020

produce.start()方法 创建/home//logs/rocketmq-cpp/ 报 Permission denied . need help~~~

@messense
Copy link
Owner

messense commented Sep 3, 2020

没办法,上游 rocketmq-client-cpp 不支持 disable/自定义 日志位置,参考 apache/rocketmq-client-python#92

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants