yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-12-13 02:57:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(restore-indices): Do not fail on MAE row count diff (#5165)

Browse Source
This commit is contained in:
Dexter Lee 2022-06-14 10:12:10 -07:00 committed by GitHub
parent 2dfc166bbd
commit b890ba0d12
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
datahub-upgrade/src/main/java/com/linkedin/datahub/upgrade/restoreindices/SendMAEStep.java
View File

@ -100,8 +100,8 @@ public class SendMAEStep implements UpgradeStep {
AspectSpec aspectSpec = entitySpec.getAspectSpec(aspectName); AspectSpec aspectSpec = entitySpec.getAspectSpec(aspectName);
if (aspectSpec == null) { if (aspectSpec == null) {
context.report() context.report()
.addLine(String.format("Failed to find aspect with name %s associated with entity named %s", .addLine(String.format("Failed to find aspect with name %s associated with entity named %s", aspectName,
aspectName, entityName)); entityName));
continue; continue;
} }
@ -135,11 +135,7 @@ public class SendMAEStep implements UpgradeStep {
} }
} }
if (totalRowsMigrated != rowCount) { if (totalRowsMigrated != rowCount) {
context.report() context.report().addLine(String.format("Failed to send MAEs for %d rows...", rowCount - totalRowsMigrated));
.addLine(
String.format("Number of MAEs sent %s does not equal the number of input rows %s...", totalRowsMigrated,
rowCount));
return new DefaultUpgradeStepResult(id(), UpgradeStepResult.Result.FAILED);
} }
return new DefaultUpgradeStepResult(id(), UpgradeStepResult.Result.SUCCEEDED); return new DefaultUpgradeStepResult(id(), UpgradeStepResult.Result.SUCCEEDED);
}; };