diff --git a/src/client_v2/coordinator.cc b/src/client_v2/coordinator.cc index 2e9c9bfdb..64c8ae3ea 100644 --- a/src/client_v2/coordinator.cc +++ b/src/client_v2/coordinator.cc @@ -35,6 +35,7 @@ void SetUpCoordinatorSubCommands(CLI::App &app) { SetUpGetRegionMap(app); SetUpGetJobList(app); SetUpCleanJobList(app); + SetUpChangeLogLevel(app); // region commands SetUpAddPeerRegion(app); SetUpRemovePeerRegion(app); @@ -60,7 +61,6 @@ void SetUpCoordinatorSubCommands(CLI::App &app) { // balance SetUpEnableOrDisableBalance(app); - } bool GetBrpcChannel(const std::string &location, brpc::Channel &channel) { @@ -612,9 +612,9 @@ void RunChangeLogLevel(GetChangeLogLevelOption const &opt) { DINGO_LOG(WARNING) << "Fail to send request to : " << cntl.ErrorText(); } - DINGO_LOG(INFO) << request.DebugString(); - DINGO_LOG(INFO) << ::dingodb::pb::node::LogLevel_descriptor()->FindValueByNumber(request.log_level())->name(); - DINGO_LOG(INFO) << response.DebugString(); + std::cout << request.DebugString() << std::endl; + std::cout << ::dingodb::pb::node::LogLevel_descriptor()->FindValueByNumber(request.log_level())->name() << std::endl; + std::cout << response.DebugString() << std::endl; } void SetUpHello(CLI::App &app) { @@ -2791,9 +2791,11 @@ void SetUpEnableOrDisableBalance(CLI::App &app) { auto opt = std::make_shared(); auto *cmd = app.add_subcommand("DisableBalance", "DisableBalance ")->group("Coordinator Command"); cmd->add_option("--coor_url", opt->coor_url, "Coordinator url, default:file://./coor_list"); - cmd->add_option("--balance_leader", opt->enable_balance_leader, "Request parameter enable_balance_leader true or false") + cmd->add_option("--balance_leader", opt->enable_balance_leader, + "Request parameter enable_balance_leader true or false") ->required(); - cmd->add_option("--balance_region", opt->enable_balance_region, "Request parameter enable_balance_region true or false") + cmd->add_option("--balance_region", opt->enable_balance_region, + "Request parameter enable_balance_region true or false") ->required(); cmd->callback([opt]() { RunEnableOrDisableBalance(*opt); }); } diff --git a/src/client_v2/pretty.cc b/src/client_v2/pretty.cc index fecd21754..05024d6a9 100644 --- a/src/client_v2/pretty.cc +++ b/src/client_v2/pretty.cc @@ -245,7 +245,7 @@ void ShowTxnTableData(const dingodb::pb::debug::DumpRegionResponse::Txn& txn, for (int i = 0; i < record.size(); ++i) { const auto& column_definition = table_definition.columns().at(i); if (!IsExcludeColumns(column_definition.name(), exclude_columns)) { - std::string column_value = dingodb::Helper::ConvertColumnValueToString(column_definition, record[i]); + std::string column_value = dingodb::Helper::ConvertColumnValueToStringV2(column_definition, record[i]); row.push_back(ftxui::paragraph(TruncateString(column_value))); } } @@ -354,7 +354,7 @@ static std::vector> ParseRecord( result.push_back( std::make_pair(column_definition.name(), - TruncateString(dingodb::Helper::ConvertColumnValueToString(column_definition, values[i])))); + TruncateString(dingodb::Helper::ConvertColumnValueToStringV2(column_definition, values[i])))); } return result;