From d75865c6e81df2045ced006ab0ae15027b25104c Mon Sep 17 00:00:00 2001 From: qiaojialingithub <646274302@qq.com> Date: Mon, 26 Jun 2017 17:32:59 +0800 Subject: [PATCH] change run mode --- src/main/scala/cn/edu/thu/tsfile/TsFileWriterFactory.scala | 4 ---- src/test/scala/cn/edu/thu/tsfile/TSFileSuit.scala | 2 +- 2 files changed, 1 insertion(+), 5 deletions(-) diff --git a/src/main/scala/cn/edu/thu/tsfile/TsFileWriterFactory.scala b/src/main/scala/cn/edu/thu/tsfile/TsFileWriterFactory.scala index 8f83ca5..1c79083 100644 --- a/src/main/scala/cn/edu/thu/tsfile/TsFileWriterFactory.scala +++ b/src/main/scala/cn/edu/thu/tsfile/TsFileWriterFactory.scala @@ -16,8 +16,4 @@ private[tsfile] class TsFileWriterFactory(options: Map[String, String]) extends context: TaskAttemptContext): OutputWriter = { new TsFileOutputWriter(path, dataSchema, options, context) } - - override def newWriter(path: String): OutputWriter = { - throw new UnsupportedOperationException("newInstance with just path not supported") - } } diff --git a/src/test/scala/cn/edu/thu/tsfile/TSFileSuit.scala b/src/test/scala/cn/edu/thu/tsfile/TSFileSuit.scala index 3adb7dd..5061d54 100644 --- a/src/test/scala/cn/edu/thu/tsfile/TSFileSuit.scala +++ b/src/test/scala/cn/edu/thu/tsfile/TSFileSuit.scala @@ -35,7 +35,7 @@ class TSFileSuit extends FunSuite with BeforeAndAfterAll { new CreateTSFile().createTSFile2(tsfilePath2) spark = SparkSession .builder() - .config("spark.master", "localhost") + .config("spark.master", "local") .appName("TSFile test") .getOrCreate() }