[ https://issues.apache.org/jira/browse/BEAM-4581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Beam JIRA Bot updated BEAM-4581: -------------------------------- Labels: portability stale-P2 (was: portability) > Python SDK does not correctly set the serialized_fn of WindowInto when > translating to the Dataflow pipeline description > ----------------------------------------------------------------------------------------------------------------------- > > Key: BEAM-4581 > URL: https://issues.apache.org/jira/browse/BEAM-4581 > Project: Beam > Issue Type: Bug > Components: runner-dataflow > Reporter: Luke Cwik > Priority: P2 > Labels: portability, stale-P2 > > serialzed_fn at the bottom should be reference to the pipeline proto > ptransform id representing this function. > {code:java} > { > "kind": "ParallelDo", > "name": "s4", > "properties": { > "display_data": [ > { > "key": "fn", > "label": "Transform Function", > "namespace": "apache_beam.transforms.core.WindowInto", > "shortValue": "WindowIntoFn", > "type": "STRING", > "value": "apache_beam.transforms.core.WindowIntoFn" > } > ], > "non_parallel_inputs": {}, > "output_info": [ > { > "encoding": { > "@type": "kind:windowed_value", > "component_encodings": [ > { > "@type": > "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", > > "component_encodings": [ > { > "@type": > "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", > > "component_encodings": [] > }, > { > "@type": > "FastPrimitivesCoder$eNprYEpOLEhMzkiNT0pNzNVLzk9JLSqGUlxuicUlAUWZuZklmWWpxc4gQa5CBs3GQsbaQqZQ/vi0xJycpMTk7Hiw+kJmPEYFZCZn56RCjWABGsFaW8iWVJykBwDlGS3/", > > "component_encodings": [] > } > ], > "is_pair_like": true > }, > { > "@type": "kind:global_window" > } > ], > "is_wrapper": true > }, > "output_name": "out", > "user_name": "assert_that/WindowInto(WindowIntoFn).out" > } > ], > "parallel_input": { > "@type": "OutputReference", > "output_name": "out", > "step_name": "s2" > }, > "serialized_fn": "<string of 328 bytes>", > "user_name": "assert_that/WindowInto(WindowIntoFn)" > } > }, > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)