flink version: 1.10.1
job parallelism: 3
checkpoint interval: 20min
I want to complete kafka's event into hdfs files
now every 20min will create a new file, so there will be 72 files in a day,
I want to merge these files in the next day.
How can i do
与恶龙缠斗过久,自身亦成为恶龙；凝视深渊过久,深渊将回以凝视…
