Fix code to pass the UT

ZhangIssac · Oct 18, 2020 · cb42aca · cb42aca
1 parent 6096f08
commit cb42aca
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...am-core/src/main/java/org/apache/kylin/stream/core/query/MultiThreadsResultCollector.java b/...am-core/src/main/java/org/apache/kylin/stream/core/query/MultiThreadsResultCollector.java
@@ -148,7 +148,7 @@ public void run() {
                 result.startRead();
                 for (Record record : result) {
                     offserTimeout = deadline - System.currentTimeMillis();
-                    if (!recordCachePool.offer(record, offserTimeout, TimeUnit.MILLISECONDS)) {
+                    if (!recordCachePool.offer(record.copy(), offserTimeout, TimeUnit.MILLISECONDS)) {
                         logger.warn("Timeout when offer to recordCachePool, deadline: {}, offser Timeout: {}", deadline, offserTimeout);
                         break;
                     }