Address review comments #951
GitHub Actions / IntegrationTests_12 Test Reports
succeeded
Nov 25, 2025 in 1s
150 passed, 4 failed and 0 skipped
✅ IntegrationTests_12-artifacts/internal/venice-test-common/build/test-results/integrationTests_12/TEST-com.linkedin.venice.controller.TestHAASController.xml
11 tests were completed in 254s with 11 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.controller.TestHAASController | 11✅ | 254s |
✅ com.linkedin.venice.controller.TestHAASController
✅ testCloudConfig
✅ testClusterResourceEmptyInstanceTag
✅ testClusterResourceInstanceTag
✅ testClusterResourceInstanceTag_updateOnRestart
✅ testConcurrentClusterInitialization
✅ testHelixUnknownInstanceOperation
✅ testRebalancePreferenceAndCapacityKeys
✅ testStartHAASControllerAsStorageClusterLeader
✅ testStartHAASHelixControllerAsControllerClusterLeader
✅ testTransitionToHAASControllerAsControllerClusterLeader
✅ testTransitionToHAASControllerAsStorageClusterLeader
✅ IntegrationTests_12-artifacts/internal/venice-test-common/build/test-results/integrationTests_12/TEST-com.linkedin.venice.endToEnd.DaVinciClientTest.xml
11 tests were completed in 376s with 11 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.endToEnd.DaVinciClientTest | 11✅ | 376s |
✅ com.linkedin.venice.endToEnd.DaVinciClientTest
✅ testConcurrentGetAndStart[0](false)
✅ testConcurrentGetAndStart[2](true)
✅ testIsDavinciHeartbeatReported
✅ testObjectReuse[0](DaVinciConfig{managed=true, isolated=false, storageClass=MEMORY_BACKED_BY_DISK, cacheConfig=null, largeBatchRequestSplitThreshold=100})
✅ testObjectReuse[2](DaVinciConfig{managed=true, isolated=false, storageClass=MEMORY_BACKED_BY_DISK, cacheConfig=ObjectCacheConfig{maxCacheSize=Optional.empty, ttlInMilliseconds=Optional.empty}, largeBatchRequestSplitThreshold=100})
✅ testReadCompressedData[0](NO_OP)
✅ testReadCompressedData[2](GZIP)
✅ testReadCompressedData[4](ZSTD_WITH_DICT)
✅ testStatusReportDuringBoostrap[0](BUILT_IN, true)
✅ testStatusReportDuringBoostrap[2](ISOLATED, false)
✅ testStatusReportDuringBoostrap[4](ISOLATED, true)
✅ IntegrationTests_12-artifacts/internal/venice-test-common/build/test-results/integrationTests_12/TEST-com.linkedin.venice.endToEnd.DaVinciClientTestWithHeartbeatReadyToServeCheckTest.xml
2 tests were completed in 60s with 2 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.endToEnd.DaVinciClientTestWithHeartbeatReadyToServeCheckTest | 2✅ | 60s |
✅ com.linkedin.venice.endToEnd.DaVinciClientTestWithHeartbeatReadyToServeCheckTest
✅ testHybridStore[0](DaVinciConfig{managed=true, isolated=false, storageClass=MEMORY_BACKED_BY_DISK, cacheConfig=null, largeBatchRequestSplitThreshold=100})
✅ testHybridStore[2](DaVinciConfig{managed=true, isolated=false, storageClass=MEMORY_BACKED_BY_DISK, cacheConfig=ObjectCacheConfig{maxCacheSize=Optional.empty, ttlInMilliseconds=Optional.empty}, largeBatchRequestSplitThreshold=100})
❌ IntegrationTests_12-artifacts/internal/venice-test-common/build/test-results/integrationTests_12/TEST-com.linkedin.venice.endToEnd.TestBatchForRocksDB.xml
41 tests were completed in 599s with 39 passed, 2 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.endToEnd.TestBatchForRocksDB | 39✅ | 2❌ | 599s |
❌ com.linkedin.venice.endToEnd.TestBatchForRocksDB
✅ testBatchFromETL
✅ testBatchFromETLForUnionWithNullSchema
✅ testBatchFromETLForUnionWithoutNullSchema
✅ testBatchFromETLWithNullDefaultValue
✅ testCompressingRecord[0](false)
✅ testCompressingRecord[2](true)
✅ testDataPushWithSchemaWithAWrongDefault
✅ testDuplicateKey
✅ testEarlyDeleteBackupStore
✅ testEmptyPush
✅ testIncrementalPush
✅ testIncrementalPushWithCompression[0](false)
✅ testIncrementalPushWithCompression[2](true)
✅ testIncrementalPushWritesToRealTimeTopicWithPolicy
✅ testKafkaInputAAStore
✅ testKafkaInputBatchJob
✅ testKafkaInputBatchJobSucceedsWhenSourceTopicIsEmpty
✅ testKafkaInputBatchJobWithLargeValues[0](false)
✅ testKafkaInputBatchJobWithLargeValues[2](true)
❌ testKafkaInputBatchJobWithZstdCompression[0](false)
java.util.concurrent.ExecutionException: com.linkedin.venice.client.exceptions.VeniceClientHttpException: http status: 400, com.linkedin.alpini.router.api.RouterException: There is no version for store 'store_102b96e60bf_3d9d014e'. Please push data to that store
✅ testKafkaInputBatchJobWithZstdCompression[2](true)
✅ testLargeValues
✅ testMetaStoreSchemaValidation
✅ testReducerCountValidation
✅ testRunJobWithSchemaThatContainsUnknownField
✅ testStoreWithNoVersionThrows400
✅ testStoreWithTooLargeValues[0](false)
✅ testStoreWithTooLargeValues[2](true)
✅ testStoreWithTooLargeValuesWithCompression[0](false, NO_OP)
✅ testStoreWithTooLargeValuesWithCompression[2](true, NO_OP)
✅ testStoreWithTooLargeValuesWithCompression[4](false, GZIP)
✅ testStoreWithTooLargeValuesWithCompression[6](true, GZIP)
✅ testStoreWithTooLargeValuesWithCompression[8](false, ZSTD_WITH_DICT)
✅ testStoreWithTooLargeValuesWithCompression[10](true, ZSTD_WITH_DICT)
❌ testZstdCompressingAvroRecordCanFailWhenNoFallbackAvailable
java.lang.AssertionError: Unexpected exception message
✅ testZstdCompressingAvroRecordWhenFallbackAvailable[0](false)
✅ testZstdCompressingAvroRecordWhenFallbackAvailable[2](true)
✅ testZstdCompressingAvroRecordWhenNoFallbackAvailableWithSleep
✅ testKafkaInputBatchJobWithZstdCompression[0](false)
✅ testKafkaInputBatchJobWithZstdCompression[2](true)
✅ testZstdCompressingAvroRecordCanFailWhenNoFallbackAvailable
✅ IntegrationTests_12-artifacts/internal/venice-test-common/build/test-results/integrationTests_12/TEST-com.linkedin.venice.server.VeniceServerTest.xml
12 tests were completed in 224s with 12 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.server.VeniceServerTest | 12✅ | 224s |
✅ com.linkedin.venice.server.VeniceServerTest
✅ testCheckBeforeJoinCluster
✅ testCheckBeforeJointClusterBeforeHelixInitializingCluster
✅ testDropStorePartitionAsynchronously
✅ testDropStorePartitionSynchronously
✅ testMetadataFetchRequest
✅ testStartServerAndShutdownWithPartitionAssignmentVerification
✅ testStartServerWhenEnableAllowlistCheckingFailed
✅ testStartServerWhenEnableAllowlistCheckingSuccessful
✅ testStartServerWithDefaultConfigForTests
✅ testStartServerWithSystemSchemaInitialization
✅ testVeniceServerWithD2[0](false)
✅ testVeniceServerWithD2[1](true)
✅ internal/venice-test-common/build/test-results/integrationTests_12/TEST-com.linkedin.venice.controller.TestHAASController.xml
11 tests were completed in 254s with 11 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.controller.TestHAASController | 11✅ | 254s |
✅ com.linkedin.venice.controller.TestHAASController
✅ testCloudConfig
✅ testClusterResourceEmptyInstanceTag
✅ testClusterResourceInstanceTag
✅ testClusterResourceInstanceTag_updateOnRestart
✅ testConcurrentClusterInitialization
✅ testHelixUnknownInstanceOperation
✅ testRebalancePreferenceAndCapacityKeys
✅ testStartHAASControllerAsStorageClusterLeader
✅ testStartHAASHelixControllerAsControllerClusterLeader
✅ testTransitionToHAASControllerAsControllerClusterLeader
✅ testTransitionToHAASControllerAsStorageClusterLeader
✅ internal/venice-test-common/build/test-results/integrationTests_12/TEST-com.linkedin.venice.endToEnd.DaVinciClientTest.xml
11 tests were completed in 376s with 11 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.endToEnd.DaVinciClientTest | 11✅ | 376s |
✅ com.linkedin.venice.endToEnd.DaVinciClientTest
✅ testConcurrentGetAndStart[0](false)
✅ testConcurrentGetAndStart[2](true)
✅ testIsDavinciHeartbeatReported
✅ testObjectReuse[0](DaVinciConfig{managed=true, isolated=false, storageClass=MEMORY_BACKED_BY_DISK, cacheConfig=null, largeBatchRequestSplitThreshold=100})
✅ testObjectReuse[2](DaVinciConfig{managed=true, isolated=false, storageClass=MEMORY_BACKED_BY_DISK, cacheConfig=ObjectCacheConfig{maxCacheSize=Optional.empty, ttlInMilliseconds=Optional.empty}, largeBatchRequestSplitThreshold=100})
✅ testReadCompressedData[0](NO_OP)
✅ testReadCompressedData[2](GZIP)
✅ testReadCompressedData[4](ZSTD_WITH_DICT)
✅ testStatusReportDuringBoostrap[0](BUILT_IN, true)
✅ testStatusReportDuringBoostrap[2](ISOLATED, false)
✅ testStatusReportDuringBoostrap[4](ISOLATED, true)
✅ internal/venice-test-common/build/test-results/integrationTests_12/TEST-com.linkedin.venice.endToEnd.DaVinciClientTestWithHeartbeatReadyToServeCheckTest.xml
2 tests were completed in 60s with 2 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.endToEnd.DaVinciClientTestWithHeartbeatReadyToServeCheckTest | 2✅ | 60s |
✅ com.linkedin.venice.endToEnd.DaVinciClientTestWithHeartbeatReadyToServeCheckTest
✅ testHybridStore[0](DaVinciConfig{managed=true, isolated=false, storageClass=MEMORY_BACKED_BY_DISK, cacheConfig=null, largeBatchRequestSplitThreshold=100})
✅ testHybridStore[2](DaVinciConfig{managed=true, isolated=false, storageClass=MEMORY_BACKED_BY_DISK, cacheConfig=ObjectCacheConfig{maxCacheSize=Optional.empty, ttlInMilliseconds=Optional.empty}, largeBatchRequestSplitThreshold=100})
❌ internal/venice-test-common/build/test-results/integrationTests_12/TEST-com.linkedin.venice.endToEnd.TestBatchForRocksDB.xml
41 tests were completed in 599s with 39 passed, 2 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.endToEnd.TestBatchForRocksDB | 39✅ | 2❌ | 599s |
❌ com.linkedin.venice.endToEnd.TestBatchForRocksDB
✅ testBatchFromETL
✅ testBatchFromETLForUnionWithNullSchema
✅ testBatchFromETLForUnionWithoutNullSchema
✅ testBatchFromETLWithNullDefaultValue
✅ testCompressingRecord[0](false)
✅ testCompressingRecord[2](true)
✅ testDataPushWithSchemaWithAWrongDefault
✅ testDuplicateKey
✅ testEarlyDeleteBackupStore
✅ testEmptyPush
✅ testIncrementalPush
✅ testIncrementalPushWithCompression[0](false)
✅ testIncrementalPushWithCompression[2](true)
✅ testIncrementalPushWritesToRealTimeTopicWithPolicy
✅ testKafkaInputAAStore
✅ testKafkaInputBatchJob
✅ testKafkaInputBatchJobSucceedsWhenSourceTopicIsEmpty
✅ testKafkaInputBatchJobWithLargeValues[0](false)
✅ testKafkaInputBatchJobWithLargeValues[2](true)
❌ testKafkaInputBatchJobWithZstdCompression[0](false)
java.util.concurrent.ExecutionException: com.linkedin.venice.client.exceptions.VeniceClientHttpException: http status: 400, com.linkedin.alpini.router.api.RouterException: There is no version for store 'store_102b96e60bf_3d9d014e'. Please push data to that store
✅ testKafkaInputBatchJobWithZstdCompression[2](true)
✅ testLargeValues
✅ testMetaStoreSchemaValidation
✅ testReducerCountValidation
✅ testRunJobWithSchemaThatContainsUnknownField
✅ testStoreWithNoVersionThrows400
✅ testStoreWithTooLargeValues[0](false)
✅ testStoreWithTooLargeValues[2](true)
✅ testStoreWithTooLargeValuesWithCompression[0](false, NO_OP)
✅ testStoreWithTooLargeValuesWithCompression[2](true, NO_OP)
✅ testStoreWithTooLargeValuesWithCompression[4](false, GZIP)
✅ testStoreWithTooLargeValuesWithCompression[6](true, GZIP)
✅ testStoreWithTooLargeValuesWithCompression[8](false, ZSTD_WITH_DICT)
✅ testStoreWithTooLargeValuesWithCompression[10](true, ZSTD_WITH_DICT)
❌ testZstdCompressingAvroRecordCanFailWhenNoFallbackAvailable
java.lang.AssertionError: Unexpected exception message
✅ testZstdCompressingAvroRecordWhenFallbackAvailable[0](false)
✅ testZstdCompressingAvroRecordWhenFallbackAvailable[2](true)
✅ testZstdCompressingAvroRecordWhenNoFallbackAvailableWithSleep
✅ testKafkaInputBatchJobWithZstdCompression[0](false)
✅ testKafkaInputBatchJobWithZstdCompression[2](true)
✅ testZstdCompressingAvroRecordCanFailWhenNoFallbackAvailable
✅ internal/venice-test-common/build/test-results/integrationTests_12/TEST-com.linkedin.venice.server.VeniceServerTest.xml
12 tests were completed in 224s with 12 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.server.VeniceServerTest | 12✅ | 224s |
✅ com.linkedin.venice.server.VeniceServerTest
✅ testCheckBeforeJoinCluster
✅ testCheckBeforeJointClusterBeforeHelixInitializingCluster
✅ testDropStorePartitionAsynchronously
✅ testDropStorePartitionSynchronously
✅ testMetadataFetchRequest
✅ testStartServerAndShutdownWithPartitionAssignmentVerification
✅ testStartServerWhenEnableAllowlistCheckingFailed
✅ testStartServerWhenEnableAllowlistCheckingSuccessful
✅ testStartServerWithDefaultConfigForTests
✅ testStartServerWithSystemSchemaInitialization
✅ testVeniceServerWithD2[0](false)
✅ testVeniceServerWithD2[1](true)
Annotations
github-actions / IntegrationTests_12 Test Reports
com.linkedin.venice.endToEnd.TestBatchForRocksDB ► testKafkaInputBatchJobWithZstdCompression[0](false)
Failed test found in:
IntegrationTests_12-artifacts/internal/venice-test-common/build/test-results/integrationTests_12/TEST-com.linkedin.venice.endToEnd.TestBatchForRocksDB.xml
internal/venice-test-common/build/test-results/integrationTests_12/TEST-com.linkedin.venice.endToEnd.TestBatchForRocksDB.xml
Error:
java.util.concurrent.ExecutionException: com.linkedin.venice.client.exceptions.VeniceClientHttpException: http status: 400, com.linkedin.alpini.router.api.RouterException: There is no version for store 'store_102b96e60bf_3d9d014e'. Please push data to that store
Raw output
java.util.concurrent.ExecutionException: com.linkedin.venice.client.exceptions.VeniceClientHttpException: http status: 400, com.linkedin.alpini.router.api.RouterException: There is no version for store 'store_102b96e60bf_3d9d014e'. Please push data to that store
at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073)
at com.linkedin.venice.endToEnd.TestBatch.lambda$testKafkaInputBatchJobWithZstdCompression$58(TestBatch.java:637)
at com.linkedin.venice.endToEnd.TestBatch.testBatchStore(TestBatch.java:932)
at com.linkedin.venice.endToEnd.TestBatch.testBatchStore(TestBatch.java:870)
at com.linkedin.venice.endToEnd.TestBatch.testBatchStore(TestBatch.java:827)
at com.linkedin.venice.endToEnd.TestBatch.testKafkaInputBatchJobWithZstdCompression(TestBatch.java:640)
Caused by: com.linkedin.venice.client.exceptions.VeniceClientHttpException: http status: 400, com.linkedin.alpini.router.api.RouterException: There is no version for store 'store_102b96e60bf_3d9d014e'. Please push data to that store
at app//com.linkedin.venice.client.store.transport.TransportClientCallback.completeFuture(TransportClientCallback.java:39)
at app//com.linkedin.venice.client.store.transport.HttpTransportClient$HttpTransportClientCallback.completed(HttpTransportClient.java:225)
at app//com.linkedin.venice.client.store.transport.HttpTransportClient$HttpTransportClientCallback.completed(HttpTransportClient.java:189)
at app//org.apache.hc.core5.concurrent.BasicFuture.completed(BasicFuture.java:123)
at app//org.apache.hc.core5.concurrent.ComplexFuture.completed(ComplexFuture.java:72)
at app//org.apache.hc.client5.http.impl.async.InternalAbstractHttpAsyncClient$2$1.completed(InternalAbstractHttpAsyncClient.java:304)
at app//org.apache.hc.core5.http.nio.support.AbstractAsyncResponseConsumer$1.completed(AbstractAsyncResponseConsumer.java:101)
at app//org.apache.hc.core5.http.nio.entity.AbstractBinAsyncEntityConsumer.completed(AbstractBinAsyncEntityConsumer.java:84)
at app//org.apache.hc.core5.http.nio.entity.AbstractBinDataConsumer.streamEnd(AbstractBinDataConsumer.java:81)
at app//org.apache.hc.core5.http.nio.support.AbstractAsyncResponseConsumer.streamEnd(AbstractAsyncResponseConsumer.java:142)
at app//org.apache.hc.client5.http.impl.async.HttpAsyncMainClientExec$1.streamEnd(HttpAsyncMainClientExec.java:251)
at app//org.apache.hc.core5.http.impl.nio.ClientHttp1StreamHandler.dataEnd(ClientHttp1StreamHandler.java:270)
at app//org.apache.hc.core5.http.impl.nio.ClientHttp1StreamDuplexer.dataEnd(ClientHttp1StreamDuplexer.java:366)
at app//org.apache.hc.core5.http.impl.nio.AbstractHttp1StreamDuplexer.onInput(AbstractHttp1StreamDuplexer.java:335)
at app//org.apache.hc.core5.http.impl.nio.AbstractHttp1IOEventHandler.inputReady(AbstractHttp1IOEventHandler.java:64)
at app//org.apache.hc.core5.http.impl.nio.ClientHttp1IOEventHandler.inputReady(ClientHttp1IOEventHandler.java:41)
at app//org.apache.hc.core5.reactor.InternalDataChannel.onIOEvent(InternalDataChannel.java:142)
at app//org.apache.hc.core5.reactor.InternalChannel.handleIOEvent(InternalChannel.java:51)
at app//org.apache.hc.core5.reactor.SingleCoreIOReactor.processEvents(SingleCoreIOReactor.java:178)
at app//org.apache.hc.core5.reactor.SingleCoreIOReactor.doExecute(SingleCoreIOReactor.java:127)
at app//org.apache.hc.core5.reactor.AbstractSingleCoreIOReactor.execute(AbstractSingleCoreIOReactor.java:86)
at app//org.apache.hc.core5.reactor.IOReactorWorker.run(IOReactorWorker.java:44)
at [email protected]/java.lang.Thread.run(Thread.java:840)
github-actions / IntegrationTests_12 Test Reports
com.linkedin.venice.endToEnd.TestBatchForRocksDB ► testZstdCompressingAvroRecordCanFailWhenNoFallbackAvailable
Failed test found in:
IntegrationTests_12-artifacts/internal/venice-test-common/build/test-results/integrationTests_12/TEST-com.linkedin.venice.endToEnd.TestBatchForRocksDB.xml
internal/venice-test-common/build/test-results/integrationTests_12/TEST-com.linkedin.venice.endToEnd.TestBatchForRocksDB.xml
Error:
java.lang.AssertionError: Unexpected exception message
Raw output
java.lang.AssertionError: Unexpected exception message
at org.testng.Assert.fail(Assert.java:85)
at com.linkedin.venice.endToEnd.TestBatch.lambda$testZstdCompressingAvroRecordCanFailWhenNoFallbackAvailable$14(TestBatch.java:292)
at com.linkedin.venice.endToEnd.TestBatch.testBatchStore(TestBatch.java:932)
at com.linkedin.venice.endToEnd.TestBatch.testBatchStore(TestBatch.java:870)
at com.linkedin.venice.endToEnd.TestBatch.testBatchStore(TestBatch.java:827)
at com.linkedin.venice.endToEnd.TestBatch.testZstdCompressingAvroRecordCanFailWhenNoFallbackAvailable(TestBatch.java:280)
Caused by: java.util.concurrent.ExecutionException: com.linkedin.venice.client.exceptions.VeniceClientHttpException: http status: 400, com.linkedin.alpini.router.api.RouterException: There is no version for store 'store_10fa1200d9d_3e67560f'. Please push data to that store
at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073)
at com.linkedin.venice.endToEnd.TestBatch.lambda$testZstdCompressingAvroRecordCanFailWhenNoFallbackAvailable$14(TestBatch.java:286)
at com.linkedin.venice.endToEnd.TestBatch.testBatchStore(TestBatch.java:932)
at com.linkedin.venice.endToEnd.TestBatch.testBatchStore(TestBatch.java:870)
at com.linkedin.venice.endToEnd.TestBatch.testBatchStore(TestBatch.java:827)
at com.linkedin.venice.endToEnd.TestBatch.testZstdCompressingAvroRecordCanFailWhenNoFallbackAvailable(TestBatch.java:280)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:569)
at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)
at org.testng.internal.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:54)
at org.testng.internal.InvokeMethodRunnable.run(InvokeMethodRunnable.java:44)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:840)
Caused by: com.linkedin.venice.client.exceptions.VeniceClientHttpException: http status: 400, com.linkedin.alpini.router.api.RouterException: There is no version for store 'store_10fa1200d9d_3e67560f'. Please push data to that store
at app//com.linkedin.venice.client.store.transport.TransportClientCallback.completeFuture(TransportClientCallback.java:39)
at app//com.linkedin.venice.client.store.transport.HttpTransportClient$HttpTransportClientCallback.completed(HttpTransportClient.java:225)
at app//com.linkedin.venice.client.store.transport.HttpTransportClient$HttpTransportClientCallback.completed(HttpTransportClient.java:189)
at app//org.apache.hc.core5.concurrent.BasicFuture.completed(BasicFuture.java:123)
at app//org.apache.hc.core5.concurrent.ComplexFuture.completed(ComplexFuture.java:72)
at app//org.apache.hc.client5.http.impl.async.InternalAbstractHttpAsyncClient$2$1.completed(InternalAbstractHttpAsyncClient.java:304)
at app//org.apache.hc.core5.http.nio.support.AbstractAsyncResponseConsumer$1.completed(AbstractAsyncResponseConsumer.java:101)
at app//org.apache.hc.core5.http.nio.entity.AbstractBinAsyncEntityConsumer.completed(AbstractBinAsyncEntityConsumer.java:84)
at app//org.apache.hc.core5.http.nio.entity.AbstractBinDataConsumer.streamEnd(AbstractBinDataConsumer.java:81)
at app//org.apache.hc.core5.http.nio.support.AbstractAsyncResponseConsumer.streamEnd(AbstractAsyncResponseConsumer.java:142)
at app//org.apache.hc.client5.http.impl.async.HttpAsyncMainClientExec$1.streamEnd(HttpAsyncMainClientExec.java:251)
at app//org.apache.hc.core5.http.impl.nio.ClientHttp1StreamHandler.dataEnd(ClientHttp1StreamHandler.java:270)
at app//org.apache.hc.core5.http.impl.nio.ClientHttp1StreamDuplexer.dataEnd(ClientHttp1StreamDuplexer.java:366)
at app//org.apache.hc.core5.http.impl.nio.AbstractHttp1StreamDuplexer.onInput(AbstractHttp1StreamDuplexer.java:335)
at app//org.apache.hc.core5.http.impl.nio.AbstractHttp1IOEventHandler.inputReady(AbstractHttp1IOEventHandler.java:64)
at app//org.apache.hc.core5.http.impl.nio.ClientHttp1IOEventHandler.inputReady(ClientHttp1IOEventHandler.java:41)
at app//org.apache.hc.core5.reactor.InternalDataChannel.onIOEvent(InternalDataChannel.java:142)
at app//org.apache.hc.core5.reactor.InternalChannel.handleIOEvent(InternalChannel.java:51)
at app//org.apache.hc.core5.reactor.SingleCoreIOReactor.processEvents(SingleCoreIOReactor.java:178)
at app//org.apache.hc.core5.reactor.SingleCoreIOReactor.doExecute(SingleCoreIOReactor.java:127)
at app//org.apache.hc.core5.reactor.AbstractSingleCoreIOReactor.execute(AbstractSingleCoreIOReactor.java:86)
at app//org.apache.hc.core5.reactor.IOReactorWorker.run(IOReactorWorker.java:44)
... 1 more
Loading