[kylin] branch master updated: Fix IT

[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


The following commit(s) were added to refs/heads/master by this push:
     new cc4aae8  Fix IT
cc4aae8 is described below

commit cc4aae8964ca8188c2633eccbb05578407e9b2ce
Author: XiaoxiangYu <hit_la...@126.com>
AuthorDate: Mon Jun 8 00:16:51 2020 +0800

    Fix IT
---
 .../apache/kylin/storage/stream/rpc/MockedStreamDataSearchClient.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/storage-stream/src/main/java/org/apache/kylin/storage/stream/rpc/MockedStreamDataSearchClient.java
 
b/storage-stream/src/main/java/org/apache/kylin/storage/stream/rpc/MockedStreamDataSearchClient.java
index 12af49c..1b8061c 100644
--- 
a/storage-stream/src/main/java/org/apache/kylin/storage/stream/rpc/MockedStreamDataSearchClient.java
+++ 
b/storage-stream/src/main/java/org/apache/kylin/storage/stream/rpc/MockedStreamDataSearchClient.java
@@ -34,6 +34,7 @@ public class MockedStreamDataSearchClient extends 
HttpStreamDataSearchClient {
 
     @Override
     public Iterator<ITuple> doSearch(DataRequest dataRequest, CubeInstance 
cube, StreamingTupleConverter tupleConverter, RecordsSerializer 
recordsSerializer, Node receiver, TupleInfo tupleInfo) throws Exception {
+        dataRequest.setDeadline(System.currentTimeMillis() + 60000L);
         DataResponse response = new DataController().query(dataRequest);
         return deserializeResponse(tupleConverter, recordsSerializer, 
cube.getName(), tupleInfo, response);
     }