Materialized Tables in Apache Flink
Author: Robin Moffatt | Source: rmoff.net | Published: 2026-04-28
한 줄 요약
Flink 1.20+의 Materialized Table은 DDL과 DML을 통합하여 라이프사이클 관리, 스키마 진화, 중단/재개를 자동화하는 새로운 테이블 추상화다.
핵심 주장/내용
- Materialized Table은 쿼리 정의를 테이블 카탈로그 엔트리에 포함시켜 CREATE TABLE + INSERT 또는 CTAS 대비 관리 부담을 대폭 줄임
- CONTINUOUS(스트리밍)와 FULL(cron 기반 배치) 두 가지 리프레시 모드를 지원하며, 파티션 테이블은 현재 파티션만 갱신
- 태스크 매니저 재시작 후 자동 복구, ALTER를 통한 스키마 진화, savepoint 기반 중단/재개 등 라이프사이클 관리가 내장
- 현재 카탈로그 지원이 제한적(Paimon + test-filesystem만), 내장 스케줄러는 프로덕션 준비 미흡
- FULL 리프레시를 무한 소스에 적용하면 조용히 실패하는 주의점 존재
주요 수치 / 사실
- Flink 1.20부터 사용 가능
- 지원 카탈로그: Paimon, test-filesystem (2개)
관련 위키
Source: 원문 보기