uros-b commented on code in PR #56526:
URL: https://github.com/apache/spark/pull/56526#discussion_r3431787265
##########
connector/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaMicroBatchStream.scala:
##########
@@ -357,7 +357,7 @@ private[kafka010] class KafkaMicroBatchStream(
}
}
} else {
- Some(latestPartitionOffsets)
Review Comment:
Note that PR description is now a bit stale. It still describes two changes
(call-site + companion defense-in-depth) and says the test calls
KafkaMicroBatchStream.metrics(..., Some(null)). The actual diff now is one
production-line change plus an instance-level test. Please update the
description accordingly.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
