|
当我的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丢失
|