szehon-ho commented on code in PR #56042:
URL: https://github.com/apache/spark/pull/56042#discussion_r3293747674
##########
sql/pipelines/src/main/scala/org/apache/spark/sql/pipelines/graph/GraphValidations.scala:
##########
@@ -126,8 +150,21 @@ trait GraphValidations extends Logging {
)
}
case _: TemporaryView =>
- // Temporary views' flows are allowed to be either streaming or
batch, so no
- // validation needs to be done for them
+ // Temporary views' flows are generally allowed to be either
streaming or batch.
+ resolvedFlow match {
+ case _: AutoCdcMergeFlow =>
+ // The exception is AutoCDC flows, which require require a
streaming-table sink to
Review Comment:
nit: duplicated word — should be "which require a streaming-table sink"
(drop the extra "require").
--
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]
