#flink
3개의 글이 있습니다.
늦게 온 이벤트가 최신 상태를 덮어쓰지 않게: Fluss Versioned Merge Engine
재시도와 지연 도착으로 과거 이벤트가 최신 상태를 덮는 문제를 Apache Fluss Versioned Merge Engine으로 막는 방법을 Flink SQL 예제와 함께 설명합니다.
apache-flussflinkstreamingdata-consistencyevent-processing
Apache Fluss 첫 실행: Flink Quickstart에서 확인할 것들
Apache Fluss를 로컬 실습 환경에서 Flink와 연결하고, Flink SQL로 카탈로그·테이블 모델·기본 키 조회와 갱신을 확인합니다.
apache-flussflinkdockerquickstartstreaming
Apache Fluss란: Kafka·Flink·Iceberg 사이의 스트리밍 레이크하우스
Apache Fluss를 Kafka·Flink·Iceberg와 역할별로 비교합니다. Log Table·Primary Key Table·통합 메타데이터로 실시간 스트림과 레이크하우스를 연결하는 방식을 정리합니다.
apache-flusslakehousestreamingflinkarchitecture