From f1902dd69c88c83c106a02b718c6b5ddaf4e7dd8 Mon Sep 17 00:00:00 2001
From: qevolg <2227465945@qq.com>
Date: Tue, 3 Dec 2024 11:45:57 +0800
Subject: [PATCH] fix(keeper): fix endpoint value too long for column/tag

---
 tools/keeper/api/adapter2.go      | 6 +++---
 tools/keeper/api/gen_metric.go    | 6 +++---
 tools/keeper/api/tables.go        | 2 +-
 tools/keeper/cmd/command.go       | 2 +-
 tools/keeper/system/empty_test.go | 8 --------
 5 files changed, 8 insertions(+), 16 deletions(-)
 delete mode 100644 tools/keeper/system/empty_test.go

diff --git a/tools/keeper/api/adapter2.go b/tools/keeper/api/adapter2.go
index 645b9a176b..92450bcca2 100644
--- a/tools/keeper/api/adapter2.go
+++ b/tools/keeper/api/adapter2.go
@@ -23,8 +23,8 @@ var adapterLog = log.GetLogger("ADP")
 type adapterReqType int
 
 const (
-	rest adapterReqType = iota // 0 - rest
-	ws                         // 1 - ws
+	rest adapterReqType = iota
+	ws
 )
 
 type Adapter struct {
@@ -210,7 +210,7 @@ var adapterTableSql = "create stable if not exists `adapter_requests` (" +
 	"`other_fail` int unsigned, " +
 	"`query_in_process` int unsigned, " +
 	"`write_in_process` int unsigned ) " +
-	"tags (`endpoint` varchar(32), `req_type` tinyint unsigned )"
+	"tags (`endpoint` varchar(255), `req_type` tinyint unsigned )"
 
 func (a *Adapter) createTable() error {
 	if a.conn == nil {
diff --git a/tools/keeper/api/gen_metric.go b/tools/keeper/api/gen_metric.go
index 5534fe453d..a78076d6db 100644
--- a/tools/keeper/api/gen_metric.go
+++ b/tools/keeper/api/gen_metric.go
@@ -749,7 +749,7 @@ func (gm *GeneralMetric) initColumnSeqMap() error {
 
 func (gm *GeneralMetric) createSTables() error {
 	var createTableSql = "create stable if not exists taosd_cluster_basic " +
-		"(ts timestamp, first_ep varchar(100), first_ep_dnode_id INT, cluster_version varchar(20)) " +
+		"(ts timestamp, first_ep varchar(255), first_ep_dnode_id INT, cluster_version varchar(20)) " +
 		"tags (cluster_id varchar(50))"
 
 	if gm.conn == nil {
@@ -760,8 +760,8 @@ func (gm *GeneralMetric) createSTables() error {
 		return err
 	}
 
-	createTableSql = "create stable if not exists taos_slow_sql_detail" +
-		" (start_ts TIMESTAMP, request_id BIGINT UNSIGNED PRIMARY KEY, query_time INT, code INT, error_info varchar(128), " +
+	createTableSql = "create stable if not exists taos_slow_sql_detail " +
+		"(start_ts TIMESTAMP, request_id BIGINT UNSIGNED PRIMARY KEY, query_time INT, code INT, error_info varchar(128), " +
 		"type TINYINT, rows_num BIGINT, sql varchar(16384), process_name varchar(32), process_id varchar(32)) " +
 		"tags (db varchar(1024), `user` varchar(32), ip varchar(32), cluster_id varchar(32))"
 
diff --git a/tools/keeper/api/tables.go b/tools/keeper/api/tables.go
index 90f0e09721..1eae2fe61a 100644
--- a/tools/keeper/api/tables.go
+++ b/tools/keeper/api/tables.go
@@ -45,7 +45,7 @@ var dnodeEpLen = strconv.Itoa(255)
 
 var CreateClusterInfoSql = "create table if not exists cluster_info (" +
 	"ts timestamp, " +
-	"first_ep binary(134), " +
+	"first_ep binary(255), " +
 	"first_ep_dnode_id int, " +
 	"version binary(12), " +
 	"master_uptime float, " +
diff --git a/tools/keeper/cmd/command.go b/tools/keeper/cmd/command.go
index 82d3efea1f..3e054a1963 100644
--- a/tools/keeper/cmd/command.go
+++ b/tools/keeper/cmd/command.go
@@ -322,7 +322,7 @@ func (cmd *Command) TransferTaosdClusterBasicInfo() error {
 	delta := time.Hour * 24 * 10
 
 	var createTableSql = "create stable if not exists taosd_cluster_basic " +
-		"(ts timestamp, first_ep varchar(100), first_ep_dnode_id INT, cluster_version varchar(20)) " +
+		"(ts timestamp, first_ep varchar(255), first_ep_dnode_id INT, cluster_version varchar(20)) " +
 		"tags (cluster_id varchar(50))"
 
 	if _, err := cmd.conn.Exec(ctx, createTableSql, util.GetQidOwn()); err != nil {
diff --git a/tools/keeper/system/empty_test.go b/tools/keeper/system/empty_test.go
deleted file mode 100644
index a4d4777d32..0000000000
--- a/tools/keeper/system/empty_test.go
+++ /dev/null
@@ -1,8 +0,0 @@
-package system
-
-import (
-	"testing"
-)
-
-func TestEmpty(t *testing.T) {
-}