flink1.10 po extends ParentPo,print时候,无法print parent属性的字段

classic Classic list List threaded Threaded
1 message Options
kcz
Reply | Threaded
Open this post in threaded view
|

flink1.10 po extends ParentPo,print时候,无法print parent属性的字段

kcz
当我的PO继承了父类时候
env.addSource(consumer)
        .uid("source")
        .setParallelism(parameterTool.getInt("source_num", 1))         //json转换时候,value包括了父类的
        .map(value -> JSONObject.parseObject(value, IPEntiy.class))
        .uid("map")
        .setParallelism(parameterTool.getInt("map_num", 1));print时候,parent的属性value丢失