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
"

展开

收起

cuicuicuic 2024-03-04 09:17:17 31 0

2 条回答

写回答

取消提交回答

小周sir

面对过去，不要迷离；面对未来，不必彷徨；活在今天，你只要把自己完全展示给别人看。
根据提供的错误信息，看起来是在执行Flink的sink操作时出现了问题。具体错误是"internal error: cache lookup failed for attribute 40 of relation 359181"，这可能是由于缓存查找失败导致的。

要解决这个问题，可以尝试以下几个步骤：
1. 检查Hologres数据库中的关系（relation）和属性（attribute）是否正确配置。确保关系和属性的定义与Flink代码中使用的一致。
2. 检查Flink代码中的连接参数是否正确设置。确保连接到正确的Hologres数据库，并且提供了正确的用户名、密码和其他必要的连接信息。
3. 检查网络连接是否正常。确保Flink应用程序可以访问Hologres数据库，并且网络连接没有中断或延迟。
4. 检查Hologres数据库的状态和性能。如果数据库负载过高或存在其他问题，可能会导致缓存查找失败。尝试优化数据库性能或联系数据库管理员以获取更多帮助。
如果以上步骤都没有解决问题，建议查看更详细的日志信息或联系相关技术支持人员以获取进一步的帮助。
2024-03-04 14:19:19

赞同展开评论打赏
xin在这

Flink 任务能否使用 VVR 8.0.5 版本，WITH 参数 sdkMode=jdbc 来写入，启动运行看看，此回答整理自钉群“实时数仓Hologres交流群”

2024-03-04 10:16:27

赞同展开评论打赏