在oracledataintegrator 12c中将spark用作暂存位置时,从kafkaMap到csv文件时出现以下错误

wz3gfoph  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(217)
ODI-1590: The execution of the script failed. 
ODIKM-SPARK-SYNC-10000: EKM Command Failed with Exception: java.lang.Exception: Traceback (most recent call last):
10   File "/tmp/kafka_file_Physical.py", line 77, in <module>
11     ,"group.id" : "kafka_file_Physical"}, fromOffsets='earliest')
12   File "/usr/lib/spark/python/lib/pyspark.zip/pyspark/streaming/kafka.py", line 138, in createDirectStream
13 AttributeError: 'str' object has no attribute 'items'

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题