2、The types of the interface org.apache.flink.streaming.api.functions.source.SourceFunction could not be inferred. Support for synthetic interfaces, lambdas, and generic or raw types is limited at this point

原因：数据类型转换失败
解决：SourceFunction , KafkaLog 一定要写 ，不然会报对象类型不对

flink SourceFunction could not be inferred. Support for synthetic interfaces, lambdas, and generic相关推荐

1. Flink sql:Table sink doesn‘t support consuming update and delete changes which is produced by node

   一.问题描述 Flink sql将kafka作为join的输出,报错: Exception in thread "main" org.apache.flink.table.api. ...

2. Flink SourceFunction/SinkFunction

   一.简介 Source 是Flink的输入,可以串行,并行,延迟,设置时间窗口等等. Sink是Flink的输出,设置任意源. Flink的编程模型就可以概况成接入Source,然后进行数据转换操作, ...

3. 1.10.Flink DataStreamAPI(API的抽象级别、Data Sources、connectors、Source容错性保证、Sink容错性保证、自定义sink、partition等)

   1.10.Flink DataStreamAPI 1.10.1.Flink API的抽象级别 1.10.2.DatSource部分详解 1.10.2.1.DataStream API之Data Sou ...

4. flink报错：The types of the interface org.apache.flink.util.OutputTag could not be inferred.

   测试flink报错如下: The types of the interface org.apache.flink.util.OutputTag could not be inferred. Suppo ...

5. flink 处理迟到数据(Trigger、设置水位线延迟时间、允许窗口处理迟到数据、将迟到数据放入侧输出流、代码示例、迟到数据触发窗口计算重复结果处理)

   文章目录 前言 1.Trigger 2.处理迟到数据 2.1 设置水位线延迟时间 2.2 允许窗口处理迟到数据 2.3 将迟到数据放入侧输出流 3.实操 3.1 代码示例 3.2 中间遇到的异常 3. ...

6. Apache Flink ML 2.2.0 发布公告

   来源 | Apache Flink 官方博客 翻译 | 林东 Apache Flink 社区很荣幸地宣布 Apache Flink ML 2.2.0 版本正式发布!本次发布的版本重点添加了 Flink ...

7. Flink 1.10.0 重磅发布，迄今最大规模版本升级！

   翻译|宋辛童 校对|李钰 Apache Flink 社区迎来了激动人心的两位数位版本号,Flink 1.10.0 正式宣告发布!作为 Flink 社区迄今为止规模最大的一次版本升级,Flink 1.1 ...

8. Apache Flink 1.10.0 最新发布，年度最大规模版本升级！

   Apache Flink 社区迎来了激动人心的两位数位版本号,Flink 1.10.0 正式宣告发布!作为 Flink 社区迄今为止规模最大的一次版本升级,Flink 1.10 容纳了超过 200 位 ...

9. Flink 命令行参数介绍

   Flink 命令行参数介绍 一.Flink Command | CLI Actions 1.1 客户端命令介绍 1.2 使用示例 二.Flink Run Command | flink run 2.1 ...

最新文章

1. 跟我学PPStream局域网共享
2. ！Web云笔记--HTML基础
3. 如何使用CSDN- Markdown编辑器(给自己看的)
4. 前端MVC Vue2学习总结（四）——条件渲染、列表渲染、事件处理器
5. 今年最有档次的9个词！（不看后悔）
6. c构造函数和析构函数_C ++构造函数和析构函数| 查找输出程序| 套装1
7. 【NC30】缺失的第一个正整数
8. LeetCode 1246. 删除回文子数组（区间DP）
9. Android studio下载安装使用遇到的问题及解决办法
10. CentOS 6、7 安装 Golang
11. button jsp隐藏_关于在同一JSP页面通过隐藏域传值的问题？
12. 基于java ee的源码,基于java EE的云ERP系统
13. QQ音乐限制专辑重复购买 此前已取消人气榜等非作品类排名
14. 中国兽医牙科X射线发生器市场趋势报告、技术动态创新及市场预测
15. GCC依赖库顺序问题
16. noip2012借教室
17. 计算机信息技术会考操作题,信息技术会考操作题整理.doc
18. 台电xh80平板android刷机 G2N8
19. 我的物联网大学【第五章】：沉默不会爆发，沉默一定会灭亡！
20. kuka机器人RSI说明

热门文章

1. 如何获取注册高德Key使用的SHA1值
2. 使用IDEA写程序时,运行忽然报错,提示:在类*** 中找不到 main 方法, 请将 main 方法定义为: public static void main(String[] args)
3. Git 换行符自动转换
4. 巧用CUDA中的pinned memory
5. 如何设置zotero连接到坚果云
6. 关于log4j:WARN No appenders could be found for logger (org.apache.hadoop.metrics2.lib.MutableMetricsFa
7. iOS第三方开源库的吐槽和备忘 - 王培
8. 初出茅庐——利用Python的Turtle库绘制玫瑰花
9. Cannot use import statement outside a module
10. 常用中文字体的英文名称