Быстрый старт сервиса Managed Flink

Перед началом работы

1. Зарегистрируйтесь в личном кабинете Cloud.ru.

   Если вы уже зарегистрированы, войдите под своей учетной записью.

2. Настройте DNS-сервер и подсеть.

3. Создайте кластер Data Platform, в котором будет размещен инстанс. Назовите кластер «dp-start».

4. Создайте бакет Object Storage. Он нужен для хранения задач Flink, чекпоинтов, сейвпоинтов и метаданных для восстановления запущенных задач в случае сбоя или перезапуска JobManager.

Создайте инстанс Managed Flink

1. Перейдите в раздел Evolution и выберите сервис Managed Flink.

2. Нажмите Создать инстанс.

3. В блоке Общие параметры заполните поля:

   • Название — flink-instance-start.

   • Кластер — выберите «dp-start».

4. В блоке Настройки выберите:

   • Бакет — созданный бакет Object Storage.

   • Лог-группа — группу хранения логов или создайте новую.

5. Нажмите Продолжить.

6. В блоке Конфигурация JobManager выберите:

   • Вычислительные ресурсы — 2 vCPU / 4 RAM.

   • Тип планировщика — Default.

7. В блоке Конфигурация TaskManager выберите:

   • Вычислительные ресурсы — 2 vCPU / 4 RAM.

   • Количество воркеров — 2.

   • Количество слотов — 2.

8. Нажмите Продолжить.

9. В блоке Сетевые настройки выберите:

   • Зона доступности — зону доступности.

   • Подсеть — подсеть с DNS-сервером.

10. В блоке Настройки доступа заполните поля:

    • (Опционально) Подключить публичный веб-интерфейс — активируйте опцию, чтобы создать публичный пользовательский интерфейс Flink.

    • Пользователь — задайте имя пользователя для доступа к UI Flink.

    • Пароль — выберите пароль из списка секретов или создайте новый для доступа к UI Flink.

11. Нажмите Создать.

Инстанс появится в списке Managed Flink и перейдет в статус «Готов» в течение 30 минут.

Подготовить скрипт

Apache Flink предоставляет несколько скриптов для тестирования возможностей продукта.

1. Скачайте готовую задачу из примеров для версии 2.x.

   Например, TopSpeedWindowing.jar.

2. Загрузите скрипт в созданный ранее бакет Object Storage.

Интерфейс Flink

1. В списке инстансов Managed Flink откройте карточку инстанса.

2. Перейдите на вкладку Информация.

3. Перейдите по ссылке в поле Публичный хост.

4. Введите данные из карточки инстанса:

   • User — Пользователь.

   • Password — Пароль, скопируйте значение секрета.

В интерфейсе Flink можно получить всю информацию о задачах.