получение следующей ошибки при отображении из kafka в файл csv с использованием spark в качестве места размещения в интеграторе данных oracle 12C - PullRequest
0 голосов
/ 10 мая 2018
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'
...