diff options
author | Peter Wu <peter@lekensteyn.nl> | 2014-05-07 22:05:03 +0200 |
---|---|---|
committer | Peter Wu <peter@lekensteyn.nl> | 2014-05-07 22:05:03 +0200 |
commit | b3f5eaaafe0fc17abe4252881f058215adafa0af (patch) | |
tree | 70cc8465a56596b9366a9cf8d37613bf58f9bc65 | |
parent | 27d2376ce73158409e232ffbc4e156b4162281e3 (diff) | |
download | TwitterDataAnalytics-b3f5eaaafe0fc17abe4252881f058215adafa0af.tar.gz |
Fix null ptr when close/commit
commit closes everything via safeClose, so ensure that tweetGenerated
re-opens it if necessary.
Fixes:
ƒ commit
€ Exception in thread "Thread-7" java.lang.NullPointerException
at io.DataWriter.writeObject(DataWriter.java:137)
at io.DataWriter.tweetGenerated(DataWriter.java:85)
at provider.CompositeResultListener.tweetGenerated(CompositeResultListener.java:51)
at io.StreamImpl$Poller.processObject(StreamImpl.java:255)
at io.StreamImpl$Poller.run(StreamImpl.java:245)
at java.lang.Thread.run(Thread.java:744)
-rw-r--r-- | src/io/DataWriter.java | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/src/io/DataWriter.java b/src/io/DataWriter.java index 4f4c022..c1e1ce9 100644 --- a/src/io/DataWriter.java +++ b/src/io/DataWriter.java @@ -82,7 +82,14 @@ public class DataWriter implements ResultListener, Closeable, Flushable { @Override public void tweetGenerated(JSONObject obj) { - writeObject(obj, m_tweet.getOutputStream(), m_tweetIdSet); + try { + // ensure that the file is open + m_tweet.open(); + + writeObject(obj, m_tweet.getOutputStream(), m_tweetIdSet); + } catch (IOException ex) { + getLogger().log(Level.SEVERE, "Cannot save tweet", ex); + } } /** |