1.????????????????????FlinkAPI??window????env.setStateBackend(new
RocksDBStateBackend("hdfs://host51:9000/flink/checkpoints",true))????rocksDB????checkpoint??????????????????????Completed
checkpoint 142 for job 25a50baff7d16ee22aecb7b1******** (806418 bytes in 426
ms).
2.??????SQLwindow????????????????????rocksDB??????checkpoint????????window??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"<[email protected]>;
????????: 2019??9??3??(??????) ????3:24
??????: "user-zh"<[email protected]>;
????: Re: flink????StateBackend????
Hi
on 2019/9/3 12:14, ???????? wrote:
> ??????????????????????StateBackend??????????????????env.setStateBackend(new
> RocksDBStateBackend("hdfs://host51:9000/flink/checkpoints",true))????????????????????SQLwindow????????checkpoint??????????????????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.
