diff --git a/go/io/fs/minio_fs.go b/go/io/fs/minio_fs.go
index 623149e9..47958623 100644
--- a/go/io/fs/minio_fs.go
+++ b/go/io/fs/minio_fs.go
@@ -74,7 +74,7 @@ func (fs *MinioFs) List(path string) ([]FileEntry, error) {
 		return nil, err
 	}
 	ret := make([]FileEntry, 0)
-	for objInfo := range fs.client.ListObjects(context.TODO(), fs.bucketName, minio.ListObjectsOptions{Prefix: path, Recursive: false}) {
+	for objInfo := range fs.client.ListObjects(context.TODO(), fs.bucketName, minio.ListObjectsOptions{Prefix: path, Recursive: true}) {
 		if objInfo.Err != nil {
 			log.Warn("list object error", zap.Error(objInfo.Err))
 			return nil, objInfo.Err
diff --git a/go/io/fs/minio_fs_test.go b/go/io/fs/minio_fs_test.go
index a6333560..d84b45a0 100644
--- a/go/io/fs/minio_fs_test.go
+++ b/go/io/fs/minio_fs_test.go
@@ -75,12 +75,7 @@ func (suite *MinioFsTestSuite) TestMinioFsDeleteFile() {
 }
 
 func (suite *MinioFsTestSuite) TestMinioFsList() {
-	file, err := suite.fs.OpenFile("default/a/b")
-	suite.NoError(err)
-	_, err = file.Write([]byte{1})
-	suite.NoError(err)
-	suite.NoError(file.Close())
-	file, err = suite.fs.OpenFile("default/a/b/c")
+	file, err := suite.fs.OpenFile("default/a/b/c")
 	suite.NoError(err)
 	_, err = file.Write([]byte{1})
 	suite.NoError(err)
@@ -88,7 +83,7 @@ func (suite *MinioFsTestSuite) TestMinioFsList() {
 
 	entries, err := suite.fs.List("default/a/")
 	suite.NoError(err)
-	suite.EqualValues([]fs.FileEntry{{Path: "a/b"}}, entries)
+	suite.EqualValues([]fs.FileEntry{{Path: "a/b/c"}}, entries)
 }
 
 func (suite *MinioFsTestSuite) TestMinioFsReadFile() {