fix tests:

snowflakedb · Sep 7, 2024 · df57b6e · df57b6e
1 parent 8f95d64
commit df57b6e
Showing 1 changed file with 0 additions and 8 deletions.
diff --git a/src/test/java/net/snowflake/ingest/streaming/internal/RowBufferTest.java b/src/test/java/net/snowflake/ingest/streaming/internal/RowBufferTest.java
@@ -505,11 +505,6 @@ private void testFlushHelper(AbstractRowBuffer<?> rowBuffer) {
     Assert.assertEquals(startOffsetToken, data.getStartOffsetToken());
     Assert.assertEquals(endOffsetToken, data.getEndOffsetToken());
     Assert.assertEquals(bufferSize, data.getBufferSize(), 0);
-
-    final ParquetChunkData chunkData = (ParquetChunkData) data.getVectors();
-    Assert.assertEquals(
-        StreamingIngestUtils.getShortname(filename),
-        chunkData.metadata.get(Constants.PRIMARY_FILE_ID_KEY));
   }
 
   @Test
@@ -783,9 +778,6 @@ private void testStatsE2EHelper(AbstractRowBuffer<?> rowBuffer) {
     Assert.assertEquals(0, columnEpStats.get("COLCHAR").getCurrentNullCount());
     Assert.assertEquals(-1, columnEpStats.get("COLCHAR").getDistinctValues());
 
-    final ParquetChunkData chunkData = (ParquetChunkData) result.getVectors();
-    Assert.assertEquals(filename, chunkData.metadata.get(Constants.PRIMARY_FILE_ID_KEY));
-
     // Confirm we reset
     ChannelData<?> resetResults = rowBuffer.flush("my_snowpipe_streaming.bdec");
     Assert.assertNull(resetResults);