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:25:46 UTC
[6/6] 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/01a1a73b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/01a1a73b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/01a1a73b
Branch: refs/heads/streams-api
Commit: 01a1a73be4926c9d518c5d1afb10f7b54db489f5
Parents: b730132
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:25:17 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/01a1a73b/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);