[hotfix] [streaming] Fix instantiation of state backends from state backend factory.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3c5f363d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3c5f363d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3c5f363d Branch: refs/heads/master Commit: 3c5f363d816a1a529832f384fb504d4b6804a00b Parents: 8325bc6 Author: Stephan Ewen <se...@apache.org> Authored: Thu Nov 19 00:24:56 2015 +0100 Committer: Stephan Ewen <se...@apache.org> Committed: Thu Nov 19 10:23:30 2015 +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/3c5f363d/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 bae0128..80c63da 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 @@ -525,7 +525,7 @@ public abstract class StreamTask<OUT, Operator extends StreamOperator<OUT>> Class<? extends StateBackendFactory> clazz = Class.forName(backendName, false, userClassLoader).asSubclass(StateBackendFactory.class); - return (StateBackend<?>) clazz.newInstance(); + return clazz.newInstance().createFromConfig(flinkConfig); } catch (ClassNotFoundException e) { throw new IllegalConfigurationException("Cannot find configured state backend: " + backendName); } catch (ClassCastException e) {
