lokeshj1703 commented on code in PR #13007:
URL: https://github.com/apache/hudi/pull/13007#discussion_r2018356987
##########
hudi-spark-datasource/hudi-spark/src/test/java/org/apache/hudi/client/functional/TestHoodieBackedMetadata.java:
##########
@@ -256,6 +259,7 @@ public void testMetadataTableBootstrap(HoodieTableType
tableType, boolean addRol
validateMetadata(testTable, true);
}
+ @Disabled("HUDI-9221")
Review Comment:
Reenabled these tests
##########
hudi-common/src/test/java/org/apache/hudi/common/testutils/FileCreateUtils.java:
##########
@@ -98,6 +98,22 @@ private static <T> void createMetaFile(HoodieTableMetaClient
metaClient, String
metadata.flatMap(m ->
metaClient.getCommitMetadataSerDe().getInstantWriter(m)));
}
+ public static String markerFileName(String fileName, IOType ioType) {
+ return String.format("%s%s.%s", fileName,
HoodieTableMetaClient.MARKER_EXTN, ioType.name());
+ }
+
+ public static String dataFileMarkerFileName(String instantTime, String
fileId, IOType ioType, String fileExtension, String writeToken) {
+ return markerFileName(FSUtils.makeBaseFileName(instantTime, writeToken,
fileId, fileExtension), ioType);
+ }
+
+ public static String logFileMarkerFileName(String instantTime, String
fileId, IOType ioType, int logVersion) {
+ return logFileMarkerFileName(instantTime, fileId, ioType,
HoodieLogFile.DELTA_EXTENSION, logVersion);
+ }
+
+ public static String logFileMarkerFileName(String instantTime, String
fileId, IOType ioType, String fileExtension, int logVersion) {
+ return markerFileName(FSUtils.makeLogFileName(fileId, fileExtension,
instantTime, logVersion, WRITE_TOKEN), ioType);
+ }
Review Comment:
These are test utils. They are used by HoodieTestTable and test classes like
TestMarkerBasedRollbackStrategy
--
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]
