You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by xx...@apache.org on 2020/10/18 09:19:34 UTC
[kylin] 02/02: Fix code to pass the UT
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 <gu...@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;
}