Big Data Technology & Architecture

Jun 4, 2020 · Big Data

Understanding Flink StreamingFileSink: File States, Rolling Policies, and Example Code

This article explains Flink's StreamingFileSink in version 1.10.0, covering how files transition through In‑progress, Pending, and Finished states, the bucket assignment and rolling policies, and provides a complete Java example for writing string data to files.