flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "了不起的盖茨比" <573693...@qq.com>
Subject flink1.10 po extends ParentPo,print时候,无法print parent属性的字段
Date Fri, 08 May 2020 09:47:19 GMT
当我的PO继承了父类时候
env.addSource(consumer)
        .uid("source")
        .setParallelism(parameterTool.getInt("source_num", 1))         //json转换时候,value包括了父类的
        .map(value -&gt; JSONObject.parseObject(value, IPEntiy.class))
        .uid("map")
        .setParallelism(parameterTool.getInt("map_num", 1));print时候,parent的属性value丢失
Mime
  • Unnamed multipart/alternative (inline, 8-Bit, 0 bytes)
View raw message