Skip to content
Permalink

Comparing changes

This is a direct comparison between two commits made in this repository or its related repositories. View the default comparison for this range or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: apache/beam
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: 49ad5e2282617162ee022f6985857880bd934729
Choose a base ref
..
head repository: apache/beam
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: 58948bc096dcc46c607f995629c7d02332ecc821
Choose a head ref
Showing with 1 addition and 1 deletion.
  1. +1 −1 .../java/io/kafka/upgrade/src/main/java/org/apache/beam/sdk/io/kafka/upgrade/KafkaIOTranslation.java
Original file line number Diff line number Diff line change
@@ -355,7 +355,7 @@ public Row toConfigRow(Read<?, ?> transform) {
}
if (TransformUpgrader.compareVersions(updateCompatibilityBeamVersion, "2.63.0") >= 0) {
Boolean offsetDeduplication = configRow.getValue("offset_deduplication");
if (offsetDeduplication != null && offsetDeduplication) {
if (offsetDeduplication != null) {
transform = transform.withOffsetDeduplication(offsetDeduplication);
}
}