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

Flink CDC我自定义了一个flink SQL的Kafka分区器,有遇到这个问题的吗?

Flink CDC我自定义了一个flink SQL的Kafka分区器,在写入的时候会报类型转换异常,有遇到这个问题的吗?

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

Flink CDC如何自定义sink批量写入呢?

Flink CDC如何自定义sink批量写入呢?

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

云上flink能不能上传自定义的一些依赖呢?让这些依赖在作业启动的时候加入到classpath。

云上flink能不能上传自定义的一些依赖呢?让这些依赖在作业启动的时候加入到classpath。

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

flink 的Connector 不支持clickhouse,你们是自定义了Connector 吗?

flink 的Connector 不支持clickhouse,你们是自定义了Connector 吗,能不能直接用flinksql写入?

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

大佬们,Flink有没有遇到过自定义的日期转换类本地运行正常,发布上去找不到类的问题?

大佬们,Flink有没有遇到过自定义的日期转换类本地运行正常,发布上去找不到类的问题?

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

Flink CDC中有自定义聚合函数,也有insert语句,为什么还会报错?

Flink CDC中有自定义聚合函数,也有insert语句,为什么还会报 No operators defined in streaming topology,这个错呢,这个要怎么解决呢?

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

Flink CDC中我使用了自定义聚合函数,但是报错这个需要怎么解决呢?

Flink CDC中我使用了自定义聚合函数,但是提示我 No operators defined in streaming topology. Cannot execute.这个需要怎么解决呢?

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

Flink这边自定义的udf, 有部分可以识别出来,有部分识别不出来,大家有遇到过这样的情况么?

Flink这边自定义的udf, 有部分可以识别出来,有部分识别不出来,大家有遇到过这样的情况么?

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

想问下各位大佬,有没有碰到 flink 1.17版本,使用自定义JdbcSink extends ?

想问下各位大佬,有没有碰到 flink 1.17版本,使用自定义JdbcSink extends RichSinkFunction 将数据写入到 mysql中不能成功,也没有任何报错和异常呀?@Overridepublic void invoke(OplogCountDto dto, Context context) throws Exception { logger.info(" ...

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

求问各位大佬:flink运行大量数据(自定义数据源)写入hudi和hive的作业运行一段时间后,?

求问各位大佬:flink运行大量数据(自定义数据源)写入hudi和hive的作业运行一段时间后,出现hive beeline客户端查询表报错:Unknown HS2 problem when communicating with Thrift server.Error: org.apache.thrift.transport.TTransportException: java.net.Socke....

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

产品推荐

阿里云实时计算Flink

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

+关注