Skip to content

Push on main

Push on main #1199

GitHub Actions / Integration Test report on GitHub succeeded Jan 8, 2025 in 1s

47 passed, 1 failed and 1 skipped

Tests failed

Report Passed Failed Skipped Time
v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerDDLIT.xml 8✅ 548s
v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerEventsIT.xml 3✅ 702s
v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerFileOverridesIT.xml 1✅ 379s
v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerIT.xml 11✅ 1❌ 1000ms
v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerMixedIT.xml 1✅ 544s
v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerSessionIT.xml 2✅ 420s
v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerShardedMigrationWithMigrationShardIdColumnIT.xml 3✅ 596s
v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerShardedMigrationWithoutMigrationShardIdColumnIT.xml 1✅ 577s
v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DatastreamToSpannerSingleDFShardedMigrationIT.xml 1✅ 775s
v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerStringOverridesIT.xml 1✅ 334s
v2/gcs-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.GCSToSourceDbInterleaveIT.xml 1✅ 934s
v2/gcs-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.GCSToSourceDbInterleaveMultiShardIT.xml 1✅ 932s
v2/gcs-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.GCSToSourceDbWithoutReaderIT.xml 1✅ 510s
v2/gcs-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.GCSToSourceDbWithReaderIT.xml 1✅ 982s
v2/gcs-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.TimezoneIT.xml 1✅ 883s
v2/spanner-change-streams-to-sharded-file-sink/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.SpannerChangeStreamToGcsCustomShardIT.xml 1✅ 641s
v2/spanner-change-streams-to-sharded-file-sink/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.SpannerChangeStreamToGcsMultiShardIT.xml 2✅ 822s
v2/spanner-change-streams-to-sharded-file-sink/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.SpannerChangeStreamToGcsSingleShardIT.xml 2✅ 763s
v2/spanner-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.SpannerToSourceDbCustomShardIT.xml 1✅ 626s
v2/spanner-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.SpannerToSourceDbCustomTransformationIT.xml 1⚪ 1ms
v2/spanner-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.SpannerToSourceDbDatatypeIT.xml 1✅ 638s
v2/spanner-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.SpannerToSourceDbInterleaveMultiShardIT.xml 1✅ 847s
v2/spanner-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.SpannerToSourceDbIT.xml 1✅ 652s
v2/spanner-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.SpannerToSourceDbTimezoneIT.xml 1✅ 969s

✅ v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerDDLIT.xml

8 tests were completed in 548s with 8 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.DataStreamToSpannerDDLIT 8✅ 548s

✅ com.google.cloud.teleport.v2.templates.DataStreamToSpannerDDLIT

✅ migrationTestWithCharsetConversion
✅ migrationTestWithAllDatatypeConversionMapping
✅ migrationTestWithSequenceColumns
✅ migrationTestWithAllDatatypeTransformation
✅ migrationTestWithDatatypeSizeReducedConversion
✅ migrationTestWithAllDatatypeDefaultMapping
✅ migrationTestWithGeneratedColumns
✅ migrationTestWithDatatypeSizeConversion

✅ v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerEventsIT.xml

3 tests were completed in 702s with 3 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.DataStreamToSpannerEventsIT 3✅ 702s

✅ com.google.cloud.teleport.v2.templates.DataStreamToSpannerEventsIT

✅ migrationTestWithUpdatesAndDeletes
✅ migrationTestWithInsertsOnly
✅ interleavedAndFKAndIndexTest

✅ v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerFileOverridesIT.xml

1 tests were completed in 379s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.DataStreamToSpannerFileOverridesIT 1✅ 379s

✅ com.google.cloud.teleport.v2.templates.DataStreamToSpannerFileOverridesIT

✅ migrationTestWithRenameTableAndColumns

❌ v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerIT.xml

12 tests were completed in 1000ms with 11 passed, 1 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.DataStreamToSpannerIT 11✅ 1❌ 1000ms

❌ com.google.cloud.teleport.v2.templates.DataStreamToSpannerIT

✅ testDataStreamOracleToSpannerJson[Staging]
✅ testDataStreamOracleToSpannerJson[Default]
✅ testDataStreamMySqlToPostgresSpanner[Default]
✅ testDataStreamOracleToSpanner[Staging]
✅ testDataStreamOracleToSpanner[Default]
❌ testDataStreamMySqlToPostgresSpanner[Staging]
	org.apache.beam.it.gcp.spanner.SpannerResourceManagerException: Failed to execute statement.
