diff options
| author | Shixiong Zhu <shixiong@databricks.com> | 2015-12-17 13:23:48 -0800 |
|---|---|---|
| committer | Shixiong Zhu <shixiong@databricks.com> | 2015-12-17 13:23:48 -0800 |
| commit | 540b5aeadc84d1a5d61bda4414abd6bf35dc7ff9 (patch) | |
| tree | a04de7b7d914b3583d1fdb49a8ea3a05490e7519 /streaming | |
| parent | 8184568810e8a2e7d5371db2c6a0366ef4841f70 (diff) | |
| download | spark-540b5aeadc84d1a5d61bda4414abd6bf35dc7ff9.tar.gz spark-540b5aeadc84d1a5d61bda4414abd6bf35dc7ff9.tar.bz2 spark-540b5aeadc84d1a5d61bda4414abd6bf35dc7ff9.zip | |
[SPARK-12410][STREAMING] Fix places that use '.' and '|' directly in split
String.split accepts a regular expression, so we should escape "." and "|".
Author: Shixiong Zhu <shixiong@databricks.com>
Closes #10361 from zsxwing/reg-bug.
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/util/FileBasedWriteAheadLog.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/util/FileBasedWriteAheadLog.scala b/streaming/src/main/scala/org/apache/spark/streaming/util/FileBasedWriteAheadLog.scala index a99b570835..b946e0d8e9 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/util/FileBasedWriteAheadLog.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/util/FileBasedWriteAheadLog.scala @@ -253,7 +253,7 @@ private[streaming] object FileBasedWriteAheadLog { def getCallerName(): Option[String] = { val stackTraceClasses = Thread.currentThread.getStackTrace().map(_.getClassName) - stackTraceClasses.find(!_.contains("WriteAheadLog")).flatMap(_.split(".").lastOption) + stackTraceClasses.find(!_.contains("WriteAheadLog")).flatMap(_.split("\\.").lastOption) } /** Convert a sequence of files to a sequence of sorted LogInfo objects */ |