IGNITE-3963 FlinkIgniteSinkSelfTest fails with exception 
IllegalArgumentException - Fixes #1112.

Signed-off-by: samaitra <saikat.mai...@gmail.com>


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-3443
Commit: f600750cda85ab859ba370bed0d22d875c6e29cf
Parents: 3e4042b
Author: samaitra <saikat.mai...@gmail.com>
Authored: Sat Oct 8 00:16:20 2016 +0530
Committer: samaitra <saikat.mai...@gmail.com>
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;

Reply via email to