PK
Видимо поэтому акку выпилили из спарка
Size: a a a
2018 April 18
PK
@WindWriter если по делу, не работал с Флинком. Возможно @ermakovpetr подскажет
S
@WindWriter если по делу, не работал с Флинком. Возможно @ermakovpetr подскажет
Ок, спасибо. Если не получится разобраться, то переедем в Amazon EMR, может там это будет стабильнее.
A
попробуй спросить у:
https://www.facebook.com/ivan.mushketyk
у него есть собственный курс про Apache Flink на Pluralsight
https://www.facebook.com/ivan.mushketyk
у него есть собственный курс про Apache Flink на Pluralsight
2018 April 19
PK
Ты придёшь на мансарду?
anonymous poll
Да, конечно! – 22
👍👍👍👍👍👍👍 63%
Нет, посмотрю лайв на FB – 13
👍👍👍👍 37%
👥 35 people voted so far.
anonymous poll
Да, конечно! – 22
👍👍👍👍👍👍👍 63%
Нет, посмотрю лайв на FB – 13
👍👍👍👍 37%
👥 35 people voted so far.
PK
Ну что, дорогие друзья, уже сегодня на уютной мансарде Rambler&Co состоится Moscow Spark #4. Ждем всех зарегистрировавшихся в гости!
ЛР
Все достаточно конкретно. Есть 5 стриминговых задач, которые запускаются в flink standalone(кластера нет). Задачки забирают определенную информацию из Kafka, обрабатывает и отдает обратно в другой топик. Но после запуска 4-5 задачи они падают
Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka.tcp://
, а потом все задачи уходят почему-то в рестарт, с записью, что у таскменеджера нет свободных слотов, хотя они есть.
Кто-то сталкивался с подобным?
Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka.tcp://
, а потом все задачи уходят почему-то в рестарт, с записью, что у таскменеджера нет свободных слотов, хотя они есть.
Кто-то сталкивался с подобным?
А перевести на Spark streaming нельзя ?
ZM
А перевести на Spark streaming нельзя ?
*facepalm*
GP
типичный ответ с роисского форума в начале нулевых
GP
- у меня проблема с дривером линух
- поставьте винду
- поставьте винду
AS
а сколько людей в начале нулевых не смогли задать такой вопрос на форуме из-за проблем с драйвером под линукс :)
ДШ
а сколько людей в начале нулевых не смогли задать такой вопрос на форуме из-за проблем с драйвером под линукс :)
а сколько людей не смогли зайти на форум изза freebsd и виндового dialup-модема....
AP
Коллеги - вопрос - что делать если в hive имя поля - это служебое слово в scala? Как чотенько case class сделать в этом случае? Конкретно фиаско с type
AP
Конечно можно в запросе сделать select type as some_type но интересует в принципе возможно мапить как то названия ?
ДШ
spark.sql("select blablabla").as[MyCaseClass]
ДШ
как то так
ДШ
писал правлда по памяти, мог ошибиться
AP
ну да только вот в MyCaseClass имя должно совпадать с именем поля из запроса, а оно называется type что печально