Repository: flume Updated Branches: refs/heads/trunk fd32492ac -> 5239b618c
FLUME-2485. Thrift Source tests fail on Oracle JDK 8 (Miroslav Holubec via Johny Rufus) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/5239b618 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/5239b618 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/5239b618 Branch: refs/heads/trunk Commit: 5239b618c2caf4c6351048c758ad84f0c67aaf86 Parents: fd32492 Author: Johny Rufus <[email protected]> Authored: Wed Aug 5 07:55:51 2015 -0700 Committer: Johny Rufus <[email protected]> Committed: Wed Aug 5 07:55:51 2015 -0700 ---------------------------------------------------------------------- .../src/test/java/org/apache/flume/source/TestThriftSource.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/5239b618/flume-ng-core/src/test/java/org/apache/flume/source/TestThriftSource.java ---------------------------------------------------------------------- diff --git a/flume-ng-core/src/test/java/org/apache/flume/source/TestThriftSource.java b/flume-ng-core/src/test/java/org/apache/flume/source/TestThriftSource.java index 8b9fa23..3d2901a 100644 --- a/flume-ng-core/src/test/java/org/apache/flume/source/TestThriftSource.java +++ b/flume-ng-core/src/test/java/org/apache/flume/source/TestThriftSource.java @@ -178,7 +178,7 @@ public class TestThriftSource { for (int i = 0; i < 300; i++) { Event event = channel.take(); Assert.assertNotNull(event); - Assert.assertTrue(Long.valueOf(event.getHeaders().get("time")) < after); + Assert.assertTrue(Long.valueOf(event.getHeaders().get("time")) <= after); events.add(Integer.parseInt(new String(event.getBody()))); } transaction.commit();
