danielrod08 commented on code in PR #27836:
URL: https://github.com/apache/flink/pull/27836#discussion_r3014721939
##########
flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroOutputFormatTest.java:
##########
@@ -200,11 +199,9 @@ public int getAttemptNumber() {
user.setTypeTimestampMicros(Instant.ofEpochSecond(0).plus(123456L,
ChronoUnit.MICROS));
// 20.00
- user.setTypeDecimalBytes(
- ByteBuffer.wrap(BigDecimal.valueOf(2000,
2).unscaledValue().toByteArray()));
+ user.setTypeDecimalBytes(BigDecimal.valueOf(2000, 2));
// 20.00
- user.setTypeDecimalFixed(
- new Fixed2(BigDecimal.valueOf(2000,
2).unscaledValue().toByteArray()));
+ user.setTypeDecimalFixed(BigDecimal.valueOf(2000, 2));
Review Comment:
Hi @mxm, thank you for the comment.
I accidentally set <enableDecimalLogicalType> to true in the pom.xml. This
caused the generated User class to only accept BigDecimal values for both
setTypeDecimalFixed and setTypeDecimalBytes. I am currently removing this
configuration and resolving the resulting issues, and reversing the changes I
made to the tests.
--
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]
