MR notes

NationalSecurityAgency · Jul 8, 2024 · 3dceafe · 3dceafe
1 parent ea14f4d
commit 3dceafe
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/warehouse/core/src/main/java/datawave/edge/util/EdgeKey.java b/warehouse/core/src/main/java/datawave/edge/util/EdgeKey.java
@@ -44,7 +44,7 @@ public class EdgeKey {
 
     private static final Logger log = Logger.getLogger(EdgeKey.class);
 
-    private static final String CANT_ENCODE_UNKNOWN_ERROR_MSG = "Can't encode unknown edge key format.";
+    private static final String UNKNOWN_EDGE_KEY_FORMAT_MSG = "Can't encode unknown edge key format.";
 
     // use the builder, not this nightmare constructor
     private EdgeKey(EDGE_FORMAT format, STATS_TYPE statsType, String sourceData, String sinkData, String family, String sourceRelationship,
@@ -927,7 +927,7 @@ public Key encode() {
                 return encode(EDGE_VERSION.DATE_PROTOBUF);
             } else {
                 // EDGE_FORMAT.UNKNOWN
-                throw new IllegalStateException(CANT_ENCODE_UNKNOWN_ERROR_MSG + this);
+                throw new IllegalStateException(UNKNOWN_EDGE_KEY_FORMAT_MSG + this);
             }
         }
 
@@ -940,7 +940,7 @@ public Key encodeLegacyProtobufKey() {
             return encode(EDGE_VERSION.PROTOBUF);
         } else {
             // EDGE_FORMAT.UNKNOWN
-            throw new IllegalStateException(CANT_ENCODE_UNKNOWN_ERROR_MSG + this);
+            throw new IllegalStateException(UNKNOWN_EDGE_KEY_FORMAT_MSG + this);
         }
     }
 
@@ -951,7 +951,7 @@ public Key encodeLegacyAttribute2Key() {
             return encode(EDGE_VERSION.BASE_ATTRIBUTE2);
         } else {
             // EDGE_FORMAT.UNKNOWN
-            throw new IllegalStateException(CANT_ENCODE_UNKNOWN_ERROR_MSG + this);
+            throw new IllegalStateException(UNKNOWN_EDGE_KEY_FORMAT_MSG + this);
         }
     }
 
@@ -962,7 +962,7 @@ public Key encodeLegacyKey() {
             return encode(EDGE_VERSION.BASE);
         } else {
             // EDGE_FORMAT.UNKNOWN
-            throw new IllegalStateException(CANT_ENCODE_UNKNOWN_ERROR_MSG + this);
+            throw new IllegalStateException(UNKNOWN_EDGE_KEY_FORMAT_MSG + this);
         }
     }
 

diff --git a/warehouse/core/src/main/java/datawave/mr/bulk/BulkInputFormat.java b/warehouse/core/src/main/java/datawave/mr/bulk/BulkInputFormat.java
@@ -1292,7 +1292,7 @@ public AccumuloIteratorOption(String iteratorOption) {
             this.iteratorName = tokenizer.nextToken();
             try {
                 this.key = URLDecoder.decode(tokenizer.nextToken(), UTF8);
-                this.value = URLDecoder.decode(tokenizer.nextToken(), "UTF8");
+                this.value = URLDecoder.decode(tokenizer.nextToken(), UTF8);
             } catch (UnsupportedEncodingException e) {
                 throw new RuntimeException(e);
             }