flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [14/24] flink git commit: [hotfix] Proper exception chaining in key/value state access of StreamingRuntimeContext
Date Fri, 16 Oct 2015 16:08:41 GMT
[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 <sewen@apache.org>
Authored: Fri Oct 9 19:34:16 2015 +0200
Committer: Stephan Ewen <sewen@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);


Mime
View raw message