[WIP] Add stream VByte encoding for shorts, integers and longs #74174
Annotations
4 errors
Upload test results:
core/trino-main/src/test/java/io/trino/operator/TestDirectExchangeClient.java#L839
Expecting message:
"Checksum verification failure on localhost when reading from http://localhost:8080/0: Data corruption, read checksum: 0xfcd7f00d3f9deb37, calculated checksum: 0x51aa7eefb5605c6f"
to match regex:
"Checksum verification failure on localhost when reading from http://localhost:8080/0: Data corruption, read checksum: 0x3f7c49fcdc6f98ea, calculated checksum: 0xcb4f99c2d19a4b04"
but did not.
Throwable that failed the check:
io.trino.spi.TrinoException: Checksum verification failure on localhost when reading from http://localhost:8080/0: Data corruption, read checksum: 0xfcd7f00d3f9deb37, calculated checksum: 0x51aa7eefb5605c6f
at io.trino.operator.HttpPageBufferClient$1.onFailure(HttpPageBufferClient.java:487)
at com.google.common.util.concurrent.Futures$CallbackListener.run(Futures.java:1132)
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)
Caused by: io.trino.operator.HttpPageBufferClient$ChecksumVerificationException: Data corruption, read checksum: 0xfcd7f00d3f9deb37, calculated checksum: 0x51aa7eefb5605c6f
at io.trino.operator.HttpPageBufferClient$PageResponseHandler.verifyChecksum(HttpPageBufferClient.java:741)
at io.trino.operator.HttpPageBufferClient$PageResponseHandler.handle(HttpPageBufferClient.java:723)
at io.trino.operator.HttpPageBufferClient$PageResponseHandler.handle(HttpPageBufferClient.java:648)
at io.airlift.http.client.testing.TestingHttpClient.execute(TestingHttpClient.java:117)
at io.airlift.http.client.testing.TestingHttpClient.lambda$executeAsync$0(TestingHttpClient.java:52)
at com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:131)
at com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:75)
at com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:82)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
... 3 more
|
|
|
Maven Tests
Process completed with exit code 1.
|
Loading