You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sb...@apache.org on 2014/07/31 04:27:51 UTC
[5/8] git commit: added null check to get rid of common exception
seen while stream initializing
added null check to get rid of common exception seen while stream initializing
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/e7141a4d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/e7141a4d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/e7141a4d
Branch: refs/heads/streams-api
Commit: e7141a4d1a7fcaa8c99827f02257ee2987e6d826
Parents: 3af77bd
Author: Steve Blackmon <sb...@w2odigital.com>
Authored: Wed Jul 30 21:25:17 2014 -0500
Committer: Steve Blackmon <sb...@w2odigital.com>
Committed: Wed Jul 30 21:26:33 2014 -0500
----------------------------------------------------------------------
.../java/org/apache/streams/local/tasks/StreamsProviderTask.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/e7141a4d/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProviderTask.java
----------------------------------------------------------------------
diff --git a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProviderTask.java b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProviderTask.java
index f5189eb..fe7ea95 100644
--- a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProviderTask.java
+++ b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProviderTask.java
@@ -168,7 +168,8 @@ public class StreamsProviderTask extends BaseStreamsTask implements DatumStatusC
break;
default: throw new RuntimeException("Type has not been added to StreamsProviderTask.");
}
- flushResults(resultSet);
+ if( resultSet != null )
+ flushResults(resultSet);
} catch( Exception e ) {
LOGGER.error("Error in processing provider stream", e);