search

allwefantasy / spark-binlog

A library for querying Binlog with Apache Spark structure streaming, for Spark SQL , DataFrames and [MLSQL](https://www.mlsql.tech).
Apache License 2.0
154 stars 54 forks source link

fix bug: 流程序异常中断产生.tmp结尾的offsets文件，重启不成功问题 #10

Closed bebee4java closed 4 years ago

bebee4java commented 4 years ago

流程序异常中断，checkpoint目录生成.tmp结尾的offsets文件，导致流程序重启失败，同样需要过滤掉.tmp结尾的文件。