diff --git a/README.md b/README.md
index 23dfb2d0..681de048 100644
--- a/README.md
+++ b/README.md
@@ -152,3 +152,6 @@ This software is free to use under the Apache License [Apache license](https://g
- DataX开源用户交流群5
-
+- DataX开源用户交流群6
+ -
+
diff --git a/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/InsertTask.java b/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/InsertTask.java
index 522d91a5..968908ca 100644
--- a/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/InsertTask.java
+++ b/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/InsertTask.java
@@ -65,6 +65,7 @@ public class InsertTask implements Runnable {
this.writeRecordSql = writeRecordSql;
this.isStop = false;
this.deleteMeta = deleteMeta;
+ connHolder.initConnection();
}
void setWriterTask(ConcurrentTableWriterTask writerTask) {
@@ -151,7 +152,6 @@ public class InsertTask implements Runnable {
public void doMultiInsert(final List buffer, final boolean printCost, final long restrict) {
checkMemstore();
- connHolder.initConnection();
Connection conn = connHolder.getConn();
boolean success = false;
long cost = 0;
@@ -165,7 +165,6 @@ public class InsertTask implements Runnable {
} catch (InterruptedException e) {
LOG.info("thread interrupted ..., ignore");
}
- connHolder.initConnection();
conn = connHolder.getConn();
LOG.info("retry {}, start do batch insert, size={}", i, buffer.size());
checkMemstore();
diff --git a/odpsreader/src/main/java/com/alibaba/datax/plugin/reader/odpsreader/util/DESCipher.java b/odpsreader/src/main/java/com/alibaba/datax/plugin/reader/odpsreader/util/DESCipher.java
index dad82d50..82e97191 100644
--- a/odpsreader/src/main/java/com/alibaba/datax/plugin/reader/odpsreader/util/DESCipher.java
+++ b/odpsreader/src/main/java/com/alibaba/datax/plugin/reader/odpsreader/util/DESCipher.java
@@ -40,7 +40,7 @@ public class DESCipher {
*
*/
- public static final String KEY = "u4Gqu4Z8";
+ public static final String KEY = "DESDES";
private final static String DES = "DES";
diff --git a/odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/util/DESCipher.java b/odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/util/DESCipher.java
index bf7f5a88..4afead52 100755
--- a/odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/util/DESCipher.java
+++ b/odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/util/DESCipher.java
@@ -40,7 +40,7 @@ public class DESCipher {
*
*/
- public static final String KEY = "u4Gqu4Z8";
+ public static final String KEY = "DESDES";
private final static String DES = "DES";