Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

flink sql postgres cdc 模式下报错 #37

Closed
lzzcj opened this issue Sep 17, 2020 · 4 comments
Closed

flink sql postgres cdc 模式下报错 #37

lzzcj opened this issue Sep 17, 2020 · 4 comments

Comments

@lzzcj
Copy link

lzzcj commented Sep 17, 2020

[ERROR] Could not execute SQL statement. Reason:
org.postgresql.util.PSQLException: 错误: 无法访问文件 "decoderbufs": No such file or directory
请问这是什么原因,貌似是pg的问题,用的pg10 window版本,请问有什么解决办法吗?

@shizhengchao
Copy link
Contributor

加上这个options试下

'debezium.plugin.name' = 'pgoutput'

@lzzcj
Copy link
Author

lzzcj commented Sep 21, 2020

加上这个options试下

'debezium.plugin.name' = 'pgoutput'

可以的,解决了!

@lzzcj lzzcj closed this as completed Sep 21, 2020
@civetming
Copy link

'debezium.plugin.name' = 'pgoutput' 加在哪里呀

@future94
Copy link

future94 commented Aug 5, 2022

'debezium.plugin.name' = 'pgoutput' 加在哪里呀

table sql加在WITH('decoding.plugin.name' = 'pgoutput')

dataStream加在PostgreSQLSource.<String>builder().decodingPluginName("pgoutput").build()

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

4 participants