본문으로 건너뛰기
최종 수정: 에

JOBS

설명​

특정 작업 유형의 작업 정보를 조회할 수 있는 임시 작업 테이블을 생성하는 테이블 함수입니다.

구문​

JOBS(
    "type"="<type>"
)

필수 매개변수​

필드설명
<type>작업 유형:
insert: INSERT INTO 유형의 작업.
mv: 구체화된 뷰 작업.

반환 값​

  • jobs("type"="insert") insert 유형 작업의 반환 값

    필드설명
    Id작업 ID
    Name작업 이름
    Definer작업 정의자
    ExecuteType실행 유형
    RecurringStrategy반복 실행 전략
    Status작업 상태
    ExecuteSql실행 SQL
    CreateTime작업 생성 시각
    SucceedTaskCount성공한 태스크 수
    FailedTaskCount실패한 태스크 수
    CanceledTaskCount취소된 태스크 수
    Comment작업 설명
    Properties작업 속성. ExecuteType = STREAMING인 작업에만 값이 있습니다.
    CurrentOffset작업이 처리를 완료한 오프셋입니다. ExecuteType = STREAMING인 작업에만 값이 있습니다.
    EndOffset작업이 데이터 소스에서 가져온 가장 큰 오프셋입니다. ExecuteType = STREAMING인 작업에만 값이 있습니다.
    LoadStatistic작업의 데이터 적재 통계
    ErrorMsg작업 실행 오류 메시지
    JobRuntimeMsg작업의 런타임 메시지
    LagBytes소스 측 로그(예: MySQL binlog 또는 PostgreSQL WAL)의 미처리 데이터 크기(바이트 단위)입니다. -1은 현재 값을 사용할 수 없음을 의미합니다. 예를 들어 S3 데이터 소스를 사용하거나 전체 스냅샷 단계인 경우에 해당합니다.
    4.1.4부터 이 열의 이름이 Lag(초 단위)에서 LagBytes(바이트 단위)로 변경되었습니다.
    LastSourceEventTimestamp작업이 커밋한 오프셋에 기록된 가장 최근 소스 측 이벤트의 타임스탬프(Unix 초 단위)입니다. 비어 있으면 값을 사용할 수 없음을 의미합니다. 4.1.4에서 추가되었습니다.
    LastTaskSuccessTime태스크가 마지막으로 성공적으로 완료된 시각

  • jobs("type"="mv") MV 유형 작업의 반환 값

    필드설명
    Id작업 ID입니다. MV 작업의 경우 tasks("type"="mv").JobId에 해당합니다.
    Name작업 이름입니다. MV 작업의 경우 mv_infos("database"="...").JobName 및 tasks("type"="mv").JobName에 해당합니다.
    MvId이 작업이 유지 관리하는 구체화된 뷰의 ID입니다.
    MvName이 작업이 유지 관리하는 구체화된 뷰의 이름입니다.
    MvDatabaseId구체화된 뷰가 속한 데이터베이스의 ID입니다.
    MvDatabaseName구체화된 뷰가 속한 데이터베이스의 이름입니다.
    ExecuteType작업 실행 유형입니다. MV 작업에서 가능한 값은 MANUAL과 RECURRING입니다. MANUAL은 수동으로, 커밋에 의해 또는 내부 이벤트에 의해 새로 고침 태스크가 트리거됨을 의미합니다. RECURRING은 새로 고침 태스크가 주기적으로 예약됨을 의미합니다.
    RecurringStrategyExecuteType에서 도출된 스케줄링 설명입니다. MANUAL TRIGGER는 작업이 타이머에 따라 실행되지 않음을 의미합니다. EVERY ... STARTS ... [ENDS ...]는 작업이 주기적으로 실행됨을 의미합니다.
    Status작업 상태입니다. 가능한 값: PENDING은 작업이 스케줄링을 기다리고 있음을 의미합니다. RUNNING은 작업이 태스크를 생성할 수 있음을 의미합니다. PAUSED는 작업이 일시 중지되었으며 재개할 수 있음을 의미합니다. STOPPED는 작업이 중지되었으며 재개할 수 없음을 의미합니다. FINISHED는 작업이 완료되었음을 의미합니다.
    CreateTime작업이 생성된 시각입니다.

MV 작업의 열거형 필드​

