nwangtw commented on a change in pull request #3223: fix saving and restoring
checkpoint from dlog
URL: https://github.com/apache/incubator-heron/pull/3223#discussion_r268899344
##########
File path: heron/io/dlog/src/java/org/apache/heron/dlog/DLInputStream.java
##########
@@ -100,6 +60,25 @@ private static LogRecordWithInputStream
nextLogRecord(LogReader reader) throws I
}
}
+ public long getNumOfBytesRead() {
+ return numOfBytesRead;
+ }
+
+ /**
+ * Get input stream representing next entry in the
+ * ledger.
+ *
+ * @return input stream, or null if no more entries
+ */
+ private LogRecordWithInputStream nextLogRecord() throws IOException {
+ try {
+ return nextLogRecord(reader);
+ } catch (EndOfStreamException e) {
+ eos = true;
Review comment:
Could it be helpful to have a log here?
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
