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

请问一下,我已经使用Flink的SQL Client通过JDBC连接模式将数据从SQL Server

请问一下,我已经使用Flink的SQL Client通过JDBC连接模式将数据从SQL Server导入到Hudi表中 然后将数据从hudi导入到SQL Server另一个表中 报错 Loading class com.mysql.jdbc.Driver'. This is deprecated. The new driver class iscom.mysql.cj.jdbc.Driver'.....

问答 2023-02-06 来自:开发者社区

请问,有人知道 flink cdc 连接 DB2,拿不到增量数据,是为什么吗?

请问,有人知道 flink cdc 连接 DB2,拿不到增量数据,是为什么吗?

问答 2022-12-04 来自:开发者社区

Flink 我在sql cli执行连接kafka建表sql(该kafka接收csv数据),然后有一条

Flink 我在sql cli执行连接kafka建表sql(该kafka接收csv数据),然后有一条数据造的不符合字段格式,导致报错,然后该flink作业就无法继续running了,请问该如何处理呢?

问答 2022-08-03 来自:开发者社区

大佬们,我flink 采用 upsert-kafka作为连接器建表(t1),数据中具有相同更新时间的

大佬们,我flink 采用 upsert-kafka作为连接器建表(t1),数据中具有相同更新时间的多条数据,查询t1表,数据取的是哪条呢

问答 2021-12-03 来自:开发者社区

flink1.11 sql ddl 连接kafka读取数据,使用事件时间窗口,无法触发,相同的sql

您好,请教您一个问题 flink1.11 sql ddl连接kafka,使用事件事件,无法触发窗口,使用process_time系统时间就可以正常触发 create table kafka_table ( log_id  string, event_date timestamp(3), process_time as PROCTIME(), ts as event_date, water...

问答 2018-11-28 来自:开发者社区

无法使用Flink-nifi连接器从Nifi输出端口读取数据

"我在具有暴露端口的虚拟机上的docker中有一个Nifi实例:8080和10000.在瘦实例上,我创建了一个带有输出端口名为“flink”的简单管道,我想使用flink-nifi连接器读取这些数据: SiteToSiteClientConfig clientConfig = new SiteToSiteClient.Builder() .url(""http://vm-...

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问