Skip to content

Commit be26181

Browse files
committed
Fix another test
1 parent 6f69c73 commit be26181

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

airbyte-integrations/connectors/destination-jdbc/src/test/java/io/airbyte/integrations/destination/jdbc/SqlOperationsUtilsTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -93,13 +93,13 @@ void testInsertRawRecordsInSingleQuery() throws SQLException {
9393
.put(JavaBaseConstants.COLUMN_NAME_AB_ID, RECORD1_UUID)
9494
.put(JavaBaseConstants.COLUMN_NAME_DATA, records.get(0).getData())
9595
.put(JavaBaseConstants.COLUMN_NAME_EMITTED_AT, DataTypeUtils
96-
.toISO8601String(records.get(0).getEmittedAt()))
96+
.toISO8601StringWithMicroseconds(Instant.ofEpochMilli(records.get(0).getEmittedAt())))
9797
.build()),
9898
Jsons.jsonNode(ImmutableMap.builder()
9999
.put(JavaBaseConstants.COLUMN_NAME_AB_ID, RECORD2_UUID)
100100
.put(JavaBaseConstants.COLUMN_NAME_DATA, records.get(1).getData())
101101
.put(JavaBaseConstants.COLUMN_NAME_EMITTED_AT, DataTypeUtils
102-
.toISO8601String(records.get(1).getEmittedAt()))
102+
.toISO8601StringWithMicroseconds(Instant.ofEpochMilli(records.get(1).getEmittedAt())))
103103
.build()));
104104

105105
actualRecords.forEach(

0 commit comments

Comments
 (0)