как определить схему исходной таблицы flink 1.7 с помощью вложенной структуры json? И пример...

Я использую Scala на Flink с DataSet API. Я хочу перераспределить мои данные по узлам. В Spark есть...

У меня проблема во флинке. мой механизм вычислений в реальном времени использует groovy скрипт для...

Я хочу прочитать содержимое файла в каталоге в потоковом режиме, то есть когда новые файлы...

Описание: когда я получил сообщение кафки, это выглядит так: {...

Я новичок во Flink, а количество слов в режиме потоковой передачи: //x is the stream of (word, 1)...

Я пытаюсь использовать Flink's StreamingFileSink для записи элементов в потоке данных в коллекцию...

Мне пришлось научиться "трудному пути", используя вызовы методов типа someDataSet.collect ()...

Я попробовал этот код в Flink Scala Repl, и я строю RichMapFunction в Java, но Scala не может...

Поток flink имеет несколько потоков данных, затем я объединяю этот поток данных с методом org

Только пример Scala в документе flink . Но я хочу знать, как использовать в Java Api. Есть ли...

Я получаю код clone flink из github и открываю его с помощью Intellij Idea, я не делал никаких...

похоже, что Apache Flink не справился бы хорошо с двумя событиями с одной и той же отметкой времени...

Запуск Fink на OpenShift Facing Below error Пожалуйста, помогите мне решить проблему. ошибка: сбой...

Могу ли я знать, что происходит с состоянием, хранящимся в диспетчере задач Flink, когда происходит...

Я должен объединить счет / сумму в потоке событий для различных объектов. Журналы событий (json...

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

Если есть тема кафки с 10 разделами, и мы хотели бы использовать flink для ее использования. Мы...

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

Я хочу установить Flink на кластере Mesos для управления ресурсами. Фактически у меня был кластер...

У меня есть следующий код: val stateUri = "file:///tmp/" new RocksDBStateBackend(stateUri...

Я использую BroadcastState для выполнения потоковых вычислений во Flink. Я определил класс,...

Я получаю следующее исключение org.apache.flink.util.FlinkException: The assigned slot...

Я устанавливаю конвейер flink, который читает из Kafka и опускается в HDFS. Я хочу обработать...

Я пишу код flink, в котором я читаю файл из локальной системы и записываю его в базу данных,...