[kylin] 02/02: Fix code to pass the UT

[xxyu]

This is an automated email from the ASF dual-hosted git repository.

xxyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kylin.git

commit cb42aca7d3f9720728f4f97868aa9dc1b58efd38
Author: ggke <g...@autohome.com.cn>
AuthorDate: Sat Oct 10 20:49:27 2020 +0800

    Fix code to pass the UT
---
 .../org/apache/kylin/stream/core/query/MultiThreadsResultCollector.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/stream-core/src/main/java/org/apache/kylin/stream/core/query/MultiThreadsResultCollector.java
 
b/stream-core/src/main/java/org/apache/kylin/stream/core/query/MultiThreadsResultCollector.java
index f0c91fd..b914e79 100644
--- 
a/stream-core/src/main/java/org/apache/kylin/stream/core/query/MultiThreadsResultCollector.java
+++ 
b/stream-core/src/main/java/org/apache/kylin/stream/core/query/MultiThreadsResultCollector.java
@@ -148,7 +148,7 @@ public class MultiThreadsResultCollector extends 
ResultCollector {
                 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;
                     }