107107import static org .apache .paimon .CoreOptions .CHANGELOG_NUM_RETAINED_MIN ;
108108import static org .apache .paimon .CoreOptions .CONSUMER_IGNORE_PROGRESS ;
109109import static org .apache .paimon .CoreOptions .DELETION_VECTORS_ENABLED ;
110- import static org .apache .paimon .CoreOptions .DELETION_VECTORS_MODIFIABLE ;
111110import static org .apache .paimon .CoreOptions .ExpireExecutionMode ;
112111import static org .apache .paimon .CoreOptions .FILE_FORMAT ;
113112import static org .apache .paimon .CoreOptions .SNAPSHOT_CLEAN_EMPTY_DIRECTORIES ;
@@ -1593,12 +1592,12 @@ public void testBranchWriteAndRead() throws Exception {
15931592
15941593 @ Test
15951594 public void testDataSplitNotIncludeDvFilesWhenStreamingRead () throws Exception {
1596- FileStoreTable table = createFileStoreTable ();
1597- Map < String , String > options = new HashMap <>();
1598- options . put ( DELETION_VECTORS_MODIFIABLE . key (), "true" );
1599- options .put (DELETION_VECTORS_ENABLED . key (), " true" );
1600- options .put (WRITE_ONLY . key (), " true" );
1601- table = table . copy ( options );
1595+ FileStoreTable table =
1596+ createFileStoreTable (
1597+ options -> {
1598+ options .set (DELETION_VECTORS_ENABLED , true );
1599+ options .set (WRITE_ONLY , true );
1600+ } );
16021601
16031602 try (StreamTableWrite write = table .newWrite (commitUser );
16041603 StreamTableCommit commit = table .newCommit (commitUser )) {
@@ -1619,12 +1618,12 @@ public void testDataSplitNotIncludeDvFilesWhenStreamingRead() throws Exception {
16191618
16201619 @ Test
16211620 public void testDataSplitNotIncludeDvFilesWhenStreamingReadChanges () throws Exception {
1622- FileStoreTable table = createFileStoreTable ();
1623- Map < String , String > options = new HashMap <>();
1624- options . put ( DELETION_VECTORS_MODIFIABLE . key (), "true" );
1625- options .put (DELETION_VECTORS_ENABLED . key (), " true" );
1626- options .put (WRITE_ONLY . key (), " true" );
1627- table = table . copy ( options );
1621+ FileStoreTable table =
1622+ createFileStoreTable (
1623+ options -> {
1624+ options .set (DELETION_VECTORS_ENABLED , true );
1625+ options .set (WRITE_ONLY , true );
1626+ } );
16281627
16291628 try (StreamTableWrite write = table .newWrite (commitUser );
16301629 StreamTableCommit commit = table .newCommit (commitUser )) {
0 commit comments