✅ testDataStreamMySqlToSpannerStreamingEngine[Default]
✅ testDataStreamMySqlToSpanner[Default]
✅ testDataStreamMySqlToSpanner[Staging]
✅ testDataStreamMySqlToSpannerJson[Default]
✅ testDataStreamMySqlToSpannerJson[Staging]
✅ testDataStreamMySqlToSpannerStreamingEngine[Staging]

✅ v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerMixedIT.xml

1 tests were completed in 544s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.DataStreamToSpannerMixedIT 1✅ 544s

✅ com.google.cloud.teleport.v2.templates.DataStreamToSpannerMixedIT

✅ mixedMigrationTest

✅ v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerSessionIT.xml

2 tests were completed in 420s with 2 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.DataStreamToSpannerSessionIT 2✅ 420s

✅ com.google.cloud.teleport.v2.templates.DataStreamToSpannerSessionIT

✅ migrationTestWithSyntheticPKAndExtraColumn
✅ migrationTestWithRenameAndDrops

✅ v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerShardedMigrationWithMigrationShardIdColumnIT.xml

3 tests were completed in 596s with 3 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.DataStreamToSpannerShardedMigrationWithMigrationShardIdColumnIT 3✅ 596s

✅ com.google.cloud.teleport.v2.templates.DataStreamToSpannerShardedMigrationWithMigrationShardIdColumnIT

✅ multiShardMigration
✅ pkReorderedMultiShardMigration
✅ customTransformationMultiShardMigration

✅ v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerShardedMigrationWithoutMigrationShardIdColumnIT.xml

1 tests were completed in 577s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.DataStreamToSpannerShardedMigrationWithoutMigrationShardIdColumnIT 1✅ 577s

✅ com.google.cloud.teleport.v2.templates.DataStreamToSpannerShardedMigrationWithoutMigrationShardIdColumnIT

✅ multiShardMigration

✅ v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DatastreamToSpannerSingleDFShardedMigrationIT.xml

1 tests were completed in 775s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.DatastreamToSpannerSingleDFShardedMigrationIT 1✅ 775s

✅ com.google.cloud.teleport.v2.templates.DatastreamToSpannerSingleDFShardedMigrationIT

✅ multiShardMigration

✅ v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerStringOverridesIT.xml

1 tests were completed in 334s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.DataStreamToSpannerStringOverridesIT 1✅ 334s

✅ com.google.cloud.teleport.v2.templates.DataStreamToSpannerStringOverridesIT

✅ migrationTestWithRenameTableAndColumns

✅ v2/gcs-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.GCSToSourceDbInterleaveIT.xml

1 tests were completed in 934s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.GCSToSourceDbInterleaveIT 1✅ 934s

✅ com.google.cloud.teleport.v2.templates.GCSToSourceDbInterleaveIT

✅ testOrderedWrites

✅ v2/gcs-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.GCSToSourceDbInterleaveMultiShardIT.xml

1 tests were completed in 932s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.GCSToSourceDbInterleaveMultiShardIT 1✅ 932s

✅ com.google.cloud.teleport.v2.templates.GCSToSourceDbInterleaveMultiShardIT

✅ testOrderedWrites

✅ v2/gcs-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.GCSToSourceDbWithoutReaderIT.xml

1 tests were completed in 510s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.GCSToSourceDbWithoutReaderIT 1✅ 510s

✅ com.google.cloud.teleport.v2.templates.GCSToSourceDbWithoutReaderIT

✅ testGCSToSource

✅ v2/gcs-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.GCSToSourceDbWithReaderIT.xml

1 tests were completed in 982s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.GCSToSourceDbWithReaderIT 1✅ 982s

✅ com.google.cloud.teleport.v2.templates.GCSToSourceDbWithReaderIT

✅ testGCSToSource

✅ v2/gcs-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.TimezoneIT.xml

1 tests were completed in 883s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.TimezoneIT 1✅ 883s

✅ com.google.cloud.teleport.v2.templates.TimezoneIT

✅ testGCSToSource

✅ v2/spanner-change-streams-to-sharded-file-sink/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.SpannerChangeStreamToGcsCustomShardIT.xml

1 tests were completed in 641s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.SpannerChangeStreamToGcsCustomShardIT 1✅ 641s

✅ com.google.cloud.teleport.v2.templates.SpannerChangeStreamToGcsCustomShardIT

✅ testMultiShardsRecordWrittenToGcsWithCustomShardId

✅ v2/spanner-change-streams-to-sharded-file-sink/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.SpannerChangeStreamToGcsMultiShardIT.xml

2 tests were completed in 822s with 2 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.SpannerChangeStreamToGcsMultiShardIT 2✅ 822s

✅ com.google.cloud.teleport.v2.templates.SpannerChangeStreamToGcsMultiShardIT

✅ testMultiShardsRecordWrittenToGcs
✅ testForwardMigrationFiltered

✅ v2/spanner-change-streams-to-sharded-file-sink/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.SpannerChangeStreamToGcsSingleShardIT.xml

2 tests were completed in 763s with 2 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.SpannerChangeStreamToGcsSingleShardIT 2✅ 763s

✅ com.google.cloud.teleport.v2.templates.SpannerChangeStreamToGcsSingleShardIT

✅ testAllDatatypes
✅ testSingleRecordWrittenToGcs

✅ v2/spanner-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.SpannerToSourceDbCustomShardIT.xml

1 tests were completed in 626s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.SpannerToSourceDbCustomShardIT 1✅ 626s

✅ com.google.cloud.teleport.v2.templates.SpannerToSourceDbCustomShardIT

✅ spannerToSourceDbCustomShard

✅ v2/spanner-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.SpannerToSourceDbCustomTransformationIT.xml

1 tests were completed in 1ms with 0 passed, 0 failed and 1 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.SpannerToSourceDbCustomTransformationIT 1⚪ 1ms

✅ com.google.cloud.teleport.v2.templates.SpannerToSourceDbCustomTransformationIT

⚪ spannerToSourceDbWithCustomTransformation

✅ v2/spanner-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.SpannerToSourceDbDatatypeIT.xml

1 tests were completed in 638s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.SpannerToSourceDbDatatypeIT 1✅ 638s

✅ com.google.cloud.teleport.v2.templates.SpannerToSourceDbDatatypeIT

✅ spannerToSourceDataTypeConversionTest

✅ v2/spanner-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.SpannerToSourceDbInterleaveMultiShardIT.xml

1 tests were completed in 847s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.SpannerToSourceDbInterleaveMultiShardIT 1✅ 847s

✅ com.google.cloud.teleport.v2.templates.SpannerToSourceDbInterleaveMultiShardIT

✅ spannerToSourceFKTest

✅ v2/spanner-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.SpannerToSourceDbIT.xml

1 tests were completed in 652s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.SpannerToSourceDbIT 1✅ 652s

✅ com.google.cloud.teleport.v2.templates.SpannerToSourceDbIT

✅ spannerToSourceDbBasic

✅ v2/spanner-to-sourcedb/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.SpannerToSourceDbTimezoneIT.xml

1 tests were completed in 969s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.google.cloud.teleport.v2.templates.SpannerToSourceDbTimezoneIT 1✅ 969s

✅ com.google.cloud.teleport.v2.templates.SpannerToSourceDbTimezoneIT

✅ timezoneTest

Annotations

Check failure on line 328 in it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/SpannerResourceManager.java

See this annotation in the file changed.

@github-actions github-actions / Integration Test report on GitHub

com.google.cloud.teleport.v2.templates.DataStreamToSpannerIT ► testDataStreamMySqlToPostgresSpanner[Staging]

Failed test found in:
  v2/datastream-to-spanner/target/surefire-reports/TEST-com.google.cloud.teleport.v2.templates.DataStreamToSpannerIT.xml
Error:
  org.apache.beam.it.gcp.spanner.SpannerResourceManagerException: Failed to execute statement.
Raw output
org.apache.beam.it.gcp.spanner.SpannerResourceManagerException: Failed to execute statement.
	at org.apache.beam.it.gcp.spanner.SpannerResourceManager.executeDdlStatements(SpannerResourceManager.java:328)
	at org.apache.beam.it.gcp.spanner.SpannerResourceManager.executeDdlStatement(SpannerResourceManager.java:299)
	at com.google.cloud.teleport.v2.templates.DataStreamToSpannerIT.lambda$createSpannerTables$4(DataStreamToSpannerIT.java:384)
	at java.base/java.lang.Iterable.forEach(Iterable.java:75)
	at com.google.cloud.teleport.v2.templates.DataStreamToSpannerIT.createSpannerTables(DataStreamToSpannerIT.java:382)
	at com.google.cloud.teleport.v2.templates.DataStreamToSpannerIT.simpleJdbcToSpannerTest(DataStreamToSpannerIT.java:271)
	at com.google.cloud.teleport.v2.templates.DataStreamToSpannerIT.simpleMySqlToSpannerTest(DataStreamToSpannerIT.java:183)
	at com.google.cloud.teleport.v2.templates.DataStreamToSpannerIT.testDataStreamMySqlToPostgresSpanner(DataStreamToSpannerIT.java:144)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:566)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
	at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
	at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
	at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
	at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
	at org.apache.maven.surefire.junitcore.pc.Scheduler$1.run(Scheduler.java:410)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: dev.failsafe.FailsafeException: java.util.concurrent.ExecutionException: com.google.cloud.spanner.SpannerException: FAILED_PRECONDITION: Operation with name "projects/cloud-teleport-testing/instances/teleport/databases/testdat_20250108_122602_wsvk9j/operations/r63e5e8db_6889_4fc2_9fb8_95854d0179a3" failed with status = GrpcStatusCode{transportCode=FAILED_PRECONDITION} and message = Duplicate name in schema: datastreamtospanner_1_2eh4w.
	at dev.failsafe.SyncExecutionImpl.executeSync(SyncExecutionImpl.java:196)
	at dev.failsafe.FailsafeExecutor.call(FailsafeExecutor.java:376)
	at dev.failsafe.FailsafeExecutor.run(FailsafeExecutor.java:220)
	at org.apache.beam.it.gcp.spanner.SpannerResourceManager.executeDdlStatements(SpannerResourceManager.java:320)
	... 30 more
Caused by: java.util.concurrent.ExecutionException: com.google.cloud.spanner.SpannerException: FAILED_PRECONDITION: Operation with name "projects/cloud-teleport-testing/instances/teleport/databases/testdat_20250108_122602_wsvk9j/operations/r63e5e8db_6889_4fc2_9fb8_95854d0179a3" failed with status = GrpcStatusCode{transportCode=FAILED_PRECONDITION} and message = Duplicate name in schema: datastreamtospanner_1_2eh4w.
	at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:594)
	at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:573)
	at com.google.common.util.concurrent.FluentFuture$TrustedFuture.get(FluentFuture.java:91)
	at com.google.common.util.concurrent.ForwardingFuture.get(ForwardingFuture.java:67)
	at com.google.api.gax.longrunning.OperationFutureImpl.get(OperationFutureImpl.java:125)
	at org.apache.beam.it.gcp.spanner.SpannerResourceManager.lambda$executeDdlStatements$4(SpannerResourceManager.java:325)
	at dev.failsafe.Functions.lambda$toCtxSupplier$9(Functions.java:228)
	at dev.failsafe.Functions.lambda$get$0(Functions.java:46)
	at dev.failsafe.internal.RetryPolicyExecutor.lambda$apply$0(RetryPolicyExecutor.java:74)
	at dev.failsafe.SyncExecutionImpl.executeSync(SyncExecutionImpl.java:187)
	... 33 more
