Oracle sink Date 数据类型插入异常 为1970-01-01 13:18:00

Flink SQL script

CREATE TABLE source_DWD_PATIENT_INFO
(
TDATE DATE
) WITH (
'connector' = 'oraclelogminer-x',
'url' = 'jdbc:oracle:thin:@//xxx:1521/helowin',
'username' = 'xxx',
'password' = 'xxx',
'cat' = 'INSERT,UPDATE,DELETE',
'table' = 'FLINKUSER.DEMO',
'read-position' = 'time',
'start-time' = '1648459161000'
);
CREATE TABLE sink_DWD_PATIENT_INFO_871
(
TDATE DATE ,
PRIMARY KEY (TDATE) NOT ENFORCED
) WITH (
-- 'connector' = 'stream-x',
-- 'print' = 'true'
'connector' = 'oracle-x',
'url' = 'jdbc:oracle:thin:@//xxx:1521/helowin',
'username' = 'xxx',
'password' = 'xxx',
'table-name' = 'FLINKUSER.DEMO1',
'sink.all-replace' = 'true'
);
INSERT INTO sink_DWD_PATIENT_INFO_871
SELECT *
FROM source_DWD_PATIENT_INFO;

++++++++++++++++++++++++++++++++++++++++++++++++++
Oracle Table Info:

DROP TABLE "FLINKUSER"."DEMO";
CREATE TABLE "FLINKUSER"."DEMO" (
"TDATE" DATE
)

DROP TABLE "FLINKUSER"."DEMO1";
CREATE TABLE "FLINKUSER"."DEMO1" (
"TDATE" DATE
)

INSERT INTO "FLINKUSER"."DEMO" VALUES (TO_DATE('2022-03-29 19:59:27', 'SYYYY-MM-DD HH24:MI:SS'));
INSERT INTO "FLINKUSER"."DEMO" VALUES (TO_DATE('2022-03-29 20:01:57', 'SYYYY-MM-DD HH24:MI:SS'));
INSERT INTO "FLINKUSER"."DEMO" VALUES (TO_DATE('2022-03-29 20:06:36', 'SYYYY-MM-DD HH24:MI:SS'));
INSERT INTO "FLINKUSER"."DEMO" VALUES (TO_DATE('2022-03-29 20:08:59', 'SYYYY-MM-DD HH24:MI:SS'));
INSERT INTO "FLINKUSER"."DEMO" VALUES (TO_DATE('2022-03-29 20:10:16', 'SYYYY-MM-DD HH24:MI:SS'));

Inizia riproducendo lo script Flink SQL fornito con le tabelle Oracle DEMO e DEMO1, quindi traccia i percorsi di conversione DATE di source e sink. Confronta i valori inseriti con i timestamp previsti e identifica il punto in cui la data diventa 1970-01-01 13:18:00. Il lavoro è completato quando i valori DATE di Oracle mantengono la data e l’ora originali durante la scrittura nel sink.

Scritto dal modello di indicizzazione a partire dal testo della issue.