Description
To reproduce, please run the following query-
b = FOREACH a GENERATE (map[])udfs.empty_dict(); DUMP b;
where empty_dict() is a Python udf-
@outputSchema("map_out: []") def empty_dict(): return {}
This returns ([]) in jython while ([null#]) in streaming_python.