Repository: ignite Updated Branches: refs/heads/master 279612e50 -> 01caff4d8
Fixed exception conversion in DataStreamerImpl. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/01caff4d Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/01caff4d Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/01caff4d Branch: refs/heads/master Commit: 01caff4d851401fbcb86d370e5a34b51a2035387 Parents: 279612e Author: sboikov <[email protected]> Authored: Thu Jun 15 14:56:35 2017 +0300 Committer: sboikov <[email protected]> Committed: Thu Jun 15 14:56:35 2017 +0300 ---------------------------------------------------------------------- .../apache/ignite/internal/IgniteClientReconnectStreamerTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/01caff4d/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectStreamerTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectStreamerTest.java b/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectStreamerTest.java index e9935d8..3959feb 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectStreamerTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectStreamerTest.java @@ -204,7 +204,7 @@ public class IgniteClientReconnectStreamerTest extends IgniteClientReconnectAbst */ private void checkStreamerClosed(IgniteDataStreamer<Integer, Integer> streamer) { try { - streamer.addData(100, 100); + streamer.addData(100, 100).get(); fail(); }
