patch for datetime overflow

intelops · Jul 12, 2023 · 2a0b8e1 · 2a0b8e1
1 parent 2764414
commit 2a0b8e1
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/client/pkg/clickhouse/db_client.go b/client/pkg/clickhouse/db_client.go
@@ -210,7 +210,7 @@ func (c *DBClient) InsertKubvizEvent(metrics model.Metrics) {
 	if _, err := stmt.Exec(
 		metrics.ClusterName,
 		string(metrics.Event.UID),
-		time.Now(),
+		time.Now().Format("2006-01-02 15:04:05"),
 		metrics.Type,
 		metrics.Event.Name,
 		metrics.Event.Namespace,
@@ -219,8 +219,8 @@ func (c *DBClient) InsertKubvizEvent(metrics model.Metrics) {
 		metrics.Event.Reason,
 		metrics.Event.Source.Host,
 		string(eventJson),
-		metrics.Event.FirstTimestamp.Time,
-		metrics.Event.LastTimestamp.Time,
+		metrics.Event.FirstTimestamp.Time.Format("2006-01-02 15:04:05"),
+		metrics.Event.LastTimestamp.Time.Format("2006-01-02 15:04:05"),
 	); err != nil {
 		log.Fatal(err)
 	}

diff --git a/client/pkg/clickhouse/statements.go b/client/pkg/clickhouse/statements.go
@@ -6,7 +6,7 @@ const kubvizTable DBStatement = `
 	CREATE TABLE IF NOT EXISTS events (
 		ClusterName String,
 		Id          String,
-		EventTime   DateTime64,
+		EventTime   String,
 		OpType      String,
 		Name         String,
 		Namespace    String,
@@ -15,8 +15,8 @@ const kubvizTable DBStatement = `
 		Reason       String,
 		Host         String,
 		Event        String,
-		FirstTime   DateTime64,
-		LastTime    DateTime64
+		FirstTime   String,
+		LastTime    String
 	) engine=File(TabSeparated)
 `
 const rakeesTable DBStatement = `