Repository: ignite Updated Branches: refs/heads/master 15a46c0db -> 2c78ad25c
IGNITE-9872 Mute failing test Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/2c78ad25 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/2c78ad25 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/2c78ad25 Branch: refs/heads/master Commit: 2c78ad25c0cec6c4962f1fb425c43d5a41102f9d Parents: 15a46c0 Author: Alexey Goncharuk <[email protected]> Authored: Tue Oct 16 16:53:57 2018 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Tue Oct 16 16:53:57 2018 +0300 ---------------------------------------------------------------------- .../stream/kafka/connect/IgniteSinkConnectorTest.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/2c78ad25/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/connect/IgniteSinkConnectorTest.java ---------------------------------------------------------------------- diff --git a/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/connect/IgniteSinkConnectorTest.java b/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/connect/IgniteSinkConnectorTest.java index d710a75..e3072ba 100644 --- a/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/connect/IgniteSinkConnectorTest.java +++ b/modules/kafka/src/test/java/org/apache/ignite/stream/kafka/connect/IgniteSinkConnectorTest.java @@ -137,7 +137,12 @@ public class IgniteSinkConnectorTest extends GridCommonAbstractTest { grid = startGrid("igniteServerNode", cfg); } + /** + * @throws Exception if failed. + */ public void testSinkPutsWithoutTransformation() throws Exception { + fail("https://issues.apache.org/jira/browse/IGNITE-9872";); + Map<String, String> sinkProps = makeSinkProps(Utils.join(TOPICS, ",")); sinkProps.remove(IgniteSinkConstants.SINGLE_TUPLE_EXTRACTOR_CLASS); @@ -145,6 +150,9 @@ public class IgniteSinkConnectorTest extends GridCommonAbstractTest { testSinkPuts(sinkProps, false); } + /** + * @throws Exception if failed. + */ public void testSinkPutsWithTransformation() throws Exception { testSinkPuts(makeSinkProps(Utils.join(TOPICS, ",")), true); } @@ -291,7 +299,6 @@ public class IgniteSinkConnectorTest extends GridCommonAbstractTest { * Test transformer. */ static class TestExtractor implements StreamSingleTupleExtractor<SinkRecord, String, String> { - /** {@inheritDoc} */ @Override public Map.Entry<String, String> extract(SinkRecord msg) { String[] parts = ((String)msg.value()).split("_");
