From 8eb250b5c97862762bbe6c84f3486f644a5e2c57 Mon Sep 17 00:00:00 2001 From: whateverblake Date: Thu, 20 Nov 2025 01:03:49 +0000 Subject: [PATCH] fix bugs on test cases KeySelectorTest.SelectFromVb and ChannelStateWriteRequestExecutorImplTest.PriorityRequest --- cpp/table/runtime/keyselector/KeySelector.h | 6 +++--- .../channel/ChannelStateWriteRequestExecutorImplTest.cpp | 4 ++-- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/cpp/table/runtime/keyselector/KeySelector.h b/cpp/table/runtime/keyselector/KeySelector.h index 055a88d..c7e6362 100644 --- a/cpp/table/runtime/keyselector/KeySelector.h +++ b/cpp/table/runtime/keyselector/KeySelector.h @@ -182,13 +182,13 @@ KeySelector::KeySelector(const std::vector &keyColTypeIds, const std // varchar and char has the possibility of being a dictionary vector due to StreamCalc filter serializers.push_back(this->VarcharSerializer); deserializers.push_back(omniruntime::op::vectorDeSerializerCenter[typeId]); + } else if (typeId == omniruntime::type::OMNI_TIMESTAMP_WITHOUT_TIME_ZONE) { + serializers.push_back(omniruntime::op::vectorSerializerCenter[omniruntime::type::OMNI_LONG]); + deserializers.push_back(omniruntime::op::vectorDeSerializerCenter[omniruntime::type::OMNI_LONG]); } else if (typeId < omniruntime::type::OMNI_INVALID) { // If it is one of the old omniruntime types serializers.push_back(omniruntime::op::vectorSerializerCenter[typeId]); deserializers.push_back(omniruntime::op::vectorDeSerializerCenter[typeId]); - } else if (typeId == omniruntime::type::OMNI_TIMESTAMP_WITHOUT_TIME_ZONE) { - serializers.push_back(omniruntime::op::vectorSerializerCenter[omniruntime::type::OMNI_LONG]); - deserializers.push_back(omniruntime::op::vectorDeSerializerCenter[omniruntime::type::OMNI_LONG]); } else { throw std::runtime_error("Key type not supported!"); } diff --git a/cpp/test/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImplTest.cpp b/cpp/test/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImplTest.cpp index e27583a..5e884a5 100644 --- a/cpp/test/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImplTest.cpp +++ b/cpp/test/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImplTest.cpp @@ -216,9 +216,9 @@ TEST(ChannelStateWriteRequestExecutorImplTest, PriorityRequests) { )); executor.submit(ChannelStateWriteRequest::completeInput(jvid, 6, 1)); - dispatcher->waitFor(6); + dispatcher->waitFor(7); - EXPECT_EQ(dispatcher->processedRequests.size(), 6); + EXPECT_EQ(dispatcher->processedRequests.size(), 7); EXPECT_EQ(dispatcher->processedRequests[0], "Register"); EXPECT_EQ(dispatcher->processedSubtaskIDs[0], 0); -- Gitee