Создать задачу Flink

Создать задачу

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

2. Откройте карточку инстанса или создайте новый.

3. Перейдите на вкладку Задачи.

4. Нажмите Создать задачу.

5. Выберите тип задачи.

6. В блоке Общие параметры:

   1. Название — название задачи.

   2. (Опционально) Нажмите Добавить описание и заполните поле Описание.

7. В блоке Скрипт приложения:

   1. Тип запускаемой задачи — выберите язык, на котором написана задача.

   2. В зависимости от выбранного типа задачи заполните поля:

      ---

      Потоковая

      Пакетная

      1. В поле Путь к запускаемому файлу — папка в Object Storage, в которой хранится файл с задачей Flink.

      2. Главный исполняемый класс — главный класс задачи на Java.

      3. Параллелизм — количество параллельных подзадач, выполняемых одновременно. Их количество ограничено количеством слотов, указанных при создании инстанса.

      4. (Опционально) Добавить аргумент — активируйте опцию, чтобы указать аргументы для выполнения задачи.

      5. В блоке Настройки снапшотов:

         1. (Опционально) Создавать сейвпоинты по расписанию — активируйте, чтобы сохранять состояние приложения. Если не активировать автоматическое создание сейвпоинтов, их можно будет создать вручную.

            1. Выберите формат сейвпоинтов.

            2. Задайте интервал.

         2. (Опционально) Создавать чекпоинты по расписанию — активируйте, чтобы сохранять данные об активных задачах.

            Задайте интервал.

            Внимание

            Если не активировать автоматическое создание чекпоинтов, их нельзя будет создать вручную.

         3. (Опционально) Автоматически очищать сейвпоинты — активируйте, чтобы удалять старые сейвпоинты.

            1. Задайте интервал.

            2. Укажите максимальное количество сейвпоинтов в хранилище, при превышении которого удалятся самые старые из них.

         Подробнее о чекпоинтах и сейвпоинтах

      6. (Опционально) В блоке Параметры запуска активируйте Режим восстановления, чтобы использовать сейвпоинт другой задачи.

         ---

         Выбрать задачу

         Выбрать каталог

         1. Выберите задачу, работу которой хотите продолжить.

         2. Выберите сейвпоинт, с момента создания которого будет продолжена задача.

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

Задача запустится автоматически и отобразится на вкладке Задачи в инстансе. В списке задач можно отслеживать статус задачи.

Следующие шаги

Далее вы можете войти в интерфейс Managed Flink:

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

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

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

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

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

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

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