Create Table Concurrent query Failure handling in Delta Lake #72356
Annotations
5 errors
|
Upload test results:
plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/TestDeltaLakeAlluxioCacheMinioAndHmsConnectorSmokeTest.java#L1
Expecting empty but was: ["s3://test-delta-lake-integration-smoke-test-jddihhp0de/test_cleanup_for_failed_create_table_as_sne84echym/20241125_173008_00953_bbafr_9a29e459-c737-413d-9bd2-6b3a43913288"]
|
|
Upload test results:
plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/TestDeltaLakeLocalConcurrentCreateTableTest.java#L155
Expecting throwable message:
"Expected response code from http://127.0.0.1:37713/v1/task/20241125_172542_00032_w5639.0.0.0/status to be 200, but was 408
Error 408 Timeout: Timed out (timeout delayed by 650 ms after scheduled time): AsyncCatchingFuture@1c91d213[status=PENDING, info=[inputFuture=[TimeoutFuture@50d39df2[status=PENDING, info=[inputFuture=[TransformFuture@1fbfa695[status=PENDING, info=[inputFuture=[SettableFuture@567a8006[status=PENDING]], function=[io.trino.execution.SqlTask$$Lambda/0x00007f2e483621f8@6b421c18]]]]]]], exceptionType=[class java.util.concurrent.TimeoutException], fallback=[io.airlift.concurrent.MoreFutures$$Lambda/0x00007f2e480ced30@79514a29]]]"
to contain:
"Table already exists"
but did not.
Throwable that failed the check:
io.trino.spi.TrinoException: Expected response code from http://127.0.0.1:37713/v1/task/20241125_172542_00032_w5639.0.0.0/status to be 200, but was 408
Error 408 Timeout: Timed out (timeout delayed by 650 ms after scheduled time): AsyncCatchingFuture@1c91d213[status=PENDING, info=[inputFuture=[TimeoutFuture@50d39df2[status=PENDING, info=[inputFuture=[TransformFuture@1fbfa695[status=PENDING, info=[inputFuture=[SettableFuture@567a8006[status=PENDING]], function=[io.trino.execution.SqlTask$$Lambda/0x00007f2e483621f8@6b421c18]]]]]]], exceptionType=[class java.util.concurrent.TimeoutException], fallback=[io.airlift.concurrent.MoreFutures$$Lambda/0x00007f2e480ced30@79514a29]]]
at io.trino.server.remotetask.SimpleHttpResponseHandler.onSuccess(SimpleHttpResponseHandler.java:62)
at io.trino.server.remotetask.SimpleHttpResponseHandler.onSuccess(SimpleHttpResponseHandler.java:27)
at com.google.common.util.concurrent.Futures$CallbackListener.run(Futures.java:1137)
at io.airlift.concurrent.BoundedExecutor.drainQueue(BoundedExecutor.java:79)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at java.base/java.lang.Thread.run(Thread.java:1575)
|
|
Upload test results:
plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/TestDeltaLakeLocalConcurrentWritesTest.java#L456
Failed to write Delta Lake transaction log entry
|
|
Upload test results:
plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/TestDeltaLakeMinioAndHmsConnectorSmokeTest.java#L1
Expecting empty but was: ["s3://test-delta-lake-integration-smoke-test-nw8u5n7bgl/test_cleanup_for_failed_create_table_as_ob1qvodces/20241125_172733_00723_ngeda_8ce81442-8a63-47bf-a5ec-886fd196f7d9"]
|
|
Maven Tests
Process completed with exit code 1.
|
Loading