Fix failing tests for append tree and mongodb

koralium · Jan 19, 2025 · 31726c1 · 31726c1
1 parent c5c24d6
commit 31726c1
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 4 deletions.
diff --git a/src/FlowtideDotNet.Storage/Tree/Internal/BPlusTreeSerializer.cs b/src/FlowtideDotNet.Storage/Tree/Internal/BPlusTreeSerializer.cs
@@ -65,7 +65,6 @@ public async Task CheckpointAsync<TMetadata>(IStateSerializerCheckpointWriter ch
 
                 return;
             }
-            throw new NotSupportedException();
         }
 
         public async Task InitializeAsync<TMetadata>(IStateSerializerInitializeReader reader, StateClientMetadata<TMetadata> metadata) where TMetadata : IStorageMetadata
@@ -96,7 +95,6 @@ public async Task InitializeAsync<TMetadata>(IStateSerializerInitializeReader re
 
                 return;
             }
-            throw new NotSupportedException();
         }
 
         public IBPlusTreeNode Deserialize(IMemoryOwner<byte> bytes, int length, StateSerializeOptions stateSerializeOptions)

diff --git a/tests/FlowtideDotNet.AcceptanceTests/Internal/FlowtideTestStream.cs b/tests/FlowtideDotNet.AcceptanceTests/Internal/FlowtideTestStream.cs
@@ -73,7 +73,7 @@ public class FlowtideTestStream : IAsyncDisposable
 
         public SqlPlanBuilder SqlPlanBuilder => sqlPlanBuilder;
 
-        public int CachePageCount { get; set; } = 0;
+        public int CachePageCount { get; set; } = 1000;
 
         public Watermark? LastWatermark => _lastWatermark;
 
@@ -225,7 +225,6 @@ public async Task StartStream(
                     SerializeOptions = stateSerializeOptions,
                     PersistentStorage = _persistentStorage,
                     DefaultBPlusTreePageSize = pageSize,
-                    //DefaultBPlusTreePageSizeBytes = 1,
                     TemporaryStorageOptions = new Storage.FileCacheOptions()
                     {
                         DirectoryPath = $"./data/tempFiles/{testName}/tmp"
-Original file line number
+Diff line change
@@ Expand Up @@
                     return;
                 }
-                throw new NotSupportedException();
             }
             public async Task InitializeAsync<TMetadata>(IStateSerializerInitializeReader reader, StateClientMetadata<TMetadata> metadata) where TMetadata : IStorageMetadata
@@ Expand Down Expand Up @@
                     return;
                 }
-                throw new NotSupportedException();
             }
             public IBPlusTreeNode Deserialize(IMemoryOwner<byte> bytes, int length, StateSerializeOptions stateSerializeOptions)
@@ Expand Down @@