Skip to content

Conversation

@liujishui87
Copy link

…eption caused by not finding the table in PostgreSQL version 17.,JDK is JDK21(#9798)

Purpose of this pull request

Does this PR introduce any user-facing change?

yes

How was this patch tested?

env {

You can set engine configuration here

execution.parallelism = 1
job.mode = "STREAMING"
checkpoint.interval = 5000
}

source {
Postgres-CDC {
username = "postgres"
password = "123456"
database-names = ["esep"]
table-names = ["esep.public.arc_meter"]
schema-names = ["public"]
startup.mode = "initial"
slot.name = "seatunnel_slot"
decode.plugin.name = "pgoutput"
url = "jdbc:postgresql://127.0.0.1:5432/postgres?loggerLevel=OFF"
}
}

sink {
jdbc {
url = "jdbc:mysql:/127.0.0.1:3306/esep?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true"
driver = "com.mysql.cj.jdbc.Driver"
username = "root"
password = "123456"
generate_sink_sql = true
database = "esep"
table = "arc_meter"
schema_save_mode = "CREATE_SCHEMA_WHEN_NOT_EXIST"
data_save_mode="APPEND_DATA"
}
}

Sync is ok.

#9798

…ption caused by not finding the table in PostgreSQL version 17.,JDK is JDK21(apache#9798)
@davidzollo
Copy link
Contributor

Please enable it can work in your forked repository, you can refer to the URL https://github.com/apache/seatunnel/pull/10058/checks?check_run_id=55257868929
image

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants