chamikaramj commented on code in PR #40726:
URL: https://github.com/apache/beam/pull/40726#discussion_r4350661225
##########
sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/catalog/IcebergCdcWriteBaseIT.java:
##########
@@ -855,7 +855,8 @@ private void roundTripThroughSource(boolean upsert, boolean
changeTypeColumn) th
}
metadataColumns.add(IcebergCdcMetadataColumns.COMMIT_SNAPSHOT_SEQUENCE_NUMBER);
PipelineOptions options = TestPipeline.testingPipelineOptions();
- if (!changeTypeColumn) {
+ // Use the legacy worker for managed transforms until the Runner v2 CDC
issue is resolved.
+ if (!changeTypeColumn ||
Boolean.getBoolean("beam.test.enableManagedTransforms")) {
Review Comment:
Skip only runner v2 tests till the Dataflow service is updated to use Beam
2.77.0 for managed transforms please. Runner v1 tests should work and we can
re-enable Runner v2 tests in a week or so when the service is updated.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
