sync data to doris from oracle #62901
Unanswered
yuanyong001
asked this question in
A - General / Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
problem:
[INVALID_ARGUMENT]Don't support flexible partial update when 'columns' is specified
program:
SET 'execution.checkpointing.interval' = '5s';
SET 'enable_unique_key_partial_update'=true;
CREATE TABLE SOURCE_T_NO_LOG (
ID INT,
NAME STRING,
AGE STRING,
SEX STRING,
ADDRESS STRING
) WITH (
'connector' = 'kafka',
'topic' = 'test_ogg', -- 替换为实际 topic
'properties.bootstrap.servers' = '192.168.21.99:9092',
'properties.group.id' = 'flink_ogg_consumer_test_ogg',
'format' = 'ogg-json',
'scan.startup.mode' = 'latest-offset' -- 根据需求调整起始位置
);
CREATE TABLE SINK_T_NO_LOG (
ID INT,
NAME STRING,
AGE STRING,
SEX STRING,
ADDRESS STRING
) WITH (
'connector' = 'doris',
'fenodes' = '192.11.21.96:8030',
'table.identifier' = 'rt_ods.ods_atz_t_no_log',
'username' = 'root',
'password' = 'abc123',
'sink.properties.format' = 'json',
'sink.properties.read_json_by_line' = 'true',
'sink.properties.strict_mode' = 'false',
'sink.properties.unique_key_update_mode' = 'UPDATE_FLEXIBLE_COLUMNS'
'sink.enable-delete' = 'true',
'sink.label-prefix' = 'oracle-sync-job-ogg-54353453465464'
);
INSERT INTO SINK_T_NO_LOG SELECT ID, NAME, AGE, SEX, ADDRESS FROM SOURCE_T_NO_LOG;
who can help me ?
Beta Was this translation helpful? Give feedback.
All reactions