1.FlinkAPI??windowenv.setStateBackend(new
RocksDBStateBackend("hdfs://host51:9000/flink/checkpoints",true))rocksDBcheckpoint??Completed
checkpoint 142 for job 25a50baff7d16ee22aecb7b1 (806418 bytes in 426
ms).
2.??SQLwindowrocksDB??checkpointwindow??checkpoint??n/a
2019-09-03 15:17:52,142 WARN
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Received late
message for now expired checkpoint attempt 1 from
915988718742f11135a6e96ba42c4e35 of job fd5010cbf20501339f1136600f0709c3.
2019-09-03 15:17:52,143 WARN
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Received late
message for now expired checkpoint attempt 1 from
191ca20964de323300551d9a144c272c of job fd5010cbf20501339f1136600f0709c3.
2019-09-03 15:17:52,144 WARN
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Received late
message for now expired checkpoint attempt 1 from
2a24625ac03ea6ac4b8632719768c502 of job fd5010cbf20501339f1136600f0709c3.
2019-09-03 15:17:52,144 WARN
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Received late
message for now expired checkpoint attempt 1 from
51b376365d044c672677c38ca1caee78 of job fd5010cbf20501339f1136600f0709c3.
2019-09-03 15:17:52,227 WARN
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Received late
message for now expired checkpoint attempt 1 from
9266a7307add46cb26f5a9352c82ceb0 of job fd5010cbf20501339f1136600f0709c3.
2019-09-03 15:18:21,881 WARN
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Received late
message for now expired checkpoint attempt 4 from
24674987621178ed1a363901acc5b128 of job fd5010cbf20501339f1136600f0709c3.
2019-09-03 15:18:21,882 WARN
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Received late
message for now expired checkpoint attempt 3 from
24674987621178ed1a363901acc5b128 of job fd5010cbf20501339f1136600f0709c3.
??
-- --
??: "Wesley Peng";
: 2019??9??3??(??) 3:24
??: "user-zh";
????: Re: flinkStateBackend
Hi
on 2019/9/3 12:14, wrote:
> ??StateBackend??env.setStateBackend(new
> RocksDBStateBackend("hdfs://host51:9000/flink/checkpoints",true))SQLwindowcheckpoint??n/a??
>
> flink-conf.xml??
> state.checkpoints.dir:
> hdfs://host51:9000/flink/flink-checkpoints??
> SQLwindow??RocksDBStateBackend
It seems like a filesystem issue, though I have no experience on it too.
regards.
