fix(batch): 修复封装大小顺序问题

2020-10-23 22:06:36 +08:00
parent 13679476bd
commit 8a780334af
1 changed files with 1 additions and 1 deletions
--- a/yb_http_avro_sink_file/src/main/java/cn/ac/iie/cusflume/sink/HttpAsyncUtils/HttpClientUtil.java
+++ b/yb_http_avro_sink_file/src/main/java/cn/ac/iie/cusflume/sink/HttpAsyncUtils/HttpClientUtil.java
@@ -796,8 +796,8 @@ public class HttpClientUtil {
                    outAvro.close();
                    outAvro = null;
                }
-                dataLengthByteArray = sumHex(resultArray.length, 4);
                resultArray = getTagRecordAndMergeAllArray(topic, dataJson, resultArray);
+                dataLengthByteArray = sumHex(resultArray.length, 4);
                if (results == null) {
                    results = byteMerger(dataLengthByteArray, resultArray);
                } else {