shunping commented on PR #35426:
URL: https://github.com/apache/beam/pull/35426#issuecomment-3029028591
I am seeing the following error in the test:
```
apache_beam/coders/coder_impl.py:1549: in decode_from_stream
value = self._value_coder.decode_from_stream(in_stream, nested)
apache_beam/coders/coder_impl.py:1641: in decode_from_stream
return self._value_coder.decode(in_stream.read(value_length))
apache_beam/coders/coder_impl.py:239: in decode
return self.decode_from_stream(create_InputStream(encoded), False)
apache_beam/coders/coder_impl.py:1954: in decode_from_stream
item = component_coder.decode_from_stream(in_stream, True)
apache_beam/coders/coder_impl.py:2007: in decode_from_stream
return self.logical_type.to_language_type(
apache_beam/typehints/schemas.py:1038: in to_language_type
return DecimalLogicalType().to_language_type(value)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _
self = <apache_beam.typehints.schemas.DecimalLogicalType object at
0x7ecfb6e93520>
value = Decimal('-1.23')
def to_language_type(self, value):
# type: (bytes) -> decimal.Decimal
> return decimal.Decimal(value.decode())
E AttributeError: 'decimal.Decimal' object has no attribute 'decode'
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
