Как выполнить модульное тестирование кода Spark Streaming?

Я использую последнюю версию Spark 1.6.0.

Посмотрел еще один пост stackoverflow Как заставить Spark Streaming подсчитывать слова в файле в модульном тесте?

Я пытаюсь использовать образец @ https://gist.github.com/emres/67b4eae86fa92df69f61 есть для написания примера юнит-теста для искры. После этого я намерен написать модульный тест для моего фактического искрового приложения. Однако я не могу использовать пример @ https://gist.github.com/emres/67b4eae86fa92df69f61< /а>. Это дает мне ошибку