Size: a a a

2021 March 02

ИК

Иван Калининский... in Data Engineers
er@essbase.ru
*В ит меня одно радует, что из-за ошибок нет риска для жизни. 😁 Нервы не в счёт .
https://www.labirint.ru/books/665544/

Помимо Теслы, которая не замечает грузовиков, и прочих дронов есть ещё проросшие везде интернет-вещи и сбор частной информации. Впрочем, пока тесла едет, а информация не слита, можно считать, всё в порядке 😕
источник

OI

Oleg Ilinsky in Data Engineers
Nikita Blagodarnyy
А перестартовать трифт-сервер с уменьшенным доспустимым бродкастом? Чтобы он не выбирал его постоянно.
ну вот у меня был по дефолту 10мб, меньше как-то совсем не понятно, зачем он)
источник

N

Nikita Blagodarnyy in Data Engineers
Oleg Ilinsky
ну вот у меня был по дефолту 10мб, меньше как-то совсем не понятно, зачем он)
а сеть норм?
источник

OI

Oleg Ilinsky in Data Engineers
Nikita Blagodarnyy
а сеть норм?
да хз, это вообще всё в кубах (попеншифт которые) работает
источник

N

Nikita Blagodarnyy in Data Engineers
Oleg Ilinsky
да хз, это вообще всё в кубах (попеншифт которые) работает
там может не в спраке и дело тогда?
источник

OI

Oleg Ilinsky in Data Engineers
🤔
ну вообще, возможно
источник

D

Dimidr0 in Data Engineers
Dmitry Zuev
Главное с Бабушкиным не работать
А почему, кстати?
источник

А

Алексей in Data Engineers
подскажите, как Flink обеспечивает реалтайм? У Spark - это микробатчи, а флинка что? Чтото типа лонг полинга?
источник

NN

No Name in Data Engineers
Dimidr0
А почему, кстати?
А кто это, кстати?
источник

SO

Simon Osipov in Data Engineers
Dimidr0
А почему, кстати?
Валера борьбой занимался и нож у него был всегда)
источник

D

Dmitriy in Data Engineers
Anton Zadorozhniy
вообще надо начать этот разговор с пристального взгляда на архитектора который такое предложил, но тут уже не технические вопросы
имя ему космический хаос
источник

ИК

Иван Калининский... in Data Engineers
Алексей
подскажите, как Flink обеспечивает реалтайм? У Spark - это микробатчи, а флинка что? Чтото типа лонг полинга?
Рилтайм недостижим физически, нужно выбирать приближение, исходя из потребностей))
источник

ИК

Иван Калининский... in Data Engineers
Dmitriy
имя ему космический хаос
сдаётся мне, что вся заваруха из-за желания не съезжать с легаси
источник

AZ

Anton Zadorozhniy in Data Engineers
Алексей
подскажите, как Flink обеспечивает реалтайм? У Spark - это микробатчи, а флинка что? Чтото типа лонг полинга?
источник

AZ

Anton Zadorozhniy in Data Engineers
вообще раздел полезный, особенно если вы пишете свой data source, там много полезных замечаний которые надо держать в уме
источник

А

Алексей in Data Engineers
основная идея получается в цикле без задержки опрашивать источник, пока не получит новую порцию данных? (вместо фиксированных по времени запуска микробатчей спарка)
>  A Flink task keeps calling pollNext(ReaderOutput) in a loop to poll records from the SourceReader.
источник

e

er@essbase.ru in Data Engineers
Иван Калининский
сдаётся мне, что вся заваруха из-за желания не съезжать с легаси
И это правда
источник

AZ

Anton Zadorozhniy in Data Engineers
Алексей
основная идея получается в цикле без задержки опрашивать источник, пока не получит новую порцию данных? (вместо фиксированных по времени запуска микробатчей спарка)
>  A Flink task keeps calling pollNext(ReaderOutput) in a loop to poll records from the SourceReader.
да, SourceReader выдает блок на каждый полл (и признак того есть есть ли там еще данные, ждать или закрывать ридер вообще, если это батч)
источник

А

Алексей in Data Engineers
Anton Zadorozhniy
да, SourceReader выдает блок на каждый полл (и признак того есть есть ли там еще данные, ждать или закрывать ридер вообще, если это батч)
спасибо
источник

AZ

Anton Zadorozhniy in Data Engineers
там самое интересное конечно это event time и watermark генераторы
источник