DM
примерно год назад слышал обвинения
ну смотря что ты делаешь
ну и был нюанс с тригерами, что окно не закрывается если нету прогресса в стриме
Size: a a a
2019 November 19
A
IP
небось типы не сходятся, col возращает какую то не типизированную хрень, а сравнение с числом
надо смотреть как получить нужный тип значения
надо смотреть как получить нужный тип значения
не в типах дело, там какието имплиситы нужны,
AZ
с вотермарками во флинке говорили не так все гладко, может продалбывать данные
детали?
DM
не в типах дело, там какието имплиситы нужны,
в типах дело, это разные штуки и ты не можешь их сравнить
нужно преобразовать одно в другое
нужно преобразовать одно в другое
DM
детали?
если память не подводит то говорил об этом
@mabrek из одсDM
речь была именно про баги, а не нюансы использования
IP
в типах дело, это разные штуки и ты не можешь их сравнить
нужно преобразовать одно в другое
нужно преобразовать одно в другое
IP
в типах дело, это разные штуки и ты не можешь их сравнить
нужно преобразовать одно в другое
нужно преобразовать одно в другое
разные типы подставляю, все варианты перебрал
DM
спасибо за скрин, но здесь нет ошибки, можно только по волне догадываться
A
речь была именно про баги, а не нюансы использования
хз, пока на окна на конференциях никто сильно не жаловался
у тех же нетфликсов терабайтные стейты
интересно было бы подробней узнать
у тех же нетфликсов терабайтные стейты
интересно было бы подробней узнать
DM
разные типы подставляю, все варианты перебрал
так может посмотреть тип у результата col?
AZ
речь была именно про баги, а не нюансы использования
просто это довольно популярный фреймворк, и вотермарки используются кругом, это должен быть какой-то известный баг
AZ
мб это про allowedLateness? там вроде были терки про то как оно апдейтит результат на поздних данных
DM
мб это про allowedLateness? там вроде были терки про то как оно апдейтит результат на поздних данных
может, я на тот момент уже не следил особо, по инерции больше подслушивал
DM
да и за это время пофиксить все могли, я потому и текущим статусом о проблемах поинтересовался
DM
https://issues.apache.org/jira/browse/FLINK-13429?jql=project %3D FLINK AND issuetype %3D Bug AND priority in (Blocker%2C Critical) AND resolution in (Unresolved%2C Fixed) AND text ~ watermark ORDER BY affectedVersion DESC%2C priority DESC%2C updated DESC
там хватает багов за все время
сейчас 3 открытых
там хватает багов за все время
сейчас 3 открытых
DM
ну и ошибки они не обязаны быть глобальными с аффектом всего, это может быть в отдельных операторах
AZ
а, ну это у всех бывает, we welcome your PRs так сказать, чегож марать сразу весь фреймворк
EV
А поясните плиз нубу про проблему скейлинга в кафка стримс и чем flink/spark приятнее в этом вопросе