问题一:"flink cdc同步mysql数据失败,查了一下是连接中断,网络问题等等,不知道如何解决?
"flink cdc同步mysql数据失败,查了一下是连接中断,网络问题等等,不知道如何解决?
参考回答:
cdc是增量同步,连接超时了,查看一下网络环境吧 。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/613253
问题二:Flink用 官网提供的 mvn clean install -DskipTests命令,出现问题?
Flink用 官网提供的 mvn clean install -DskipTests命令,出现问题?
参考回答:
去官网下个最大的小版本,先用8编译好了再说吧,还有就是你编译的flink版本按官网推荐的jdk用。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/612860
问题三:Flink传入是String,输出也是STRING。但是总是报类型强转失败呢。请问这是怎么回事啊?
Flink传入是String,输出也是STRING。但是总是报类型强转失败呢。请问这是怎么回事啊?
参考回答:
用row包一下试试,前面output定义了输出是array,所以就不能直接返回字符串了,你重新定义一下output或者就用string[]返回结果应该就可以了 。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/612855
问题四:Flink中udf是怎么定义接收和返回的数据类型的呢?
Flink中udf是怎么定义接收和返回的数据类型的呢?
参考回答:
"input就用array
返回值用string,不一定要用jsonobject 。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/612854
问题五:flinksql的lateral view总是报错,如何解决?
flinksql的lateral view总是报错,如何解决?
参考回答:
试下这么写
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/612853