You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 牙牙 <43...@qq.com> on 2020/04/30 09:42:38 UTC

广播流传输自定义对象无效

hi,all
我这边遇到一个问题:
在定义广播流(non-keyed类型)的sourceFunction时,实际传输的流中元素数据为热加载的某个具体实现类A,此类A继承某个抽象类B,此抽象类B实现指定接口C,sourceFunction的泛型T指定为抽象类B类型。
现象:
下游算子的processFunction中,对于接收广播流数据的方法中收不到实现类A,实现类A实现序列化接口了,私有属性均有getter和setter。


还请哪位大佬,指点迷津!