Я пытаюсь прочитать файл из hdfs, используя scala, но я получаю следующее исключение, когда запускаю следующий код:
val rdd = sc.textFile("hdfs://localhost:8020/user/training/pdp/OpBilling.csv")
java.io.IOException: Сбой при локальном исключении: com.google.protobuf.InvalidProtocolBufferException: сообщение протокола содержит недопустимый тег (ноль) .;Сведения о хосте: локальный хост: "hadoop / 127.0.0.1";хост назначения: "localhost": 8020;