h | @viirya
Spark Technology Center
http://www.spark.tc/
--
View this message in context:
http://apache-spark-developers-list.1001551.n3.nabble.com/the-uniqueSource-in-StreamExecution-where-is-it-be-changed-please-tp22084p22087.html
Sent from the Apache
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:
