Codec fixes for varint

ollionorg · Jan 28, 2025 · 3a10a0e · 3a10a0e
1 parent 6853a29
commit 3a10a0e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...est/java/com/google/cloud/teleport/v2/templates/SpannerToCassandraSourceDbDatatypeIT.java b/...est/java/com/google/cloud/teleport/v2/templates/SpannerToCassandraSourceDbDatatypeIT.java
@@ -418,6 +418,8 @@ private void assertRowInCassandraDB() throws InterruptedException, MultipleFailu
         () ->
             assertThat(row.getInstant("timestamp_column"))
                 .isEqualTo(java.time.Instant.parse("2025-01-27T10:30:00.000Z")),
-        () -> assertThat(row.getLong("varint_column")).isEqualTo(7076111819049546854L));
+        () ->
+            assertThat(row.getBigInteger("varint_column"))
+                .isEqualTo(java.math.BigInteger.valueOf(7076111819049546854L)));
   }
 }