Skip to content

Commit 012d9af

Browse files
committed
add null table exception
1 parent 10e455d commit 012d9af

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

v2/datastream-to-spanner/src/main/java/com/google/cloud/teleport/v2/templates/datastream/ChangeEventContext.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,10 @@ protected ChangeEventContext(
7878
this.changeEvent = changeEvent;
7979
this.dataTable = changeEvent.get(DatastreamConstants.EVENT_TABLE_NAME_KEY).asText();
8080
Table table = ddl.table(this.dataTable);
81+
if (table == null) {
82+
throw new DroppedTableException(
83+
"Table from change event does not exist in Spanner. table=" + this.dataTable);
84+
}
8185
Set<String> existingPrimaryKeyColumnNames =
8286
table.primaryKeys().stream().map(k -> k.name()).collect(Collectors.toSet());
8387

0 commit comments

Comments
 (0)