Я пытаюсь выполнить потоковое воспроизведение с помощью Spark.Модель, которую он строит, но я не могу предсказать значения на тестовых данных.Там нет ошибки, которая отображается при выполнении прогноза.Я использую следующий код в качестве ссылки.https://spark.apache.org/docs/2.2.0/mllib-clustering.html#streaming-k-means
Может кто-нибудь помочь мне с этим, так как я не могу устранить его дальше.
Проблема, которую я чувствую, состоит в том, что мои testData не в нужном формате.Правильно ли мое предположение?Ниже приводится формат тестовых данных
