NULL_RETURNS in KafkaBatchSliceCollection.java: 71

[StrongestNumber9]

Describe the bug

 *** CID 1594360:    (NULL_RETURNS)
/src/main/java/com/teragrep/pth_06/scheduler/KafkaBatchSliceCollection.java: 71 in com.teragrep.pth_06.scheduler.KafkaBatchSliceCollection.processRange(org.apache.spark.sql.connector.read.streaming.Offset, org.apache.spark.sql.connector.read.streaming.Offset)()
65             this.kq = kq;
66         }
67     
68         public KafkaBatchSliceCollection processRange(Offset start, Offset end) {
69             KafkaOffset kafkaStartOffset = ((DatasourceOffset)start).getKafkaOffset();
70             KafkaOffset kafkaEndOffset = ((DatasourceOffset)end).getKafkaOffset();
>>>     CID 1594360:    (NULL_RETURNS)
>>>     Dereferencing a pointer that might be "null" "kafkaEndOffset" when calling "generate".
71             KafkaBatchSliceCollection rv = generate(kafkaStartOffset, kafkaEndOffset);
72             LOGGER.debug("processRange(): arg start " + start + " arg end: " + end + " rv: " + rv );
73             return rv;
74         }
75     
76         private KafkaBatchSliceCollection generate(KafkaOffset start, KafkaOffset end) {
/src/main/java/com/teragrep/pth_06/scheduler/KafkaBatchSliceCollection.java: 71 in com.teragrep.pth_06.scheduler.KafkaBatchSliceCollection.processRange(org.apache.spark.sql.connector.read.streaming.Offset, org.apache.spark.sql.connector.read.streaming.Offset)()
65             this.kq = kq;
66         }
67     
68         public KafkaBatchSliceCollection processRange(Offset start, Offset end) {
69             KafkaOffset kafkaStartOffset = ((DatasourceOffset)start).getKafkaOffset();
70             KafkaOffset kafkaEndOffset = ((DatasourceOffset)end).getKafkaOffset();
>>>     CID 1594360:    (NULL_RETURNS)
>>>     Dereferencing a pointer that might be "null" "kafkaStartOffset" when calling "generate".
71             KafkaBatchSliceCollection rv = generate(kafkaStartOffset, kafkaEndOffset);
72             LOGGER.debug("processRange(): arg start " + start + " arg end: " + end + " rv: " + rv );
73             return rv;
74         }
75     
76         private KafkaBatchSliceCollection generate(KafkaOffset start, KafkaOffset end) {

Software version

3.0.1