问答 Oracle LogMiner + Oracle Time 类型数据错误

Oracle LogMiner + Oracle Time 类型数据错误

   爱吃火锅    发布于 2022-03-15 14:37 最新回复 2022-03-15 15:00  来自于   爱吃火锅  201  1

Sink 表 数据

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user57/question/1e5f17520d1c2df3ddc21e6b535b18c2..jpg


FlinkX SQL script

CREATE TABLE source
(
ID bigint,
TTIME DATE ,
TTIMESTAMP TIMESTAMP
) WITH (
'connector' = 'oraclelogminer-x'
,'url' = 'jdbc:oracle:thin:@xxx:1521:helowin'
,'username' = 'xxx'
,'password' = 'xxx'
,'cat' = 'insert,delete,update'
,'table' = 'xxx'
-- ,'timestamp-format.standard' = 'SQL'
);

CREATE TABLE sink
(
ID bigint primary key,
TTIME DATE ,
TTIMESTAMP TIMESTAMP
) WITH (
'connector' = 'oracle-x',
'url' = 'jdbc:oracle:thin:@xxx:1521:helowin',
'table-name' = 'xxx',
'username' = 'xxx',
'password' = 'xxx'
);

insert into sink
select *
from source u;

INSERT INTO "xxx"."DEMO" VALUES ('1', TO_DATE('2022-03-15 14:17:23', 'SYYYY-MM-DD HH24:MI:SS'), TO_TIMESTAMP('2022-03-15 14:17:25.000000', 'SYYYY-MM-DD HH24:MI:SS:FF6'));

1条回答
爱吃火锅
回复于 2022-03-15 15:00

我看了下 oracle sink 端的 rowData 数据 Date 类型的数据为19066,在做logminner +stream 数据正常输出 ,为什么对接Oracle会发生这样的问题


http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user57/answer/3710334f5497b764b9f9c484a510b56e..png

0 0
社区公告
  • 大数据领域最专业的产品&技术交流社区,专注于探讨与分享大数据领域有趣又火热的信息,专业又专注的数据人园地

最新活动更多
微信扫码获取数字化转型资料
钉钉扫码加入技术交流群