From ed1c4e47fa37e8887bb9ead233ca11a1722a5e71 Mon Sep 17 00:00:00 2001 From: lj044500 <1261005343@qq.com> Date: Tue, 4 Sep 2018 10:46:01 +0800 Subject: [PATCH] add folder xml file dispose --- .../src/main/scala/cn/piflow/bundle/xml/FolderXmlParser.scala | 1 - 1 file changed, 1 deletion(-) diff --git a/piflow-bundle/src/main/scala/cn/piflow/bundle/xml/FolderXmlParser.scala b/piflow-bundle/src/main/scala/cn/piflow/bundle/xml/FolderXmlParser.scala index 1b3fb86..3257f2a 100644 --- a/piflow-bundle/src/main/scala/cn/piflow/bundle/xml/FolderXmlParser.scala +++ b/piflow-bundle/src/main/scala/cn/piflow/bundle/xml/FolderXmlParser.scala @@ -22,7 +22,6 @@ class FolderXmlParser extends ConfigurableStop{ var rowTag:String = _ var xmlpath:String = _ - override def perform(in: JobInputStream, out: JobOutputStream, pec: JobContext): Unit = { val spark = pec.get[SparkSession]()