flink-admin

Введение

flink web admin, основанный на flink rest api, поддерживает управление постоянным хранением задач, редактирование, отправку, запуск и остановку JOB. Поддерживает развёртывание задач в нескольких кластерах, задачи могут выбирать разные кластеры в зависимости от сценария. Поддерживает сохранение точек сохранения одним щелчком мыши и восстановление задач с указанной точки сохранения. Поддерживает управление источниками данных и шифрование сохранённой информации о конфигурации источников данных. Поддерживает синхронизацию структуры таблицы одним щелчком. Поддерживает визуализацию конфигурации для одной таблицы, нескольких таблиц, полной и добавочной синхронизации базы данных (реализовано FlinkCDC). Поддерживает mysql to mysql, es.

Стек технологий

Springboot 2.3.9 + FreeMarker + flink 1.13.3 + flinkCDC 2.1.0

Архитектура

Инструкция по установке

Создание базы данных

CREATE DATABASE IF NOT EXISTS flink-admin DEFAULT CHARSET utf8mb4;
SOURCE flink-admin.sql

Запуск проекта

git clone https://gitee.com/chongho/flink-admin.git
# mvn install
# java -jar flink-web-console.jar

Использование

http://localhost:8086/
admin/123456

Скриншоты функций

Загрузка пакета ресурсов
Список заданий Добавление задания Задание синхронизации данных Добавление задачи синхронизации данных

Изменение шаблона задания

1. Загрузите flink-cdc-job.jar в кластер flink.
2. Измените соответствующий jarId.
   

Вклад

1. Форкните этот репозиторий.
2. Создайте ветку Feat_xxx.
3. Отправьте код.
4. Создайте Pull Request.

Свяжитесь с нами

Примечание

Copyright © 2022 中和农信