yystopf
/
piflow
forked from opensci/piflow
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

GetHttp ,Posthttp

This commit is contained in:
yanfqidong0604 2018-10-19 08:57:19 +08:00
parent e0d20b842b
commit b2943ce928
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
piflow-bundle/src/main/scala/cn/piflow/bundle/url/PostUrl.scala
View File

@ -33,7 +33,7 @@ class PostUrl extends ConfigurableStop{
override def perform(in: JobInputStream, out: JobOutputStream, pec: JobContext): Unit = {
val spark = pec.get[SparkSession]()
// val path = "hdfs://10.0.86.89:9000/yg/test.json"
// val jsonPath = "hdfs://10.0.86.89:9000/yg/test.json"
// val path = "hdfs://10.0.86.89:9000/xjzhu/example.json"