Yanjia Gary Li created HUDI-1018: ------------------------------------ Summary: Handle empty checkpoint better in delta streamer Key: HUDI-1018 URL: https://issues.apache.org/jira/browse/HUDI-1018 Project: Apache Hudi Issue Type: Improvement Reporter: Yanjia Gary Li
Right now we are handling empty string checkpoint in DeltaSync([https://github.com/apache/hudi/blob/master/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java#L260]) and different sources([https://github.com/apache/hudi/blob/master/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/KafkaOffsetGen.java#L58]). We should clean this up and put all logics into one place. -- This message was sent by Atlassian Jira (v8.3.4#803005)