From 8b8c6f13dec76fc08bcd58f27947e5eff3b15662 Mon Sep 17 00:00:00 2001 From: shuiyisong Date: Fri, 29 Aug 2025 14:50:27 +0800 Subject: [PATCH 1/4] fix: update auth value str Signed-off-by: shuiyisong --- .../src/main/java/io/greptime/models/AuthInfo.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ingester-protocol/src/main/java/io/greptime/models/AuthInfo.java b/ingester-protocol/src/main/java/io/greptime/models/AuthInfo.java index f8ed5b4..a80c533 100644 --- a/ingester-protocol/src/main/java/io/greptime/models/AuthInfo.java +++ b/ingester-protocol/src/main/java/io/greptime/models/AuthInfo.java @@ -55,7 +55,7 @@ public static AuthInfo noAuthorization() { * @return the base64 encoded string */ public String toBase64() { - String authInfoStr = String.format("%s:%s", this.username, this.password); + String authInfoStr = String.format("Basic %s:%s", this.username, this.password); return Base64.getEncoder().encodeToString(authInfoStr.getBytes(StandardCharsets.UTF_8)); } From 8dfc3d5c8d75ad5588ba28c98f951813d26a42e2 Mon Sep 17 00:00:00 2001 From: shuiyisong Date: Thu, 15 Jan 2026 15:31:48 +0800 Subject: [PATCH 2/4] chore: fix encoding value Signed-off-by: shuiyisong --- .../src/main/java/io/greptime/BulkWriteClient.java | 2 +- .../src/main/java/io/greptime/models/AuthInfo.java | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/ingester-protocol/src/main/java/io/greptime/BulkWriteClient.java b/ingester-protocol/src/main/java/io/greptime/BulkWriteClient.java index 7386354..fc94aac 100644 --- a/ingester-protocol/src/main/java/io/greptime/BulkWriteClient.java +++ b/ingester-protocol/src/main/java/io/greptime/BulkWriteClient.java @@ -132,7 +132,7 @@ private BulkStreamWriter bulkStreamWriteTo( ctx.entrySet().forEach(e -> headers.insert(e.getKey(), String.valueOf(e.getValue()))); headers.insert(Keys.Headers.GREPTIMEDB_DBNAME, database); if (authInfo != null) { - headers.insert(Keys.Headers.GREPTIMEDB_AUTH, authInfo.toBase64()); + headers.insert(Keys.Headers.GREPTIMEDB_AUTH, authInfo.base64HeaderValue()); } HeaderCallOption headerOption = new HeaderCallOption(headers); AsyncExecCallOption execOption = new AsyncExecCallOption(this.asyncPool); diff --git a/ingester-protocol/src/main/java/io/greptime/models/AuthInfo.java b/ingester-protocol/src/main/java/io/greptime/models/AuthInfo.java index a80c533..e3aef28 100644 --- a/ingester-protocol/src/main/java/io/greptime/models/AuthInfo.java +++ b/ingester-protocol/src/main/java/io/greptime/models/AuthInfo.java @@ -54,9 +54,9 @@ public static AuthInfo noAuthorization() { * * @return the base64 encoded string */ - public String toBase64() { - String authInfoStr = String.format("Basic %s:%s", this.username, this.password); - return Base64.getEncoder().encodeToString(authInfoStr.getBytes(StandardCharsets.UTF_8)); + public String base64HeaderValue() { + String encoded = Base64.getEncoder().encodeToString(String.format("%s:%s", this.username, this.password).getBytes(StandardCharsets.UTF_8)); + return String.format("Basic %s", encoded); } @Override From 00a815304a792c19208e00b4c1b89c24ade72501 Mon Sep 17 00:00:00 2001 From: shuiyisong Date: Thu, 15 Jan 2026 15:40:58 +0800 Subject: [PATCH 3/4] chore: fix fmt Signed-off-by: shuiyisong --- .../src/main/java/io/greptime/models/AuthInfo.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/ingester-protocol/src/main/java/io/greptime/models/AuthInfo.java b/ingester-protocol/src/main/java/io/greptime/models/AuthInfo.java index e3aef28..8f7e801 100644 --- a/ingester-protocol/src/main/java/io/greptime/models/AuthInfo.java +++ b/ingester-protocol/src/main/java/io/greptime/models/AuthInfo.java @@ -55,7 +55,9 @@ public static AuthInfo noAuthorization() { * @return the base64 encoded string */ public String base64HeaderValue() { - String encoded = Base64.getEncoder().encodeToString(String.format("%s:%s", this.username, this.password).getBytes(StandardCharsets.UTF_8)); + String encoded = Base64.getEncoder() + .encodeToString( + String.format("%s:%s", this.username, this.password).getBytes(StandardCharsets.UTF_8)); return String.format("Basic %s", encoded); } From 5099f7f462b97c2b6dacfcb907db92cc74b8a716 Mon Sep 17 00:00:00 2001 From: shuiyisong Date: Thu, 15 Jan 2026 15:43:34 +0800 Subject: [PATCH 4/4] chore: fix fmt Signed-off-by: shuiyisong --- .../src/main/java/io/greptime/models/AuthInfo.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ingester-protocol/src/main/java/io/greptime/models/AuthInfo.java b/ingester-protocol/src/main/java/io/greptime/models/AuthInfo.java index 8f7e801..b5ab035 100644 --- a/ingester-protocol/src/main/java/io/greptime/models/AuthInfo.java +++ b/ingester-protocol/src/main/java/io/greptime/models/AuthInfo.java @@ -56,8 +56,8 @@ public static AuthInfo noAuthorization() { */ public String base64HeaderValue() { String encoded = Base64.getEncoder() - .encodeToString( - String.format("%s:%s", this.username, this.password).getBytes(StandardCharsets.UTF_8)); + .encodeToString( + String.format("%s:%s", this.username, this.password).getBytes(StandardCharsets.UTF_8)); return String.format("Basic %s", encoded); }