Skip to content

[FLINK-31309] Delete DFS schema when create table failed in HiveCatalog#575

Merged
JingsongLi merged 2 commits into
apache:masterfrom
FangYongs:FLINK-31309_delete_file_for_hive_create
Mar 6, 2023
Merged

[FLINK-31309] Delete DFS schema when create table failed in HiveCatalog#575
JingsongLi merged 2 commits into
apache:masterfrom
FangYongs:FLINK-31309_delete_file_for_hive_create

Conversation

@FangYongs
Copy link
Copy Markdown
Contributor

Delete DFS schema when create table failed in HiveCatalog

Copy link
Copy Markdown
Contributor

@JingsongLi JingsongLi left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks @FangYongs , left two comments.

" 'uri' = '',",
" 'warehouse' = '" + path + "',",
" 'metastore.client.class' = '"
+ TestHiveMetaStoreClient.class.getName()
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Can you create a new class FailMetaStoreClient?

} catch (TException e) {
Path path = getDataTableLocation(identifier);
try {
fileIO.delete(path, true);
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Maybe introduce a method in FileIO, deleteDirectoryQuietly?

@FangYongs
Copy link
Copy Markdown
Contributor Author

Thanks @JingsongLi Done

Copy link
Copy Markdown
Contributor

@JingsongLi JingsongLi left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

+1

@JingsongLi JingsongLi merged commit fa51956 into apache:master Mar 6, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants