Я получаю неожиданную ошибку в файле JSON - PullRequest
Новая
       32

Я получаю неожиданную ошибку в файле JSON

1 голос
/ 04 октября 2019

При использовании файла JSON от Кафки во мгновение ока я получаю эту ошибку:

Причина: org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.io. JsonEOFException: неожиданный конец ввода: ожидаемый маркер закрытия для объекта (начальный маркер в [Source: (byte []) "[{"; строка: 1, столбец: 2]) в [Source: (byte []) "[{ ";строка: 1, столбец: 5]

Это мой файл JSON: 

[{
        "locationID": "ASK",
        "temp": 35
    },
    {
        "locationID": "BC",
        "temp": 45
    },
    {
        "locationID":"CHD",
        "temp": 55
    },
    {
        "locationID": "RAJ",
        "temp": 65
    },
    {
        "locationID": "EGY",
        "temp": 55
}]

Это код:

Почему яне в состоянии сделать поток с ключами из этого

1 Ответ

0 голосов
/ 04 октября 2019

Насколько я знаю, вам всегда нужно вводить однострочные строки json. Так что в вашем примере используйте это:

[{"locationID": "ASK", "temp": 35}, {"locationID": "BC", "temp": 45}, {"locationID": "CHD", "temp": 55}, {"locationID": "RAJ", "temp": 65}, {"locationID": "EGY", "temp": 55}]

Для более общего подхода вы можете использовать что-то вроде следующего для переформатирования ваших многострочных строк json:

.selectExpr("REPLACE(CAST(value as string), '\n', '') as json")

...