Flink这个问题怎么解决？

Flink这个问题怎么解决？
Caused by: java.lang.RuntimeException: SplitFetcher thread 0 received unexpected exception while polling the records
at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:150)
at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:105)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
... 1 more
Caused by: java.io.IOException: Failed to read hologres binlog, failed reason:
at com.alibaba.ververica.connectors.hologres.jdbc.HologresJDBCBinlogShardSplitReader.binlogFetch(HologresJDBCBinlogShardSplitReader.java:106)
at com.alibaba.ververica.connectors.hologres.binlog.source.reader.AbstractHologresBinlogShardSplitReader.fetch(AbstractHologresBinlogShardSplitReader.java:131)
at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58)
at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:142)
... 6 more
Caused by: com.alibaba.hologres.client.exception.HoloClientException: shard id 5 fetch binlog fail
at com.alibaba.hologres.client.BinlogShardGroupReader$Collector.exceptionally(BinlogShardGroupReader.java:149)
at com.alibaba.hologres.client.impl.binlog.handler.BinlogActionHandler.doHandle(BinlogActionHandler.java:185)
at com.alibaba.hologres.client.impl.binlog.handler.BinlogActionHandler.handle(BinlogActionHandler.java:85)
at com.alibaba.hologres.client.impl.binlog.handler.BinlogActionHandler.handle(BinlogActionHandler.java:41)
at com.alibaba.hologres.client.impl.Worker.handle(Worker.java:94)
at com.alibaba.hologres.client.impl.Worker.run(Worker.java:123)
... 1 more
Caused by: com.alibaba.hologres.org.postgresql.util.PSQLException: ERROR: syntax error
at com.alibaba.hologres.org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2565)
at com.alibaba.hologres.org.postgresql.core.v3.QueryExecutorImpl.processCopyResults(QueryExecutorImpl.java:1224)
at com.alibaba.hologres.org.postgresql.core.v3.QueryExecutorImpl.startCopy(QueryExecutorImpl.java:906)
at com.alibaba.hologres.org.postgresql.core.v3.replication.V3ReplicationProtocol.initializeReplication(V3ReplicationProtocol.java:60)
at com.alibaba.hologres.org.postgresql.core.v3.replication.V3ReplicationProtocol.startLogical(V3ReplicationProtocol.java:44)
at com.alibaba.hologres.org.postgresql.replication.fluent.ReplicationStreamBuilder$1.start(ReplicationStreamBuilder.java:38)
at com.alibaba.hologres.org.postgresql.replication.fluent.logical.LogicalStreamBuilder.start(LogicalStreamBuilder.java:41)
at com.alibaba.hologres.client.impl.binlog.handler.BinlogActionHandler$ConnectionContext.init(BinlogActionHandler.java:139)
at com.alibaba.hologres.client.impl.binlog.handler.BinlogActionHandler.doHandle(BinlogActionHandler.java:180)
... 5 more