阿里云文档 2025-02-27

Catalog

本文介绍Catalog相关问题。

问答 2023-08-22 来自:开发者社区

Flink CDC我根据这个添加的代码,现在报错Caused by: java.lang.?

Flink CDC我根据这个添加的代码,现在报错Caused by: java.lang.ClassCastException: org.apache.kafka.connect.data.SchemaBuilder cannot be cast to com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.data.Schema....

问答 2023-07-13 来自:开发者社区

请教各位一下,跑flink cdc样例程序,报错Caused by: java.io这个如何解决?

请教各位一下,跑flink cdc样例程序,报错Caused by: java.io.NotSerializableException: com.ververica.cdc.connectors.mysql.table.StartupOptions,这个如何解决?

问答 2023-05-01 来自:开发者社区

请问Flink CDC有没有遇到过tidbcdc连接报错:Caused by: java.lang.

请问Flink CDC有没有遇到过tidbcdc连接报错:Caused by: java.lang.IllegalArgumentException: Invalid range: [+INF..{116,128,0,0,0,0,0,2,64,95,114,31,255,255,255,255,255,255,255}) at org.apache.flink.shaded.guava30.co....

问答 2023-04-25 来自:开发者社区

Flink CDC 这个报错是什么原因Caused by: java.lang.NoSuchFiel

Flink CDC 这个报错是什么原因Caused by: java.lang.NoSuchFieldError: INCREMENTAL_SNAPSHOT_CHUNK_SIZE

问答 2023-01-09 来自:开发者社区

使用flink-oracle-cdc,遇到一个问题。报错: Caused by: java.lang

使用flink-oracle-cdc,遇到一个问题。报错: Caused by: java.lang.IllegalStateException: Retrieve schema history failed, the schema records for engine b98b3d1e-0629-4335-b406-4d363a762c8c has been removed, this mig....

问答 2023-01-09 来自:开发者社区

flink1.15.1提交任务到yarn报错:Caused by: org.apache.flink

flink1.15.1提交任务到yarn报错:Caused by: org.apache.flink.core.fs.UnsupportedFileSystemSchemeException: Cannot support file system for 'hdfs' via Hadoop, because Hadoop is not in the classpath, or some clas....

问答 2023-01-09 来自:开发者社区

flink打包后运行出现这个报错:Caused by: org.apache.flink.table

flink打包后运行出现这个报错:Caused by: org.apache.flink.table.api.ValidationException: Cannot discover a connector using option: 'connector'='postgres-cdc'

问答 2023-01-09 来自:开发者社区

Flink 报错:Caused by: org.apache.flink.table.api.Val

Flink 报错:Caused by: org.apache.flink.table.api.ValidationException: Column types of query result and sink for 'vvp.default.xxx' do not match.

文章 2022-12-28 来自:开发者社区

Flink作业报错:Caused by: The connector is trying to read binlog starting at GTIDs ..., but this is no longer available on the server

问题描述Flink作业报错:Caused by: The connector is trying to read binlog starting at GTIDs ..., but this is no longer available on the server. Reconfigure the connector to use a snapshot when needed.问题原因正在读的b....

Flink作业报错:Caused by: The connector is trying to read binlog starting at GTIDs ..., but this is no longer available on the server

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注