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

在Flink CDC中cdc 3.1的版本 从mysql写入到paimon报错,如何解决?

在Flink CDC中cdc 3.1的版本 从mysql写入到paimon报错,如何解决?请参考图片:

问答 2024-04-17 来自:开发者社区

flink CDAS同步数据至SR serverless ,只把表结构同步过去,就报错,如何解决?

flink CDAS同步数据至SR serverless ,只把表结构同步过去,同步数据就报错,如何解决?Caused by: com.starrocks.streamload.shade.org.apache.http.ProtocolException: The server failed to respond with a valid HTTP response 作业链接:https://....

文章 2024-03-14 来自:开发者社区

Flink CDC产品常见问题之用superset连接starrocks报错如何解决

问题一:Flink CDC里谁试过用superset连接starrocks的,报错要怎么办啊? Flink CDC里谁试过用superset连接starrocks的,官网的方法好像不太行,报错要怎么办啊? 参考答案: 确保你在Superset的数据库连接设置中输入了正确的StarRocks主机地址、端口、数据库名、用户名和密码。 如果StarR...

Flink CDC产品常见问题之用superset连接starrocks报错如何解决
问答 2024-03-11 来自:开发者社区

Flink使用dinky提交代码,所有目前我对于这个报错没太多思路,如何解决?

Flink使用dinky提交代码,任务是从kafka流入hive。现在遇到的问题是序列化问题。他仔细检查了我所有关于flink-sql-connector-hive-3.1.2_2.11-1.13.6.jar的包,版本全部是一样的,dinky和flink,包版本都一样,所有目前我对于这个报错没太多思路?

文章 2024-03-09 来自:开发者社区

Flink CDC产品常见问题之运行mysql to doris pipeline报错如何解决

问题一:Flink CDC里racle 全量阶段是通过 log 获取数据吗? Flink CDC里racle 全量阶段是通过 log 获取数据吗? 参考回答: 先select再捕捉binlog,是正常的。 关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/592324 ...

Flink CDC产品常见问题之运行mysql to doris pipeline报错如何解决
文章 2024-02-26 来自:开发者社区

Flink报错问题之flink 1.11 upsert结果报错如何解决

问题一:[sql-client] 通过sql-client提交sql怎么设置checkpointing.in 通过sql-client提交sql怎么设置checkpointing.interval? 我看了一下sql-client-defaults.yaml中的execution, 并没有发现这个参数。请教大家一下。 谢谢 *来自志愿者整理的flink邮件归档 ...

文章 2024-02-26 来自:开发者社区

Flink报错问题之报类型转换错误如何解决

问题一:flink-1.11 KafkaDynamicTableSouce groupBy 结果怎样发送到 INSERT INTO kafka_dws_artemis_out_order select warehouse_id, count(*) from kafka_ods_artemis_out_order group by warehouse_id; ...

文章 2024-02-25 来自:开发者社区

flink问题之使用debezium-json format报错如何解决

问题一:flink 1.11 es未定义pk的sink问题 根据文档[1]的描述,1.11的es sql connector如果在ddl里没有声明primary key,将会使用append模式sink数据,并使用es本身生成的id作为document_id。但是我在测试时发现,如果我的ddl里没有定义primary key,写入时没有正确生成document_id,反而是将i...

文章 2024-02-25 来自:开发者社区

Flink报错问题之执行sqlQuery时报错如何解决

问题一:flink1.11 sql 发布到yarn session时找不到hbase相关的类 最近在升级flink1.11,sql中用到hbase connctor,发布到yarn-session时,报如下异常: 2020-07-29 11:49:55 org.apache.hadoop.hbase.DoNotRetryIOException: java.lang.NoC...

文章 2024-02-25 来自:开发者社区

Flink报错问题之jdbc表报错如何解决

问题一:sql-client的jdbc表出错 你好,我创建了一个jdbc的表 创建表 mvp_dim_anticheat_args_all ( ID BIGINT, 字符串, cnt_7d INT, cnt_30d INT, 主键 (id) 未强制执行 ) 和 ( '连接器' = 'jdbc', 'driver'='com.mysql.jdbc.Driver', 'url' = ...

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

产品推荐

实时计算 Flink

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

+关注