vinothchandar commented on a change in pull request #4114:
URL: https://github.com/apache/hudi/pull/4114#discussion_r756968221
##########
File path:
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/HoodieFlinkTable.java
##########
@@ -110,16 +109,15 @@ protected HoodieIndex getIndex(HoodieWriteConfig config,
HoodieEngineContext con
@Override
public <T extends SpecificRecordBase> Option<HoodieTableMetadataWriter>
getMetadataWriter(Option<T> actionMetadata) {
synchronized (this) {
- if (!isMetadataAvailabilityUpdated) {
- // This code assumes that if metadata availability is updated once it
will not change.
- // Please revisit this logic if that's not the case. This is done to
avoid repeated calls to fs.exists().
+ // Metadata table bootstrapping might have failed due to pending actions.
Review comment:
this method in geneneral seems like a duplicated code, Can we move this
to the super class
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
