问题 2 解决方法记录
查询编码格式:
# 进入 spark shell
I have no name!@30c585604392:/opt/bitnami/spark/bin$ spark-shell
# 获取 file.encoding
scala> System.getProperty("file.encoding")
原因:spark 编码格式不匹配
执行语句时添加参数:
./bin/spark-submit \
--master spark://master:7077 \
--conf spark.driver.extraJavaOptions=" -Dfile.encoding=utf-8 " \
--conf spark.executor.extraJavaOptions=" -Dfile.encoding=utf-8 " \
--class com.vesoft.nebula.exchange.Exchange /tmp/nebula-exchange-2.6.1.jar \
-c /tmp/clickhouse_application.conf
问题 2 解决!
感谢各位大佬解答。