Hologres中，这是flink在sink的时候报错了？
"Hologres中，这是flink在sink的时候报错了？
error: internal error: cache lookup failed for attribute 40 of relation 359181
Caused by: com.alibaba.hologres.org.postgresql.util.PSQLException: ERROR: internal error: cache lookup failed for attribute 40 of relation 359181
at com.alibaba.hologres.org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2565) ~[?:?]
at com.alibaba.hologres.org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2297) ~[?:?]
at com.alibaba.hologres.org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:322) ~[?:?]
at com.alibaba.hologres.org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:481) ~[?:?]
at com.alibaba.hologres.org.postgresql.jdbc.PgStatement.execute(PgStatement.java:401) ~[?:?]
at com.alibaba.hologres.org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:164) ~[?:?]
at com.alibaba.hologres.org.postgresql.jdbc.PgPreparedStatement.execute(PgPreparedStatement.java:153) ~[?:?]
at com.alibaba.hologres.client.impl.handler.PutActionHandler.lambda$doHandlePutAction$0(PutActionHandler.java:178) ~[?:?]
at com.alibaba.hologres.client.impl.ConnectionHolder.doRetryExecute(ConnectionHolder.java:244) ~[?:?]
at com.alibaba.hologres.client.impl.ConnectionHolder.retryExecuteWithVersion(ConnectionHolder.java:210) ~[?:?]
at com.alibaba.hologres.client.impl.handler.PutActionHandler.doHandlePutAction(PutActionHandler.java:165) ~[?:?]
at com.alibaba.hologres.client.impl.handler.PutActionHandler.handle(PutActionHandler.java:94) ~[?:?]
at com.alibaba.hologres.client.impl.handler.PutActionHandler.handle(PutActionHandler.java:33) ~[?:?]
at com.alibaba.hologres.client.impl.Worker.handle(Worker.java:94) ~[?:?]
at com.alibaba.hologres.client.impl.Worker.run(Worker.java:123) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1147) ~[?:1.8.0_102]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:622) ~[?:1.8.0_102]
... 1 more
"
写回答
-
面对过去，不要迷离；面对未来，不必彷徨；活在今天，你只要把自己完全展示给别人看。根据提供的错误信息，看起来是在执行Flink的sink操作时出现了问题。具体错误是"internal error: cache lookup failed for attribute 40 of relation 359181"，这可能是由于缓存查找失败导致的。
要解决这个问题，可以尝试以下几个步骤：
检查Hologres数据库中的关系（relation）和属性（attribute）是否正确配置。确保关系和属性的定义与Flink代码中使用的一致。
检查Flink代码中的连接参数是否正确设置。确保连接到正确的Hologres数据库，并且提供了正确的用户名、密码和其他必要的连接信息。
检查网络连接是否正常。确保Flink应用程序可以访问Hologres数据库，并且网络连接没有中断或延迟。
检查Hologres数据库的状态和性能。如果数据库负载过高或存在其他问题，可能会导致缓存查找失败。尝试优化数据库性能或联系数据库管理员以获取更多帮助。
如果以上步骤都没有解决问题，建议查看更详细的日志信息或联系相关技术支持人员以获取进一步的帮助。
2024-03-04 14:19:19赞同 1 展开评论 打赏 -
Flink 任务能否使用 VVR 8.0.5 版本，WITH 参数 sdkMode=jdbc 来写入，启动运行看看 ，此回答整理自钉群“实时数仓Hologres交流群”
2024-03-04 10:16:27赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本技术圈将为大家分析有关阿里云产品Hologres的最新产品动态、技术解读等，也欢迎大家加入钉钉群--实时数仓Hologres交流群32314975
