antigeneral (公众号:大数据羊说):
问题1:为什么flink 要用到java序列化机制。和flink类型系统的数据序列化机制的用途有啥区别
问题2:变量没有继承 serializable为啥就不报错,实例化就报错?
问题3:为啥加 transient 就不报错?
flink datastream api 强调 function 实现时,实例化的变量要继承 serializable接口,如果没实现借口的话需要添加 transient 字段,否则会报不可序列化异常。
antigeneral (公众号:大数据羊说):
每日一题:状态,状态后端,CK三者之间的区别及关系
antigeneral (公众号:大数据羊说):
每日一题:一个 Flink任务使用了周期性watermark生成器+事件时间窗口。这个Flink 任务在任务failover时能保障事件时间窗口输出结果和之前一样吗?
antigeneral (公众号:大数据羊说):
每日一题:watermark到底是干啥的?应用场景?
antigeneral (公众号:大数据羊说):
每日一题:为什么flink datastream api 在函数入参或者出参有泛型时,不能使用 lambda 表达式