JOB 문

JOB 문 (JOB Statements)

JOB 문은 Flink 작업 관리를 위해 사용합니다. Flink SQL은 현재 SHOW JOBS, DESCRIBE JOB, STOP JOB의 세 가지 JOB 문을 지원합니다.

출처: 문서

본문

JOB 문은 Flink 작업의 관리를 위해 사용합니다.

Flink SQL은 현재 다음 JOB 문을 지원합니다:

SHOW JOBS
DESCRIBE JOB
STOP JOB

JOB 문 실행 (Run a JOB statement)

다음 예시는 SQL CLI에서 JOB 문을 실행하는 방법을 보여줍니다.

Flink SQL> SHOW JOBS;
+----------------------------------+----------+---------+-------------------------+
|                           job id | job name |  status |              start time |
+----------------------------------+----------+---------+-------------------------+
| 228d70913eab60dda85c5e7f78b5782c |    myjob | RUNNING | 2023-02-11T05:03:51.523 |
+----------------------------------+----------+---------+-------------------------+

Flink SQL> DESCRIBE JOB '228d70913eab60dda85c5e7f78b5782c';
+----------------------------------+----------+---------+-------------------------+
|                           job id | job name |  status |              start time |
+----------------------------------+----------+---------+-------------------------+
| 228d70913eab60dda85c5e7f78b5782c |    myjob | RUNNING | 2023-02-11T05:03:51.523 |
+----------------------------------+----------+---------+-------------------------+

Flink SQL> SET 'execution.checkpointing.savepoint-dir'='file:/tmp/';
[INFO] Execute statement succeeded.

Flink SQL> STOP JOB '228d70913eab60dda85c5e7f78b5782c' WITH SAVEPOINT;
+-----------------------------------------+
|                          savepoint path |
+-----------------------------------------+
| file:/tmp/savepoint-3addd4-0b224d9311e6 |
+-----------------------------------------+

SHOW JOBS

SHOW JOBS

Flink 클러스터의 작업들을 보여줍니다.

주의 SHOW JOBS 문은 SQL CLI 또는 SQL Gateway에서만 동작합니다.

DESCRIBE JOB

{ DESCRIBE | DESC } JOB '<job_id>'

Flink 클러스터에서 지정된 작업을 보여줍니다.

주의 DESCRIBE JOB 문은 SQL CLI 또는 SQL Gateway에서만 동작합니다.

STOP JOB

STOP JOB '<job_id>' [WITH SAVEPOINT] [WITH DRAIN]

지정된 작업을 중지합니다.

WITH SAVEPOINT 작업을 중지하기 직전에 savepoint를 수행합니다. savepoint 경로는 클러스터 구성 또는 SET 문(후자가 우선)을 통해 execution.checkpointing.savepoint-dir로 지정할 수 있습니다.

WITH DRAIN 마지막 체크포인트 배리어 이전에 워터마크를 최대 값으로 올립니다. 작업을 영구적으로 종료하려 할 때 사용하세요.

주의 STOP JOB 문은 SQL CLI 또는 SQL Gateway에서만 동작합니다.