diff --git a/chunjun-connectors/chunjun-connector-gbase8s/pom.xml b/chunjun-connectors/chunjun-connector-gbase8s/pom.xml
index bf317b4ee3..3d01871766 100644
--- a/chunjun-connectors/chunjun-connector-gbase8s/pom.xml
+++ b/chunjun-connectors/chunjun-connector-gbase8s/pom.xml
@@ -41,6 +41,8 @@
 			<artifactId>chunjun-connector-jdbc-base</artifactId>
 			<version>${project.version}</version>
 		</dependency>
+
+		<!-- 建议从(https://cdn.gbase.cn/products/27/czrl6z38BvTfEQS4uyQcS/gbasedbtjdbc_3.5.1.jar)下载此驱动jar包，并install本地-->
 		<dependency>
 			<groupId>com.gbasedbt.jdbc.Driver</groupId>
 			<artifactId>gbasedbt</artifactId>
diff --git a/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/sink/HdfsOrcOutputFormat.java b/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/sink/HdfsOrcOutputFormat.java
index 6adafddaad..75a8b53902 100644
--- a/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/sink/HdfsOrcOutputFormat.java
+++ b/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/sink/HdfsOrcOutputFormat.java
@@ -149,7 +149,7 @@ protected void openSource() {
     @Override
     // todo the deviation needs to be calculated accurately
     protected long getCurrentFileSize() {
-        return (long) (bytesWriteCounter.getLocalValue() * getDeviation());
+        return (long) ((bytesWriteCounter.getLocalValue() - lastWriteSize) * getDeviation());
     }
 
     @Override
diff --git a/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/sink/HdfsParquetOutputFormat.java b/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/sink/HdfsParquetOutputFormat.java
index 445c69d227..a182a4ca4d 100644
--- a/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/sink/HdfsParquetOutputFormat.java
+++ b/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/sink/HdfsParquetOutputFormat.java
@@ -156,7 +156,7 @@ protected void nextBlock() {
     public void flushDataInternal() {
         log.info(
                 "Close current parquet record writer, write data size:[{}]",
-                SizeUnitType.readableFileSize(bytesWriteCounter.getLocalValue()));
+                SizeUnitType.readableFileSize(bytesWriteCounter.getLocalValue() - lastWriteSize));
         try {
             if (writer != null) {
                 writer.close();
diff --git a/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/sink/HdfsTextOutputFormat.java b/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/sink/HdfsTextOutputFormat.java
index a35a733a33..2b54cf2912 100644
--- a/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/sink/HdfsTextOutputFormat.java
+++ b/chunjun-connectors/chunjun-connector-hdfs/src/main/java/com/dtstack/chunjun/connector/hdfs/sink/HdfsTextOutputFormat.java
@@ -77,7 +77,7 @@ protected void nextBlock() {
     public void flushDataInternal() {
         log.info(
                 "Close current text stream, write data size:[{}]",
-                SizeUnitType.readableFileSize(bytesWriteCounter.getLocalValue()));
+                SizeUnitType.readableFileSize(bytesWriteCounter.getLocalValue() - lastWriteSize));
 
         try {
             if (stream != null) {
diff --git a/chunjun-connectors/chunjun-connector-opengauss/pom.xml b/chunjun-connectors/chunjun-connector-opengauss/pom.xml
index d110e479bd..1f38710d82 100644
--- a/chunjun-connectors/chunjun-connector-opengauss/pom.xml
+++ b/chunjun-connectors/chunjun-connector-opengauss/pom.xml
@@ -47,7 +47,7 @@
 		<dependency>
 			<groupId>org.opengauss</groupId>
 			<artifactId>opengauss-jdbc</artifactId>
-			<version>5.0.1</version>
+			<version>5.0.1-og</version>
 		</dependency>
 	</dependencies>
 
diff --git a/chunjun-connectors/pom.xml b/chunjun-connectors/pom.xml
index 4e14d2d0bc..2d43e9eaa1 100755
--- a/chunjun-connectors/pom.xml
+++ b/chunjun-connectors/pom.xml
@@ -58,7 +58,7 @@
 		<module>chunjun-connector-greenplum</module>
 		<module>chunjun-connector-dm</module>
 		<module>chunjun-connector-gbase</module>
-		<module>chunjun-connector-gbase8s</module>
+<!--		<module>chunjun-connector-gbase8s</module>-->
 <!--		<module>chunjun-connector-gbasehk</module>-->
 		<module>chunjun-connector-clickhouse</module>
 		<module>chunjun-connector-saphana</module>
diff --git a/chunjun-core/src/main/java/com/dtstack/chunjun/sink/format/BaseFileOutputFormat.java b/chunjun-core/src/main/java/com/dtstack/chunjun/sink/format/BaseFileOutputFormat.java
index 3dba41f14b..7c5998f3ad 100644
--- a/chunjun-core/src/main/java/com/dtstack/chunjun/sink/format/BaseFileOutputFormat.java
+++ b/chunjun-core/src/main/java/com/dtstack/chunjun/sink/format/BaseFileOutputFormat.java
@@ -58,6 +58,7 @@ public abstract class BaseFileOutputFormat extends BaseRichOutputFormat {
     protected List<String> preCommitFilePathList = new ArrayList<>();
     protected long nextNumForCheckDataSize;
     protected long lastWriteTime = System.currentTimeMillis();
+    protected long lastWriteSize;
 
     @Override
     public void initializeGlobal(int parallelism) {
@@ -155,6 +156,7 @@ public void flushData() {
         if (rowsOfCurrentBlock != 0) {
             flushDataInternal();
             sumRowsOfBlock += rowsOfCurrentBlock;
+            lastWriteSize = bytesWriteCounter.getLocalValue();
             log.info(
                     "flush file:{}, rowsOfCurrentBlock = {}, sumRowsOfBlock = {}",
                     currentFileName,
diff --git a/chunjun-local-test/pom.xml b/chunjun-local-test/pom.xml
index e476e2142d..22f564d18b 100644
--- a/chunjun-local-test/pom.xml
+++ b/chunjun-local-test/pom.xml
@@ -51,58 +51,71 @@
 			<artifactId>chunjun-connector-stream</artifactId>
 			<version>${project.version}</version>
 		</dependency>
-		<dependency>
-			<groupId>com.dtstack.chunjun</groupId>
-			<artifactId>chunjun-connector-binlog</artifactId>
-			<version>${project.version}</version>
-		</dependency>
+		<!--rdb test start-->
+<!--		<dependency>-->
+<!--			<groupId>com.dtstack.chunjun</groupId>-->
+<!--			<artifactId>chunjun-connector-mysql</artifactId>-->
+<!--			<version>${project.version}</version>-->
+<!--		</dependency>-->
+		<!--rdb test end-->
+
+		<!--hdfs test start-->
+<!--		<dependency>-->
+<!--			<groupId>com.dtstack.chunjun</groupId>-->
+<!--			<artifactId>chunjun-connector-hdfs</artifactId>-->
+<!--			<version>${project.version}</version>-->
+<!--		</dependency>-->
+<!--		<dependency>-->
+<!--			<artifactId>hadoop-mapreduce-client-core</artifactId>-->
+<!--			<exclusions>-->
+<!--				<exclusion>-->
+<!--					<artifactId>commons-cli</artifactId>-->
+<!--					<groupId>commons-cli</groupId>-->
+<!--				</exclusion>-->
+<!--				<exclusion>-->
+<!--					<artifactId>snappy-java</artifactId>-->
+<!--					<groupId>org.xerial.snappy</groupId>-->
+<!--				</exclusion>-->
+<!--			</exclusions>-->
+<!--			<groupId>org.apache.hadoop</groupId>-->
+<!--			<version>2.7.5</version>-->
+<!--		</dependency>-->
+<!--		<dependency>-->
+<!--			<artifactId>hadoop-common</artifactId>-->
+<!--			<exclusions>-->
+<!--				<exclusion>-->
+<!--					<artifactId>gson</artifactId>-->
+<!--					<groupId>com.google.code.gson</groupId>-->
+<!--				</exclusion>-->
+<!--				<exclusion>-->
+<!--					<artifactId>commons-cli</artifactId>-->
+<!--					<groupId>commons-cli</groupId>-->
+<!--				</exclusion>-->
+<!--				<exclusion>-->
+<!--					<artifactId>snappy-java</artifactId>-->
+<!--					<groupId>org.xerial.snappy</groupId>-->
+<!--				</exclusion>-->
+<!--			</exclusions>-->
+<!--			<groupId>org.apache.hadoop</groupId>-->
+<!--			<version>2.7.5</version>-->
+<!--		</dependency>-->
+<!--		<dependency>-->
+<!--			<artifactId>hadoop-hdfs</artifactId>-->
+<!--			<exclusions>-->
+<!--				<exclusion>-->
+<!--					<artifactId>commons-cli</artifactId>-->
+<!--					<groupId>commons-cli</groupId>-->
+<!--				</exclusion>-->
+<!--				<exclusion>-->
+<!--					<artifactId>netty-all</artifactId>-->
+<!--					<groupId>io.netty</groupId>-->
+<!--				</exclusion>-->
+<!--			</exclusions>-->
+<!--			<groupId>org.apache.hadoop</groupId>-->
+<!--			<version>2.7.5</version>-->
+<!--		</dependency>-->
+		<!--hdfs test end-->
 
-		<dependency>
-			<groupId>com.dtstack.chunjun</groupId>
-			<artifactId>chunjun-connector-iceberg</artifactId>
-			<version>${project.version}</version>
-		</dependency>
-		<dependency>
-			<groupId>com.dtstack.chunjun</groupId>
-			<artifactId>chunjun-connector-mongodb</artifactId>
-			<version>${project.version}</version>
-		</dependency>
-
-		<dependency>
-			<groupId>com.dtstack.chunjun</groupId>
-			<artifactId>chunjun-connector-emqx</artifactId>
-			<version>${project.version}</version>
-		</dependency>
-		<dependency>
-			<groupId>com.dtstack.chunjun</groupId>
-			<artifactId>chunjun-connector-jdbc-base</artifactId>
-			<version>${project.version}</version>
-		</dependency>
-
-		<dependency>
-			<groupId>com.dtstack.chunjun</groupId>
-			<artifactId>chunjun-connector-mysql</artifactId>
-			<version>${project.version}</version>
-		</dependency>
-
-		<dependency>
-			<groupId>com.dtstack.chunjun</groupId>
-			<artifactId>chunjun-connector-kafka</artifactId>
-			<version>${project.version}</version>
-		</dependency>
-
-		<dependency>
-			<groupId>com.dtstack.chunjun</groupId>
-			<artifactId>chunjun-connector-kingbase</artifactId>
-			<version>${project.version}</version>
-		</dependency>
-
-		<!-- -->
-		<dependency>
-			<groupId>com.dtstack.chunjun</groupId>
-			<artifactId>chunjun-connector-ftp</artifactId>
-			<version>${project.version}</version>
-		</dependency>
 
 		<dependency>
 			<groupId>org.apache.flink</groupId>
@@ -110,12 +123,6 @@
 			<version>${flink.version}</version>
 		</dependency>
 
-		<dependency>
-			<groupId>com.dtstack.chunjun</groupId>
-			<artifactId>chunjun-connector-oceanbase</artifactId>
-			<version>master</version>
-		</dependency>
-
 		<dependency>
 			<groupId>org.apache.avro</groupId>
 			<artifactId>avro</artifactId>