Gergely G

@chamikaramj The cache hit will never be detected for the downloaded JARs because of this line: https://github.com/apache/beam/blob/bb51380f1b29a2b69ab82ef795a8895ebd89f87e/sdks/python/apache_beam/runners/portability/artifact_service.py#L294 It always evaluates to False. A worse problem though that, as mentioned above...

Part of the solution could be in [avro_value_to_beam_value()](https://github.com/apache/beam/blob/cfbcdf03906f0ffe3553b94f391c566eeed8b2fe/sdks/python/apache_beam/io/avroio.py#L656) Checking for the `beam_type` matching this FieldType: ``` logical_type { urn: "beam:logical_type:millis_instant:v1" representation { atomic_type: INT64 } } ``` The converter could...