From cc7a3f8474975e49a5b4e87c9ae9d8ea0185fc9f Mon Sep 17 00:00:00 2001
From: Kousuke Saruta <sarutak@oss.nttdata.co.jp>
Date: Fri, 10 Mar 2017 11:59:47 -0800
Subject: [PATCH] Fix the logic about creating name of temporary checkpoint
 directory

---
 .../org/apache/spark/sql/streaming/StreamingQueryManager.scala  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sql/core/src/main/scala/org/apache/spark/sql/streaming/StreamingQueryManager.scala b/sql/core/src/main/scala/org/apache/spark/sql/streaming/StreamingQueryManager.scala
index 38edb40dfb78..be0b4ff0efd7 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/streaming/StreamingQueryManager.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/streaming/StreamingQueryManager.scala
@@ -206,7 +206,7 @@ class StreamingQueryManager private[sql] (sparkSession: SparkSession) {
       if (useTempCheckpointLocation) {
         // Delete the temp checkpoint when a query is being stopped without errors.
         deleteCheckpointOnStop = true
-        Utils.createTempDir(namePrefix = s"temporary").getCanonicalPath
+        Utils.createTempDir(namePrefix = s"temporary").getCanonicalFile.toURI.toString
       } else {
         throw new AnalysisException(
           "checkpointLocation must be specified either " +