IGNITE-3963 FlinkIgniteSinkSelfTest fails with exception IllegalArgumentException - Fixes #1112.
Signed-off-by: samaitra <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f600750c Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f600750c Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f600750c Branch: refs/heads/ignite-2788 Commit: f600750cda85ab859ba370bed0d22d875c6e29cf Parents: 3e4042b Author: samaitra <[email protected]> Authored: Sat Oct 8 00:16:20 2016 +0530 Committer: samaitra <[email protected]> Committed: Sat Oct 8 00:16:20 2016 +0530 ---------------------------------------------------------------------- .../src/main/java/org/apache/ignite/sink/flink/IgniteSink.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/f600750c/modules/flink/src/main/java/org/apache/ignite/sink/flink/IgniteSink.java ---------------------------------------------------------------------- diff --git a/modules/flink/src/main/java/org/apache/ignite/sink/flink/IgniteSink.java b/modules/flink/src/main/java/org/apache/ignite/sink/flink/IgniteSink.java index e0ae783..2f18f80 100644 --- a/modules/flink/src/main/java/org/apache/ignite/sink/flink/IgniteSink.java +++ b/modules/flink/src/main/java/org/apache/ignite/sink/flink/IgniteSink.java @@ -34,7 +34,7 @@ public class IgniteSink<IN> extends RichSinkFunction<IN> { private static final long DFLT_FLUSH_FREQ = 10000L; /** Logger. */ - private final IgniteLogger log; + private final transient IgniteLogger log; /** Automatic flush frequency. */ private long autoFlushFrequency = DFLT_FLUSH_FREQ;
