diff --git a/be/src/olap/wal/wal_table.cpp b/be/src/olap/wal/wal_table.cpp index e64cf00911f46e..3a31ebcf9c0fd1 100644 --- a/be/src/olap/wal/wal_table.cpp +++ b/be/src/olap/wal/wal_table.cpp @@ -259,6 +259,8 @@ Status WalTable::_handle_stream_load(int64_t wal_id, const std::string& wal, ctx->auth.token = "relay_wal"; // this is a fake, fe not check it now ctx->auth.user = "admin"; ctx->group_commit = false; + ctx->load_type = TLoadType::MANUL_LOAD; + ctx->load_src_type = TLoadSourceType::RAW; auto st = _http_stream_action->process_put(nullptr, ctx); if (st.ok()) { // wait stream load finish