From ca24de60a1277fddf99f6ba338e2c3bf249a8890 Mon Sep 17 00:00:00 2001
From: changeAtLater <128348688+changeAtLater@users.noreply.github.com>
Date: Fri, 12 May 2023 11:42:30 +0800
Subject: [PATCH] fix JSONEvent charset bug

---
 .../src/main/java/org/apache/flume/event/JSONEvent.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flume-ng-sdk/src/main/java/org/apache/flume/event/JSONEvent.java b/flume-ng-sdk/src/main/java/org/apache/flume/event/JSONEvent.java
index 9ee90aec6c..4f44263e8d 100644
--- a/flume-ng-sdk/src/main/java/org/apache/flume/event/JSONEvent.java
+++ b/flume-ng-sdk/src/main/java/org/apache/flume/event/JSONEvent.java
@@ -58,7 +58,7 @@ public byte[] getBody() {
   @Override
   public void setBody(byte[] body) {
     if (body != null) {
-      this.body = new String(body);
+      this.body = new String(body, charset);
     } else {
       this.body = "";
     }