[ https://issues.apache.org/jira/browse/HUDI-1018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17134533#comment-17134533 ]
Yanjia Gary Li commented on HUDI-1018: -------------------------------------- [~Litianye] since we solve this ticket together with [https://github.com/apache/hudi/pull/1719]. Please close this once merged. > 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 > Components: DeltaStreamer > Reporter: Yanjia Gary Li > Assignee: Tianye Li > Priority: Major > > 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)