Flink CDC synchronizes Oracle data to Kafka in real-time. The Oracle database
has set up sharded storage, and when starting a Flink job, an error occurs
directly. Using the same configuration, tables without sharded storage can be
synchronized normally. Please help
configuration????String ddl = "CREATE TABLE rm_address_oracle (\n" +
" ID STRING,\n" +
" FULL_NAME STRING,\n" +
" NAME STRING,\n" +
" SPEC_ID STRING,\n" +
" SHARDING_ID STRING,\n" +
" REGION_ID STRING,\n" +
" PARENT_ID STRING,\n" +
" PRIMARY KEY (ID) NOT ENFORCED\n" +
") WITH (\n" +
" 'connector' = 'oracle-cdc',\n" +
" 'hostname' = '',\n" +
" 'port' = '',\n" +
" 'username' = '',\n" +
" 'password' = '',\n" +
" 'database-name' = '',\n" +
" 'schema-name' = '', \n" +
" 'table-name' = 'RM_ADDRESS_TT',\n" +
" 'debezium.database.tablename.case.insensitive' = 'false',\n" +
" 'debezium.log.mining.strategy' = 'online_catalog',\n" +
" 'debezium.log.mining.continuous.mine' = 'true',\n" +
" 'debezium.snapshot.mode' = 'initial',\n" +
" 'debezium.capture.mode' = 'incremental',\n" +
"\t'debezium.snapshot.fetch.size' = '1000',\n" +
"\t'debezium.history.storage' =
'io.debezium.storage.kafka.history.KafkaHistory',\n" +
"\t'debezium.history.kafka.topic' = 'HISTORICAL_DATA',\n" +
" 'debezium.history.producer.bootstrap.servers' = '',\n" +
" 'debezium.history.consumer.bootstrap.servers' = '',\n" +
"\t'debezium.snapshot.locking.mode' = 'minimal',\n" +
" 'debezium.snapshot.include.collection.list' = 'RM_ADDRESS_TT'\n" +
");";
report errors????io.debezium.DebeziumException: The db history topic or its
content is fully or partially missing. Please check database history topic
configuration and re-execute
Kafka Historical Theme????
Table based storage of information??
PARTITION "P371"
PCTFREE 10 INITRANS 2 MAXTRANS 255 NOLOGGING
STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645
PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1
BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT)
TABLESPACE "HA_TBS" ,
PARTITION "P398"
PCTFREE 10 INITRANS 2 MAXTRANS 255 NOLOGGING
STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645
PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1
BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT)
TABLESPACE "HA_TBS" ,
PARTITION "P379"
PCTFREE 10 INITRANS 2 MAXTRANS 255 NOLOGGING
STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645
PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1
BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT)
TABLESPACE "HA_TBS" ,
PARTITION "P391"
PCTFREE 10 INITRANS 2 MAXTRANS 255 NOLOGGING
STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645
PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1
BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT)
TABLESPACE "HA_TBS" ,
PARTITION "P373"
PCTFREE 10 INITRANS 2 MAXTRANS 255 NOLOGGING
STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645
PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1
BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT)
TABLESPACE "HA_TBS" ,
PARTITION "P392"
PCTFREE 10 INITRANS 2 MAXTRANS 255 NOLOGGING
STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645
PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1
BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT)
TABLESPACE "HA_TBS" ,
PARTITION "P372"
PCTFREE 10 INITRANS 2 MAXTRANS 255 NOLOGGING
STORAGE(INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645
PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1
BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT)
TABLESPACE "HA_TBS" ,
PARTITION "P393"
??????????
[email protected]
