FAILED apache_beam/io/external/xlang_jdbcio_it_test.py::CrossLanguageJdbcIOTest::test_xlang_jdbc_write_read_0_postgres - RuntimeError: Pipeline BeamApp-jenkins-1208002334-8b3649cd_9ce5b455-0bb4-4895-a9e9-7ffe529a5ea8 failed in state FAILED: java.lang.RuntimeException: Error received from SDK harness for instruction 25: Traceback (most recent call last):
  File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python39/src/sdks/python/apache_beam/runners/worker/bundle_processor.py", line 231, in process_encoded
    decoded_value = self.windowed_coder_impl.decode_from_stream(
  File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python39/src/sdks/python/apache_beam/coders/coder_impl.py", line 1488, in decode_from_stream
    value = self._value_coder.decode_from_stream(in_stream, nested)
  File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python39/src/sdks/python/apache_beam/coders/coder_impl.py", line 1837, in decode_from_stream
    item = component_coder.decode_from_stream(in_stream, True)
  File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python39/src/sdks/python/apache_beam/coders/coder_impl.py", line 1890, in decode_from_stream
    return self.logical_type.to_language_type(
  File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python39/src/sdks/python/apache_beam/typehints/schemas.py", line 1000, in to_language_type
    return DecimalLogicalType().to_language_type(value)
  File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python39/src/sdks/python/apache_beam/typehints/schemas.py", line 962, in to_language_type
    return decimal.Decimal(value.decode())
AttributeError: 'decimal.Decimal' object has no attribute 'decode'

The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python39/src/sdks/python/apache_beam/runners/worker/sdk_worker.py", line 297, in _execute
    response = task()
  File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python39/src/sdks/python/apache_beam/runners/worker/sdk_worker.py", line 372, in <lambda>
    lambda: self.create_worker().do_instruction(request), request)
  File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python39/src/sdks/python/apache_beam/runners/worker/sdk_worker.py", line 625, in do_instruction
    return getattr(self, request_type)(
  File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python39/src/sdks/python/apache_beam/runners/worker/sdk_worker.py", line 663, in process_bundle
    bundle_processor.process_bundle(instruction_id))
  File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python39/src/sdks/python/apache_beam/runners/worker/bundle_processor.py", line 1056, in process_bundle
    input_op_by_transform_id[element.transform_id].process_encoded(
  File "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python39/src/sdks/python/apache_beam/runners/worker/bundle_processor.py", line 234, in process_encoded
    raise ValueError(
ValueError: Error decoding input stream with coder WindowedValueCoder[RowCoder]