Skip to content

Commit

Permalink
fixes test
Browse files Browse the repository at this point in the history
  • Loading branch information
Harnoor7 committed Dec 16, 2024
1 parent 1754dbc commit ff4017e
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ public void testToFromZNRecord() {
new RealtimeToOfflineSegmentsTaskMetadata("testTable_REALTIME", 1000);
ZNRecord znRecord = metadata.toZNRecord();
assertEquals(znRecord.getId(), "testTable_REALTIME");
assertEquals(znRecord.getSimpleField("watermarkMs"), "1000");
assertEquals(znRecord.getSimpleField("windowStartMs"), "1000");

RealtimeToOfflineSegmentsTaskMetadata realtimeToOfflineSegmentsTaskMetadata =
RealtimeToOfflineSegmentsTaskMetadata.fromZNRecord(znRecord);
Expand Down

0 comments on commit ff4017e

Please sign in to comment.