[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/ef709093 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ef709093 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ef709093 Branch: refs/heads/release-0.10 Commit: ef709093b38ae12ea25b381aa54995d676aa3d33 Parents: a7e799b 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:27:46 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/ef709093/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) {