Caused by: com.google.cloud.spanner.SpannerException: FAILED_PRECONDITION: Operation with name "projects/cloud-teleport-testing/instances/teleport/databases/testdat_20250108_122602_wsvk9j/operations/r63e5e8db_6889_4fc2_9fb8_95854d0179a3" failed with status = GrpcStatusCode{transportCode=FAILED_PRECONDITION} and message = Duplicate name in schema: datastreamtospanner_1_2eh4w.
	at com.google.cloud.spanner.SpannerExceptionFactory.newSpannerExceptionPreformatted(SpannerExceptionFactory.java:302)
	at com.google.cloud.spanner.SpannerExceptionFactory.fromApiException(SpannerExceptionFactory.java:322)
	at com.google.cloud.spanner.SpannerExceptionFactory.newSpannerException(SpannerExceptionFactory.java:174)
	at com.google.cloud.spanner.SpannerExceptionFactory.newSpannerException(SpannerExceptionFactory.java:110)
	at com.google.cloud.spanner.DatabaseAdminClientImpl.lambda$updateDatabaseDdl$11(DatabaseAdminClientImpl.java:470)
	at com.google.api.core.ApiFutures$ApiFunctionToGuavaFunction.apply(ApiFutures.java:396)
	at com.google.common.util.concurrent.AbstractCatchingFuture$CatchingFuture.doFallback(AbstractCatchingFuture.java:237)
	at com.google.common.util.concurrent.AbstractCatchingFuture$CatchingFuture.doFallback(AbstractCatchingFuture.java:225)
	at com.google.common.util.concurrent.AbstractCatchingFuture.run(AbstractCatchingFuture.java:135)
	at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:31)
	at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1298)
	at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:1059)
	at com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:809)
	at com.google.common.util.concurrent.AbstractTransformFuture.run(AbstractTransformFuture.java:129)
	at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:31)
	at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1298)
	at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:1059)
	at com.google.common.util.concurrent.AbstractFuture.set(AbstractFuture.java:784)
	at com.google.api.gax.retrying.BasicRetryingFuture.handleAttempt(BasicRetryingFuture.java:203)
	at com.google.api.gax.retrying.CallbackChainRetryingFuture$AttemptCompletionListener.handle(CallbackChainRetryingFuture.java:135)
	at com.google.api.gax.retrying.CallbackChainRetryingFuture$AttemptCompletionListener.run(CallbackChainRetryingFuture.java:115)
	at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:31)
	at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1298)
	at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:1059)
	at com.google.common.util.concurrent.AbstractFuture.set(AbstractFuture.java:784)
	at com.google.common.util.concurrent.AbstractTransformFuture$TransformFuture.setResult(AbstractTransformFuture.java:259)
	at com.google.common.util.concurrent.AbstractTransformFuture.run(AbstractTransformFuture.java:171)
	at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:31)
	at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1298)
	at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:1059)
	at com.google.common.util.concurrent.AbstractFuture.set(AbstractFuture.java:784)
	at com.google.api.gax.retrying.BasicRetryingFuture.handleAttempt(BasicRetryingFuture.java:203)
	at com.google.api.gax.retrying.CallbackChainRetryingFuture$AttemptCompletionListener.handle(CallbackChainRetryingFuture.java:135)
	at com.google.api.gax.retrying.CallbackChainRetryingFuture$AttemptCompletionListener.run(CallbackChainRetryingFuture.java:115)
	at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:31)
	at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1298)
	at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:1059)
	at com.google.common.util.concurrent.AbstractFuture.set(AbstractFuture.java:784)
	at com.google.api.core.AbstractApiFuture$InternalSettableFuture.set(AbstractApiFuture.java:87)
	at com.google.api.core.AbstractApiFuture.set(AbstractApiFuture.java:70)
	at com.google.api.gax.grpc.GrpcExceptionCallable$ExceptionTransformingFuture.onSuccess(GrpcExceptionCallable.java:88)
	at com.google.api.core.ApiFutures$1.onSuccess(ApiFutures.java:89)
	at com.google.common.util.concurrent.Futures$CallbackListener.run(Futures.java:1137)
	at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:31)
	at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1298)
	at com.google.common.util.concurrent.AbstractFuture.complete(AbstractFuture.java:1059)
	at com.google.common.util.concurrent.AbstractFuture.set(AbstractFuture.java:784)
	at io.grpc.stub.ClientCalls$GrpcFuture.set(ClientCalls.java:563)
	at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:536)
	at io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39)
	at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23)
	at io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40)
	at com.google.api.gax.grpc.ChannelPool$ReleasingClientCall$1.onClose(ChannelPool.java:570)
	at io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39)
	at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23)
	at io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40)
	at io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39)
	at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23)
	at io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40)
	at com.google.cloud.spanner.spi.v1.SpannerErrorInterceptor$1$1.onClose(SpannerErrorInterceptor.java:100)
	at io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39)
	at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23)
	at io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40)
	at io.grpc.census.CensusStatsModule$StatsClientInterceptor$1$1.onClose(CensusStatsModule.java:814)
	at io.grpc.PartialForwardingClientCallListener.onClose(PartialForwardingClientCallListener.java:39)
	at io.grpc.ForwardingClientCallListener.onClose(ForwardingClientCallListener.java:23)
	at io.grpc.ForwardingClientCallListener$SimpleForwardingClientCallListener.onClose(ForwardingClientCallListener.java:40)
	at io.grpc.census.CensusTracingModule$TracingClientInterceptor$1$1.onClose(CensusTracingModule.java:494)
	at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:564)
	at io.grpc.internal.ClientCallImpl.access$100(ClientCallImpl.java:72)
	at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:729)
	at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:710)
	at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
	at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)
	... 3 more