Skip to content

Commit 4141b42

Browse files
committed
foo
1 parent 43397a8 commit 4141b42

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TableRowToStorageApiProto.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1188,7 +1188,8 @@ public static ByteString mergeNewFields(
11881188
throw new RuntimeException(e);
11891189
}
11901190
TableRow original =
1191-
TableRowToStorageApiProto.tableRowFromMessage(message, true, Predicates.alwaysTrue());
1191+
TableRowToStorageApiProto.tableRowFromMessage(
1192+
schemaInformation, message, true, Predicates.alwaysTrue());
11921193
Map<String, Descriptors.FieldDescriptor> fieldDescriptors =
11931194
descriptor.getFields().stream()
11941195
.collect(Collectors.toMap(Descriptors.FieldDescriptor::getName, Functions.identity()));

0 commit comments

Comments
 (0)