Return-Path: 
 <commits-return-5673-apmail-flink-commits-archive=flink.apache.org@flink.apache.org>
X-Original-To: apmail-flink-commits-archive@minotaur.apache.org
Delivered-To: apmail-flink-commits-archive@minotaur.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id 31A68181C9
	for <apmail-flink-commits-archive@minotaur.apache.org>;
 Thu, 19 Nov 2015 09:24:59 +0000 (UTC)
Received: (qmail 81511 invoked by uid 500); 19 Nov 2015 09:24:59 -0000
Delivered-To: apmail-flink-commits-archive@flink.apache.org
Received: (qmail 81464 invoked by uid 500); 19 Nov 2015 09:24:59 -0000
Mailing-List: contact commits-help@flink.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:commits-help@flink.apache.org>
List-Unsubscribe: <mailto:commits-unsubscribe@flink.apache.org>
List-Post: <mailto:commits@flink.apache.org>
List-Id: <commits.flink.apache.org>
Reply-To: dev@flink.apache.org
Delivered-To: mailing list commits@flink.apache.org
Received: (qmail 81400 invoked by uid 99); 19 Nov 2015 09:24:59 -0000
Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org)
 (140.211.11.23)
    by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 19 Nov 2015 09:24:59 +0000
Received: by git1-us-west.apache.org (ASF Mail Server at
 git1-us-west.apache.org, from userid 33)
	id D76E7DF9A3; Thu, 19 Nov 2015 09:24:58 +0000 (UTC)
Content-Type: text/plain; charset="us-ascii"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
From: sewen@apache.org
To: commits@flink.apache.org
Date: Thu, 19 Nov 2015 09:24:59 -0000
Message-Id: <36cd8c2091da4f0eb722dec0045a5510@git.apache.org>
In-Reply-To: <7ded25862fcf4809b9cd2acd583139af@git.apache.org>
References: <7ded25862fcf4809b9cd2acd583139af@git.apache.org>
X-Mailer: ASF-Git Admin Mailer
Subject: [2/2] flink git commit: [hotfix] [streaming] Fix instantiation of
 state backends from state backend factory.

[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 <sewen@apache.org>
Authored: Thu Nov 19 00:24:56 2015 +0100
Committer: Stephan Ewen <sewen@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) {