问答 2025-03-21 来自:开发者社区

flink1.19和hive3.1.3,cdc从mysql同步数据到hive,插入时报错?

使用的是flink sql处理流程是从mysql进kafka之后,通过kafka插入hive,在插入数据时会报错,选了upsert-kafka,sql没有更新或者删除操作 Flink SQL> [ERROR] Could not execute SQL statement. Reason: org.apache.flink.table.api.TableException: Table si...

问答 2024-05-20 来自:开发者社区

Flink CDC里用的 flink1.19的 抽mysql写到 paimon报错怎么办?

java.lang.NoClassDefFoundError: com/ververica/cdc/common/utils/StringUtils Flink CDC里我也是这个问题 我用的 flink1.19的 抽mysql写到 paimon里面 昨天运行了一天 都正常 今天突然就报错了

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