You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ma...@apache.org on 2015/06/24 08:10:59 UTC
incubator-kylin git commit: KYLIN-802 bug fix
Repository: incubator-kylin
Updated Branches:
refs/heads/0.8 c40fac8d9 -> 13958713f
KYLIN-802 bug fix
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/13958713
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/13958713
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/13958713
Branch: refs/heads/0.8
Commit: 13958713ff7605226d2c15e28808cfcb0256b2db
Parents: c40fac8
Author: honma <ho...@ebay.com>
Authored: Wed Jun 24 14:10:49 2015 +0800
Committer: honma <ho...@ebay.com>
Committed: Wed Jun 24 14:10:49 2015 +0800
----------------------------------------------------------------------
.../apache/kylin/job/streaming/PeriodicalStreamBuilderTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/13958713/job/src/test/java/org/apache/kylin/job/streaming/PeriodicalStreamBuilderTest.java
----------------------------------------------------------------------
diff --git a/job/src/test/java/org/apache/kylin/job/streaming/PeriodicalStreamBuilderTest.java b/job/src/test/java/org/apache/kylin/job/streaming/PeriodicalStreamBuilderTest.java
index d53d419..abfc699 100644
--- a/job/src/test/java/org/apache/kylin/job/streaming/PeriodicalStreamBuilderTest.java
+++ b/job/src/test/java/org/apache/kylin/job/streaming/PeriodicalStreamBuilderTest.java
@@ -104,7 +104,7 @@ public class PeriodicalStreamBuilderTest extends LocalFileMetadataTestCase {
for (BlockingQueue<StreamMessage> queue : queues) {
queue.put(new StreamMessage(messageCount, String.valueOf(ts).getBytes()));
}
- if (expectedOffset == 0 && ts > timeout) {
+ if (expectedOffset == 0 && ts >= timeout) {
expectedOffset = messageCount - 1;
}
messageCount++;