You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/10/16 18:08:41 UTC
[14/24] flink git commit: [hotfix] Proper exception chaining in
key/value state access of StreamingRuntimeContext
[hotfix] Proper exception chaining in key/value state access of StreamingRuntimeContext
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ca8c73db
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ca8c73db
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ca8c73db
Branch: refs/heads/master
Commit: ca8c73db2dbb4744968f4c8fa77841f44cb1773b
Parents: b81598e
Author: Stephan Ewen <se...@apache.org>
Authored: Fri Oct 9 19:34:16 2015 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Fri Oct 16 15:26:10 2015 +0200
----------------------------------------------------------------------
.../flink/streaming/api/operators/StreamingRuntimeContext.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/ca8c73db/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java
index 40998dd..a51bb27 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java
@@ -117,7 +117,7 @@ public class StreamingRuntimeContext extends AbstractRuntimeUDFContext {
catch (Exception e) {
throw new RuntimeException("Cannot analyze type '" + stateType.getName() +
"' from the class alone, due to generic type parameters. " +
- "Please specify the TypeInformation directly.");
+ "Please specify the TypeInformation directly.", e);
}
return getKeyValueState(typeInfo, defaultState);