From a9c2e9de2b3b1ad07ec3c83aa69d5f68bb6588ca Mon Sep 17 00:00:00 2001
From: lry22221111 <2247557140@qq.com>
Date: Tue, 31 Dec 2024 17:27:53 +0800
Subject: [PATCH] [fix][store] Scalar only support coprocessor v1

---
 src/coprocessor/coprocessor_scalar.cc | 2 +-
 src/coprocessor/coprocessor_scalar.h  | 2 ++
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/coprocessor/coprocessor_scalar.cc b/src/coprocessor/coprocessor_scalar.cc
index 55a353328..185c6d647 100755
--- a/src/coprocessor/coprocessor_scalar.cc
+++ b/src/coprocessor/coprocessor_scalar.cc
@@ -103,7 +103,7 @@ butil::Status CoprocessorScalar::Filter(const pb::common::VectorScalardata& scal
 
   std::unique_ptr<std::vector<expr::Operand>> result_operand_ptr;
 
-  status = DoRelExprCore(0x02, original_record, result_operand_ptr);
+  status = DoRelExprCore(default_scalar_codec_version_, original_record, result_operand_ptr);
   if (!status.ok()) {
     DINGO_LOG(ERROR) << status.error_cstr();
     return status;
diff --git a/src/coprocessor/coprocessor_scalar.h b/src/coprocessor/coprocessor_scalar.h
index 821ab5e3b..343bf39b8 100755
--- a/src/coprocessor/coprocessor_scalar.h
+++ b/src/coprocessor/coprocessor_scalar.h
@@ -18,6 +18,7 @@
 #include <serial/schema/base_schema.h>
 
 #include <any>
+#include <cstdint>
 #include <vector>
 
 #include "butil/status.h"
@@ -59,6 +60,7 @@ class CoprocessorScalar : public CoprocessorV2 {
   static bvar::Adder<uint64_t> bvar_coprocessor_v2_filter_scalar_running_num;
   static bvar::Adder<uint64_t> bvar_coprocessor_v2_filter_scalar_total_num;
   static bvar::LatencyRecorder coprocessor_v2_filter_scalar_latency;
+  const int default_scalar_codec_version_{1};
 };
 
 }  // namespace dingodb