Skip to content

Commit 8f98821

Browse files
committed
fix tests
1 parent 8aa942b commit 8f98821

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/TableRowToStorageApiProtoTest.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@
1717
*/
1818
package org.apache.beam.sdk.io.gcp.bigquery;
1919

20-
import static org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.DATETIME_SPACE_FORMATTER;
2120
import static org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.TIMESTAMP_FORMATTER;
2221
import static org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.TYPE_MAP_PROTO_CONVERTERS;
2322
import static org.junit.Assert.assertEquals;
@@ -1404,7 +1403,7 @@ private TableRow normalizeTableRowF(
14041403
case INT64:
14051404
return convertedValue.toString();
14061405
case DOUBLE:
1407-
return BigDecimal.valueOf((double) convertedValue).stripTrailingZeros().toString();
1406+
return TableRowToStorageApiProto.DECIMAL_FORMAT.format((double) convertedValue);
14081407
case BYTES:
14091408
ByteString byteString =
14101409
(ByteString)
@@ -1432,7 +1431,7 @@ private TableRow normalizeTableRowF(
14321431
case DATETIME:
14331432
long packedDateTime = (long) convertedValue;
14341433
return CivilTimeEncoder.decodePacked64DatetimeMicrosAsJavaTime(packedDateTime)
1435-
.format(DATETIME_SPACE_FORMATTER);
1434+
.format(BigQueryUtils.BIGQUERY_DATETIME_FORMATTER);
14361435
case TIME:
14371436
long packedTime = (long) convertedValue;
14381437
return CivilTimeEncoder.decodePacked64TimeMicrosAsJavaTime(packedTime).toString();

0 commit comments

Comments
 (0)