Skip to content

Commit 9a2c99a

Browse files
committed
fix ut
1 parent 4e63d3b commit 9a2c99a

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/ForStResourceContainerTest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -310,8 +310,10 @@ public ColumnFamilyOptions createColumnOptions(
310310
public void testDirectoryResources() throws Exception {
311311
Path localJobPath = new Path(TMP_FOLDER.newFolder().getPath());
312312
Path localBasePath = new Path(localJobPath, "base");
313+
localBasePath.getFileSystem().mkdirs(localBasePath);
313314
Path remoteJobPath = new Path(TMP_FOLDER.newFolder().getPath());
314315
Path remoteBasePath = new Path(remoteJobPath, "base");
316+
remoteBasePath.getFileSystem().mkdirs(remoteBasePath);
315317
try (final ForStResourceContainer optionsContainer =
316318
new ForStResourceContainer(
317319
new Configuration(),

0 commit comments

Comments
 (0)