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 {