[flink-table-store] branch master updated: [hotfix] Fix SchemaManagerTest.testDeleteSchemaWithSchemaId

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git


The following commit(s) were added to refs/heads/master by this push:
     new 17b3b2fd [hotfix] Fix SchemaManagerTest.testDeleteSchemaWithSchemaId
17b3b2fd is described below

commit 17b3b2fd2b7fed996a2c532cbaf9ccd274d14181
Author: JingsongLi <lzljs3620...@aliyun.com>
AuthorDate: Tue Mar 14 10:16:12 2023 +0800

    [hotfix] Fix SchemaManagerTest.testDeleteSchemaWithSchemaId
---
 .../org/apache/flink/table/store/file/schema/SchemaManagerTest.java | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/flink-table-store-core/src/test/java/org/apache/flink/table/store/file/schema/SchemaManagerTest.java
 
b/flink-table-store-core/src/test/java/org/apache/flink/table/store/file/schema/SchemaManagerTest.java
index 4959c37a..d66d7747 100644
--- 
a/flink-table-store-core/src/test/java/org/apache/flink/table/store/file/schema/SchemaManagerTest.java
+++ 
b/flink-table-store-core/src/test/java/org/apache/flink/table/store/file/schema/SchemaManagerTest.java
@@ -23,6 +23,7 @@ import org.apache.flink.table.store.file.WriteMode;
 import org.apache.flink.table.store.file.utils.FailingFileIO;
 import org.apache.flink.table.store.fs.FileIOFinder;
 import org.apache.flink.table.store.fs.Path;
+import org.apache.flink.table.store.fs.local.LocalFileIO;
 import org.apache.flink.table.store.types.BigIntType;
 import org.apache.flink.table.store.types.DataField;
 import org.apache.flink.table.store.types.DoubleType;
@@ -61,6 +62,7 @@ public class SchemaManagerTest {
     @TempDir java.nio.file.Path tempDir;
 
     private SchemaManager manager;
+    private Path path;
 
     private final List<String> partitionKeys = Collections.singletonList("f0");
     private final List<String> primaryKeys = Arrays.asList("f0", "f1");
@@ -75,7 +77,7 @@ public class SchemaManagerTest {
         String failingName = UUID.randomUUID().toString();
         FailingFileIO.reset(failingName, 100, 100);
         String root = FailingFileIO.getFailingPath(failingName, 
tempDir.toString());
-        Path path = new Path(root);
+        path = new Path(root);
         manager = new SchemaManager(FileIOFinder.find(path), path);
     }
 
@@ -300,6 +302,8 @@ public class SchemaManagerTest {
                         primaryKeys,
                         options,
                         "append-only table with primary key");
+        // use non-failing manager
+        SchemaManager manager = new SchemaManager(LocalFileIO.create(), path);
         manager.createTable(schema);
         String schemaContent = manager.latest().get().toString();