0
ответов
Apache Flink - запрашиваемое состояние трансляции
Я использую шаблон состояния вещания, где правила передаются всем операторам. В административных целях я хотел бы получить доступ к содержимому состояния вещания из-за границы
вопрос задан: 25 March 2019 01:28
0
ответов
Apache Flink - настройка диспетчера задач HA
В критически важных установках постоянная доступность обязательна. Мы думаем о том, чтобы использовать Apache Flink в качестве нашего потокового движка, но у нас есть сложные SLA. Наш план работы будет основан на одном ...
вопрос задан: 4 March 2019 13:41
0
ответов
Команда вышла со статусом 1 при запуске приложения через марафон
Я использую Mesos и Marathon, чтобы обеспечить высокую доступность для кластера Flink. Более подробно, у меня есть кластер из двух узлов с установленным докером на каждом из них. Я установил Apache Mesos на каждом ...
вопрос задан: 2 March 2019 14:18
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 на Zeppelin У меня есть эта ошибка & ldquo; TooLongFrameException: скорректированная длина кадра превышает & ldquo;
Я пытаюсь запустить простую работу в Apache Flink с помощью Zeppelin. Я создал Docker-контейнер с запущенным zeppelin 0.8.0. В этом же контейнере у меня работает apache flink 1.6.1. Когда я бегу ...
вопрос задан: 18 January 2019 16:13
0
ответов
Apache flink-kafka Добавление нескольких потребителей в одну группу потребителей flink-kafka
Я читаю тему «ABC», в которой есть 5 разделов, но на самом деле, когда я создал группу потребителей (то есть Flinkkafkaconsumer09), у нее только один экземпляр потребителя, и этот потребитель потребляет все ...
вопрос задан: 18 January 2019 13:52
0
ответов
Развертывание задания Flink завершается с ошибкой StackOverflow из-за рекурсивного вызова ParserATNSimulator
При развертывании задания Flink я получаю следующую рекурсивную ошибку в ParserATNSimulator, которая приводит к сбою задания. Это вызывает переполнение стека. Что может вызвать это? Информация о работе: мой график работы ...
вопрос задан: 17 January 2019 00:45
0
ответов
Не удалось включить базовую проверку подлинности с помощью эластичного соединителя поиска
Я пытаюсь добавить эластичный поиск в качестве приемника, и мой текущий эластичный поиск включил SSL и обычную аутентификацию. Я не мог подключиться кasticsearch с базовой аутентификацией. Журнал ошибок: Ошибка: (...
вопрос задан: 16 January 2019 15:23
0
ответов
В чем разница между max и maxBy в KeyedStream
KeyedStream # max (String field) Применяет агрегацию, которая дает текущий максимум потока данных при заданном выражении поля по заданному ключу. Независимый агрегат сохраняется для каждого ключа. ...
вопрос задан: 16 January 2019 12:01
0
ответов
Почему пример Apache Beam WordCount, запущенный на Flink, был намного медленнее, чем пример родного примера flink flink?
Я просто изучал луч Apache и Flink.I запускаю пример Beam WordCount и запускаю на flink.The flink веб-интерфейс показывает общее время работы было 8s, но когда запустить flink родной WordCount пример, он просто использовал 2s ....
вопрос задан: 14 July 2018 02:25
0
ответов
Чем отличаются JoinFunction и CoGroupFunction в Apache Flink?
В чем разница между JoinFunction и CoGroupFunction в Apache Flink? Чем отличаются семантика и исполнение?
вопрос задан: 26 September 2016 20:26
0
ответов
Порядок потокового события Flink
Я сталкиваюсь с некоторыми проблемами, понимающими семантику вокруг оконного времени события. Следующая программа генерирует несколько кортежей с метками времени, которые используются как время события, и создает простое окно ...
вопрос задан: 8 December 2015 21:02