i.d.c.p.connection.WalPositionLocator : First LSN ‘LSN{1FB5/4E7D8E28}’ received d.c.p.PostgresStreamingChangeEventSource : WAL resume position ‘LSN{1FB5/4E7D8E28}’ discovered ] io.debezium.jdbc.JdbcConnection : Connection gracefully closed
有没有哪位大佬知道,这是没获取到日志的顺序吗还是怎么的?怎么解决?[阿里云实时计算 Flink版]
「点点赞赏,手留余香」
还没有人赞赏,快来当第一个赞赏的人吧!
这是一个报错信息,表明您在使用 Flink 进行数据同步时,没有正确地获取到数据库中的日志位置。 这个问题可能是由于以下原因导致的:
未启用数据库日志同步:如果您没有启用数据库日志同步,那么在 Flink 中进行数据同步时,可能会出现这个问题。 日志位置不正确:如果您在 Flink 中配置的日志位置不正确,那么在 Flink 中进行数据同步时,可能会出现这个问题。 数据同步出现问题:如果在 Flink 中进行数据同步时出现了数据不一致或其他问题,那么可能会导致这个问题。 为了解决这个问题,您可以尝试以下方法:
启用数据库日志同步:如果您未启用数据库日志同步,那么可以启用它,以便正确地获取到数据库中的日志位置。 确认日志位置正确:如果您在 Flink 中配置的日志位置不正确,那么可以确认一下,以便正确地获取到数据库中的日志位置。 检查数据同步是否出现问题:如果在 Flink 中进行数据同步时出现了数据不一致或其他问题,那么可以检查一下,以便解决问题。 总之,如果您遇到了这个问题,可以查看 Flink 的文档和示例代码,以便更好地解决问题。