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

Flink CDC用的stream api 自定义反序列化器显示类型转换问题?

Flink CDC用的stream api 自定义反序列化器显示类型转换问题?

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

各位大佬,这个Flink CDC sql类型转换 有没有对应API呀,难道要自己解析一个个映射吗?!

各位大佬,这个Flink CDC sql类型转换 有没有对应API呀,难道要自己解析一个个映射吗?

基于阿里云Hologres&Flink实时计算平台搭建数据仓库(实时)

23 课时 |
322 人已学 |
免费

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
955 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
518 人已学 |
免费
开发者课程背景图
问答 2023-01-16 来自:开发者社区

flink任务,连接多个 kafka的 topic作为数据源,报类型转换异常。为什么?

flink任务,连接多个 kafka的 topic作为数据源,报类型转换异常。会把第二个 kafka的类型转换成第一个kafka的类型,有大佬知道为啥吗

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

flink sql 怎样将从hbase中取出的BYTES类型转换成Int?

Exception in thread "main" org.apache.flink.table.api.ValidationException: Field types of query result and registered TableSink default_catalog.default_database.user_cnt do not match. Query schema: [....

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

flink sql 中怎么把ROW类型转换成INT?

用.访问成功了,不过报了另外一个错误: offset (0) + length (4) exceed the capacity of the array: 2 这个错误提示 是不是 hbase取出来的int类型, 用users.addColumn("cf", "age", classOf[Integer]) 来转换是不是不对, 怎么把int转换成Integer呢或者把Integer转换成int ....

问答 2019-01-28 来自:开发者社区

flink 类型转换,scala 继承map接口后,报java.lang.ClassCastException

类型: case class RIchMap(data:Map[String,Any] = Map()) extends Map[String, Any] with GenMap[String, Any] with Serializable 执行:stream.flatMapRichMap(TypeInformation.of(classOf[RichMap])) 传类型: fun: RichM....

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

产品推荐

阿里云实时计算Flink

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

+关注