From fc5d7a1c59f8769dffac145a7c7e8dc533a7fc65 Mon Sep 17 00:00:00 2001 From: Takuya UESHIN Date: Thu, 9 Aug 2018 02:27:23 +0900 Subject: [PATCH] Fix. --- .../spark/sql/execution/streaming/MicroBatchExecution.scala | 2 +- .../streaming/state/SymmetricHashJoinStateManager.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MicroBatchExecution.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MicroBatchExecution.scala index d6cdc6d5443f7..b1c91ac94b268 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MicroBatchExecution.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/MicroBatchExecution.scala @@ -396,7 +396,7 @@ class MicroBatchExecution( reader.commit(reader.deserializeOffset(off.json)) case (src, _) => throw new IllegalArgumentException( - s"Unknows source is found at constructNextBatch: $src") + s"Unknown source is found at constructNextBatch: $src") } } else { throw new IllegalStateException(s"batch ${currentBatchId - 1} doesn't exist") diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/SymmetricHashJoinStateManager.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/SymmetricHashJoinStateManager.scala index 4676db29b20b3..6e7cd2db213d2 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/SymmetricHashJoinStateManager.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/SymmetricHashJoinStateManager.scala @@ -275,7 +275,7 @@ class SymmetricHashJoinStateManager( s.copy(desc = newDesc(desc)) -> value case (s, _) => throw new IllegalArgumentException( - s"Unknown state store custom metric is found at metrics: $s") + s"Unknown state store custom metric is found at metrics: $s") } ) }