File tree Expand file tree Collapse file tree
clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -537,17 +537,19 @@ public void testTargetRegionPushWithDeferredSwapVersionStatusChecks(
537537
538538 pushJob .run ();
539539 } catch (Exception e ) {
540+ String expectedTopic = "kafka-topic" ;
540541 if (VersionStatus .PARTIALLY_ONLINE .equals (versionStatus )) {
541542 Assert .assertEquals (
542543 e .getMessage (),
543- "Version pubsub-topic is only partially online in some regions. Check nuage to see which regions are not serving the latest version."
544+ "Version " + expectedTopic
545+ + " is only partially online in some regions. Check nuage to see which regions are not serving the latest version."
544546 + " It is possible that there was a failure in rolling forward on the controller side or ingestion failed in some regions." );
545547 } else if (VersionStatus .KILLED .equals (versionStatus )) {
546- Assert .assertEquals (e .getMessage (), "Version pubsub-topic was killed and cannot be served." );
548+ Assert .assertEquals (e .getMessage (), "Version " + expectedTopic + " was killed and cannot be served." );
547549 } else {
548550 Assert .assertEquals (
549551 e .getMessage (),
550- "Version pubsub-topic was rolled back after ingestion completed due to validation failure" );
552+ "Version " + expectedTopic + " was rolled back after ingestion completed due to validation failure" );
551553 }
552554 }
553555 }
You can’t perform that action at this time.
0 commit comments