HeartSaVioR commented on a change in pull request #26108: [SPARK-26154][SS]
Streaming left/right outer join should not return outer nulls for already
matched rows
URL: https://github.com/apache/spark/pull/26108#discussion_r335254184
##########
File path:
sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala
##########
@@ -1069,6 +1069,16 @@ object SQLConf {
.checkValue(v => Set(1, 2).contains(v), "Valid versions are 1 and 2")
.createWithDefault(2)
+ val STREAMING_JOIN_STATE_FORMAT_VERSION =
Review comment:
What you see "version" in state store denotes "batchId", which is different
from semantic of "version" in here which denotes the difference of schema - I
know that's confusing - not sure why "version" is taken instead of "batch" or
"epoch" in state store. We already mixed up multiple terms to denote the same
(or similar - epoch is not strictly same as batch when it's being used in
continuous mode, as there's no micro-batch).
----------------------------------------------------------------
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
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
