Не в состоянии объявить аккумулятор типа String
Я пытаюсь определить переменную аккумулятора типа String в оболочке Scala (драйвер), но получаю следующую ошибку: -
scala> val myacc = sc.accumulator("Test")
<console>:21: error: could not find implicit value for parameter param: org.apache.spark.AccumulatorParam[String]
val myacc = sc.accumulator("Test")
^
Кажется, это не проблема для аккумуляторов типа Int или Double.
Спасибо