diff --git a/be/src/util/es_scroll_query.cpp b/be/src/util/es_scroll_query.cpp
index 2948ec31881148..abdb9f2a72463c 100644
--- a/be/src/util/es_scroll_query.cpp
+++ b/be/src/util/es_scroll_query.cpp
@@ -72,7 +72,7 @@ std::string ESScrollQueryBuilder::build(const std::map<std::string, std::string>
         }
         es_query_dsl.AddMember("_source", source_node, allocator);
     }
-    int size = atoi(properties.at(ESScanReader::BATCH_SIZE).c_str());
+    int size = atoi(properties.at(ESScanReader::KEY_BATCH_SIZE).c_str());
     rapidjson::Value sort_node(rapidjson::kArrayType);
     rapidjson::Value field("_doc", allocator);
     sort_node.PushBack(field, allocator);
diff --git a/be/test/util/es_scan_reader_test.cpp b/be/test/util/es_scan_reader_test.cpp
index 7b1df013a19ddd..2b5d7f84b34b81 100644
--- a/be/test/util/es_scan_reader_test.cpp
+++ b/be/test/util/es_scan_reader_test.cpp
@@ -94,7 +94,6 @@ class RestSearchScrollAction : public HttpHandler {
             std::string post_body = req->get_request_body();
             rapidjson::Document post_doc;
             post_doc.Parse<0>(post_body.c_str());
-            int size = 1;
             std::string scroll_id;
             if (!post_doc.HasMember("scroll_id")) {
                 HttpChannel::send_reply(req,HttpStatus::NOT_FOUND, "invalid scroll request");
@@ -166,7 +165,6 @@ class RestClearScrollAction : public HttpHandler {
             std::string post_body = req->get_request_body();
             rapidjson::Document post_doc;
             post_doc.Parse<0>(post_body.c_str());
-            int size = 1;
             std::string scroll_id;
             if (!post_doc.HasMember("scroll_id")) {
                 HttpChannel::send_reply(req,HttpStatus::NOT_FOUND, "invalid scroll request");