Size: a a a

2020 September 29

N

Nikita Blagodarnyy in Data Engineers
работало до пятницы, в пн отъехало
источник

AB

Andrey Bel in Data Engineers
Всем привет,может кто сталкивался, гугл слабо помог пока - я  создаю авро через avro4s делаю кейс класс  и мне нужно получить одно поле

{  "type" : "string",
"avro.java.string" : "String"  }
а получаю
         
{ "type" : "string"}
и на этом падает джоба большая, спросил уже у буржуя одного , нашел пост с такой же проблемой он пишет просто сменил на java avro api
видел еще варианты имплисит SchemaFor и еще кое что но хотелось бы более простое решение.
Заранее спасибо
источник

АЖ

Андрей Жуков... in Data Engineers
Nikita Blagodarnyy
да по-дедовски, spark.read.parquet(«path»).filter(dt=param1)
попробуй с дебагом - может, он на чтении меты с ума сходит?
источник

GP

Grigory Pomadchin in Data Engineers
Andrey Bel
Всем привет,может кто сталкивался, гугл слабо помог пока - я  создаю авро через avro4s делаю кейс класс  и мне нужно получить одно поле

{  "type" : "string",
"avro.java.string" : "String"  }
а получаю
         
{ "type" : "string"}
и на этом падает джоба большая, спросил уже у буржуя одного , нашел пост с такой же проблемой он пишет просто сменил на java avro api
видел еще варианты имплисит SchemaFor и еще кое что но хотелось бы более простое решение.
Заранее спасибо
Версии авро совпадают?
источник

GP

Grigory Pomadchin in Data Engineers
и что делаешь то? какой код, где падает?
источник

N

Nikita Blagodarnyy in Data Engineers
Андрей Жуков
попробуй с дебагом - может, он на чтении меты с ума сходит?
да похоже на то. по прямому пути проблем нет. говорят, сильно много данных завезли на выходных.
источник

АЖ

Андрей Жуков... in Data Engineers
может,  футеры где-то поломались?
источник

AB

Andrey Bel in Data Engineers
Grigory Pomadchin
Версии авро совпадают?
это даже не смотрел- сделал диф моей схемы с целевой там явные различия как в посте
генерю авро не по схеме а через кейс класса

там замороченная система вообщем собираются кейсклассы а потом  через шейплес создается org.apache.avro.generic.GenericRecord
источник

GP

Grigory Pomadchin in Data Engineers
я видел в скала группе твой пост, я имел ввиду не это
источник

GP

Grigory Pomadchin in Data Engineers
как код ломается? как ты его используешь так что что-то ломается
источник

GP

Grigory Pomadchin in Data Engineers
Авро столькими способами можно использовать в спарке
источник

GP

Grigory Pomadchin in Data Engineers
да и не только в спарке
источник

GP

Grigory Pomadchin in Data Engineers
схематично накидай что б понять что ты хочешь
источник

AB

Andrey Bel in Data Engineers
код ломается не у меня))код ломается когда джоба основной системы читает мой авро
источник

AB

Andrey Bel in Data Engineers
попробую
источник

GP

Grigory Pomadchin in Data Engineers
что значит Джоба читает авро?
источник

GP

Grigory Pomadchin in Data Engineers
Читает как?
источник

GP

Grigory Pomadchin in Data Engineers
Датасорс?
источник

AB

Andrey Bel in Data Engineers
имею ввиду что я записываю авро на хадуп а после этого другая джоба его читает, я к ней отношения не имею, я только записываю
источник

GP

Grigory Pomadchin in Data Engineers
как записываешь то и читаешь?
источник