Skip to content

Commit

Permalink
change run mode
Browse files Browse the repository at this point in the history
  • Loading branch information
qiaojialin committed Jun 26, 2017
1 parent f8d2572 commit d75865c
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 5 deletions.
4 changes: 0 additions & 4 deletions src/main/scala/cn/edu/thu/tsfile/TsFileWriterFactory.scala
Original file line number Diff line number Diff line change
Expand Up @@ -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")
}
}
2 changes: 1 addition & 1 deletion src/test/scala/cn/edu/thu/tsfile/TSFileSuit.scala
Original file line number Diff line number Diff line change
Expand Up @@ -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()
}
Expand Down

0 comments on commit d75865c

Please sign in to comment.