Skip to content

Commit

Permalink
fixing
Browse files Browse the repository at this point in the history
Committed-by: xiaolei.zl from Dev container
  • Loading branch information
zhanglei1949 committed Oct 29, 2024
1 parent 288dffa commit cd7d84a
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 12 deletions.
2 changes: 0 additions & 2 deletions flex/engines/graph_db/database/wal.h
Original file line number Diff line number Diff line change
Expand Up @@ -26,8 +26,6 @@
#include <string>
#include <thread>

#include "flex/utils/result.h"

#ifdef BUILD_KAFKA_WAL_WRITER
#include "cppkafka/cppkafka.h"
#endif
Expand Down
10 changes: 0 additions & 10 deletions flex/engines/http_server/handler/graph_db_http_handler.cc
Original file line number Diff line number Diff line change
Expand Up @@ -426,16 +426,6 @@ class stored_proc_handler : public StoppableHandler {
}

private:
std::pair<int, seastar::sstring> get_executor_id_from_wal_payload(
const seastar::sstring& payload) {
if (payload.size() < 4) {
LOG(ERROR) << "Invalid payload size: " << payload.size();
return std::make_pair(-1, payload);
}
auto executor_id = *reinterpret_cast<const int*>(payload.data());
return std::make_pair(executor_id, payload.substr(4));
}

query_dispatcher dispatcher_;
#ifdef HAVE_OPENTELEMETRY_CPP
opentelemetry::nostd::unique_ptr<opentelemetry::metrics::Counter<uint64_t>>
Expand Down

0 comments on commit cd7d84a

Please sign in to comment.