Im trying to write some data to Hadoop by using this code
The state backend is set without time
StateBackend sb = new FsStateBackend("hdfs://***:9000/flink/my_city/checkpoints");
BucketingSink<Tuple2<IntWritable, Text>> sink =
the result is that all the files are stuck in in.programs
status and not closed.
is it related to the state backend configuration.