spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "萝卜丝炒饭" <>
Subject the uniqueSource in StreamExecution, where is it be changed please?
Date Sat, 05 Aug 2017 05:00:00 GMT
Hi all,

These days I am learning the code about the StreamExecution.
In the method constructNextBatch(about line 365), I found the value of latestOffsets changed
but I can not find where the s.getOffset of uniqueSource is  changed.
here is the code link:

Would you like help understand it please?

View raw message