diff --git a/piflow-bundle/pom.xml b/piflow-bundle/pom.xml
index 2333dba..8ec6be3 100644
--- a/piflow-bundle/pom.xml
+++ b/piflow-bundle/pom.xml
@@ -170,11 +170,7 @@
             <artifactId>ojdbc</artifactId>
             <version>6.0.0</version>
         </dependency>
-        <dependency>
-            <groupId>jdbc_oracle</groupId>
-            <artifactId>ojdbc</artifactId>
-            <version>5.0.0</version>
-        </dependency>
+
 
         <!-- https://mvnrepository.com/artifact/org.apache.flume/flume-ng-core -->
         <dependency>
diff --git a/piflow-bundle/src/main/scala/cn/piflow/bundle/jdbc/JdbcReadFromOracle.scala b/piflow-bundle/src/main/scala/cn/piflow/bundle/jdbc/JdbcReadFromOracle.scala
index d4faa94..ec1d505 100644
--- a/piflow-bundle/src/main/scala/cn/piflow/bundle/jdbc/JdbcReadFromOracle.scala
+++ b/piflow-bundle/src/main/scala/cn/piflow/bundle/jdbc/JdbcReadFromOracle.scala
@@ -50,8 +50,9 @@ class JdbcReadFromOracle extends ConfigurableStop{
 
     val filedNames: Array[String] = schame.split(",")
     var rowsArr:ArrayBuffer[ArrayBuffer[Any]]=ArrayBuffer()
+    var rowArr:ArrayBuffer[Any]=ArrayBuffer()
     while (rs.next()){
-      var rowArr:ArrayBuffer[Any]=ArrayBuffer()
+      rowArr.clear()
       for(fileName <- filedNames){
         val name_type: Array[String] = fileName.split("\\.")
         val name: String = name_type(0)
diff --git a/piflow-bundle/src/main/scala/cn/piflow/bundle/jdbc/JdbcWriteToOracle.scala b/piflow-bundle/src/main/scala/cn/piflow/bundle/jdbc/JdbcWriteToOracle.scala
index de05483..20238ad 100644
--- a/piflow-bundle/src/main/scala/cn/piflow/bundle/jdbc/JdbcWriteToOracle.scala
+++ b/piflow-bundle/src/main/scala/cn/piflow/bundle/jdbc/JdbcWriteToOracle.scala
@@ -26,7 +26,7 @@ class JdbcWriteToOracle extends ConfigurableStop{
     val inDF: DataFrame = in.read()
 
     Class.forName("oracle.jdbc.driver.OracleDriver")
-    val con: Connection = DriverManager.getConnection("jdbc:oracle:thin:@10.0.86.237:1521/newdb","my","bigdata")
+    val con: Connection = DriverManager.getConnection(url,user,password)
     val star: Statement = con.createStatement()
 
     val fileNames: Array[String] = inDF.columns