Ошибка утверждения при использовании Scala future с Spark

Я использовал искровой код в будущем Scala. Я сталкиваюсь с ошибкой строки, как Assertion Failed <None>, Это происходит в штучной упаковке ошибки.

Каждая трассировка стека начинается со строки sqlContext.udf.register. Когда я помещаю синхронизированный блок в регистр udf, Ошибка исчезает.

  • Версия Scala - 2.10.8
  • Искра - 1.6.0

0 ответов

Другие вопросы по тегам