mirror of
https://github.com/emqx/neuron.git
synced 2026-10-26 11:56:10 +08:00
@@ -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);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -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 (?, ?, ?, ?, ?)";
|
||||
|
||||
Reference in New Issue
Block a user