Để 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:
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
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
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
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
Bước 7: Nhấn Next Step để chuyển sang màn Review & Create
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 Status là Succeeded và Status của Flink là Healthy (~10 phút)