Open StrongestNumber9 opened 2 months ago
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
Describe the bug
Software version
3.0.1