Я выполняю задание Flink на кластере Flink Yarn, и для параллелизма задано значение 1, так что это...
Недавно мне не удалось загрузить какие-либо jar-файлы в мой кластер Flink, работающий под YARN в...
Я новичок в скале и моргании.Я использую следующий код, чтобы использовать сообщение json из потока...
У меня есть два потока.Первый - это поток на основе времени, и я использовал countTimeWindow, чтобы...
Можно ли записать набор данных в bucketingSink? env.createInput(textInputFormat) .rebalance()
В функции обработки окна можно узнать, какие элементы были выселены? Вариант использования: Окно с...
Я пытаюсь вставить данные датчика в базу данных притока.Я успешно выполнил описанный выше сценарий...
Я сохраняю POJO через Cassandra apache Sink. Как установить «Время жизни» в этой раковине Cassandra
Я использую flink run -m yarn-cluster -c my.Main для подачи заявки в кластер пряжи ， код содержит...
Я знаю, что вы можете зарегистрировать агрегатный UDF (AggregateFunction) и использовать его в...
У меня есть сценарий использования "Apache Flink", где у меня есть конвейер оператора Window, за...
Итак, у нас есть события a, b, c, x, y, z в источнике kafka в течение 10-минутного окна, и у меня...
Я хотел бы иметь параллельный источник Flink, который потребляет из очереди блокировки в памяти.Моя...
Я пытаюсь следовать этому руководству по Flink [1] для обработки ошибок в ElasticSearchSink путем...
Я сейчас использую Flink V 1.4.2 Если у меня есть POJO: class CustomObj{ public Map<String,...
У меня есть HashMap в POJO в Flink v 1.4.2 , например: class CustomObj{ public Map<String,...
У меня есть задание Flink в Java, в котором реализована логика интерфейса поставщика услуг (SPI)...
Я новичок во Флинке.Я хочу вычислить порог для данного набора данных.Например, значение датчика...
Почти моя работа Flink работает нормально, но иногда Flink бросает NPE, когда я отправляю работу....
В потоковом приложении Flink, которое принимает сообщения от Kafka, 1) Как отключить автоматическую...
Подумайте, я это делаю: DataStream<POJO> ds = ... ds
У меня есть поток данных с временем события, возможно ли создавать окна без данных в Apache Flink
Я создал MqttConnector для Flink (Java), и он принимает сообщения в классе, который имеет Tuple3...
Вот что я хочу сделать в Apache Flink: Возьмите DataStream<T>, введите Key By поле x и затем...
Я попытался установить максимальный параллелизм для задания Flink, используя метод ExecutionConfig