We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b85646b commit 5178343Copy full SHA for 5178343
1 file changed
sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/DebeziumIO.java
@@ -323,9 +323,9 @@ protected Schema getRecordSchema() {
323
324
return Schema.builder()
325
.addFields(valueSchema.getFields())
326
- // TODO(https://github.com/apache/beam/issues/39557):
327
- // Restore 'primaryKeyColumns' once Python can decode ARRAY<STRING>
328
- // schema options across the Java/Python cross-language boundary.
+ // TODO(https://github.com/apache/beam/issues/39557):
+ // Restore 'primaryKeyColumns' once Python can decode ARRAY<STRING>
+ // schema options across the Java/Python cross-language boundary.
329
.build();
330
}
331
0 commit comments