You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sh...@apache.org on 2016/11/07 04:30:30 UTC

[43/50] [abbrv] ignite git commit: IGNITE-3963 FlinkIgniteSinkSelfTest fails with exception IllegalArgumentException - Fixes #1112.

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

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