You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2017/03/14 13:57:27 UTC
flink git commit: [hotfix] [log] Log proper user defined state
backend in StreamTask
Repository: flink
Updated Branches:
refs/heads/master a00de2b4d -> dabeb74c1
[hotfix] [log] Log proper user defined state backend in StreamTask
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dabeb74c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dabeb74c
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/dabeb74c
Branch: refs/heads/master
Commit: dabeb74c10e755c655a06cdc8846dc7227d63cb9
Parents: a00de2b
Author: Till Rohrmann <tr...@apache.org>
Authored: Tue Mar 14 14:56:27 2017 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Tue Mar 14 14:57:12 2017 +0100
----------------------------------------------------------------------
.../java/org/apache/flink/streaming/runtime/tasks/StreamTask.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/dabeb74c/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
index 1e208ee..ccaa312 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
@@ -713,7 +713,7 @@ public abstract class StreamTask<OUT, OP extends StreamOperator<OUT>>
if (fromJob != null) {
// backend has been configured on the environment
- LOG.info("Using user-defined state backend: {}.", stateBackend);
+ LOG.info("Using user-defined state backend: {}.", fromJob);
return fromJob;
}
else {