12
ответов
Получение исключения NullPointerException при попытке создать RMQSink во Flink [дубликат]
Я пытаюсь сделать Sink для Flink, чтобы отправлять сообщения от Flink до RabbitMQ. Когда я создаю Sink в основном, все работает нормально - я получаю сообщение в специальной очереди на RabbitMQ. ...
вопрос задан: 26 May 2016 16:15
3
ответа
Как повернуть N x N матрица на 90 градусов? [закрытый]
Как повернуть N x N матрица на 90 градусов. Я хочу, чтобы это было оперативным?
вопрос задан: 23 May 2010 19:27
2
ответа
Применение оконной функции отбрасывает события в результате
Я пытаюсь посчитать элементы в потоке, обогащая результат временем окончания окна. События получены от Kafka с использованием kafka10, предоставленного Flink. EventTime используется ....
вопрос задан: 17 January 2019 10:01
1
ответ
Как записать в разные файлы на основе контента для пакетной обработки во Flink?
Я пытаюсь обработать некоторые файлы в HDFS и записать результаты обратно в HDFS. Файлы уже подготовлены до начала работы. Дело в том, что я хочу писать в разные пути и файлы на основе ...
вопрос задан: 19 March 2019 23:33
1
ответ
Как отсортировать поток по времени события, используя Flink SQL
У меня вышел из строя DataStream < Event > что я хочу отсортировать так, чтобы события были упорядочены по их временным меткам. Я упростил свой вариант использования до того, что мой класс Event имеет только ...
вопрос задан: 3 March 2019 15:35
1
ответ
Почему контрольные точки так сильно влияют на задержку?
Я наблюдаю, что наличие контрольных точек при использовании бэкэнда памяти вызывает неожиданное увеличение наблюдаемых задержек. Рассмотрим следующую контрольную точку: 2019-02-27 15: 35: 46,322 INFO org ....
вопрос задан: 27 February 2019 16:37
1
ответ
Flink - интеграционное тестирование с несколькими источниками
У меня есть задание Flink, которое я тестирую интеграцией, используя описанный здесь подход: https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/testing.html#integration-testing. Задание занимает ...
вопрос задан: 27 February 2019 15:05
1
ответ
Flink Пользовательская сериализация с registerTypeWithKryoSerializer
Я хотел бы посоветовать вам быстрое возможное улучшение в DOC онлайн с сериализацией. На самом деле вы проделали потрясающую работу как над реализацией, так и над документацией. Путь ...
вопрос задан: 19 January 2019 10:12
1
ответ
Как использовать System.console в качестве источника Apache Flink
Apache Flink предоставляет множество различных потоковых источников, но мне было интересно, можно ли использовать консоль в качестве источника данных. Я не нашел ни одного примера в Интернете. Я придумал ...
вопрос задан: 18 January 2019 17:41
1
ответ
Flink: следует ли перезапустить весь кластер в случае сбоя одного диспетчера задач?
У нас работает автономный кластер Flink с 2 менеджерами вакансий и 3 менеджерами задач. Всякий раз, когда происходит сбой ТМ, мы просто перезапускаем эту конкретную ТМ и продолжаем обработку. Но читая ...
вопрос задан: 18 January 2019 09:51
1
ответ
Добавить точку сохранения в Datastream
У меня есть источник kafka, из которого мое приложение flink читает данные и обрабатывает их, я хочу добавить механизм сохранения точки flink, чтобы возобновить процесс с того места, где он был оставлен, а не ...
вопрос задан: 17 January 2019 14:45
1
ответ
Использование ROW () для вложенной структуры данных
Я успешно использовал JsonRowSerializationSchema из артефакта flink-json для создания TableSink < Row > и вывести JSON из SQL, используя ROW. Он отлично работает для передачи плоских данных: INSERT ...
вопрос задан: 16 January 2019 19:39
1
ответ
Apache Flink - ограничить количество выставляемых метрик
У нас есть работа с 30 операторами. Когда мы выполняем эту работу с параллелизмом в 12 шагов, в итоге получается 400 000 метрик, что слишком много для нашей метрической платформы. ...
вопрос задан: 16 January 2019 10:49
0
ответов
Слоты задач Flink распределяются неравномерно при установке параллелизма оператора, превышающего параллелизм по умолчанию
Я выполняю задание Flink в кластере, содержащем 3 менеджера задач (поверх 3 модулей Kubernetes). Параллелизм задания по умолчанию равен 9, а один из операторов настроен на параллелизм 18. Номер задания ...
вопрос задан: 26 March 2019 16:36
0
ответов
Apache flink - задача простого оконного задания - java.lang.RuntimeException: сегмент был освобожден - проблема Mini Cluster
Apache flink - задача простого оконного задания - java.lang.RuntimeException: сегмент освобожден Привет, я новичок flink, и в своей работе я пытаюсь использовать оконное управление, чтобы просто объединять элементы в ...
вопрос задан: 21 January 2019 12:13
0
ответов
Flink потокового SQL JOIN через два преобразования одного и того же потока
Привет, я просто пытаюсь понять, правильно ли я понимаю время потоковой передачи. В настоящее время мы используем время события и хотим самостоятельно присоединиться к потоку, так как нам нужно присоединиться к результату ...
вопрос задан: 18 January 2019 18:20
0
ответов
Apache flink-kafka Добавление нескольких потребителей в одну группу потребителей flink-kafka
Я читаю тему «ABC», в которой есть 5 разделов, но на самом деле, когда я создал группу потребителей (то есть Flinkkafkaconsumer09), у нее только один экземпляр потребителя, и этот потребитель потребляет все ...
вопрос задан: 18 January 2019 13:52
0
ответов
Порядок потокового события Flink
Я сталкиваюсь с некоторыми проблемами, понимающими семантику вокруг оконного времени события. Следующая программа генерирует несколько кортежей с метками времени, которые используются как время события, и создает простое окно ...
вопрос задан: 8 December 2015 21:02