This is an automated email from the ASF dual-hosted git repository.

chenliang613 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/carbondata.git


The following commit(s) were added to refs/heads/master by this push:
     new f18846cc2e optimize code smell in streaming module (#4327)
f18846cc2e is described below

commit f18846cc2eeb31e0e9737a4ea679d0449aa583fd
Author: Bo Xu <[email protected]>
AuthorDate: Thu Oct 19 15:50:22 2023 +0800

    optimize code smell in streaming module (#4327)
---
 .../org/apache/carbondata/streaming/CarbonStreamOutputFormat.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/streaming/src/main/java/org/apache/carbondata/streaming/CarbonStreamOutputFormat.java
 
b/streaming/src/main/java/org/apache/carbondata/streaming/CarbonStreamOutputFormat.java
index 7bc68c653e..4816deab09 100644
--- 
a/streaming/src/main/java/org/apache/carbondata/streaming/CarbonStreamOutputFormat.java
+++ 
b/streaming/src/main/java/org/apache/carbondata/streaming/CarbonStreamOutputFormat.java
@@ -49,7 +49,7 @@ public class CarbonStreamOutputFormat extends 
FileOutputFormat<Void, Object> {
 
   public static final int CARBON_STREAM_CACHE_SIZE_DEFAULT = 32 * 1024 * 1024;
 
-  private static final String LOAD_Model = 
"mapreduce.output.carbon.load.model";
+  private static final String LOAD_MODEL = 
"mapreduce.output.carbon.load.model";
 
   private static final String SEGMENT_ID = "carbon.segment.id";
 
@@ -62,12 +62,12 @@ public class CarbonStreamOutputFormat extends 
FileOutputFormat<Void, Object> {
   public static void setCarbonLoadModel(Configuration hadoopConf, 
CarbonLoadModel carbonLoadModel)
       throws IOException {
     if (carbonLoadModel != null) {
-      hadoopConf.set(LOAD_Model, 
ObjectSerializationUtil.convertObjectToString(carbonLoadModel));
+      hadoopConf.set(LOAD_MODEL, 
ObjectSerializationUtil.convertObjectToString(carbonLoadModel));
     }
   }
 
   public static CarbonLoadModel getCarbonLoadModel(Configuration hadoopConf) 
throws IOException {
-    String value = hadoopConf.get(LOAD_Model);
+    String value = hadoopConf.get(LOAD_MODEL);
     if (value == null) {
       return null;
     } else {

Reply via email to