например. У меня есть два DataStream<Tuple4<String, String, Date, String>> с именами...

После нескольких дней изучения того, почему мое приложение Flink не работает должным образом Я...

Используя Apache Flink 1.4.2, я получаю следующее исключение com.esotericsoftware.kryo

Я пытался получить данные из postgre, используя flink. Ниже приведен код: dbData =env

Мой вопрос может вызвать путаницу, поэтому сначала прочтите описание. Может быть полезно определить...

После обновления до Apache Flink 1.4.2 мы получаем следующие ошибки каждые несколько секунд на...

У меня есть таблица с данными, и мне нужно объединить два поля. Я написал запрос, но он не работает...

Я разрабатываю алгоритм дискретизации в мгновение ока, но у меня возникают проблемы с применением...

Мы пытаемся построить Flink Job для агрегации цен с довольно сложной логикой. например. предыдущая...

Я пытался получить данные из базы данных и вести их подсчет.Если число равно 1, тогда обновление...

Я пытаюсь поиграть с расширенным состоянием Флинка в простом случае. Я просто хочу умножить поток...

Я создал потоковую программу для потокового оплога mongodb, используя flink и kafka. Согласно...

Я пытаюсь объединить 2 выбора. Я должен сделать запрос в коде, похоже на этот запрос select * from...

Я пытаюсь работать с файлом как поток с окном. Вот код object Prog { def main(args: Array[String])...

Я хочу присоединиться к трем или более потокам данных или таблицам по заданному ключу и общему окну

Я отправил одно событие с isStart true в kafka и заставил Flink потреблять событие из kafka, также...

Я пытаюсь создать кластер EMR для Apache Flink, и первый вариант, который я могу выбрать, выглядит...

Мы используем потоковую передачу Flink для запуска нескольких заданий в одном кластере.Наши рабочие...

У нас есть кластер Flink, управляемый другой командой.Кластер распределяется между несколькими...

У меня есть автономный кластер Flink на основе Flink 1.4.2 (1 менеджер заданий, 4 слота задач) и я...

Попытка перейти от Flink 1.3.2 к 1.5 У нас есть кластер, развернутый с помощью kubernetes.Все...

Я работаю над потоковым приложением на основе Apache Flink (1.5.0).В рамках этого я запустил Flink...

Я запускаю SQL с несколькими проекциями, каждый из которых отнимает много времени, например: SELECT...

Я пытаюсь отправить данные в Hive через Kafka -> Flink -> Hive, используя следующий фрагмент кода:...

Из официального документа для Flink CEP мы видим, что результат Relaxed Contiguity не включает в...