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

时间：2024-04-23 20:19:33

数据湖探索 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:示例3：将DMS Kafka作为源表，Print作为结果表（适用于Kafka集群已开启SASL_SSL场景）

下一篇：数据湖探索 DLI-Kafka:示例3：将DMS Kafka作为源表，Print作为结果表（适用于Kafka集群已开启SASL_SSL场景）