Skip to content

Commit 0a48f48

Browse files
committed
Renamed variable to match Beam version
1 parent ac2205b commit 0a48f48

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

v1/src/main/java/com/google/cloud/teleport/spanner/spannerio/SpannerSchema.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -246,8 +246,9 @@ private static Type parseSpannerType(String spannerType, Dialect dialect) {
246246
Matcher m = pattern.matcher(spannerType);
247247
if (m.find()) {
248248
// Substring "xxx[]" or "xxx[] vector length yyy"
249-
String arrayElementType = m.group(1);
250-
Type itemType = parseSpannerType(arrayElementType, dialect);
249+
// Must check array type first
250+
String spannerArrayType = m.group(1);
251+
Type itemType = parseSpannerType(spannerArrayType, dialect);
251252
return Type.array(itemType);
252253
}
253254
type = POSTGRES_TYPE_MAP.get(spannerType);

0 commit comments

Comments
 (0)