File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
clients/da-vinci-client/src/main/java/com/linkedin/davinci Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -224,13 +224,13 @@ public synchronized CompletableFuture<Void> subscribe(
224224
225225 VersionBackend savedVersion = daVinciCurrentVersion ;
226226 List <Integer > partitionList = daVinciCurrentVersion .getPartitions (partitions );
227- if (checkpointInfo .getAllPartitionsTimestamp () != null ) {
227+ if (checkpointInfo != null && checkpointInfo .getAllPartitionsTimestamp () != null ) {
228228 Map <Integer , Long > timestamps = new HashMap <>();
229229 for (int partition : partitionList ) {
230230 timestamps .put (partition , checkpointInfo .getAllPartitionsTimestamp ());
231231 }
232232 checkpointInfo .setTimestampsMap (timestamps );
233- } else if (checkpointInfo .isSeekToTail ()) {
233+ } else if (checkpointInfo != null && checkpointInfo .isSeekToTail ()) {
234234 Map <Integer , PubSubPosition > positionMap = new HashMap <>();
235235 for (int partition : partitionList ) {
236236 positionMap .put (partition , PubSubSymbolicPosition .LATEST );
You can’t perform that action at this time.
0 commit comments