数据湖探索 DLI-Kafka源表:常见问题

时间：2024-11-16 13:21:41

数据湖探索 DLI

常见问题

Flink作业运行失败，作业运行日志中如下报错信息，应该怎么解决？
```
org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata
```
跨源未绑定或未绑定成功，或是Kafka集群安全组未配置放通 DLI 队列的网段地址。参考增强型跨源连接重新配置跨源，或者Kafka集群安全组放通DLI队列的网段地址。

Flink作业运行失败，作业运行日志中如下报错信息，应该怎么解决？

Caused by: java.lang.RuntimeException: RealLine:45;Table 'default_catalog.default_database.printSink' declares persistable metadata columns, but the underlying DynamicTableSink doesn't implement the SupportsWritingMetadata interface. If the column should not be persisted, it can be declared with the VIRTUAL keyword.

sink表中定义了metadata类型，但是Print connector并不支持把sink表中的matadata去掉即可。

上一篇：数据湖探索 DLI-Kafka源表:前提条件

下一篇：数据湖探索 DLI-Kafka源表:前提条件