diff --git a/src/connection/connection.c b/src/connection/connection.c
index c98a8395..d8c418b1 100644
--- a/src/connection/connection.c
+++ b/src/connection/connection.c
@@ -503,7 +503,8 @@ ssize_t neu_conn_recv(neu_conn_t *conn, uint8_t *buf, ssize_t len)
                 conn->param.log,
                 "tcp conn fd: %d, recv buf len %zd, ret: %zd, errno: %s(%d)",
                 conn->fd, len, ret, strerror(errno), errno);
-            if (ret == 0 || (conn->connection_ok && ret == -1 && errno != EAGAIN)) {
+            if (ret == 0 ||
+                (conn->connection_ok && ret == -1 && errno != EAGAIN)) {
                 conn_disconnect(conn);
             }
         }
diff --git a/src/persist/datalayers/flight_sql_client.cpp b/src/persist/datalayers/flight_sql_client.cpp
index b3b00b32..e1b7a8fa 100644
--- a/src/persist/datalayers/flight_sql_client.cpp
+++ b/src/persist/datalayers/flight_sql_client.cpp
@@ -109,7 +109,7 @@ arrow::Status Client::InsertPrepared(const std::string &         table_name,
 {
     flight::FlightCallOptions call_options;
     call_options.headers.push_back(
-        std::make_pair("authorization", "Bearer " + bearer_token_));
+        std::make_pair("authorization", bearer_token_));
 
     std::string sql = "INSERT INTO " + table_name +
         " (time, node_name, group_name, tag, value) VALUES (?, ?, ?, ?, ?)";