From 523a62018a2ab4e963a5076efe92aa4014788e97 Mon Sep 17 00:00:00 2001 From: vinlee19 <1401597760@qq.com> Date: Tue, 30 Apr 2024 22:15:09 +0800 Subject: [PATCH] fix asncdcaddremove.sql error --- .../src/test/resources/db2_server/asncdcaddremove.sql | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/test/resources/db2_server/asncdcaddremove.sql b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/test/resources/db2_server/asncdcaddremove.sql index e5e59e0e2d..5ef4a46233 100644 --- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/test/resources/db2_server/asncdcaddremove.sql +++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/test/resources/db2_server/asncdcaddremove.sql @@ -198,7 +198,7 @@ SET stmtSQL = 'INSERT INTO ASNCDC.IBMSNAP_PRUNCNTL ( ' || ' (Select CURRENT_SERVER from sysibm.sysdummy1 ), ' || '''ASNCDC'', ' || '''CDC_' || tableschema || '_' || tablename || ''', ' || - ' ( SELECT CASE WHEN max(CAST(MAP_ID AS INT)) IS NULL THEN CAST(1 AS VARCHAR(10)) ELSE CAST(CAST(max(MAP_ID) AS INT) + 1 AS VARCHAR(10)) END AS MYINT from ASNCDC.IBMSNAP_PRUNCNTL ) ' || + ' ( SELECT CASE WHEN max(CAST(MAP_ID AS INT)) IS NULL THEN CAST(1 AS VARCHAR(10)) ELSE CAST(max(CAST(MAP_ID AS INT)) + 1 AS VARCHAR(10)) END AS MYINT from ASNCDC.IBMSNAP_PRUNCNTL ) ' || ' )'; EXECUTE IMMEDIATE stmtSQL;