From 21da2d4061312d0766bcddb319ca209946415e88 Mon Sep 17 00:00:00 2001 From: Star Zheng Date: Sat, 1 Apr 2023 10:06:37 +0800 Subject: [PATCH 1/2] =?UTF-8?q?fix:=20issue(#1729)=E4=BF=AE=E5=A4=8DJOB=5F?= =?UTF-8?q?WRITER=E5=80=BC=E9=94=99=E8=AF=AF=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/alibaba/datax/core/util/container/CoreConstant.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/java/com/alibaba/datax/core/util/container/CoreConstant.java b/core/src/main/java/com/alibaba/datax/core/util/container/CoreConstant.java index 6a0b6205..a1ca164d 100755 --- a/core/src/main/java/com/alibaba/datax/core/util/container/CoreConstant.java +++ b/core/src/main/java/com/alibaba/datax/core/util/container/CoreConstant.java @@ -105,7 +105,7 @@ public class CoreConstant { public static final String DATAX_JOB_POSTHANDLER_PLUGINNAME = "job.postHandler.pluginName"; // ----------------------------- 局部使用的变量 - public static final String JOB_WRITER = "reader"; + public static final String JOB_WRITER = "writer"; public static final String JOB_READER = "reader"; From 98600015e54903aaaa1169d360e3e42cab560a07 Mon Sep 17 00:00:00 2001 From: Star Zheng Date: Sat, 1 Apr 2023 10:18:46 +0800 Subject: [PATCH 2/2] =?UTF-8?q?fix:=20issue(#1695,#1700)fetchSingleValueWi?= =?UTF-8?q?thRetry=E6=96=B9=E6=B3=95=E5=AD=98=E5=9C=A8=E8=BF=9E=E6=8E=A5?= =?UTF-8?q?=E6=B3=84=E6=BC=8F=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../datax/plugin/writer/oceanbasev10writer/util/DbUtils.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/util/DbUtils.java b/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/util/DbUtils.java index 5138c9cb..e590fe6b 100644 --- a/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/util/DbUtils.java +++ b/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/util/DbUtils.java @@ -62,7 +62,7 @@ public class DbUtils { ++retry; LOG.warn("fetch value with {} error {}", query, e); } finally { - DBUtil.closeDBResources(result, stmt, null); + DBUtil.closeDBResources(result, stmt, conn); } } while (need_retry);