diff --git a/hapi-fhir-jpaserver-migrate/src/main/java/ca/uhn/fhir/jpa/migrate/tasks/api/BaseMigrationTasks.java b/hapi-fhir-jpaserver-migrate/src/main/java/ca/uhn/fhir/jpa/migrate/tasks/api/BaseMigrationTasks.java
index d041155d70f..91bba26581c 100644
--- a/hapi-fhir-jpaserver-migrate/src/main/java/ca/uhn/fhir/jpa/migrate/tasks/api/BaseMigrationTasks.java
+++ b/hapi-fhir-jpaserver-migrate/src/main/java/ca/uhn/fhir/jpa/migrate/tasks/api/BaseMigrationTasks.java
@@ -335,16 +335,18 @@ public class BaseMigrationTasks<T extends Enum> {
 			}
 		}
 
-		public class BuilderAddTableByColumns implements IAcceptsTasks {
+		public class BuilderAddTableByColumns extends BuilderWithTableName implements IAcceptsTasks {
 			private final AddTableByColumnTask myTask;
 
 			public BuilderAddTableByColumns(IAcceptsTasks theSink, String theTableName, String thePkColumnName) {
+				super(theSink, theTableName);
 				myTask = new AddTableByColumnTask();
 				myTask.setTableName(theTableName);
 				myTask.setPkColumn(thePkColumnName);
 				theSink.addTask(myTask);
 			}
 
+			@Override
 			public BuilderWithTableName.BuilderAddColumnWithName addColumn(String theColumnName) {
 				return new BuilderWithTableName.BuilderAddColumnWithName(theColumnName, this);
 			}