Flink java ??????????????????????????????????????????
------------------ ???????? ------------------ ??????: "zhisheng"<zhisheng2...@gmail.com>; ????????: 2021??5??13??(??????) ????4:19 ??????: "user-zh"<user-zh@flink.apache.org>; ????: Re: Flink 1.11????LeaseRenewer?????????? ?????????????????????????????????? ??????????????????????????????????Flink ?????? 1.10.0???????????? JM ???????????????? 6k?????????? flink ???? Kafka???????? HBase ???????? Checkpoint?????????????????????????? https://tva1.sinaimg.cn/large/008i3skNgy1gqgvhdu674j31je0u0795.jpg zilong xiao <acidzz...@gmail.com> ??2020??12??8?????? ????6:21?????? > ???????????? kafka -> flink -> > http/prometheus?????????????????????????????????????????????????????????????????????????????????????????????????? ????debug????~ > > Paul Lam <paullin3...@gmail.com> ??2020??12??8?????? ????6:00?????? > > > Hi, > > > > ???????????????????????????????????????? HDFS?????????? checkpoint ???? HDFS ???????????????????????????????????? > > > > Best, > > Paul Lam > > > > > 2020??12??8?? 11:03??zilong xiao <acidzz...@gmail.com> ?????? > > > > > > Hi Paul, > > > ??????????????????????????user1@cluserA??HDFS client??????????????????????????????????????Flink > > > > > > 1.11????????Flink????????HDFS??????????2.8.1????Flink??????????????????????????????checkpoint??????DEBUG??????????????root > > > cause???? > > > > > > ???? ???????????????????????????? HDFS ?????????????????????????????????????????????????????????? > > > > > > Paul Lam <paullin3...@gmail.com> ??2020??12??8?????? ????10:45?????? > > > > > >> ?????? LeaseRenewer ?? JVM ???????????????????????????? HDFS ?????????????? > > >> > > >> ?????????????????????????????????????????????? user1@cluserA???????? HDFS client ?????????????? > > >> > > >> Best, > > >> Paul Lam > > >> > > >>> 2020??12??7?? 18:11??zilong xiao <acidzz...@gmail.com> ?????? > > >>> > > >>> ??????????????????Flink SQL 1.11??????container????????????????Thread > > Dump??????????????LeaseRenewer > > >>> ??????????TIMED_WAITING???????????????????????????????????????????????????????????????????????????????? > > >>> > > >>> Flink version: 1.11 > > >>> State backend??filesystem > > >>> checkpoint interval: 60s > > >> > > >> > > > > >