@@ -2176,14 +2176,14 @@ private BatchOperation buildBatchOperation(String tableName, List<? extends Row>
2176
2176
for (KeyValue kv : keyValueList ) {
2177
2177
singleOpResultNum ++;
2178
2178
if (isTableGroup ) {
2179
- byte [] old_qualifier = kv .getQualifier ();
2180
- byte [] new_qualifier = new byte [family .length + 1 /* length of "." */ + old_qualifier .length ];
2181
- System .arraycopy (family , 0 , new_qualifier , 0 , family .length );
2182
- new_qualifier [family .length ] = 0x2E ; // 0x2E in utf-8 is "."
2183
- System .arraycopy (old_qualifier , 0 , new_qualifier , family .length +1 ,old_qualifier .length );
2184
- KeyValue new_kv = modifyQualifier (kv , new_qualifier );
2179
+ byte [] oldQualifier = kv .getQualifier ();
2180
+ byte [] newQualifier = new byte [family .length + 1 /* length of "." */ + oldQualifier .length ];
2181
+ System .arraycopy (family , 0 , newQualifier , 0 , family .length );
2182
+ newQualifier [family .length ] = 0x2E ; // 0x2E in utf-8 is "."
2183
+ System .arraycopy (oldQualifier , 0 , newQualifier , family .length +1 , oldQualifier .length );
2184
+ KeyValue newKV = modifyQualifier (kv , newQualifier );
2185
2185
batch
2186
- .addOperation (buildMutation (new_kv , INSERT_OR_UPDATE , true , put .getTTL ()));
2186
+ .addOperation (buildMutation (newKV , INSERT_OR_UPDATE , true , put .getTTL ()));
2187
2187
} else {
2188
2188
batch .addOperation (buildMutation (kv , INSERT_OR_UPDATE , false , put .getTTL ()));
2189
2189
}
0 commit comments