heartneo opened a new issue, #9193: URL: https://github.com/apache/seatunnel/issues/9193
### Search before asking - [x] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened Caused by: org.postgresql.util.PSQLException: ERROR: must be superuser to create FOR ALL TABLES publication at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2553) at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2285) at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:323) at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:481) at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:401) at org.postgresql.jdbc.PgStatement.executeWithFlags(PgStatement.java:322) at org.postgresql.jdbc.PgStatement.executeCachedSql(PgStatement.java:308) at org.postgresql.jdbc.PgStatement.executeWithFlags(PgStatement.java:284) at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:279) at io.debezium.connector.postgresql.connection.PostgresReplicationConnection.initPublication(PostgresReplicationConnection.java:169) ... 13 more at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:220) ### SeaTunnel Version 2.3.10版本 postgresql cdc 使用pg普通账号同步单表 提示需要需要管理员及所有表发布权限，如果使用管理员账号会在发布表中发布所有表，请帮助分析同步单表需要发布所有表的原因 ### SeaTunnel Config ```conf env { # You can set engine configuration here execution.parallelism = 1 job.mode = "STREAMING" checkpoint.interval = 5000 read_limit.bytes_per_second=7000000 read_limit.rows_per_second=400 } source { Postgres-CDC { plugin_output = "customers_Postgre_cdc" username = "xxx" password = "xxx" database-names = ["xxx"] schema-names = ["xxx"] table-names = ["xx.xx.xx"] base-url = "jdbc:postgresql://xx:xx/xx" } } sink { Doris { fenodes = "xx:xx" username = "xx" password = "xx" database = "xx" table = "xx" sink.enable-2pc = "true" sink.enable-delete = "true" sink.label-prefix = "test-sync" doris.config = { format = "json" read_json_by_line="true" } } } ``` ### Running Command ```shell cluster ``` ### Error Exception ```log 管理员账号可以同步但发布所有表 ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version _No response_ ### Screenshots _No response_ ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [x] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
