Skip to content

Commit

Permalink
cleanup workaround
Browse files Browse the repository at this point in the history
  • Loading branch information
xiangjinwu committed Nov 20, 2023
1 parent 6ae695c commit 23d4b96
Showing 1 changed file with 2 additions and 5 deletions.
7 changes: 2 additions & 5 deletions src/connector/src/sink/encoder/avro.rs
Original file line number Diff line number Diff line change
Expand Up @@ -570,9 +570,7 @@ mod tests {
Some(ScalarImpl::Interval(Interval::from_month_day_usec(
13, 2, 1000000,
))),
// https://github.com/apache/avro/pull/2283
// r#"{"type": "fixed", "name": "Duration", "size": 12, "logicalType": "duration"}"#,
r#"{"type": {"type": "fixed", "name": "Duration", "size": 12}, "logicalType": "duration"}"#,
r#"{"type": "fixed", "name": "Duration", "size": 12, "logicalType": "duration"}"#,
Value::Duration(apache_avro::Duration::new(
apache_avro::Months::new(13),
apache_avro::Days::new(2),
Expand Down Expand Up @@ -648,8 +646,7 @@ mod tests {
-1,
i64::MAX,
))),
// https://github.com/apache/avro/pull/2283
r#"{"type": {"type": "fixed", "name": "Duration", "size": 12}, "logicalType": "duration"}"#,
r#"{"type": "fixed", "name": "Duration", "size": 12, "logicalType": "duration"}"#,
"encode error: -1 mons -1 days +2562047788:00:54.775807 overflows avro duration",
);

Expand Down

0 comments on commit 23d4b96

Please sign in to comment.