구체화된 뷰의 새로 고침 작업을 확인할 때 주로 사용하는 열거형 필드는 다음과 같습니다.

  • ExecuteType: 작업이 새로 고침 태스크를 생성하는 방식입니다.
    • MANUAL: 작업이 자체 타이머에 따라 실행되지 않습니다. 수동으로, 커밋에 의해 또는 시스템에 의해 새로 고침이 트리거될 때만 태스크가 생성됩니다.
    • RECURRING: 작업이 일정에 따라 실행되며 주기적으로 새로 고침 태스크를 생성합니다.
  • RecurringStrategy: ExecuteType을 바탕으로 생성된, 사람이 읽기 쉬운 스케줄링 규칙입니다.
    • MANUAL TRIGGER: 작업이 주기적으로 예약되지 않습니다. ExecuteType이 MANUAL일 때 일반적으로 표시되는 값입니다.
    • EVERY <interval> <unit> STARTS <time> [ENDS <time>]: 작업이 주기적으로 예약됩니다. 예를 들어 EVERY 10 MINUTE STARTS 2025-01-17 14:42:53과 같이 표시됩니다.
  • Status: 작업 자체의 현재 상태입니다.
    • PENDING: 작업이 스케줄링되기를 기다리고 있습니다.
    • RUNNING: 작업이 활성 상태이며 새로 고침 태스크를 생성할 수 있습니다.
    • PAUSED: 작업이 일시 중지되었습니다. 재개될 때까지 새 새로 고침 태스크를 생성하지 않습니다.
    • STOPPED: 작업이 중지되었으며 재개할 수 없습니다.
    • FINISHED: 작업이 완료되었습니다. 장기간 유지되는 MV 새로 고침 작업에서는 드물지만, 범용 작업 프레임워크에서는 나타날 수 있습니다.

구체화된 뷰 하나에는 새로 고침 작업 하나가 있으며, 새로 고침 작업 하나에서 여러 새로 고침 태스크를 생성할 수 있습니다. jobs("type"="mv").Name을 사용하여 해당 작업을 mv_infos("database"="...").JobName 및 tasks("type"="mv").JobName과 연결합니다.

예제​

구체화된 뷰의 새로 고침 작업을 조회합니다.

select *
from jobs("type"="mv")
where MvDatabaseName = "test" and MvName = "mv1"\G
*************************** 1. row ***************************
               Id: 19508
             Name: inner_mtmv_19494
             MvId: 19494
           MvName: mv1
     MvDatabaseId: 16016
   MvDatabaseName: test
      ExecuteType: MANUAL
RecurringStrategy: MANUAL TRIGGER
           Status: RUNNING
       CreateTime: 2025-01-07 22:13:31

이 결과에서 각 필드의 의미는 다음과 같습니다.

  • Id는 MV 새로 고침 작업의 ID입니다. JobId는 tasks("type"="mv")에서 이와 동일한 값을 가집니다.
  • Name은 MV 새로 고침 작업의 이름입니다. JobName은 mv_infos("database"="test") 및 tasks("type"="mv")에서 이와 동일한 값을 가집니다.
  • MvId와 MvName은 이 작업이 유지 관리하는 구체화된 뷰를 식별합니다.
  • MvDatabaseId와 MvDatabaseName은 구체화된 뷰가 속한 데이터베이스를 식별합니다.
  • ExecuteType이 MANUAL이므로 이 작업은 자체 타이머에 따라 실행되지 않습니다. 구체화된 뷰를 수동으로 새로 고치거나, 커밋 시 새로 고치거나, 시스템이 새로 고침을 트리거할 때 새로 고침 태스크가 생성됩니다.
  • RecurringStrategy는 MANUAL TRIGGER이며, 이는 ExecuteType = MANUAL에 부합합니다. 새로 고침 일정이 설정된 구체화된 뷰에서는 이 필드가 EVERY ... STARTS ...와 같이 표시됩니다.
  • Status가 RUNNING이므로 작업이 새로 고침 태스크를 생성할 수 있습니다. PAUSED인 경우 새 태스크가 생성되려면 먼저 구체화된 뷰 작업을 재개해야 합니다.
  • CreateTime은 이 MV 새로 고침 작업이 생성된 시각입니다.

이 작업에서 생성한 태스크를 조회하려면 작업 이름을 사용합니다.

select *
from tasks("type"="mv")
where JobName = "inner_mtmv_19494"
order by CreateTime desc;

모든 insert 작업을 조회합니다.

select * from jobs("type"="insert");
+----------------+----------------+---------+-------------+--------------------------------------------+---------+--------------------------------------------------------------+---------------------+------------------+-----------------+-------------------+---------+
| Id             | Name           | Definer | ExecuteType | RecurringStrategy                          | Status  | ExecuteSql                                                   | CreateTime          | SucceedTaskCount | FailedTaskCount | CanceledTaskCount | Comment |
+----------------+----------------+---------+-------------+--------------------------------------------+---------+--------------------------------------------------------------+---------------------+------------------+-----------------+-------------------+---------+
| 78533940810334 | insert_tab_job | root    | RECURRING   | EVERY 10 MINUTE STARTS 2025-01-17 14:42:53 | RUNNING | INSERT INTO test.insert_tab SELECT * FROM test.example_table | 2025-01-17 14:32:53 | 0                | 0               | 0                 |         |
+----------------+----------------+---------+-------------+--------------------------------------------+---------+--------------------------------------------------------------+---------------------+------------------+-----------------+-------------------+---------+
Report issue