diff options
| author | Kousuke Saruta <sarutak@oss.nttdata.co.jp> | 2016-06-20 15:12:40 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2016-06-20 15:12:40 -0700 |
| commit | 6daa8cf1a642a669cd3a0305036c4390e4336a73 (patch) | |
| tree | 8ec179571b5cfc96dfe17eb959322688446b8b50 /sql | |
| parent | b99129cc452defc266f6d357f5baab5f4ff37a36 (diff) | |
| download | spark-6daa8cf1a642a669cd3a0305036c4390e4336a73.tar.gz spark-6daa8cf1a642a669cd3a0305036c4390e4336a73.tar.bz2 spark-6daa8cf1a642a669cd3a0305036c4390e4336a73.zip | |
[SPARK-16061][SQL][MINOR] The property "spark.streaming.stateStore.maintenanceInterval" should be renamed to "spark.sql.streaming.stateStore.maintenanceInterval"
## What changes were proposed in this pull request?
The property spark.streaming.stateStore.maintenanceInterval should be renamed and harmonized with other properties related to Structured Streaming like spark.sql.streaming.stateStore.minDeltasForSnapshot.
## How was this patch tested?
Existing unit tests.
Author: Kousuke Saruta <sarutak@oss.nttdata.co.jp>
Closes #13777 from sarutak/SPARK-16061.
Diffstat (limited to 'sql')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStore.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStore.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStore.scala index 9948292470..066765324a 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStore.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/StateStore.scala @@ -115,7 +115,7 @@ case class KeyRemoved(key: UnsafeRow) extends StoreUpdate */ private[sql] object StateStore extends Logging { - val MAINTENANCE_INTERVAL_CONFIG = "spark.streaming.stateStore.maintenanceInterval" + val MAINTENANCE_INTERVAL_CONFIG = "spark.sql.streaming.stateStore.maintenanceInterval" val MAINTENANCE_INTERVAL_DEFAULT_SECS = 60 private val loadedProviders = new mutable.HashMap[StateStoreId, StateStoreProvider]() |