mkhludnev commented on PR #27406: URL: https://github.com/apache/beam/pull/27406#issuecomment-1628323082
> Thanks, if I understood correctly, the problem is on AvroUtil side; JdbcIO can still read from jdbc and send correct elements (Decimal with correct unit) downstream; but if try to write to Avro files, avro schema cannot be created from Beam schema that Beam Row provides. Is that the issue? 1. @Abacn, thanks for looking into. 2. Your interpretation of end-user problem is correct. 3. This problem/failure also hides another the smaller one - JdbcIO.readRows() doesn't pass the scale when converts DECIMAL(10,2). 4. Can you give a clue where start to tackle this problem? I suppose to add a condition for capturing FixedPrecisionNumeric into `AvroUtils.getFieldSchema(AvroUtils.java:1095)`. WDYT? -- 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]
