Tất cả tài liệu

FPT Data Platform

    Tạo Apache Flink
    Tạo Apache Flink
    Updated on 24 Jul 2025

    Để tạo Flink người dùng thực hiện các bước sau:

    Bước 1: Tại thanh menu chọn Data Platform > chọn Workspace Management > chọn Workspace name

    Bước 2: Nhấn Create > hiển thị popup New Service > chọn Flink > Create

    Bước 3: Trong form tạo Flink, nhập thông tin màn Basic Information:

    • Name (required): Tên dịch vụ

    Chú ý: Tên Apache có thể chứa các kí tự chữ cái thường a-z hoặc chữ cái in hoa A-Z hoặc các kí tự số 0-9. Đặc biệt không dùng dấu cách có thể thay dấu cách bằng dấu “-” hoặc “_”.

    • Description (optional): Mô tả

    • Version (required): chọn version

    Picture 1

    Bước 4: Nhấn Next Step để chuyển sang màn nhập thông tin Nodes Configuration

    Nhập thông tin sau:

    Job manager

    • Storage policy (required): chọn Storage Policy

    • Type: mặc định là Medium-4 (2 CPU – 4 GB RAM)

    • Number of nodes: giá trị mặc định là 2

    Task manager

    • Storage policy (required): chọn Storage Policy

    • Type (required): chọn cấu hình

    • Number of nodes: nhập số node

    Chú ý: số node phải lớn hơn hoặc bằng 1 và nhỏ hơn hoặc bằng 10

    Nếu người dùng muốn tự động tăng cấu hình Worker của Flink, tích chọn Enable worker auto scaling > nhập số node tối đa cho Worker

    Chú ý: Số max node phải lớn số Number of nodes và nhỏ hơn hoặc bằng 10

    Picture 1

    Bước 5: Nhấn Next Step để chuyển sang màn Additional Properties

    Nhập các thông tin sau:

    Checkpoint/Savepoint storage lưu trạng thái của ứng dụng streaming:

    • Enpoint: nhập thông tin endpoint

    • Access key: nhập khóa truy cập

    • Secret: nhập mật khẩu

    • Bucket name: nhập tên bucket

    • Path: nhập đường dẫn path

    Nhấn Test Connection để kiểm tra kết nối từ Workspace tới Storage

    Job Storage chứa job file *.jar, có thể tải lên trực tiếp job vào S3:

    • Job Storage: chọn Storage đã được mount trên Workspace

    • Path: nhập đường dẫn chứa tệp

    Task slot

    • Slot per task: nhập số Slot per task

    Chú ý: số Slot per task phải lớn hơn hoặc bằng 1 và nhỏ hơn hoặc bằng 4

    • Total slot: số total slot phụ thuộc vào số slot per task

    Picture 1

    Bước 7: Nhấn Next Step để chuyển sang màn Review & Create

    Picture 1

    Bước 8: Kiểm tra thông tin nhập sau đó nhấn Create để hoàn thành việc khởi tạo Apache Flink

    Apache Flink hoàn thành khởi tạo khi Worker StatusSucceededStatus của FlinkHealthy (~10 phút)