Github user xuanyuanking commented on a diff in the pull request:
https://github.com/apache/spark/pull/21293#discussion_r187598365
--- Diff: core/src/main/scala/org/apache/spark/SparkEnv.scala ---
@@ -227,6 +228,7 @@ object SparkEnv extends Logging {
mockOutputCommitCoordinator: Option[OutputCommitCoordinator] =
None): SparkEnv = {
val isDriver = executorId == SparkContext.DRIVER_IDENTIFIER
+ val isContinuous = conf.getBoolean("spark.streaming.continuousMode",
false)
--- End diff --
Yep, I agree, we are now trying to set this in physical plan, not in user
config.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
