diff --git a/piflow-bundle/config.properties b/piflow-bundle/config.properties index 62d76d2..580b151 100644 --- a/piflow-bundle/config.properties +++ b/piflow-bundle/config.properties @@ -1,4 +1,4 @@ -server.ip=10.0.86.97 +server.ip=10.0.86.239 server.port=8001 #spark.master=spark://10.0.86.89:7077 diff --git a/piflow-bundle/src/main/scala/cn/piflow/bundle/common/DoFlatMapStop.scala b/piflow-bundle/src/main/scala/cn/piflow/bundle/common/DoFlatMapStop.scala index a3b5c66..ff84dcc 100644 --- a/piflow-bundle/src/main/scala/cn/piflow/bundle/common/DoFlatMapStop.scala +++ b/piflow-bundle/src/main/scala/cn/piflow/bundle/common/DoFlatMapStop.scala @@ -14,7 +14,7 @@ class DoFlatMapStop extends ConfigurableStop{ val authorEmail: String = "ygang@cnic.cn" val description: String = "DoFlatMap Stop." val inportList: List[String] = List(PortEnum.DefaultPort.toString) - val outportList: List[String] = List(PortEnum.AnyPort.toString) + val outportList: List[String] = List(PortEnum.DefaultPort.toString) var SCRIPT: String = _ diff --git a/piflow-bundle/src/main/scala/cn/piflow/bundle/common/DoMapStop.scala b/piflow-bundle/src/main/scala/cn/piflow/bundle/common/DoMapStop.scala index 2546687..e79ed75 100644 --- a/piflow-bundle/src/main/scala/cn/piflow/bundle/common/DoMapStop.scala +++ b/piflow-bundle/src/main/scala/cn/piflow/bundle/common/DoMapStop.scala @@ -17,7 +17,7 @@ class DoMapStop extends ConfigurableStop{ val authorEmail: String = "ygang@cnic.cn" val description: String = "DoMap stop." val inportList: List[String] = List(PortEnum.DefaultPort.toString) - val outportList: List[String] = List(PortEnum.AnyPort.toString) + val outportList: List[String] = List(PortEnum.DefaultPort.toString) var targetSchema: StructType = null var SCRIPT: String = _ diff --git a/piflow-bundle/src/main/scala/cn/piflow/bundle/common/ExecuteSQLStop.scala b/piflow-bundle/src/main/scala/cn/piflow/bundle/common/ExecuteSQLStop.scala index 543d642..0c193fc 100644 --- a/piflow-bundle/src/main/scala/cn/piflow/bundle/common/ExecuteSQLStop.scala +++ b/piflow-bundle/src/main/scala/cn/piflow/bundle/common/ExecuteSQLStop.scala @@ -16,14 +16,12 @@ class ExecuteSQLStop extends ConfigurableStop{ val authorEmail: String = "ygang@cnic.cn" val description: String = "ExecuteSQL Stop " val inportList: List[String] = List(PortEnum.DefaultPort.toString) - val outportList: List[String] = List(PortEnum.AnyPort.toString) + val outportList: List[String] = List(PortEnum.DefaultPort.toString) var sql: String = _ var bundle2TableNames: String = _ - - override def perform(in: JobInputStream, out: JobOutputStream, pec: JobContext): Unit = {