flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard

Oracle add data has error

Open ccczhouxin opened this issue 1 year ago • 1 comments

Search before asking

  • [X] I searched in the issues and found nothing similar.

Flink version

1.18.1

Flink CDC version

3.0.0

Database and its version

oracle 11g

Minimal reproduce step

I run the document at https://ververica.github.io/flink-cdc-connectors/release-3.0/content/connectors/oracle-cdc.html,when i add a data to table,it has some error
Properties debeziumProperties = new Properties(); debeziumProperties.setProperty("log.mining.strategy", "online_catalog"); debeziumProperties.setProperty("include.schema.changes", "true"); debeziumProperties.setProperty("value.converter.schemas.enable", "true");

    OracleSourceBuilder.OracleIncrementalSource oracleChangeEventSource =
            new OracleSourceBuilder()
                    .hostname("hostname")
                    .port(1521)
                    .databaseList("ORCL")
                    .schemaList("FLINKUSER")
                    .tableList("FLINKUSER.CREATETABLE")
                    .username("flinkuser")
                    .password("flinkpw")
                    .deserializer(new JsonDebeziumDeserializationSchema())
                    .includeSchemaChanges(true) // output the schema changes as well
                    .startupOptions(StartupOptions.initial())
                    .debeziumProperties(debeziumProperties)
                    .splitSize(2)
                    .build();

    StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
    env.enableCheckpointing(3000L);

    DataStreamSource oracleChangeEventStream = env.fromSource(
                    oracleChangeEventSource,
                    WatermarkStrategy.noWatermarks(),
                    "OracleParallelSource")
            .setParallelism(4)
            .setParallelism(1);

    oracleChangeEventStream.print();

image

What did you expect to see?

Is it my configuration problem

What did you see instead?

null error

Anything else?

No response

Are you willing to submit a PR?

  • [X] I'm willing to submit a PR!

ccczhouxin avatar Feb 02 '24 02:02 ccczhouxin

When i add column at table,id has other error. image

ccczhouxin avatar Feb 04 '24 05:02 ccczhouxin

Closing this issue as it has been migrated to Apache Jira.

PatrickRen avatar Apr 09 '24 05:04 PatrickRen